See
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Samza/2514/display/redirect>
Changes:
------------------------------------------
[...truncated 8.22 MB...]
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:244)
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:4647)
at
org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:241)
at
org.apache.beam.runners.samza.SamzaRunner.runSamzaApp(SamzaRunner.java:204)
at
org.apache.beam.runners.samza.SamzaRunner.runPortablePipeline(SamzaRunner.java:113)
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:750)
[samza-runner-job-invoker-4] ERROR org.apache.samza.container.SamzaContainer$ -
Failed to create a producer for n14, so skipping.
java.lang.UnsupportedOperationException: SamzaImpulseSystem doesn't support
producing
at
org.apache.beam.runners.samza.translation.SamzaImpulseSystemFactory.getProducer(SamzaImpulseSystemFactory.java:59)
at
org.apache.samza.system.SystemFactory.getProducer(SystemFactory.java:66)
at
org.apache.samza.container.SamzaContainer$$anonfun$15.apply(SamzaContainer.scala:247)
at
org.apache.samza.container.SamzaContainer$$anonfun$15.apply(SamzaContainer.scala:244)
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.Map$Map4.foreach(Map.scala:188)
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:244)
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:4647)
at
org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:241)
at
org.apache.beam.runners.samza.SamzaRunner.runSamzaApp(SamzaRunner.java:204)
at
org.apache.beam.runners.samza.SamzaRunner.runPortablePipeline(SamzaRunner.java:113)
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:750)
[samza-runner-job-invoker-4] ERROR org.apache.samza.container.SamzaContainer$ -
Failed to create a producer for n1, so skipping.
java.lang.UnsupportedOperationException: SamzaImpulseSystem doesn't support
producing
at
org.apache.beam.runners.samza.translation.SamzaImpulseSystemFactory.getProducer(SamzaImpulseSystemFactory.java:59)
at
org.apache.samza.system.SystemFactory.getProducer(SystemFactory.java:66)
at
org.apache.samza.container.SamzaContainer$$anonfun$15.apply(SamzaContainer.scala:247)
at
org.apache.samza.container.SamzaContainer$$anonfun$15.apply(SamzaContainer.scala:244)
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.Map$Map4.foreach(Map.scala:188)
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:244)
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:4647)
at
org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:241)
at
org.apache.beam.runners.samza.SamzaRunner.runSamzaApp(SamzaRunner.java:204)
at
org.apache.beam.runners.samza.SamzaRunner.runPortablePipeline(SamzaRunner.java:113)
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:750)
[samza-runner-job-invoker-4] ERROR org.apache.samza.container.SamzaContainer$ -
Failed to create a producer for n8, so skipping.
java.lang.UnsupportedOperationException: SamzaImpulseSystem doesn't support
producing
at
org.apache.beam.runners.samza.translation.SamzaImpulseSystemFactory.getProducer(SamzaImpulseSystemFactory.java:59)
at
org.apache.samza.system.SystemFactory.getProducer(SystemFactory.java:66)
at
org.apache.samza.container.SamzaContainer$$anonfun$15.apply(SamzaContainer.scala:247)
at
org.apache.samza.container.SamzaContainer$$anonfun$15.apply(SamzaContainer.scala:244)
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.Map$Map4.foreach(Map.scala:188)
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:244)
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:4647)
at
org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:241)
at
org.apache.beam.runners.samza.SamzaRunner.runSamzaApp(SamzaRunner.java:204)
at
org.apache.beam.runners.samza.SamzaRunner.runPortablePipeline(SamzaRunner.java:113)
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:750)
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got system producers: Set()
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got serdes from factories: Set(stateValueSerde, byteArraySerde)
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got serdes from serialized instances: Set()
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got change log system streams: Map()
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got intermediate streams: List()
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Setting up JVM metrics.
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Setting up message chooser.
[samza-runner-job-invoker-4] INFO
org.apache.samza.system.chooser.DefaultChooser - Building default chooser with:
useBatching=false, useBootstrapping=false, usePriority=false
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Setting up metrics reporters.
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got metrics reporters: Set()
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got security manager: null
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got checkpoint manager: null
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got checkpointListeners : Map()
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got offset manager: org.apache.samza.checkpoint.OffsetManager@435a96f8
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got storage engines: Set(beamStore)
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got thread pool size: 0
[samza-runner-job-invoker-4] INFO org.apache.samza.task.TaskFactoryUtil -
Adapting StreamOperatorTaskFactory to inject container thread pool
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got default storage engine base directory:
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/src/state
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got base directory for non logged data stores:
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/src/state
[samza-runner-job-invoker-4] 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-4] INFO org.apache.samza.container.SamzaContainer$ -
Got base directory for logged data stores:
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/src/state
[samza-runner-job-invoker-4] INFO
org.apache.samza.storage.ContainerStorageManager - Starting with
changelogSystemStreams = {} taskSideInputStoreSSPs = {Partition 0={}}
[samza-runner-job-invoker-4] WARN
org.apache.samza.storage.ContainerStorageManager - Logged and non-logged store
base directory are configured to same path:
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/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-4] INFO
org.apache.samza.storage.ContainerStorageManager - Created store beamStore for
task Partition 0 in mode BulkLoad
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got task SSPs: Set(SystemStreamPartition [n14, n14, 0], SystemStreamPartition
[n10, n10, 0], SystemStreamPartition [n1, n1, 0], SystemStreamPartition [n8,
n8, 0])
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got task side input SSPs: Set()
[samza-runner-job-invoker-4] INFO org.apache.samza.table.TableManager - Added 0
tables
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Got table manager
[samza-runner-job-invoker-4] INFO org.apache.samza.container.RunLoopFactory -
Got window milliseconds: -1.
[samza-runner-job-invoker-4] INFO org.apache.samza.container.RunLoopFactory -
Got commit milliseconds: -1.
[samza-runner-job-invoker-4] INFO org.apache.samza.container.RunLoopFactory -
Got taskMaxConcurrency: 1.
[samza-runner-job-invoker-4] INFO org.apache.samza.container.RunLoopFactory -
Got asyncCommitEnabled: false.
[samza-runner-job-invoker-4] INFO org.apache.samza.container.RunLoopFactory -
Got callbackTimeout: -1.
[samza-runner-job-invoker-4] INFO org.apache.samza.container.RunLoopFactory -
Got maxIdleMs: 10.
[samza-runner-job-invoker-4] INFO org.apache.samza.container.RunLoopFactory -
Run loop in asynchronous mode.
[samza-runner-job-invoker-4] INFO
org.apache.samza.container.disk.NoThrottlingDiskQuotaPolicy - Using a no
throttling disk quota policy
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Disk quotas disabled because polling interval is not set
(container.disk.poll.interval.ms)
[samza-runner-job-invoker-4] INFO org.apache.samza.container.SamzaContainer$ -
Samza container setup complete.
[samza-runner-job-invoker-4] 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-4] INFO org.apache.samza.processor.StreamProcessor -
Starting the container: org.apache.samza.container.SamzaContainer@68d0c5d5 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-2
[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-2
[Samza StreamProcessor Container Thread-0] INFO
org.apache.samza.metrics.JmxServer - Started JmxServer registry port=45987
server port=32935
url=service:jmx:rmi://localhost:32935/jndi/rmi://localhost:45987/jmxrmi
[Samza StreamProcessor Container Thread-0] INFO STARTUP_LOGGER - Started
JmxServer registry port=45987 server port=32935
url=service:jmx:rmi://localhost:32935/jndi/rmi://localhost:45987/jmxrmi
[Samza StreamProcessor Container Thread-0] INFO
org.apache.samza.metrics.JmxServer - If you are tunneling, you might want to
try JmxServer registry port=45987 server port=32935
url=service:jmx:rmi://apache-ci-beam-jenkins-2:32935/jndi/rmi://apache-ci-beam-jenkins-2:45987/jmxrmi
[Samza StreamProcessor Container Thread-0] INFO STARTUP_LOGGER - If you are
tunneling, you might want to try JmxServer registry port=45987 server
port=32935
url=service:jmx:rmi://apache-ci-beam-jenkins-2:32935/jndi/rmi://apache-ci-beam-jenkins-2:45987/jmxrmi
JMX Server: JmxServer registry port=45987 server port=32935
url=service:jmx:rmi://apache-ci-beam-jenkins-2:32935/jndi/rmi://apache-ci-beam-jenkins-2:45987/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 [n1, n1, 0] -> 0,
SystemStreamPartition [n8, n8, 0] -> 0, SystemStreamPartition [n14, n14, 0] ->
0, SystemStreamPartition [n10, n10, 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:
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/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=[/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/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:
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/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:
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/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: manifest unknown: manifest
unknown
[grpc-default-executor-6] INFO
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn
Logging client connected.
[grpc-default-executor-6] INFO
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn
Logging client connected.
[grpc-default-executor-8] INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService -
Beam Fn Control client connected with id 41-1
[grpc-default-executor-8] INFO
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/src/sdks/go/pkg/beam/core/runtime/harness/harness.go:698
- Connecting via grpc @ localhost:40701 for control ...
[grpc-default-executor-8] INFO
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Go_VR_Samza/src/sdks/go/pkg/beam/core/runtime/harness/harness.go:698
- Connecting via grpc @ localhost:45665 for logging ...
[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.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.
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-2' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy142.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1215)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1207)
at hudson.Launcher$ProcStarter.join(Launcher.java:524)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:814)
at hudson.model.Build$BuildExecution.build(Build.java:199)
at hudson.model.Build$BuildExecution.doRun(Build.java:164)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:522)
at hudson.model.Run.execute(Run.java:1896)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44)
at hudson.model.ResourceController.execute(ResourceController.java:101)
at hudson.model.Executor.run(Executor.java:442)
Caused by: java.io.IOException: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:94)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:75)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:105)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-2 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
