date:20181106

Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Dataflow #935

2018-11-06 Thread Apache Jenkins Server

See 


Changes:

[daniel.o.programmer] [BEAM-5304] Adding default and dynamic ports to ULR.

--
[...truncated 270.56 KB...]
INFO: Adding Query7/Window.Into()/Window.Assign as step s6
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/BidToPrice as step s7
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/WithKeys/AddKeys/Map
 as step s8
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/AddNonce
 as step s9
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/GroupByKey
 as step s10
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/Combine.GroupedValues
 as step s11
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/StripNonce/Map
 as step s12
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/Window.Remerge/Identity/Map
 as step s13
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PrepareCold/Map
 as step s14
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/Flatten.PCollections
 as step s15
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/GroupByKey
 as step s16
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/Combine.GroupedValues
 as step s17
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Values/Values/Map
 as step s18
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
 as step s19
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly
 as step s20
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
 as step s21
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Combine.GloballyAsSingletonView/CreateDataflowView as step 
s22
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Select as step s23
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Forget as step s24
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Debug as step s25
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Stamp as step s26
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7.Format as step s27
Nov 06, 2018 7:20:25 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding

Jenkins build is back to normal : beam_PostCommit_Py_VR_Dataflow #1634

2018-11-06 Thread Apache Jenkins Server

See 



-
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #1837

2018-11-06 Thread Apache Jenkins Server

See 
<https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/1837/display/redirect?page=changes>

Changes:

[kenn] Separate Nexmark static utils into static class

[kenn] mv NexmarkQuery NexmarkQueryTransform

[kenn] Unify Java-only and SQL NexmarkQuery hierarchies

[david.moravek] [BEAM-5987] Fix Spark SideInputReader performance.

[marek.simunek] [BEAM-5857] Fix: unnecessary submission of a new job when 
calling

[markliu] Updating Python worker container to beam-master-20181106

--
[...truncated 58.91 MB...]
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.yaml/snakeyaml/1.18/e4a441249ade301985cb8d009d4e4a72b85bf68e/snakeyaml-1.18.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/snakeyaml-1.18-R-oOCdgXK4J6PV-saHyToQ.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpcore/4.4.6/e3fd8ced1f52c7574af952e2e6da0df8df08eb82/httpcore-4.4.6.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/httpcore-4.4.6-qfvVA-CAJQfv7q_7VrvfUg.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-support/1.6.4/314daafb761541293595630e10a3699ebc07881d/powermock-api-support-1.6.4.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/powermock-api-support-1.6.4-kZE14BNW5086fK5PAMlvkA.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/ru.vyarus/generics-resolver/2.0.1/2182e67f161ddbe3ff8cb055bb54398354fda3f5/generics-resolver-2.0.1.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/generics-resolver-2.0.1-VrpA4CuIscdXm0wF6oMTaQ.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-classloading-base/1.6.4/4c411d648d0b7d1f5f52a3dc138bbb80afe37ad5/powermock-classloading-base-1.6.4.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/powermock-classloading-base-1.6.4-JGeHyMPVBR2NvFX4bwkGYg.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.antlr/antlr-runtime/3.1.2/c4ca32c2be1b22a5553dd3171f51f9b2b04030b/antlr-runtime-3.1.2.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/antlr-runtime-3.1.2-dpdEvr2kPK4dWHj9fUOv1A.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/io.netty/netty-common/4.1.25.Final/e17d5c05c101fe14536ce3fb34b36c54e04791f6/netty-common-4.1.25.Final.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/netty-common-4.1.25.Final-cYwMY1_F2pzboFUnBL3CxQ.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.xerial.snappy/snappy-java/1.1.4/d94ae6d7d27242eaa4b6c323f881edbb98e48da6/snappy-java-1.1.4.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/snappy-java-1.1.4-SFNwbMuGq13aaoKVzeS1Tw.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/com.beust/jcommander/1.27/58c9cbf0f1fa296f93c712f2cf46de50471920f9/jcommander-1.27.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/jcommander-1.27-YxYbyOYD5gurYr1hw0nzcA.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading 
/home/jenkins/.gradle/caches/modules-2/files-2.1/org.javassist/javassist/3.20.0-GA/a9cbcdfb7e9f86fbc74d3afae65f2248bfbf82a0/javassist-3.20.0-GA.jar
 to 
