See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/153/display/redirect?page=changes>
Changes:
[ehudm] Fix localfilesystem _list() operation.
[aaltay] [BEAM-4108] Generate javadocs for release (#5121)
------------------------------------------
[...truncated 1.71 MB...]
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 Source:
Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
(Distinct/KeyByElement/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Min/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Max/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Count/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem)(1/1)
switched to DEPLOYING
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying Source:
Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
(Distinct/KeyByElement/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Min/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Max/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Count/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem) (1/1)
(attempt #0) to localhost
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 Source:
Read(UnboundedCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
(Distinct/KeyByElement/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Min/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Max/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem,
Count/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem)(1/1)
switched to DEPLOYING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_ERROR
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 Source:
PAssert$5/Create.Values/Read(CreateSource) ->
PAssert$5/WindowToken/Window.Assign.out(1/1) switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 Source: PAssert$5/Create.Values/Read(CreateSource) ->
PAssert$5/WindowToken/Window.Assign.out(1/1) switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_ERROR
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task Source:
Count/CreateVoid/Read(CreateSource) (1/1) (6d55d5e21401d8b327429bc8e9de2da7)
[DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: Source:
Count/CreateVoid/Read(CreateSource) (1/1) (6d55d5e21401d8b327429bc8e9de2da7)
[DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task Source:
PAssert$6/Create.Values/Read(CreateSource) ->
PAssert$6/WindowToken/Window.Assign.out (1/1)
(c348bfa3178e5933b53ee66997483dc6) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: Source:
PAssert$6/Create.Values/Read(CreateSource) ->
PAssert$6/WindowToken/Window.Assign.out (1/1)
(c348bfa3178e5933b53ee66997483dc6) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task Source:
PAssert$8/Create.Values/Read(CreateSource) ->
PAssert$8/WindowToken/Window.Assign.out (1/1)
(7c3dab7fd9ac4aeceab2599bc95d403f) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: Source:
PAssert$8/Create.Values/Read(CreateSource) ->
PAssert$8/WindowToken/Window.Assign.out (1/1)
(7c3dab7fd9ac4aeceab2599bc95d403f) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Max/CreateVoid/Read(CreateSource) (1/1)
(5816beb820ba609b5b82285162760f30) switched from CREATED to DEPLOYING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task Source:
Max/CreateVoid/Read(CreateSource) (1/1) (5816beb820ba609b5b82285162760f30)
[DEPLOYING]
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task Source: Max/CreateVoid/Read(CreateSource)
(1/1) (5816beb820ba609b5b82285162760f30) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: Source:
Max/CreateVoid/Read(CreateSource) (1/1) (5816beb820ba609b5b82285162760f30)
[DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Count/CreateVoid/Read(CreateSource) (1/1)
(6d55d5e21401d8b327429bc8e9de2da7) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM grizzled.slf4j.Logger info
INFO: Received task Source: UniqueCount/CreateVoid/Read(CreateSource) (1/1)
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: PAssert$6/Create.Values/Read(CreateSource) ->
PAssert$6/WindowToken/Window.Assign.out (1/1)
(c348bfa3178e5933b53ee66997483dc6) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: PAssert$8/Create.Values/Read(CreateSource) ->
PAssert$8/WindowToken/Window.Assign.out (1/1)
(7c3dab7fd9ac4aeceab2599bc95d403f) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Max/CreateVoid/Read(CreateSource) (1/1)
(5816beb820ba609b5b82285162760f30) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Count/CreateVoid/Read(CreateSource) (1/1)
(6d55d5e21401d8b327429bc8e9de2da7) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: PAssert$6/Create.Values/Read(CreateSource) ->
PAssert$6/WindowToken/Window.Assign.out (1/1)
(c348bfa3178e5933b53ee66997483dc6) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: PAssert$8/Create.Values/Read(CreateSource) ->
PAssert$8/WindowToken/Window.Assign.out (1/1)
(7c3dab7fd9ac4aeceab2599bc95d403f) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Max/CreateVoid/Read(CreateSource) (1/1)
(5816beb820ba609b5b82285162760f30) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 Source:
PAssert$6/Create.Values/Read(CreateSource) ->
PAssert$6/WindowToken/Window.Assign.out(1/1) switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 Source: PAssert$6/Create.Values/Read(CreateSource) ->
PAssert$6/WindowToken/Window.Assign.out(1/1) switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_ERROR
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 Source:
Count/CreateVoid/Read(CreateSource)(1/1) switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 Source: Count/CreateVoid/Read(CreateSource)(1/1)
switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_ERROR
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 Source: Max/CreateVoid/Read(CreateSource)(1/1)
switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 Source: Max/CreateVoid/Read(CreateSource)(1/1) switched
to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_ERROR
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 Source:
PAssert$8/Create.Values/Read(CreateSource) ->
PAssert$8/WindowToken/Window.Assign.out(1/1) switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 Source: PAssert$8/Create.Values/Read(CreateSource) ->
PAssert$8/WindowToken/Window.Assign.out(1/1) switched to RUNNING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_ERROR
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: UniqueCount/CreateVoid/Read(CreateSource) (1/1)
(430843e6c49d7f32f314caf495da14aa) switched from CREATED to DEPLOYING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task Source:
UniqueCount/CreateVoid/Read(CreateSource) (1/1)
(430843e6c49d7f32f314caf495da14aa) [DEPLOYING]
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task Source:
UniqueCount/CreateVoid/Read(CreateSource) (1/1)
(430843e6c49d7f32f314caf495da14aa) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: Source:
UniqueCount/CreateVoid/Read(CreateSource) (1/1)
(430843e6c49d7f32f314caf495da14aa) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: UniqueCount/CreateVoid/Read(CreateSource) (1/1)
(430843e6c49d7f32f314caf495da14aa) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
Apr 18, 2018 7:48:00 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Apr 18, 2018 7:48:00 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Apr 18, 2018 7:48:00 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@101ef3d]
Apr 18, 2018 7:48:00 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@70fc839]
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.blob.BlobClient
downloadFromBlobServer
INFO: Downloading
0ecae81049aebef39730e846085e957c/p-719f35506828b54ed2a03e26a458e6ee3b1dc30a-309069ea09054fdeaf301ff06107cba7
from localhost/127.0.0.1:35647
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Min/CreateVoid/Read(CreateSource) (1/1)
(c7c580bfcd959a3f99408dfe9f171814) switched from SCHEDULED to DEPLOYING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying Source: Min/CreateVoid/Read(CreateSource) (1/1) (attempt
#0) to localhost
Apr 18, 2018 7:48:00 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Distinct/DropValues -> Distinct/ExtractFirstKey/ParMultiDo(Anonymous)
-> UniqueCount/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem
(1/1) (7d01329d5fea33a98e06a3c8e1efcb36) switched from SCHEDULED to DEPLOYING.
Apr 18, 2018 7:48:00 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@190252ba]
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying Distinct/DropValues ->
Distinct/ExtractFirstKey/ParMultiDo(Anonymous) ->
UniqueCount/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/1)
(attempt #0) to localhost
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 Source: Min/CreateVoid/Read(CreateSource)(1/1)
switched to DEPLOYING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 Source: Min/CreateVoid/Read(CreateSource)(1/1) switched
to DEPLOYING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_ERROR
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 Distinct/DropValues ->
Distinct/ExtractFirstKey/ParMultiDo(Anonymous) ->
UniqueCount/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem(1/1)
switched to DEPLOYING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 Distinct/DropValues ->
Distinct/ExtractFirstKey/ParMultiDo(Anonymous) ->
UniqueCount/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem(1/1)
switched to DEPLOYING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_ERROR
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: UniqueCount/Combine.perKey(Count) ->
UniqueCount/Values/Values/Map/ParMultiDo(Anonymous) ->
UniqueCount/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
->
UniqueCount/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> ToKeyedWorkItem (1/1) (657cd8c9670e8a2a1d1139a1492e0a65) switched from
SCHEDULED to DEPLOYING.
Apr 18, 2018 7:48:00 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Apr 18, 2018 7:48:00 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Apr 18, 2018 7:48:00 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Apr 18, 2018 7:48:00 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@328e7d90]
Apr 18, 2018 7:48:00 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@2c46cc39]
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: PAssert$7/Create.Values/Read(CreateSource) ->
PAssert$7/WindowToken/Window.Assign.out (1/1)
(b459d46f9cb9edddce1fddc0ab5cb2dd) switched from CREATED to DEPLOYING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task Source:
PAssert$7/Create.Values/Read(CreateSource) ->
PAssert$7/WindowToken/Window.Assign.out (1/1)
(b459d46f9cb9edddce1fddc0ab5cb2dd) [DEPLOYING]
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task Source:
PAssert$7/Create.Values/Read(CreateSource) ->
PAssert$7/WindowToken/Window.Assign.out (1/1)
(b459d46f9cb9edddce1fddc0ab5cb2dd) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: Source:
PAssert$7/Create.Values/Read(CreateSource) ->
PAssert$7/WindowToken/Window.Assign.out (1/1)
(b459d46f9cb9edddce1fddc0ab5cb2dd) [DEPLOYING].
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: PAssert$7/Create.Values/Read(CreateSource) ->
PAssert$7/WindowToken/Window.Assign.out (1/1)
(b459d46f9cb9edddce1fddc0ab5cb2dd) switched from DEPLOYING to RUNNING.
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying UniqueCount/Combine.perKey(Count) ->
UniqueCount/Values/Values/Map/ParMultiDo(Anonymous) ->
UniqueCount/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
->
UniqueCount/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> ToKeyedWorkItem (1/1) (attempt #0) to localhost
Apr 18, 2018 7:48:00 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@4e36b2bb]
Apr 18, 2018 7:48:00 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/18/2018 19:48:00 UniqueCount/Combine.perKey(Count) ->
UniqueCount/Values/Values/Map/ParMultiDo(Anonymous) ->
UniqueCount/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
->
UniqueCount/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> ToKeyedWorkItem(1/1) switched to DEPLOYING
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSource STANDARD_OUT
04/18/2018 19:48:00 UniqueCount/Combine.perKey(Count) ->
UniqueCount/Values/Values/Map/ParMultiDo(Anonymous) ->
UniqueCount/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
->
UniqueCount/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> ToKeyedWorkItem(1/1) switched to DEPLOYING
Java HotSpot(TM) 64-Bit Server VM warning: INFO:
os::commit_memory(0x00000007a2600000, 288358400, 0) failed; error='Cannot
allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 288358400 bytes for committing
reserved memory.
# An error report file with more information is saved as:
#
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/hs_err_pid15664.log>
Could not stop
org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@3ff058a5.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message
[MethodInvocation method: stop()].
at
org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:34)
at
org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:31)
at
org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:133)
at
org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:34)
at
org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:73)
at
org.gradle.internal.operations.BuildOperationIdentifierPreservingRunnable.run(BuildOperationIdentifierPreservingRunnable.java:39)
at
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
at
org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at
org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test
Executor 4' finished with non-zero exit value 1
at
org.gradle.process.internal.DefaultExecHandle$ExecResultImpl.assertNormalExitValue(DefaultExecHandle.java:389)
at
org.gradle.process.internal.worker.DefaultWorkerProcess.waitForStop(DefaultWorkerProcess.java:190)
at
org.gradle.process.internal.worker.DefaultWorkerProcessBuilder$MemoryRequestingWorkerProcess.waitForStop(DefaultWorkerProcessBuilder.java:228)
at
org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:124)
at
org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:63)
at
org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:57)
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:35)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
... 10 more
:beam-runners-flink_2.11:validatesRunnerStreaming FAILED
:beam-runners-flink_2.11:validatesRunnerStreaming (Thread[Task worker for
':',5,main]) completed. Took 1 mins 48.429 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 1
* 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 1
* 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.5.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 11m 3s
33 actionable tasks: 33 executed
Publishing build scan...
https://gradle.com/s/ewatgqaclskkg
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 eh...@google.com
Not sending mail to unregistered user aal...@gmail.com
Not sending mail to unregistered user sid...@google.com
