Synapse pipeline failed running Data Flow activity - Job failed due to reason: Code not found for stream

Question

"message":"Job failed due to reason: Code not found for stream ~> StgFactLedgerTransactions. Details:java.lang.Throwable: Code not found for stream ~> StgFactLedgerTransactions\n\tat com.microsoft.dataflow.transformers.SelectPlanner$$anonfun$12.apply(Select.scala:149)\n\tat com.microsoft.dataflow.transformers.SelectPlanner$$anonfun$12.apply(Select.scala:149)\n\tat scala.Option.getOrElse(Option.scala:121)\n\tat com.microsoft.dataflow.transformers.SelectPlanner$.physicalPlan(Select.scala:149)\n\tat com.microsoft.dataflow.FlowRunner$$anonfun$com$microsoft$dataflow$FlowRunner$$runner$1$$anon$2$$anonfun$traverseStreamGroup$1.apply(FlowRunner.scala:775)\n\tat com.microsoft.dataflow.FlowRunner$$anonfun$com$microsoft$dataflow$FlowRunner$$runner$1$$anon$2$$anonfun$traverseStreamGroup$1.apply(FlowRunner.scala:764)\n\tat scala.collection.immutable.List.takeWhile(List.scala:361)\n\tat com.microsoft.dataflow.FlowRunner$$anonfun$com$microsoft$dataflow$FlowRunner$$runner$1$$anon$2.traverseStreamGroup(FlowRunner.scala:764)\n\tat com.microsoft.dataflow.FlowRunner$$anonfun$com$microsoft$dataflow$FlowRunner$$runner$1$$anon$2.getNextTaskGroup(F","failureType":"UserError","target":"FactLedgerTransactions","errorCode":"DFExecutorUserError"}

Answer 1

Hi @Vladimir Rutstein ,

Thank you for posting query in Microsoft Q&A Platform. Could you please help with below asks to understand issue better?

• Are you triggering pipeline or debug running? If its trigger run then make sure you have published all changes and then only run the pipeline.
• Is your data flow activity running successfully before?
• Could you please share more details on implementation of data flow?
• Are you able to perfomr data preview inside dataflow for each and every transformation?

I mainly suspect issue may be because of unpublished changes. Kindly publish changes and then trigger and see.

Please let me know how it goes. Thank you.