Zbyszko added a comment.

  After adding some additional logging, this is what we see:
  
  > 2020-04-08 07:44:07,287 ERROR 
org.wikidata.query.rdf.updater.ExtractTriplesFunction         - Exception 
thrown for op: FullImport(Property:P1331 
<https://phabricator.wikimedia.org/P1331>,2020-04-08T07:42:30Z,1152868984)
  > org.wikidata.query.rdf.tool.exception.ContainedException: Didn't get a 
revision id for []
  >     at 
org.wikidata.query.rdf.tool.rdf.Munger$MungeOperation.finishCommon(Munger.java:792)
  >     at 
org.wikidata.query.rdf.tool.rdf.Munger$MungeOperation.munge(Munger.java:398)
  >     at org.wikidata.query.rdf.tool.rdf.Munger.munge(Munger.java:131)
  >     at 
org.wikidata.query.rdf.updater.ExtractTriplesFunction.munge(ExtractTriplesFunction.scala:53)
  >     at 
org.wikidata.query.rdf.updater.ExtractTriplesFunction.map(ExtractTriplesFunction.scala:37)
  >     at 
org.wikidata.query.rdf.updater.ExtractTriplesFunction.map(ExtractTriplesFunction.scala:20)
  >     at 
org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:41)
  >     at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:641)
  >     at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:616)
  >     at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:596)
  >     at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$BroadcastingOutputCollector.collect(OperatorChain.java:711)
  >     at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$BroadcastingOutputCollector.collect(OperatorChain.java:664)
  >     at 
org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:730)
  >     at 
org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:708)
  >     at 
org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:53)
  >     at 
org.wikidata.query.rdf.updater.RouteIgnoredMutationToSideOutput.processElement(DecideMutationOperationMapFunction.scala:56)
  >     at 
org.wikidata.query.rdf.updater.RouteIgnoredMutationToSideOutput.processElement(DecideMutationOperationMapFunction.scala:47)
  >     at 
org.apache.flink.streaming.api.operators.ProcessOperator.processElement(ProcessOperator.java:66)
  >     at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:641)
  >     at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:616)
  >     at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:596)
  >     at 
org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:730)
  >     at 
org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:708)
  >     at 
org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:41)
  >     at 
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:173)
  >     at 
org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.processElement(StreamTaskNetworkInput.java:151)
  >     at 
org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:128)
  >     at 
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:69)
  >     at 
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:311)
  >     at 
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:187)
  >     at 
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:487)
  >     at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:470)
  >     at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707)
  >     at org.apache.flink.runtime.taskmanager.Task.run(Task.java:532)
  >     at java.lang.Thread.run(Thread.java:748)
  
  From what I see - every single issue with that is related to operation about 
property. Are we handling them incorrectly?

TASK DETAIL
  https://phabricator.wikimedia.org/T249099

EMAIL PREFERENCES
  https://phabricator.wikimedia.org/settings/panel/emailpreferences/

To: Zbyszko
Cc: dcausse, Aklapper, Zbyszko, darthmon_wmde, Nandana, Lahi, Gq86, 
Lucas_Werkmeister_WMDE, GoranSMilovanovic, QZanden, EBjune, merbst, 
LawExplorer, _jensen, rosalieper, Scott_WUaS, Jonas, Xmlizer, jkroll, 
Wikidata-bugs, Jdouglas, aude, Tobias1984, Manybubbles, Mbch331
_______________________________________________
Wikidata-bugs mailing list
Wikidata-bugs@lists.wikimedia.org
https://lists.wikimedia.org/mailman/listinfo/wikidata-bugs

Reply via email to