Uploaded image for project: 'Apache Hop (incubating)'
  1. Apache Hop (incubating)
  2. HOP-2073

Beam: Boolean to date conversion error

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: pre-apache
    • Fix Version/s: None
    • Component/s: None
    • Labels:

      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)

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              mxm Maximilian Michels
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: