[HOP-2073] Beam: Boolean to date conversion error

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: pre-apache
• Fix Version/s: 1.1.0
• Labels: pre-apache
• Assignee: Unassigned
• Reporter: Hans Van Akelyen
• Created: 04/Oct/20 12:22
• Updated: 28/Feb/22 12:24
• Resolved: 28/Feb/22 12:24

Description

Caused by a silly code typo:

java.lang.RuntimeException: Error executing TransformFn
at org.apache.hop.beam.core.transform.TransformTransform$StepFn.processElement (TransformTransform.java:526)
Caused by: java.lang.IllegalArgumentException: Unable to encode element 'org.apache.hop.beam.core.HopRow@3b643400' with coder 'HopRowCoder'.
at org.apache.beam.sdk.coders.Coder.getEncodedElementByteSize (Coder.java:300)
at org.apache.beam.sdk.coders.Coder.registerByteSizeObserver (Coder.java:291)
at org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.registerByteSizeObserver (WindowedValue.java:625)
at org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.registerByteSizeObserver (WindowedValue.java:541)
at org.apache.beam.runners.dataflow.worker.IntrinsicMapTaskExecutorFactory$ElementByteSizeObservableCoder.registerByteSizeObserver (IntrinsicMapTaskExecutorFactory.java:400)
at org.apache.beam.runners.dataflow.worker.util.common.worker.OutputObjectAndByteCounter.update (OutputObjectAndByteCounter.java:125)
at org.apache.beam.runners.dataflow.worker.DataflowOutputCounter.update (DataflowOutputCounter.java:64)
at org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process (OutputReceiver.java:43)
at org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output (SimpleParDoFn.java:280)
at org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue (SimpleDoFnRunner.java:267)
Caused by: java.lang.ClassCastException: java.lang.Boolean cannot be cast to java.util.Date
at org.apache.hop.beam.core.coder.HopRowCoder.write (HopRowCoder.java:124)
at org.apache.hop.beam.core.coder.HopRowCoder.encode (HopRowCoder.java:71)
at org.apache.hop.beam.core.coder.HopRowCoder.encode (HopRowCoder.java:39)
at org.apache.beam.sdk.coders.Coder.getEncodedElementByteSize (Coder.java:297)