[#20970] Fix gRPC leak by closing ResidualSource at BoundedToUnbounde… #24293
6 parse errors, 10 fail, 1 skipped, 143 pass in 1h 59m 55s
Annotations
github-actions / Test Results
Error processing result file
CData section too big found, line 99410, column 56 (TEST-org.apache.beam.sdk.transforms.ViewTest.xml, line 99410)
Raw output
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ViewTest.xml
github-actions / Test Results
Error processing result file
CData section too big found, line 100529, column 20 (TEST-org.apache.beam.sdk.transforms.windowing.WindowTest.xml, line 100529)
Raw output
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.windowing.WindowTest.xml
github-actions / Test Results
Error processing result file
CData section too big found, line 99503, column 30 (TEST-org.apache.beam.sdk.transforms.ReshuffleTest.xml, line 99503)
Raw output
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ReshuffleTest.xml
github-actions / Test Results
Error processing result file
CData section too big found, line 89891, column 34 (TEST-org.apache.beam.sdk.transforms.ParDoTest$StateTests.xml, line 89891)
Raw output
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$StateTests.xml
github-actions / Test Results
Error processing result file
CData section too big found, line 84831, column 7 (TEST-org.apache.beam.sdk.transforms.ParDoTest$TimerTests.xml, line 84831)
Raw output
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$TimerTests.xml
github-actions / Test Results
Error processing result file
CData section too big found, line 98124, column 153 (TEST-org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.xml, line 98124)
Raw output
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.xml
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$BasicTests
github-actions / Test Results
testPipelineOptionsParameter (org.apache.beam.sdk.transforms.ParDoTest$BasicTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$BasicTests.xml [took 50s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 1: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$BasicTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 20 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor340.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 32 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 36 more
Caused by: java.io.FileNotFoundException: /tmp/spark-72c08eb6-2970-4c74-837d-2477f18d87c3/userFiles-acbc8618-a4a5-43ad-b19f-893bc91992e7/beam-sdks-java-core-2.52.0-SNAPSHOT-unshaded.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 47 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$BasicTests.testPipelineOptionsParameter(ParDoTest.java:646)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests
github-actions / Test Results
testParDoWithOnlyTaggedOutput (org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.xml [took 1m 2s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 3: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 20 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor539.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 32 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 36 more
Caused by: java.io.FileNotFoundException: /tmp/spark-5160c6b5-1c24-42b1-90bb-01ef6ada55f1/userFiles-1a4aed3a-a788-45b7-a019-d9cdee1b5f2f/beam-sdks-java-core-2.52.0-SNAPSHOT.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 47 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoWithOnlyTaggedOutput(ParDoTest.java:818)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests
github-actions / Test Results
testMultiOutputParDoWithSideInputs (org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.xml [took 1m 24s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 10: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 19 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor539.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 31 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 35 more
Caused by: java.io.FileNotFoundException: /tmp/spark-5160c6b5-1c24-42b1-90bb-01ef6ada55f1/userFiles-1a4aed3a-a788-45b7-a019-d9cdee1b5f2f/beam-sdks-java-core-2.52.0-SNAPSHOT.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 46 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testMultiOutputParDoWithSideInputs(ParDoTest.java:1251)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests
github-actions / Test Results
testParDoEmptyWithTaggedOutput (org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.xml [took 1m 6s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 1: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at java.util.ArrayList.readObject(ArrayList.java:799)
at sun.reflect.GeneratedMethodAccessor67.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1184)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2322)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 20 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor539.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 46 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 50 more
Caused by: java.io.FileNotFoundException: /tmp/spark-5160c6b5-1c24-42b1-90bb-01ef6ada55f1/userFiles-1a4aed3a-a788-45b7-a019-d9cdee1b5f2f/beam-sdks-java-core-2.52.0-SNAPSHOT.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 61 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoEmptyWithTaggedOutput(ParDoTest.java:765)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests
github-actions / Test Results
testParDoWithTaggedOutput (org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.xml [took 1m 11s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 3: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at java.util.ArrayList.readObject(ArrayList.java:799)
at sun.reflect.GeneratedMethodAccessor67.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1184)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2322)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 20 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor539.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 46 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 50 more
Caused by: java.io.FileNotFoundException: /tmp/spark-5160c6b5-1c24-42b1-90bb-01ef6ada55f1/userFiles-1a4aed3a-a788-45b7-a019-d9cdee1b5f2f/beam-sdks-java-core-2.52.0-SNAPSHOT.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 61 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoWithTaggedOutput(ParDoTest.java:723)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests
github-actions / Test Results
testMultiOutputParDoWithSideInputsIsCumulative (org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.xml [took 1m 15s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 10: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 19 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor539.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 31 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 35 more
Caused by: java.io.FileNotFoundException: /tmp/spark-5160c6b5-1c24-42b1-90bb-01ef6ada55f1/userFiles-1a4aed3a-a788-45b7-a019-d9cdee1b5f2f/beam-sdks-java-core-2.52.0-SNAPSHOT.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 46 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testMultiOutputParDoWithSideInputsIsCumulative(ParDoTest.java:1289)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests
github-actions / Test Results
testSideInputAnnotationWithMultipleSideInputs (org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.xml [took 1m 6s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 13: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 19 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor539.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 31 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 35 more
Caused by: java.io.FileNotFoundException: /tmp/spark-5160c6b5-1c24-42b1-90bb-01ef6ada55f1/userFiles-1a4aed3a-a788-45b7-a019-d9cdee1b5f2f/beam-sdks-java-core-2.52.0-SNAPSHOT.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 46 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testSideInputAnnotationWithMultipleSideInputs(ParDoTest.java:1179)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests
github-actions / Test Results
testSideInputAnnotation (org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.xml [took 1m 2s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 5: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 19 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor539.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 31 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 35 more
Caused by: java.io.FileNotFoundException: /tmp/spark-5160c6b5-1c24-42b1-90bb-01ef6ada55f1/userFiles-1a4aed3a-a788-45b7-a019-d9cdee1b5f2f/beam-sdks-java-core-2.52.0-SNAPSHOT.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 46 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testSideInputAnnotation(ParDoTest.java:1076)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests
github-actions / Test Results
testParDoWithEmptyTaggedOutput (org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.xml [took 59s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 2: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 20 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor539.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 32 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 36 more
Caused by: java.io.FileNotFoundException: /tmp/spark-5160c6b5-1c24-42b1-90bb-01ef6ada55f1/userFiles-1a4aed3a-a788-45b7-a019-d9cdee1b5f2f/beam-sdks-java-core-2.52.0-SNAPSHOT.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 47 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoWithEmptyTaggedOutput(ParDoTest.java:789)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check warning on line 0 in org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests
github-actions / Test Results
testBagStateCoderInference (org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests) failed
runners/spark/3/job-server/build/test-results/validatesPortableRunnerBatch/TEST-org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests.xml [took 51s]
Raw output
java.lang.RuntimeException: The Runner experienced the following error during execution:
java.lang.RuntimeException: Error received from SDK harness for instruction 3: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:78)
at org.apache.beam.runners.core.construction.ParDoTranslation.doFnWithExecutionInformationFromProto(ParDoTranslation.java:765)
at org.apache.beam.runners.core.construction.ParDoTranslation.getDoFn(ParDoTranslation.java:397)
at org.apache.beam.fn.harness.FnApiDoFnRunner.<init>(FnApiDoFnRunner.java:376)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:191)
at org.apache.beam.fn.harness.FnApiDoFnRunner$Factory.createRunnerForPTransform(FnApiDoFnRunner.java:160)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:307)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createRunnerAndConsumersForPTransformRecursively(ProcessBundleHandler.java:261)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:858)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:511)
at org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:969)
at org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:507)
at org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
at org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
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:750)
Caused by: java.io.InvalidClassException: org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests; unable to create instance
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2200)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:503)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:461)
at org.apache.beam.sdk.util.SerializableUtils.deserializeFromByteArray(SerializableUtils.java:75)
... 19 more
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedSerializationConstructorAccessor369.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.io.ObjectStreamClass.newInstance(ObjectStreamClass.java:1102)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2197)
... 31 more
Caused by: java.util.ServiceConfigurationError: org.apache.beam.sdk.io.FileSystemRegistrar: Error reading configuration file
at java.util.ServiceLoader.fail(ServiceLoader.java:232)
at java.util.ServiceLoader.parse(ServiceLoader.java:309)
at java.util.ServiceLoader.access$200(ServiceLoader.java:185)
at java.util.ServiceLoader$LazyIterator.hasNextService(ServiceLoader.java:357)
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:393)
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:474)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterators.addAll(Iterators.java:366)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:146)
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Lists.newArrayList(Lists.java:132)
at org.apache.beam.sdk.io.FileSystems.setDefaultPipelineOptions(FileSystems.java:550)
at org.apache.beam.sdk.testing.TestPipeline.testingPipelineOptions(TestPipeline.java:511)
at org.apache.beam.sdk.testing.TestPipeline.create(TestPipeline.java:265)
at org.apache.beam.sdk.transforms.ParDoTest$SharedTestBase.<init>(ParDoTest.java:193)
... 35 more
Caused by: java.io.FileNotFoundException: /tmp/spark-72c08eb6-2970-4c74-837d-2477f18d87c3/userFiles-acbc8618-a4a5-43ad-b19f-893bc91992e7/beam-sdks-java-core-2.52.0-SNAPSHOT-unshaded.jar (No such file or directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:236)
at java.util.zip.ZipFile.<init>(ZipFile.java:162)
at java.util.jar.JarFile.<init>(JarFile.java:173)
at java.util.jar.JarFile.<init>(JarFile.java:110)
at sun.net.www.protocol.jar.URLJarFile.<init>(URLJarFile.java:93)
at sun.net.www.protocol.jar.URLJarFile.getJarFile(URLJarFile.java:69)
at sun.net.www.protocol.jar.JarFileFactory.get(JarFileFactory.java:84)
at sun.net.www.protocol.jar.JarURLConnection.connect(JarURLConnection.java:122)
at sun.net.www.protocol.jar.JarURLConnection.getInputStream(JarURLConnection.java:152)
at java.net.URL.openStream(URL.java:1093)
at java.util.ServiceLoader.parse(ServiceLoader.java:304)
... 46 more
at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:81)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:321)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests.testBagStateCoderInference(ParDoTest.java:3915)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:750)
Check notice on line 0 in .github
github-actions / Test Results
1 skipped test found
There is 1 skipped test, see "Raw output" for the name of the skipped test.
Raw output
org.apache.beam.sdk.values.PDoneTest ‑ testEmptyTransform
Check notice on line 0 in .github
github-actions / Test Results
154 tests found
There are 154 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunnerTest ‑ testGarbageCollectForStatefulDoFnRunner
org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunnerTest ‑ testLateDroppingForStatefulDoFnRunner
org.apache.beam.runners.core.metrics.MetricsPusherTest ‑ pushesSystemMetrics
org.apache.beam.runners.core.metrics.MetricsPusherTest ‑ pushesUserMetrics
org.apache.beam.sdk.PipelineTest ‑ testIdentityTransform
org.apache.beam.sdk.PipelineTest ‑ testMultipleApply
org.apache.beam.sdk.PipelineTest ‑ testTupleInjectionTransform
org.apache.beam.sdk.PipelineTest ‑ testTupleProjectionTransform
org.apache.beam.sdk.io.CountingSourceTest ‑ testBoundedSourceSplits
org.apache.beam.sdk.io.CountingSourceTest ‑ testUnboundedSourceSplits
org.apache.beam.sdk.metrics.MetricsTest$AttemptedMetricTests ‑ testAttemptedCounterMetrics
org.apache.beam.sdk.metrics.MetricsTest$AttemptedMetricTests ‑ testAttemptedDistributionMetrics
org.apache.beam.sdk.schemas.AvroSchemaTest ‑ testAvroPipelineGroupBy
org.apache.beam.sdk.testing.PAssertTest ‑ testContainsInAnyOrder
org.apache.beam.sdk.testing.PAssertTest ‑ testContainsInAnyOrderNotSerializable
org.apache.beam.sdk.testing.PAssertTest ‑ testContainsInAnyOrderWithMatchers
org.apache.beam.sdk.testing.PAssertTest ‑ testEmpty
org.apache.beam.sdk.testing.PAssertTest ‑ testGlobalWindowContainsInAnyOrder
org.apache.beam.sdk.testing.PAssertTest ‑ testIsEqualTo
org.apache.beam.sdk.testing.PAssertTest ‑ testNotEqualTo
org.apache.beam.sdk.testing.PAssertTest ‑ testPAssertThatFlattened
org.apache.beam.sdk.testing.PAssertTest ‑ testPAssertThatListSatisfiesMultipleMatchers
org.apache.beam.sdk.testing.PAssertTest ‑ testPAssertThatListSatisfiesOneMatcher
org.apache.beam.sdk.testing.PAssertTest ‑ testSerializablePredicate
org.apache.beam.sdk.testing.PAssertTest ‑ testWindowedContainsInAnyOrder
org.apache.beam.sdk.testing.PAssertTest ‑ testWindowedIsEqualTo
org.apache.beam.sdk.testing.PAssertTest ‑ testWindowedSerializablePredicate
org.apache.beam.sdk.transforms.CombineFnsTest ‑ testComposedCombine
org.apache.beam.sdk.transforms.CombineFnsTest ‑ testComposedCombineNullValues
org.apache.beam.sdk.transforms.CombineFnsTest ‑ testComposedCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$AccumulationTests ‑ testAccumulatingCombine
org.apache.beam.sdk.transforms.CombineTest$AccumulationTests ‑ testAccumulatingCombineEmpty
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBasicCombine
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBasicCombineEmpty
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBinaryCombinePerKeyInstanceMethodReference
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testBinaryCombinePerKeyLambda
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testCombinePerKeyInstanceMethodReference
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testCombinePerKeyLambda
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testCombinePerKeyPrimitiveDisplayData
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testCombinePerKeyWithHotKeyFanoutPrimitiveDisplayData
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testHotKeyCombining
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testHotKeyCombiningWithAccumulationMode
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testSimpleCombine
org.apache.beam.sdk.transforms.CombineTest$BasicTests ‑ testSimpleCombineEmpty
org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests ‑ testSimpleCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests ‑ testSimpleCombineWithContextEmpty
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testCombineGloballyAsSingletonView
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testCombineGloballyInstanceMethodReference
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testCombineGloballyLambda
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testFixedWindowsCombine
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testFixedWindowsCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testGlobalCombineWithDefaultsAndTriggers
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testSessionsCombine
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testSessionsCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testSlidingWindowsCombine
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testSlidingWindowsCombineWithContext
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testWindowedCombineEmpty
org.apache.beam.sdk.transforms.CombineTest$WindowingTests ‑ testWindowedCombineGloballyAsSingletonView
org.apache.beam.sdk.transforms.CreateTest ‑ testCreate
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateEmpty
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWithKVVoidType
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWithNullsAndValues
org.apache.beam.sdk.transforms.CreateTest ‑ testCreateWithVoidType
org.apache.beam.sdk.transforms.FlattenTest ‑ testEmptyFlattenAsSideInput
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenInputMultipleCopies
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterables
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterablesCollections
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterablesEmpty
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterablesLists
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenIterablesSets
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenMultiplePCollectionsHavingMultipleConsumers
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollections
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollectionsEmpty
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollectionsEmptyThenParDo
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollectionsSingletonList
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenPCollectionsThenParDo
org.apache.beam.sdk.transforms.FlattenTest ‑ testFlattenWithDifferentInputAndOutputCoders
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testGroupByKey
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testGroupByKeyEmpty
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testGroupByKeyWithBadEqualsHashCode
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testLargeKeys100KB
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testLargeKeys10KB
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testLargeKeys10MB
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testLargeKeys1MB
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testTimestampCombinerEarliest
org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests ‑ testTimestampCombinerLatest
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testGroupByKeyAndWindows
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testGroupByKeyMergingWindows
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testGroupByKeyMultipleWindows
org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests ‑ testRewindowWithTimestampCombiner
org.apache.beam.sdk.transforms.ImpulseTest ‑ testImpulse
org.apache.beam.sdk.transforms.KeysTest ‑ testKeys
org.apache.beam.sdk.transforms.KeysTest ‑ testKeysEmpty
org.apache.beam.sdk.transforms.KvSwapTest ‑ testKvSwap
org.apache.beam.sdk.transforms.MapElementsTest ‑ testPrimitiveDisplayData
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testFieldAccessSchemaPipeline
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testInferredSchemaPipeline
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testNestedSchema
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testReadAndWrite
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testReadAndWriteMultiOutput
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testReadAndWriteWithSchemaRegistry
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testSchemaConversionPipeline
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testSchemaFieldDescriptorSelectionUnboxing
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testSchemaFieldSelectionNested
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testSchemaFieldSelectionUnboxing
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testSchemasPassedThrough
org.apache.beam.sdk.transforms.ParDoSchemaTest ‑ testSimpleSchemaPipeline
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testParDo
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testParDoEmpty
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testParDoEmptyOutputs
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testParDoInCustomTransform
org.apache.beam.sdk.transforms.ParDoTest$BasicTests ‑ testPipelineOptionsParameter
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests ‑ testParDoWithErrorInFinishBatch
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests ‑ testParDoWithErrorInProcessElement
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests ‑ testParDoWithErrorInStartBatch
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests ‑ testWindowingInStartAndFinishBundle
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testMultiOutputChaining
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testMultiOutputParDoWithSideInputs
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testMultiOutputParDoWithSideInputsIsCumulative
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoEmptyWithTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithEmptyTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithOnlyTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithSideInputs
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithSideInputsIsCumulative
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testParDoWithTaggedOutput
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSameSideInputReadTwice
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotation
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputAnnotationWithMultipleSideInputs
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests ‑ testSideInputsWithMultipleWindows
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testBagStateCoderInference
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testBagStateCoderInferenceFailure
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testCombiningStateCoderInference
org.apache.beam.sdk.transforms.ParDoTest$StateCoderInferenceTests ‑ testCombiningStateCoderInferenceFailure
org.apache.beam.sdk.transforms.ParDoTest$TimerCoderInferenceTests ‑ testValueStateCoderInference
org.apache.beam.sdk.transforms.ParDoTest$TimerCoderInferenceTests ‑ testValueStateCoderInferenceFailure
org.apache.beam.sdk.transforms.ParDoTest$TimerCoderInferenceTests ‑ testValueStateCoderInferenceFromInputCoder
org.apache.beam.sdk.transforms.ReifyTimestampsTest ‑ extractFromValuesSucceeds
org.apache.beam.sdk.transforms.ReifyTimestampsTest ‑ extractFromValuesWhenValueTimestampedLaterSucceeds
org.apache.beam.sdk.transforms.ReifyTimestampsTest ‑ inValuesSucceeds
org.apache.beam.sdk.transforms.WithTimestampsTest ‑ withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed
org.apache.beam.sdk.transforms.WithTimestampsTest ‑ withTimestampsLambdaShouldApplyTimestamps
org.apache.beam.sdk.transforms.WithTimestampsTest ‑ withTimestampsShouldApplyTimestamps
org.apache.beam.sdk.transforms.WithTimestampsTest ‑ withTimestampsWithNullFnShouldThrowOnConstruction
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testCoGroupByKey
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testCoGroupByKeyGetOnly
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testCoGroupByKeyHandleResults
org.apache.beam.sdk.transforms.join.CoGroupByKeyTest ‑ testCoGroupByKeyWithWindowing
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testMergingWindowing
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testNonPartitioningWindowing
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testPartitioningWindowing
org.apache.beam.sdk.transforms.windowing.WindowingTest ‑ testWindowPreservation
org.apache.beam.sdk.values.PCollectionRowTupleTest ‑ testComposePCollectionRowTuple
org.apache.beam.sdk.values.PCollectionTupleTest ‑ testComposePCollectionTuple
org.apache.beam.sdk.values.PDoneTest ‑ testEmptyTransform