gs://temp-storage-for-end-to-end-tests/spannerwriteit0testreportfailures-jenkins-1107020700-4a151032/output/results/staging/javassist-3.20.0-GA-qJ3XkH124GHsLAfnYqdCVg.jar
Nov 07, 2018 2:07:02 AM org.apache.beam.runners.dataflow.util.Packa

Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink #236

2018-11-06 Thread Apache Jenkins Server

See 



-
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org

Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Dataflow #930

2018-11-06 Thread Apache Jenkins Server

See 


Changes:

[lukasz.gajowy] [BEAM-5356] Move metrics related functionality to common place

[lukasz.gajowy] [BEAM-5356] Move step & source common code to one place

[lukasz.gajowy] [BEAM-5356] Provide common load test pipeline options

[lukasz.gajowy] [BEAM-5356] Add CoGroupByKey Load Test

--
[...truncated 541.23 KB...]
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly
 as step s20
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
 as step s21
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Combine.GloballyAsSingletonView/CreateDataflowView as step 
s22
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Select as step s23
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Forget as step s24
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Debug as step s25
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Stamp as step s26
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7.Format as step s27
Nov 06, 2018 9:09:16 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7.DevNull as step s28
Nov 06, 2018 9:09:16 AM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging pipeline description to 
gs://temp-storage-for-perf-tests/nexmark/staging/
Nov 06, 2018 9:09:17 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading <96595 bytes, hash emlRRFgzYADY5CxgskLLkw> to 
gs://temp-storage-for-perf-tests/nexmark/staging/pipeline-emlRRFgzYADY5CxgskLLkw.pb
Dataflow SDK version: 2.9.0-SNAPSHOT
Nov 06, 2018 9:09:19 AM org.apache.beam.runners.dataflow.util.PackageUtil 
stageClasspathElements
INFO: Staging files complete: 114 files cached, 27 files newly uploaded
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4.ReadBounded as step s1
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.Monitor as step s2
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.Snoop as step s3
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Filter/ParDo(Anonymous) as step s4
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.WinningBids/Window/Window.Assign as step s5
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query4/Query4.WinningBids/justNewAuctions/IsNewAuction/ParDo(Anonymous) as step 
s6
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.WinningBids/justNewAuctions/AsAuction as step s7
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.WinningBids/AuctionById: as step s8
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.WinningBids/justBids/IsBid/ParDo(Anonymous) as step 
s9
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.WinningBids/justBids/AsBid as step s10
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.WinningBids/BidByAuction as step s11
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.WinningBids/CoGroupByKey/MakeUnionTable0 as step s12
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query4/Query4.WinningBids/CoGroupByKey/MakeUnionTable1 as step s13
Nov 06, 2018 9:09:19 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding

Jenkins build is back to normal : beam_PostCommit_Python_VR_Flink #644

2018-11-06 Thread Apache Jenkins Server

See 



-
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org

Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #646

2018-11-06 Thread Apache Jenkins Server

See 


Changes:

[robertwb] Remove unused is_pair_like hack.

