[HOP-1870] Exception in thread "Thread-52" java.lang.RuntimeException: Error starting the Beam pipeline

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Fix Version/s: Not applicable
• Component/s: Beam
• Labels: Question pre-apache user_experience
• Assignee: Unassigned
• Reporter: Maximilian Michels
• Created: 04/Oct/20 12:19
• Updated: 24/Aug/21 08:34
• Resolved: 24/Aug/21 08:34

Description

Please run the one pipeline found in this repo.

Error:

```
2020/05/24 17:50:49 - transform_event_data_to_json - Executing this pipeline using the Beam Pipeline Engine with run configuration 'Hop Beam Examples Local Runner'
Exception in thread "Thread-52" java.lang.RuntimeException: Error starting the Beam pipeline
at org.apache.hop.beam.engines.BeamPipelineEngine.lambda$startThreads$0(BeamPipelineEngine.java:295)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.lang.RuntimeException: Error executing TransformFn
at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:348)
at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:318)
at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:213)
at org.apache.hop.beam.engines.BeamPipelineEngine.executePipeline(BeamPipelineEngine.java:243)
at org.apache.hop.beam.engines.BeamPipelineEngine.lambda$startThreads$0(BeamPipelineEngine.java:293)
... 1 more
Caused by: java.lang.RuntimeException: Error executing TransformFn
at org.apache.hop.beam.core.transform.TransformTransform$StepFn.processElement(TransformTransform.java:504)
Caused by: java.lang.ClassCastException: java.util.Date cannot be cast to java.sql.Timestamp
at org.apache.hop.core.row.value.ValueMetaTimestamp.getTimestamp(ValueMetaTimestamp.java:126)
at org.apache.hop.core.row.value.ValueMetaTimestamp.getString(ValueMetaTimestamp.java:115)
at org.apache.hop.core.row.value.ValueMetaBase.convertData(ValueMetaBase.java:3767)
at org.apache.hop.pipeline.transforms.selectvalues.SelectValues.metadataValues(SelectValues.java:329)
at org.apache.hop.pipeline.transforms.selectvalues.SelectValues.processRow(SelectValues.java:379)
at org.apache.hop.pipeline.SingleThreadedPipelineExecutor.oneIteration(SingleThreadedPipelineExecutor.java:338)
at org.apache.hop.beam.core.transform.TransformTransform$StepFn.emptyRowBuffer(TransformTransform.java:545)
at org.apache.hop.beam.core.transform.TransformTransform$StepFn.processElement(TransformTransform.java:500)
at org.apache.hop.beam.core.transform.TransformTransform$StepFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:224)
at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:182)
at org.apache.beam.repackaged.direct_java.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78)
at org.apache.beam.runners.direct.ParDoEvaluator.processElement(ParDoEvaluator.java:240)
at org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.processElement(DoFnLifecycleManagerRemovingTransformEvaluator.java:54)
at org.apache.beam.runners.direct.DirectTransformExecutor.processElements(DirectTransformExecutor.java:160)
at org.apache.beam.runners.direct.DirectTransformExecutor.run(DirectTransformExecutor.java:124)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
```