Page MenuHomePhabricator

Fix Serialization Bug
Closed, ResolvedPublic

Description

The latest version of the Streaming Updater Producer has a bug that prevents Flink from starting.

Relevant part of stack trace

	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.<init>(FlinkKafkaProducer.java:571)
	at org.wikidata.query.rdf.updater.OutputStreams.prepareSideOutputStream(OutputStreams.scala:63)
	at org.wikidata.query.rdf.updater.OutputStreams.lateEventsOutput(OutputStreams.scala:37)
	at org.wikidata.query.rdf.updater.OutputStreams.pipelineSinks(OutputStreams.scala:56)
	at org.wikidata.query.rdf.updater.UpdaterJob$.main(UpdaterJob.scala:27)
	at org.wikidata.query.rdf.updater.UpdaterJob.main(UpdaterJob.scala)

This is a blocker to deployment of the streaming updater

Event Timeline

Change 668239 had a related patch set uploaded (by Mstyles; owner: Mstyles):
[wikidata/query/rdf@master] serialization bug fix

https://gerrit.wikimedia.org/r/668239

Change 668239 merged by jenkins-bot:
[wikidata/query/rdf@master] serialization bug fix

https://gerrit.wikimedia.org/r/668239

Gehel claimed this task.