--
[...truncated 4.47 MB...]
[flink-runner-job-server] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint 
listening at localhost:36887
[flink-runner-job-server] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Proposing leadership to contender 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint@34b6c662 @ 
http://localhost:36887
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster 
- Starting job dispatcher(s) for JobManger
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - 
http://localhost:36887 was granted leadership with 
leaderSessionID=38ae1ca7-3a45-45ea-bed7-e150dfa465c2
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Received confirmation of leadership for leader http://localhost:36887 , 
session=38ae1ca7-3a45-45ea-bed7-e150dfa465c2
[flink-runner-job-server] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService 
- Starting RPC endpoint for 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher at 
akka://flink/user/dispatcheraa4612b3-2137-4f28-954f-a682daccc2eb .
[flink-runner-job-server] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Proposing leadership to contender 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher@6d84a07 @ 
akka://flink/user/dispatcheraa4612b3-2137-4f28-954f-a682daccc2eb
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster 
- Flink Mini Cluster started successfully
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher 
akka://flink/user/dispatcheraa4612b3-2137-4f28-954f-a682daccc2eb was granted 
leadership with fencing token 707d16a4-4e44-4f0e-a9a5-a735062a3884
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all 
persisted jobs.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Received confirmation of leadership for leader 
akka://flink/user/dispatcheraa4612b3-2137-4f28-954f-a682daccc2eb , 
session=707d16a4-4e44-4f0e-a9a5-a735062a3884
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 
b4bf8f172e0884e5a0c429d93d63837e (test_windowing_1541508495.58).
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for 
org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_41 
.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Initializing job 
test_windowing_1541508495.58 (b4bf8f172e0884e5a0c429d93d63837e).
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy 
NoRestartStrategy for test_windowing_1541508495.58 
(b4bf8f172e0884e5a0c429d93d63837e).
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool at 
akka://flink/user/e11e4dff-4d49-46a5-8e08-d0f3592309c7 .
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via 
failover strategy: full graph restart
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master 
for job test_windowing_1541508495.58 (b4bf8f172e0884e5a0c429d93d63837e).
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization 
on master in 0 ms.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - No state backend has been 
configured, using default (Memory / JobManager) MemoryStateBackend (data in 
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Proposing leadership to contender 
org.apache.flink.runtime.jobmaster.JobManagerRunner@358bab61 @ 
akka://flink/user/jobmanager_41
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job 
test_windowing_1541508495.58 (b4bf8f172e0884e5a0c429d93d63837e) was granted 
leadership with session id b02bac01-1736-4513-8178-619837c21490 at 
akka://flink/user/jobmanager_41.
[flink-akka.actor.default-dispatcher-4] INFO

Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #645

2018-11-06 Thread Apache Jenkins Server

See 


--
[...truncated 4.44 MB...]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - 
http://localhost:32841 was granted leadership with 
leaderSessionID=6f6ef14c-90b2-434e-bb2f-cd68b87ca5ed
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Received confirmation of leadership for leader http://localhost:32841 , 
session=6f6ef14c-90b2-434e-bb2f-cd68b87ca5ed
[flink-runner-job-server] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService 
- Starting RPC endpoint for 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher at 
akka://flink/user/dispatcher92d3e5a9-9a98-4d77-8fb5-53ccfb3219e4 .
[flink-runner-job-server] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Proposing leadership to contender 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher@755a8a1d @ 
akka://flink/user/dispatcher92d3e5a9-9a98-4d77-8fb5-53ccfb3219e4
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster 
- Flink Mini Cluster started successfully
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher 
akka://flink/user/dispatcher92d3e5a9-9a98-4d77-8fb5-53ccfb3219e4 was granted 
leadership with fencing token 80303f54-8520-4a75-919f-1ef4d656a55f
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all 
persisted jobs.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Received confirmation of leadership for leader 
akka://flink/user/dispatcher92d3e5a9-9a98-4d77-8fb5-53ccfb3219e4 , 
session=80303f54-8520-4a75-919f-1ef4d656a55f
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 
ff59339f3c85d0106d6cfe35038bb3eb (test_windowing_1541506262.95).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for 
org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_41 
.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Initializing job 
test_windowing_1541506262.95 (ff59339f3c85d0106d6cfe35038bb3eb).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy 
NoRestartStrategy for test_windowing_1541506262.95 
(ff59339f3c85d0106d6cfe35038bb3eb).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool at 
akka://flink/user/c8887da9-9f3d-477c-9e9e-57ced05b816b .
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via 
failover strategy: full graph restart
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master 
for job test_windowing_1541506262.95 (ff59339f3c85d0106d6cfe35038bb3eb).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization 
on master in 0 ms.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - No state backend has been 
configured, using default (Memory / JobManager) MemoryStateBackend (data in 
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
- Proposing leadership to contender 
org.apache.flink.runtime.jobmaster.JobManagerRunner@4eb5fd5b @ 
akka://flink/user/jobmanager_41
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job 
test_windowing_1541506262.95 (ff59339f3c85d0106d6cfe35038bb3eb) was granted 
leadership with session id 7bedef9c-e922-434e-93a8-ccd173a37eda at 
akka://flink/user/jobmanager_41.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job 
test_windowing_1541506262.95 (ff59339f3c85d0106d6cfe35038bb3eb)
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
test_windowing_1541506262.95 (ff59339f3c85d0106d6cfe35038bb3eb) switched from 
state CREATED to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source 
-> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) 
(3f4bf077a5d9032935979d2cd06decd6) switched from

Jenkins build is back to normal : beam_PostCommit_Java_GradleBuild #1832

2018-11-06 Thread Apache Jenkins Server

See 



-
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #231

2018-11-06 Thread Apache Jenkins Server

See 


Changes:

[robertwb] Remove unused is_pair_like hack.

--
[...truncated 81.68 MB...]
[CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) switched 
from CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Creating FileSystem stream leak safety net for task CHAIN MapPartition 
(MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) [DEPLOYING]
[CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Loading JAR files for task CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) [DEPLOYING].
[CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Registering task at network: CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) [DEPLOYING].
[CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #230

2018-11-06 Thread Apache Jenkins Server

See 


--
[...truncated 479.26 MB...]
[MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16) (ed553fae380d990bb9f876e9613a49f8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(1/16) (47edf11b8430af3e1adac747a9883736) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16) (ed553fae380d990bb9f876e9613a49f8).
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (5/16).
[MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16) (ed553fae380d990bb9f876e9613a49f8) [FINISHED]
[MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(14/16) (eea462389cc7d6e7b9415618e1626407) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(4/16) (ca286059766a937b6ae19e5ea5348287) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) 
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (8/16) 
(2d239e86c00b3a19d8ffd481a2083ae2) [DEPLOYING].
[MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(14/16) (eea462389cc7d6e7b9415618e1626407).
[MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(4/16) (ca286059766a937b6ae19e5ea5348287).
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task MapPartition 
(MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
bd5274a0267ea462dbf6e152019b5376.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) 
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (8/16) 
(2d239e86c00b3a19d8ffd481a2083ae2) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task MapPartition (MapPartition at 
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(4/16) (ca286059766a937b6ae19e5ea5348287) [FINISHED]
[jobmanager-future-thread-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16) 
(17c7292bb8695dd017da1ed38f9c4e26) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16) 
(938cf7bd3c5cfbd66134332ba133b4ae) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-6] INFO

Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Dataflow #931

2018-11-06 Thread Apache Jenkins Server

See 


--
[...truncated 268.64 KB...]
INFO: Adding Query7.ReadBounded as step s1
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Monitor as step s2
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Snoop as step s3
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/justBids/IsBid/ParDo(Anonymous) as step s4
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/justBids/AsBid as step s5
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Window.Into()/Window.Assign as step s6
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/BidToPrice as step s7
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/WithKeys/AddKeys/Map
 as step s8
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/AddNonce
 as step s9
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/GroupByKey
 as step s10
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/Combine.GroupedValues
 as step s11
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/StripNonce/Map
 as step s12
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/Window.Remerge/Identity/Map
 as step s13
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PrepareCold/Map
 as step s14
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/Flatten.PCollections
 as step s15
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/GroupByKey
 as step s16
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/Combine.GroupedValues
 as step s17
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Values/Values/Map
 as step s18
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
 as step s19
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly
 as step s20
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
 as step s21
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Combine.GloballyAsSingletonView/CreateDataflowView as step 
s22
Nov 06, 2018 12:04:30 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Select as step s23
Nov 06, 2018 12:04:30 PM

Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Dataflow #932

2018-11-06 Thread Apache Jenkins Server

See 


Changes:

[robertwb] Remove unused is_pair_like hack.

--
[...truncated 260.21 KB...]
INFO: Adding Query7/justBids/AsBid as step s5
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Window.Into()/Window.Assign as step s6
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/BidToPrice as step s7
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/WithKeys/AddKeys/Map
 as step s8
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/AddNonce
 as step s9
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/GroupByKey
 as step s10
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PreCombineHot/Combine.GroupedValues
 as step s11
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/StripNonce/Map
 as step s12
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/Window.Remerge/Identity/Map
 as step s13
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PrepareCold/Map
 as step s14
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/Flatten.PCollections
 as step s15
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/GroupByKey
 as step s16
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Combine.perKeyWithFanout(MaxLong)/PostCombine/Combine.GroupedValues
 as step s17
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/Combine.globally(MaxLong)/Values/Values/Map
 as step s18
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
 as step s19
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly
 as step s20
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
Query7/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
 as step s21
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Combine.GloballyAsSingletonView/CreateDataflowView as step 
s22
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Select as step s23
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Forget as step s24
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Debug as step s25
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7/Query7.Stamp as step s26
Nov 06, 2018 12:41:10 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Query7.Format

Jenkins build is back to normal : beam_PostCommit_Python_VR_Flink #647

2018-11-06 Thread Apache Jenkins Server

See 



-
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org

Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Dataflow #935

Jenkins build is back to normal : beam_PostCommit_Py_VR_Dataflow #1634

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #1837

Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink #236

Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Dataflow #930

Jenkins build is back to normal : beam_PostCommit_Python_VR_Flink #644

Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #646

Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #645

Jenkins build is back to normal : beam_PostCommit_Java_GradleBuild #1832

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #231

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #230

Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Dataflow #931

Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Dataflow #932

Jenkins build is back to normal : beam_PostCommit_Python_VR_Flink #647

14 matches

Site Navigation

Mail list logo

Footer information