You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2022/05/04 15:13:37 UTC
Build failed in Jenkins: beam_PostCommit_Go_VR_Samza #1168
See <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/1168/display/redirect>
Changes:
------------------------------------------
[...truncated 3.40 MB...]
at org.apache.samza.container.SamzaContainer$$anonfun$15.apply(SamzaContainer.scala:243)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:221)
at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at org.apache.samza.container.SamzaContainer$.apply(SamzaContainer.scala:243)
at org.apache.samza.container.SamzaContainer.apply(SamzaContainer.scala)
at org.apache.samza.processor.StreamProcessor.createSamzaContainer(StreamProcessor.java:407)
at org.apache.samza.processor.StreamProcessor$1.onNewJobModel(StreamProcessor.java:513)
at org.apache.samza.standalone.PassthroughJobCoordinator.start(PassthroughJobCoordinator.java:99)
at org.apache.samza.processor.StreamProcessor.start(StreamProcessor.java:317)
at org.apache.samza.runtime.LocalApplicationRunner.lambda$run$2(LocalApplicationRunner.java:241)
at java.util.concurrent.ConcurrentHashMap$KeySetView.forEach(ConcurrentHashMap.java:4649)
at org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:241)
at org.apache.beam.runners.samza.SamzaRunner.runSamzaApp(SamzaRunner.java:200)
at org.apache.beam.runners.samza.SamzaRunner.runPortablePipeline(SamzaRunner.java:111)
at org.apache.beam.runners.samza.SamzaPipelineRunner.run(SamzaPipelineRunner.java:72)
at org.apache.beam.runners.jobsubmission.JobInvocation.runPipeline(JobInvocation.java:86)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:125)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:57)
at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:78)
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:748)
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got system producers: Set()
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got serdes from factories: Set(stateValueSerde, byteArraySerde)
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got serdes from serialized instances: Set()
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got change log system streams: Map()
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got intermediate streams: List()
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Setting up JVM metrics.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Setting up message chooser.
[samza-runner-job-invoker-0] INFO org.apache.samza.system.chooser.DefaultChooser - Building default chooser with: useBatching=false, useBootstrapping=false, usePriority=false
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Setting up metrics reporters.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got metrics reporters: Set()
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got security manager: null
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got checkpoint manager: null
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got checkpointListeners : Map()
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got offset manager: org.apache.samza.checkpoint.OffsetManager@15a6d57c
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got storage engines: Set(beamStore)
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got thread pool size: 0
[samza-runner-job-invoker-0] INFO org.apache.samza.task.TaskFactoryUtil - Adapting StreamOperatorTaskFactory to inject container thread pool
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got default storage engine base directory: <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/state>
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got base directory for non logged data stores: <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/state>
[samza-runner-job-invoker-0] WARN org.apache.samza.container.SamzaContainer$ - No override was provided for logged store base directory. This disables local state re-use on application restart. If you want to enable this feature, set LOGGED_STORE_BASE_DIR as an environment variable in all machines running the Samza container or configure job.logged.store.base.dir for your application
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got base directory for logged data stores: <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/state>
[samza-runner-job-invoker-0] INFO org.apache.samza.storage.ContainerStorageManager - Starting with changelogSystemStreams = {} sideInputSystemStreams = {}
[samza-runner-job-invoker-0] WARN org.apache.samza.storage.ContainerStorageManager - Logged and non-logged store base directory are configured to same path: <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/state.> It is recommended to configurethem separately to ensure clean up of non-logged store data doesn't accidentally impact logged store data.
[samza-runner-job-invoker-0] INFO org.apache.samza.storage.ContainerStorageManager - Created store beamStore for task Partition 0 in mode BulkLoad
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got task SSPs: Set(SystemStreamPartition [n10, n10, 0], SystemStreamPartition [n4, n4, 0], SystemStreamPartition [n1, n1, 0], SystemStreamPartition [n16, n16, 0], SystemStreamPartition [n12, n12, 0])
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got task side input SSPs: Set()
[samza-runner-job-invoker-0] INFO org.apache.samza.table.TableManager - Added 0 tables
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Got table manager
[samza-runner-job-invoker-0] INFO org.apache.samza.container.RunLoopFactory - Got window milliseconds: -1.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.RunLoopFactory - Got commit milliseconds: -1.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.RunLoopFactory - Got taskMaxConcurrency: 1.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.RunLoopFactory - Got asyncCommitEnabled: false.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.RunLoopFactory - Got callbackTimeout: -1.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.RunLoopFactory - Got maxIdleMs: 10.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.RunLoopFactory - Run loop in asynchronous mode.
[samza-runner-job-invoker-0] INFO org.apache.samza.container.disk.NoThrottlingDiskQuotaPolicy - Using a no throttling disk quota policy
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Disk quotas disabled because polling interval is not set (container.disk.poll.interval.ms)
[samza-runner-job-invoker-0] INFO org.apache.samza.container.SamzaContainer$ - Samza container setup complete.
[samza-runner-job-invoker-0] WARN org.apache.samza.config.TaskConfig - Unable to parse user-configure value for task.shutdown.ms - null. Using default value 30000
[samza-runner-job-invoker-0] INFO org.apache.samza.processor.StreamProcessor - Starting the container: org.apache.samza.container.SamzaContainer@6781f206 for the stream processor: 1.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting container.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.metrics.JmxServer - According to Util.getLocalHost.getHostName we are apache-ci-beam-jenkins-4
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.metrics.JmxServer - Not overriding system property com.sun.management.jmxremote.authenticate as already has value false
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.metrics.JmxServer - Not overriding system property com.sun.management.jmxremote.ssl as already has value false
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.metrics.JmxServer - Not overriding system property java.rmi.server.hostname as already has value apache-ci-beam-jenkins-4
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.metrics.JmxServer - Started JmxServer registry port=45569 server port=33647 url=service:jmx:rmi://localhost:33647/jndi/rmi://localhost:45569/jmxrmi
[Samza StreamProcessor Container Thread-0] INFO STARTUP_LOGGER - Started JmxServer registry port=45569 server port=33647 url=service:jmx:rmi://localhost:33647/jndi/rmi://localhost:45569/jmxrmi
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.metrics.JmxServer - If you are tunneling, you might want to try JmxServer registry port=45569 server port=33647 url=service:jmx:rmi://apache-ci-beam-jenkins-4:33647/jndi/rmi://apache-ci-beam-jenkins-4:45569/jmxrmi
[Samza StreamProcessor Container Thread-0] INFO STARTUP_LOGGER - If you are tunneling, you might want to try JmxServer registry port=45569 server port=33647 url=service:jmx:rmi://apache-ci-beam-jenkins-4:33647/jndi/rmi://apache-ci-beam-jenkins-4:45569/jmxrmi
JMX Server: JmxServer registry port=45569 server port=33647 url=service:jmx:rmi://apache-ci-beam-jenkins-4:33647/jndi/rmi://apache-ci-beam-jenkins-4:45569/jmxrmi
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Registering task instance metrics.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting JVM metrics.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting metrics reporters.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting admin multiplexer.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Registering task instances with offsets.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting offset manager.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.checkpoint.OffsetManager - Successfully loaded last processed offsets: {}
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.checkpoint.OffsetManager - Successfully loaded starting offsets: Map(Partition 0 -> Map(SystemStreamPartition [n10, n10, 0] -> 0, SystemStreamPartition [n4, n4, 0] -> 0, SystemStreamPartition [n1, n1, 0] -> 0, SystemStreamPartition [n16, n16, 0] -> 0, SystemStreamPartition [n12, n12, 0] -> 0))
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Registering task instances with producers.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting producer multiplexer.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting container storage manager.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.ContainerStorageManager - Checkpointed changelog ssp offsets: {}
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.ContainerStorageManager - Store Restore started
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.TransactionalStateTaskRestoreManager - Got current changelog offsets for taskName: Partition 0 as: {}
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.TransactionalStateTaskRestoreManager - Marking current directory: <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/state/beamStore/Partition_0> for store: beamStore in task: Partition 0 for deletion since it is not a logged store.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.TransactionalStateTaskRestoreManager - Store directories to be retained in Task: Partition 0 are: {}
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.TransactionalStateTaskRestoreManager - Store directories to be deleted in Task: Partition 0 are: {beamStore=[<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/state/beamStore/Partition_0]}>
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.TransactionalStateTaskRestoreManager - Stores to be restored in Task: Partition 0 are: {}
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.TransactionalStateTaskRestoreManager - Deleting persistent store directory: <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/state/beamStore/Partition_0> for store: beamStore in task: Partition 0
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.TransactionalStateTaskRestoreManager - Creating missing persistent store current directory: <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/state/beamStore/Partition_0> for store: beamStore in task: Partition 0
[Samza Restore Thread-0] INFO org.apache.samza.storage.ContainerStorageManager - Starting stores in task instance Partition 0
[Samza Restore Thread-0] INFO org.apache.samza.storage.TransactionalStateTaskRestoreManager - Stopped persistent store: beamStore in task: Partition 0
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.ContainerStorageManager - Re-created store beamStore in read-write mode for task Partition 0 because it a persistent store
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.storage.ContainerStorageManager - Store Restore complete
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting table manager in task instance Partition 0
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting host statistics monitor
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Initializing stream tasks.
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull docker image apache/beam_go_sdk:dev, cause: Received exit code 1 for command 'docker pull apache/beam_go_sdk:dev'. stderr: Error response from daemon: manifest for apache/beam_go_sdk:dev not found
[grpc-default-executor-2] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client connected.
[grpc-default-executor-3] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 15-1
[grpc-default-executor-3] INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:654 - Connecting via grpc @ localhost:40515 ...
[grpc-default-executor-3] INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:654 - Connecting via grpc @ localhost:43495 ...
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull docker image apache/beam_java8_sdk:2.39.0.dev, cause: Received exit code 1 for command 'docker pull apache/beam_java8_sdk:2.39.0.dev'. stderr: Error response from daemon: manifest for apache/beam_java8_sdk:2.39.0.dev not found
[grpc-default-executor-3] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 15-3
[grpc-default-executor-3] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client connected.
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[grpc-default-executor-3] INFO org.apache.beam.fn.harness.FnHarness - Fn Harness started
[grpc-default-executor-3] INFO org.apache.beam.fn.harness.FnHarness - Entering instruction processing loop
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 processing time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Registering task instances with consumers.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Starting consumer multiplexer.
[Samza StreamProcessor Container Thread-0] INFO org.apache.samza.container.SamzaContainer - Entering run loop.
[Samza StreamProcessor Container Thread-0] WARN org.apache.samza.processor.StreamProcessor - Received container start notification for container: org.apache.samza.container.SamzaContainer@6781f206 in stream processor: 1.
[grpc-default-executor-3] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 15-9
[grpc-default-executor-5] INFO org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client connected.
[grpc-default-executor-3] INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:654 - Connecting via grpc @ localhost:39365 ...
[grpc-default-executor-3] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 15-10
[grpc-default-executor-3] INFO org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client connected.
[grpc-default-executor-5] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 15-11
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 15-8
[grpc-default-executor-3] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 15-2
[grpc-default-executor-5] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 15-4
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 15-7
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[Samza StreamProcessor Container Thread-0] INFO org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory - Loaded 0 event time timers in memory
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 15-5
ptest.go:102: Failed to execute job: failed to get metrics
caused by:
rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing dial tcp 127.0.0.1:43415: connect: connection refused"
caused by:
rpc error: code = Unavailable desc = error reading from server: EOF
--- FAIL: TestXLang_CoGroupBy (14.58s)
=== RUN TestXLang_Combine
--- FAIL: TestXLang_Combine (0.59s)
panic: tried cross-language for beam:transforms:xlang:test:compk against localhost:37135 and failed
expanding external transform
expanding transform with ExpansionRequest: components:{pcollections:{key:"n3" value:{unique_name:"n3" coder_id:"c2@fujzwECIot" is_bounded:BOUNDED windowing_strategy_id:"w0@fujzwECIot"}} windowing_strategies:{key:"w0@fujzwECIot" value:{window_fn:{urn:"beam:window_fn:global_windows:v1"} merge_status:NON_MERGING window_coder_id:"c3@fujzwECIot" trigger:{default:{}} accumulation_mode:DISCARDING output_time:END_OF_WINDOW closing_behavior:EMIT_IF_NONEMPTY on_time_behavior:FIRE_IF_NONEMPTY environment_id:"go"}} coders:{key:"c0@fujzwECIot" value:{spec:{urn:"beam:coder:string_utf8:v1"}}} coders:{key:"c1@fujzwECIot" value:{spec:{urn:"beam:coder:varint:v1"}}} coders:{key:"c2@fujzwECIot" value:{spec:{urn:"beam:coder:kv:v1"} component_coder_ids:"c0@fujzwECIot" component_coder_ids:"c1@fujzwECIot"}} coders:{key:"c3@fujzwECIot" value:{spec:{urn:"beam:coder:global_window:v1"}}} environments:{key:"go" value:{}}} transform:{unique_name:"External" spec:{urn:"beam:transforms:xlang:test:compk"} inputs:{key:"i0" value:"n3"} environment_id:"go"} namespace:"fujzwECIot"
expansion failed
caused by:
rpc error: code = Unavailable desc = error reading from server: EOF [recovered]
panic: tried cross-language for beam:transforms:xlang:test:compk against localhost:37135 and failed
expanding external transform
expanding transform with ExpansionRequest: components:{pcollections:{key:"n3" value:{unique_name:"n3" coder_id:"c2@fujzwECIot" is_bounded:BOUNDED windowing_strategy_id:"w0@fujzwECIot"}} windowing_strategies:{key:"w0@fujzwECIot" value:{window_fn:{urn:"beam:window_fn:global_windows:v1"} merge_status:NON_MERGING window_coder_id:"c3@fujzwECIot" trigger:{default:{}} accumulation_mode:DISCARDING output_time:END_OF_WINDOW closing_behavior:EMIT_IF_NONEMPTY on_time_behavior:FIRE_IF_NONEMPTY environment_id:"go"}} coders:{key:"c0@fujzwECIot" value:{spec:{urn:"beam:coder:string_utf8:v1"}}} coders:{key:"c1@fujzwECIot" value:{spec:{urn:"beam:coder:varint:v1"}}} coders:{key:"c2@fujzwECIot" value:{spec:{urn:"beam:coder:kv:v1"} component_coder_ids:"c0@fujzwECIot" component_coder_ids:"c1@fujzwECIot"}} coders:{key:"c3@fujzwECIot" value:{spec:{urn:"beam:coder:global_window:v1"}}} environments:{key:"go" value:{}}} transform:{unique_name:"External" spec:{urn:"beam:transforms:xlang:test:compk"} inputs:{key:"i0" value:"n3"} environment_id:"go"} namespace:"fujzwECIot"
expansion failed
caused by:
rpc error: code = Unavailable desc = error reading from server: EOF
goroutine 208 [running]:
testing.tRunner.func1.2(0xd71960, 0xc000390640)
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1143 +0x332
testing.tRunner.func1(0xc00067e900)
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1146 +0x4b6
panic(0xd71960, 0xc000390640)
/home/jenkins/sdk/go1.16.12/src/runtime/panic.go:965 +0x1b9
github.com/apache/beam/sdks/v2/go/pkg/beam.CrossLanguage(0xc000380b60, 0xc0004d8a00, 0xea218d, 0x20, 0x0, 0x0, 0x0, 0xc0000400a0, 0xf, 0xc0006afc10, ...)
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/pkg/beam/xlang.go>:162 +0x1f7
github.com/apache/beam/sdks/v2/go/examples/xlang.CombinePerKey(0xc0003806e0, 0xc0004d8a00, 0xc0000400a0, 0xf, 0xc0001a8cc0, 0x0)
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/examples/xlang/transforms.go>:67 +0x3fe
github.com/apache/beam/sdks/v2/go/test/integration/xlang.TestXLang_Combine(0xc00067e900)
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/test/integration/xlang/xlang_test.go>:162 +0x31f
testing.tRunner(0xc00067e900, 0xeca6e0)
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1193 +0xef
created by testing.(*T).Run
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1238 +0x2b3
FAIL github.com/apache/beam/sdks/v2/go/test/integration/xlang 38.167s
$ TEST_EXIT_CODE=0
$ cd ../..
./run_validatesrunner_tests.sh: line 103: kill: (2487009) - No such process
$ exit 1
$ exit 1
./run_validatesrunner_tests.sh: line 103: kill: (2487009) - No such process
> Task :sdks:go:test:samzaValidatesRunner FAILED
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=12b8e82d-bc26-4580-ad08-913a78c31866, currentDir=<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src}>
Attempting to read last messages from the daemon log...
Daemon pid: 2460405
log file: /home/jenkins/.gradle/daemon/7.4/daemon-2460405.out.log
----- Last 20 lines from daemon log file - daemon-2460405.out.log -----
panic(0xd71960, 0xc000390640)
/home/jenkins/sdk/go1.16.12/src/runtime/panic.go:965 +0x1b9
github.com/apache/beam/sdks/v2/go/pkg/beam.CrossLanguage(0xc000380b60, 0xc0004d8a00, 0xea218d, 0x20, 0x0, 0x0, 0x0, 0xc0000400a0, 0xf, 0xc0006afc10, ...)
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/pkg/beam/xlang.go>:162 +0x1f7
github.com/apache/beam/sdks/v2/go/examples/xlang.CombinePerKey(0xc0003806e0, 0xc0004d8a00, 0xc0000400a0, 0xf, 0xc0001a8cc0, 0x0)
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/examples/xlang/transforms.go>:67 +0x3fe
github.com/apache/beam/sdks/v2/go/test/integration/xlang.TestXLang_Combine(0xc00067e900)
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/ws/src/sdks/go/test/integration/xlang/xlang_test.go>:162 +0x31f
testing.tRunner(0xc00067e900, 0xeca6e0)
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1193 +0xef
created by testing.(*T).Run
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1238 +0x2b3
FAIL github.com/apache/beam/sdks/v2/go/test/integration/xlang 38.167s
$ TEST_EXIT_CODE=0
$ cd ../..
./run_validatesrunner_tests.sh: line 103: kill: (2487009) - No such process
$ exit 1
$ exit 1
./run_validatesrunner_tests.sh: line 103: kill: (2487009) - No such process
Daemon vm is shutting down... The daemon has exited normally or was terminated in response to a user interrupt.
----- End of the daemon log -----
FAILURE: Build failed with an exception.
* What went wrong:
Gradle build daemon disappeared unexpectedly (it may have been killed or may have crashed)
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Go_VR_Samza #1169
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/1169/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org