See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/218/display/redirect?page=changes>
Changes:
[sidhom] [BEAM-4149] Set worker id to "" if it is not set in the request header
[sidhom] [BEAM-3327] Refactor ControlClientPool to allow client multiplexing
[sidhom] [BEAM-3327] Basic Docker environment factory
------------------------------------------
[...truncated 63.30 MB...]
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.taskexecutor.TaskManagerServices checkTempDirs
INFO: Temporary file directory '/tmp': total 492 GB, usable 374 GB (76.02%
usable)
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.clusterframework.FlinkResourceManager
triggerConnectingToJobManager
INFO: Trying to associate with JobManager leader
akka://flink/user/jobmanager_1
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.clusterframework.FlinkResourceManager
jobManagerLeaderConnected
INFO: Resource Manager associating with leading JobManager
Actor[akka://flink/user/jobmanager_1#1359063283] - leader session
dd6eb48e-2ad8-4103-b25b-afdc16b560b9
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool <init>
INFO: Allocated 332 MB for network buffer pool (number of memory segments:
10632, bytes per segment: 32768).
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.query.QueryableStateUtils
createKvStateClientProxy
WARNING: Could not load Queryable State Client Proxy. Probable reason:
flink-queryable-state-runtime is not in the classpath. Please put the
corresponding jar from the opt to the lib folder.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.query.QueryableStateUtils
createKvStateServer
WARNING: Could not load Queryable State Server. Probable reason:
flink-queryable-state-runtime is not in the classpath. Please put the
corresponding jar from the opt to the lib folder.
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.io.network.NetworkEnvironment start
INFO: Starting the network environment and its components.
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.taskexecutor.TaskManagerServices createMemoryManager
INFO: Limiting managed memory to 1046 MB, memory will be allocated lazily.
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.io.disk.iomanager.IOManager <init>
INFO: I/O manager uses directory
/tmp/flink-io-99481433-e889-4b7d-a9e3-86fce1abbb5f for spill files.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.filecache.FileCache <init>
INFO: User file cache uses directory
/tmp/flink-dist-cache-b29ee499-9c57-49c8-bf7b-486e3e09f353
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.filecache.FileCache <init>
INFO: User file cache uses directory
/tmp/flink-dist-cache-3ac52ff9-4a85-46c3-9262-76e1304144bb
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Starting TaskManager actor at
akka://flink/user/taskmanager_1#1402864746.
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: TaskManager data connection information:
65bbeb315b0552855adc3bef5dea09a6 @ localhost (dataPort=-1)
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: TaskManager has 1 task slot(s).
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Memory usage stats: [HEAP: 370/1348/3342 MB, NON HEAP: 105/109/-1 MB
(used/committed/max)]
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Trying to register at JobManager akka://flink/user/jobmanager_1
(attempt 1, timeout: 500 milliseconds)
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.instance.InstanceManager
registerTaskManager
INFO: Registered TaskManager at localhost (akka://flink/user/taskmanager_1)
as db4d7a55be13798b23c75447d1b769a7. Current number of registered hosts is 1.
Current number of alive task slots is 1.
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.clusterframework.FlinkResourceManager
handleResourceStarted
INFO: TaskManager 65bbeb315b0552855adc3bef5dea09a6 has started.
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Successful registration at JobManager
(akka://flink/user/jobmanager_1), starting network stack and library cache.
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Determined BLOB server address to be localhost/127.0.0.1:37558.
Starting BLOB cache.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.blob.AbstractBlobCache
<init>
INFO: Created BLOB cache storage directory
/tmp/blobStore-5104c259-53b5-43dc-ba13-05fa366d2da6
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.blob.AbstractBlobCache
<init>
INFO: Created BLOB cache storage directory
/tmp/blobStore-2b2aac6b-2e91-4fbc-b1d3-d0b82e51c1d8
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.client.JobClientActor
handleMessage
INFO: Received SubmitJobAndWait(JobGraph(jobId:
e0d2dc948aa15f41784f0e86217c7308)) but there is no connection to a JobManager
yet.
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.client.JobSubmissionClientActor handleCustomMessage
INFO: Received job metricspushertest0test-jenkins-0424155100-42599993
(e0d2dc948aa15f41784f0e86217c7308).
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.client.JobClientActor
disconnectFromJobManager
INFO: Disconnect from JobManager null.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.client.JobClientActor
connectToJobManager
INFO: Connect to JobManager
Actor[akka://flink/user/jobmanager_1#1359063283].
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: Connected to JobManager at
Actor[akka://flink/user/jobmanager_1#1359063283] with leader session id
dd6eb48e-2ad8-4103-b25b-afdc16b560b9.
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_OUT
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#1359063283]
with leader session id dd6eb48e-2ad8-4103-b25b-afdc16b560b9.
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_ERROR
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.client.JobSubmissionClientActor tryToSubmitJob
INFO: Sending message to JobManager akka://flink/user/jobmanager_1 to
submit job metricspushertest0test-jenkins-0424155100-42599993
(e0d2dc948aa15f41784f0e86217c7308) and wait for progress
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.client.JobSubmissionClientActor$1 call
INFO: Upload jar files to job manager akka://flink/user/jobmanager_1.
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.client.JobSubmissionClientActor$1 call
INFO: Submit job to the job manager akka://flink/user/jobmanager_1.
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Submitting job e0d2dc948aa15f41784f0e86217c7308
(metricspushertest0test-jenkins-0424155100-42599993).
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Using restart strategy NoRestartStrategy for
e0d2dc948aa15f41784f0e86217c7308.
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.executiongraph.ExecutionGraph <init>
INFO: Job recovers via failover strategy: full graph restart
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder buildGraph
INFO: Running initialization on master for job
metricspushertest0test-jenkins-0424155100-42599993
(e0d2dc948aa15f41784f0e86217c7308).
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder buildGraph
INFO: Successfully ran initialization on master in 0 ms.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Scheduling job e0d2dc948aa15f41784f0e86217c7308
(metricspushertest0test-jenkins-0424155100-42599993).
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job metricspushertest0test-jenkins-0424155100-42599993
(e0d2dc948aa15f41784f0e86217c7308) switched from state CREATED to RUNNING.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
switched from CREATED to SCHEDULED.
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.client.JobSubmissionClientActor handleCustomMessage
INFO: Job e0d2dc948aa15f41784f0e86217c7308 was successfully submitted to
the JobManager akka://flink/deadLetters.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/24/2018 15:51:01 Job execution switched to status RUNNING.
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_OUT
04/24/2018 15:51:01 Job execution switched to status RUNNING.
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_ERROR
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/24/2018 15:51:01 Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting)(1/1) switched to SCHEDULED
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_OUT
04/24/2018 15:51:01 Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting)(1/1) switched to SCHEDULED
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_ERROR
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
switched from SCHEDULED to DEPLOYING.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (attempt #0) to localhost
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/24/2018 15:51:01 Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting)(1/1) switched to DEPLOYING
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_OUT
04/24/2018 15:51:01 Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting)(1/1) switched to DEPLOYING
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_ERROR
Apr 24, 2018 3:51:01 PM grizzled.slf4j.Logger info
INFO: Received task Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1)
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
switched from CREATED to DEPLOYING.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
[DEPLOYING]
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
[DEPLOYING].
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
[DEPLOYING].
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
switched from DEPLOYING to RUNNING.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
switched from DEPLOYING to RUNNING.
Apr 24, 2018 3:51:01 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/24/2018 15:51:01 Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting)(1/1) switched to RUNNING
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_OUT
04/24/2018 15:51:01 Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting)(1/1) switched to RUNNING
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_ERROR
Apr 24, 2018 3:51:01 PM
org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
WARNING: The operator name Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
exceeded the 80 characters length limit and was truncated.
Apr 24, 2018 3:51:01 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Apr 24, 2018 3:51:01 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
open
INFO: Unbounded Flink Source 0/1 is reading from sources:
[org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter@12593af2]
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
switched from RUNNING to FINISHED.
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a).
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
[FINISHED]
Apr 24, 2018 3:51:02 PM grizzled.slf4j.Logger info
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/1) (e38d535c4cf8cf2b9a32d119dcdb5c0a)
switched from RUNNING to FINISHED.
Apr 24, 2018 3:51:02 PM
org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job metricspushertest0test-jenkins-0424155100-42599993
(e0d2dc948aa15f41784f0e86217c7308) switched from state RUNNING to FINISHED.
Apr 24, 2018 3:51:02 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job
e0d2dc948aa15f41784f0e86217c7308
Apr 24, 2018 3:51:02 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/24/2018 15:51:02 Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting)(1/1) switched to FINISHED
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_OUT
04/24/2018 15:51:02 Source:
GenerateSequence/Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting)(1/1) switched to FINISHED
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_ERROR
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/24/2018 15:51:02 Job execution switched to status FINISHED.
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_OUT
04/24/2018 15:51:02 Job execution switched to status FINISHED.
org.apache.beam.runners.core.metrics.MetricsPusherTest > test STANDARD_ERROR
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.client.JobClientActor
terminate
INFO: Terminate JobClientActor.
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.client.JobClientActor
disconnectFromJobManager
INFO: Disconnect from JobManager
Actor[akka://flink/user/jobmanager_1#1359063283].
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.client.JobClient
awaitJobResult
INFO: Job execution complete
Apr 24, 2018 3:51:02 PM
org.apache.flink.runtime.minicluster.FlinkMiniCluster stop
INFO: Stopping FlinkMiniCluster.
Apr 24, 2018 3:51:02 PM grizzled.slf4j.Logger info
INFO: Stopping TaskManager akka://flink/user/taskmanager_1#1402864746.
Apr 24, 2018 3:51:02 PM grizzled.slf4j.Logger info
INFO: Disassociating from JobManager
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Apr 24, 2018 3:51:02 PM
org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-99481433-e889-4b7d-a9e3-86fce1abbb5f
Apr 24, 2018 3:51:02 PM
org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Apr 24, 2018 3:51:02 PM grizzled.slf4j.Logger info
INFO: Task manager akka://flink/user/taskmanager_1 is completely shut down.
Apr 24, 2018 3:51:02 PM grizzled.slf4j.Logger info
INFO: Stopping JobManager akka://flink/user/jobmanager_1.
Apr 24, 2018 3:51:02 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:37558
Apr 24, 2018 3:51:02 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Execution finished in 370 msecs
Apr 24, 2018 3:51:02 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Final accumulator values:
Apr 24, 2018 3:51:02 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@43ca22b1
Gradle Test Executor 4 finished executing tests.
:beam-runners-flink_2.11:validatesRunnerStreaming FAILED
:beam-runners-flink_2.11:validatesRunnerStreaming (Thread[Task worker for
':',5,main]) completed. Took 4 mins 43.142 secs.
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11:validatesRunnerBatch'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 137
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at
https://docs.gradle.org/4.6/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11:validatesRunnerStreaming'.
> Process 'Gradle Test Executor 3' finished with non-zero exit value 137
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at
https://docs.gradle.org/4.6/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
See
https://docs.gradle.org/4.6/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 11m 53s
35 actionable tasks: 31 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/ojfpv6qbiuaa2
Build cache (/home/jenkins/.gradle/caches/build-cache-1) has not been cleaned
up in 4 days
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Recording test results
ERROR: Step ‘Publish JUnit test result report’ failed: No test report files
were found. Configuration error?
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
