See
<https://ci-beam.apache.org/job/beam_PerformanceTests_SparkReceiver_IO/374/display/redirect>
Changes:
------------------------------------------
[...truncated 434.21 KB...]
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:52:39.446Z: java.lang.IllegalArgumentException: Trying to claim
offset 1195650 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:52:59.539Z: java.lang.IllegalArgumentException: Trying to claim
offset 1460200 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] WARN
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:53:09.110Z: Querying the configuration of Pub/Sub subscription
_starting_signal/ failed. If the ack deadline on the subscription has been
changed from the default value, this may affect performance. Also, this
prevents Dataflow from checking for unsupported settings on the subscription.
See
https://cloud.google.com/dataflow/docs/concepts/security-and-permissions#accessing_pubsub
for further details. If the error is not correctable, the job may be updated
with a valid Pub/Sub configuration. Specific error: INVALID_ARGUMENT:
[type.googleapis.com/util.MessageSetPayload='[dist_proc.dax.internal.StackTraceProto]
{ stack_top_loc { filepath:
"dist_proc/dax_extensions/workflow/cloud/service/pubsub_subscription_util.cc"
line: 592 } address: 93900670094513 address: 93900670074511 address:
93900670062118 address: 93900670065739 address: 93900670523266 address:
93900670055716 address: 93900548147242 address: 139654123165657 address:
139654122595999 } [dist_proc.dax.internal.TrailProto] { trail_point {
source_file_loc { filepath:
"dist_proc/dax_extensions/workflow/cloud/service/pubsub_subscription_util.cc"
line: 592 } } } [dist_proc.dax.MessageCode] { argument { string_val:
"_starting_signal/" key: "subscription_name" } argument { string_val: "Invalid
resource name given (name=_starting_signal/). Refer to
https://cloud.google.com/pubsub/docs/admin#resource_names for more
information." key: "error" } origin_id: 1773860027434714116
[dist_proc.dax.pubsub_resource_message_ext]: GETTING_PUBSUB_SUBSCRIPTION_FAILED
}']
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:53:19.632Z: java.lang.IllegalArgumentException: Trying to claim
offset 1739050 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:53:49.757Z: java.lang.IllegalArgumentException: Trying to claim
offset 55750 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:54:09.828Z: java.lang.IllegalArgumentException: Trying to claim
offset 284900 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:54:19.872Z: java.lang.IllegalArgumentException: Trying to claim
offset 576600 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:54:39.976Z: java.lang.IllegalArgumentException: Trying to claim
offset 860600 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:54:50.021Z: java.lang.IllegalArgumentException: Trying to claim
offset 1119050 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:55:00.079Z: java.lang.IllegalArgumentException: Trying to claim
offset 1383600 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:55:20.156Z: java.lang.IllegalArgumentException: Trying to claim
offset 1567050 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:55:30.207Z: java.lang.IllegalArgumentException: Trying to claim
offset 1796000 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:55:50.274Z: java.lang.IllegalArgumentException: Trying to claim
offset 2052200 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:57:00.455Z: java.lang.IllegalArgumentException: Trying to claim
offset 3350 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:57:20.526Z: java.lang.IllegalArgumentException: Trying to claim
offset 315400 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:57:30.573Z: java.lang.IllegalArgumentException: Trying to claim
offset 667000 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:57:40.610Z: java.lang.IllegalArgumentException: Trying to claim
offset 952100 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:58:00.675Z: java.lang.IllegalArgumentException: Trying to claim
offset 1271200 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:58:10.719Z: java.lang.IllegalArgumentException: Trying to claim
offset 1537850 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] ERROR
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler -
2023-04-12T17:58:20.765Z: java.lang.IllegalArgumentException: Trying to claim
offset 1827100 before start of the range [2092110, 9223372036854775807)
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
org.apache.beam.runners.dataflow.****.repackaged.org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
org.apache.beam.sdk.io.sparkreceiver.ReadFromSparkReceiverWithOffsetDoFn.processElement(ReadFromSparkReceiverWithOffsetDoFn.java:333)
[Test ****] WARN org.apache.beam.runners.dataflow.DataflowPipelineJob - No
terminal state was returned within allotted timeout. State value RUNNING
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT >
testSparkReceiverIOReadsInStreamingWithOffset FAILED
java.lang.AssertionError: expected:<5000000> but was:<328817>
at org.junit.Assert.fail(Assert.java:89)
at org.junit.Assert.failNotEquals(Assert.java:835)
at org.junit.Assert.assertEquals(Assert.java:647)
at org.junit.Assert.assertEquals(Assert.java:633)
at
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT.testSparkReceiverIOReadsInStreamingWithOffset(SparkReceiverIOIT.java:337)
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT STANDARD_ERROR
[AMQP Connection 34.29.242.170:5672] WARN
com.rabbitmq.client.impl.ForgivingExceptionHandler - An unexpected connection
driver error occurred (Exception message: Connection reset)
[Test ****] ERROR org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT -
Error during RabbitMQ clean up
java.io.IOException
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
at
com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:147)
at com.rabbitmq.client.impl.ChannelN.queueDelete(ChannelN.java:1042)
at
com.rabbitmq.client.impl.recovery.AutorecoveringChannel.queueDelete(AutorecoveringChannel.java:388)
at
com.rabbitmq.client.impl.recovery.AutorecoveringChannel.queueDelete(AutorecoveringChannel.java:382)
at
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT.clearRabbitMQ(SparkReceiverIOIT.java:253)
at
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT.afterClass(SparkReceiverIOIT.java:138)
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.RunAfters.invokeMethod(RunAfters.java:46)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:33)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
at
org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
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.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at
org.gradle.api.internal.tasks.testing.****.TestWorker$2.run(TestWorker.java:176)
at
org.gradle.api.internal.tasks.testing.****.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
at
org.gradle.api.internal.tasks.testing.****.TestWorker.execute(TestWorker.java:100)
at
org.gradle.api.internal.tasks.testing.****.TestWorker.execute(TestWorker.java:60)
at
org.gradle.process.internal.****.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
at
org.gradle.process.internal.****.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:133)
at
org.gradle.process.internal.****.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:71)
at
****.org.gradle.process.internal.****.GradleWorkerMain.run(GradleWorkerMain.java:69)
at
****.org.gradle.process.internal.****.GradleWorkerMain.main(GradleWorkerMain.java:74)
Suppressed: com.rabbitmq.client.AlreadyClosedException: connection is
already closed due to connection error; cause: java.net.SocketException:
Connection reset
at
com.rabbitmq.client.impl.AMQChannel.processShutdownSignal(AMQChannel.java:401)
at
com.rabbitmq.client.impl.ChannelN.startProcessShutdownSignal(ChannelN.java:287)
at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:608)
at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:542)
at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:535)
at
com.rabbitmq.client.impl.recovery.AutorecoveringChannel.lambda$close$0(AutorecoveringChannel.java:74)
at
com.rabbitmq.client.impl.recovery.AutorecoveringChannel.executeAndClean(AutorecoveringChannel.java:102)
at
com.rabbitmq.client.impl.recovery.AutorecoveringChannel.close(AutorecoveringChannel.java:74)
at
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT.$closeResource(SparkReceiverIOIT.java:224)
at
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT.clearRabbitMQ(SparkReceiverIOIT.java:254)
... 35 more
Suppressed: com.rabbitmq.client.AlreadyClosedException: connection is
already closed due to connection error; cause: java.net.SocketException:
Connection reset
at
com.rabbitmq.client.impl.AMQConnection.startShutdown(AMQConnection.java:990)
at
com.rabbitmq.client.impl.AMQConnection.close(AMQConnection.java:1105)
at
com.rabbitmq.client.impl.AMQConnection.close(AMQConnection.java:1034)
at
com.rabbitmq.client.impl.AMQConnection.close(AMQConnection.java:1018)
at
com.rabbitmq.client.impl.AMQConnection.close(AMQConnection.java:1010)
at
com.rabbitmq.client.impl.recovery.AutorecoveringConnection.close(AutorecoveringConnection.java:284)
at
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT.$closeResource(SparkReceiverIOIT.java:224)
at
org.apache.beam.sdk.io.sparkreceiver.SparkReceiverIOIT.clearRabbitMQ(SparkReceiverIOIT.java:254)
... 35 more
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error
at
com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66)
at
com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36)
at
com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:502)
at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:293)
at
com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:141)
... 39 more
Caused by: java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:210)
at java.net.SocketInputStream.read(SocketInputStream.java:141)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288)
at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:91)
at
com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:184)
at
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:665)
at java.lang.Thread.run(Thread.java:750)
Gradle Test Executor 2 finished executing tests.
> Task :sdks:java:io:sparkreceiver:2:integrationTest FAILED
1 test completed, 1 failed
Finished generating test XML results (0.034 secs) into:
<https://ci-beam.apache.org/job/beam_PerformanceTests_SparkReceiver_IO/ws/src/sdks/java/io/sparkreceiver/2/build/test-results/integrationTest>
Generating HTML test report...
Finished generating test html results (0.037 secs) into:
<https://ci-beam.apache.org/job/beam_PerformanceTests_SparkReceiver_IO/ws/src/sdks/java/io/sparkreceiver/2/build/reports/tests/integrationTest>
:sdks:java:io:sparkreceiver:2:integrationTest (Thread[Execution **** Thread
4,5,main]) completed. Took 34 mins 50.616 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:io:sparkreceiver:2:integrationTest'.
> There were failing tests. See the report at:
> file://<https://ci-beam.apache.org/job/beam_PerformanceTests_SparkReceiver_IO/ws/src/sdks/java/io/sparkreceiver/2/build/reports/tests/integrationTest/index.html>
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.5.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 35m 46s
145 actionable tasks: 88 executed, 55 from cache, 2 up-to-date
Publishing build scan...
https://gradle.com/s/yqrpgr5crnyqi
Stopped 1 **** daemon(s).
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
