Details
-
Sub-task
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
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
- is blocked by
-
BEAM-8545 don't docker pull before docker run
- Resolved