Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10375

ExceptionInChainedStubException hides wrapped exception in cause

    Details

      Description

      ExceptionInChainedStubException does not have the wrapped exception as the cause. This creates generally unhelpful exception traces like this:

      org.apache.beam.sdk.util.UserCodeException: org.apache.flink.runtime.operators.chaining.ExceptionInChainedStubException
      	at org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:36)
      	at org.apache.beam.sdk.io.WriteFiles$ApplyShardingKeyFn$DoFnInvoker.invokeProcessElement(Unknown Source)
      	at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
      	at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:149)
      	at org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate.processElement(DoFnRunnerWithMetricsUpdate.java:66)
      	at org.apache.beam.runners.flink.translation.functions.FlinkDoFnFunction.mapPartition(FlinkDoFnFunction.java:120)
      	at org.apache.flink.runtime.operators.MapPartitionDriver.run(MapPartitionDriver.java:103)
      	at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:490)
      	at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:355)
      	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
      	at java.lang.Thread.run(Thread.java:748)
      Caused by: org.apache.flink.runtime.operators.chaining.ExceptionInChainedStubException
      	at org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver.collect(ChainedFlatMapDriver.java:82)
      	at org.apache.flink.runtime.operators.util.metrics.CountingCollector.collect(CountingCollector.java:35)
      	at org.apache.beam.runners.flink.translation.functions.FlinkDoFnFunction$DoFnOutputManager.output(FlinkDoFnFunction.java:149)
      	at org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:219)
      	at org.apache.beam.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.java:69)
      	at org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:517)
      	at org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:505)
      	at org.apache.beam.sdk.io.WriteFiles$ApplyShardingKeyFn.processElement(WriteFiles.java:686)
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mpedersen Mike Pedersen
                Reporter:
                mpedersen Mike Pedersen
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: