Details

    • Sub-task
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • Not applicable
    • test-failures
    • None

    Description

       13:43:05 [grpc-default-executor-1] ERROR org.apache.beam.fn.harness.control.BeamFnControlClient - Exception while trying to handle InstructionRequest 10 java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info*13:43:05* at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:74)13:43:05 at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:609)13:43:05 at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:285)13:43:05 at org.apache.beam.fn.harness.DoFnPTransformRunnerFactory$Context.<init>(DoFnPTransformRunnerFactory.java:197)13:43:05 at org.apache.beam.fn.harness.DoFnPTransformRunnerFactory.createRunnerForPTransform(DoFnPTransformRunnerFactory.java:96)13:43:05 at org.apache.beam.fn.harness.DoFnPTransformRunnerFactory.createRunnerForPTransform(DoFnPTransformRunnerFactory.java:64)13:43:05 at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:194)13:43:05 at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:163)13:43:05 at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:290)13:43:05 at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:160)13:43:05 at org.apache.beam.fn.harness.control.BeamFnControlClient.lambda$processInstructionRequests$0(BeamFnControlClient.java:144)13:43:05 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)13:43:05 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)13:43:05 at java.lang.Thread.run(Thread.java:748)13:43:05 Caused by: java.io.InvalidClassException: org.apache.beam.sdk.options.ValueProvider$StaticValueProvider; local class incompatible: stream classdesc serialVersionUID = -7089438576249123133, local class serialVersionUID = -7141898054594373712*13:43:05* at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:699)13:43:05 at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1885)13:43:05 at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1751)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2042)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1975)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1567)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1975)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1567)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)13:43:05 at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)13:43:05 at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)13:43:05 at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)13:43:05 at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431)13:43:05 at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:71)13:43:05 ... 13 more

      Attachments

        Issue Links

          Activity

            People

              heejong Heejong Lee
              ibzib Kyle Weaver
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: