See <https://builds.apache.org/job/beam_Release_NightlySnapshot/498/display/redirect?page=changes>
Changes: [owenzhang1990] [BEAM-79] add Gearpump runner [klk] move integration tests to profile [klk] add package-info.java [klk] Update Gearpump runner version to 0.3.0-incubating [klk] Rename DoFn to OldDoFn in Gearpump runner [dhalperi] gearpump: switch to stable version [dhalperi] Made byteArrayCoder final static [dhalperi] CompressedSource: CompressedReader is never splittable [dhalperi] Do not add DataDisks to windmill service jobs. [dhalperi] Remove timeout in DirectRunnerTest [dhalperi] Improve Write Error Message [dhalperi] Remove Streaming Write Overrides in DataflowRunner [dhalperi] Remove Counter and associated code [dhalperi] [BEAM-495] Create General Verifier for File Checksum [dhalperi] Add output checksum to WordCountITOptions [dhalperi] More unit test and code style fix [dhalperi] Using IOChannelUtils to resolve file path [dhalperi] Added unit tests and error handling in removeTemporaryTables [dhalperi] [flink] add missing maven config to example pom [dhalperi] Remove DataflowPipelineJob from examples [dhalperi] [BEAM-432] Corrected BigQueryIO javadoc [dhalperi] Add TransformEvaluatorFactory#cleanup [dhalperi] Replace CloningThreadLocal with DoFnLifecycleManager [dhalperi] Add DoFn @Setup and @Teardown [dhalperi] Move ParDo Lifecycle tests to their own file [dhalperi] Exclude ParDoTest from Dataflow @RunnableOnService [dhalperi] Exclude guava-testlib from shading relocation [dhalperi] ByteKeyRangeTracker: synchronize toString [dhalperi] Fix repackaging exclude pattern for guava-testlib [dhalperi] Rewrites DoFnReflector to go via DoFnSignature [dhalperi] Replace ParDo with simpler transforms where possible [dhalperi] Set Gcs upload buffer size to 1M in streaming mode in DataflowRunner [dhalperi] addressed feedback [dhalperi] fix unused imports [dhalperi] DatastoreIO Sink as ParDo [dhalperi] Change name of result returned by BigQueryIO.Read [dhalperi] Fix NPE in BigQueryIO.TransformingReader [dhalperi] Add inEarlyPanesInGlobalWindow as a PAssert Extractor [dhalperi] Add TestStream to the Testing package [dhalperi] Implement TestStream in the DirectRunner [dhalperi] Incorporate private IP option for Dataflow runner [dhalperi] Datastore Sink support for writing Mutations [dhalperi] Mark JAXBContext as Volatile in JAXBCoder [dhalperi] Modify example dependencies to only add runners as optional [dhalperi] DatastoreIO v1beta3 to v1 [dhalperi] Remove unused constant in ExecutorServiceParallelExecutor [dhalperi] Remove extra timer firings in WatermarkManager [dhalperi] FileBasedSink: improve parallelism in GCS copy/remove [dhalperi] [BEAM-574] Remove log when new records have not been read yet (KafkaIO) [dhalperi] Write: Remove invalid import [dhalperi] JUnit tests: add @RunWith annotation [dhalperi] Remove ParDoTest Suppression in Google Cloud Dataflow [dhalperi] Fix Emission in startBundle/finishBundle in Flink Wrappers [dhalperi] [BEAM-253] Unify Flink-Streaming Operator Wrappers [dhalperi] Fix Checkstyle Errors in FlinkStreamingTransformTranslators [dhalperi] [BEAM-102] Add Side Inputs in Flink Streaming Runner [dhalperi] Allow DoFn Reuse in ParDoTest.TestDoFnWithContext [dhalperi] Don't Suppress Throwable in PAssert in Streaming Mode [dhalperi] Fix Flink Runner Pom for Batch RunnableOnService tests [dhalperi] Enable Flink Streaming Runner RunnableOnService tests [dhalperi] Fix combine tests with Accumulation Mode [dhalperi] Use AllPanes as the PaneExtractor in IterableAssert [dhalperi] Make ParDoLifecycleTest Serializable to Fix Test with TupleTag [dhalperi] Fix Exception Unwrapping in TestFlinkRunner [dhalperi] Update checkstyle.xml to put all imports in one group [dhalperi] Optimize imports [dhalperi] BigQueryIO.Write: raise size limit to 11 TiB [dhalperi] Cleanup some javadoc that referring Dataflow [dhalperi] Move the samples data to gs://apache-beam-samples/ [dhalperi] [BEAM-545] Promote JobName to PipelineOptions [dhalperi] Update DoFn javadocs to remove references to OldDoFn and Dataflow [dhalperi] Make WriteTest more resilient to Randomness [dhalperi] checkstyle: prohibit API client repackaged Guava [dhalperi] Modified BigtableIO to use DoFn setup/tearDown methods instead of [dhalperi] [BEAM-294] Rename dataflow references to beam [dhalperi] Added support for reporting aggregator values to Spark sinks [dhalperi] travis.yml: disable updating snapshots [dhalperi] Query latest timestamp [dhalperi] [BEAM-589] Fixing IO.Read transformation [dhalperi] kinesis: a connector for Amazon Kinesis [dhalperi] Organize imports in Kinesis [dhalperi] Fix javadoc in Kinesis [dhalperi] [BEAM-592] Fix SparkRunner Dependency Problem in WordCount [dhalperi] DataflowRunner: get PBegin from PInput [dhalperi] [BEAM-313] Provide a context for SparkRunner [dhalperi] Update Dataflow Container Version [dhalperi] [BEAM-572] Remove Spark Reference in WordCount [dhalperi] Returned KafkaIO getWatermark log line in debug mode [dhalperi] take advantage of setup/teardown for KafkaWriter [dhalperi] Add LeaderBoardTest [dhalperi] [BEAM-569] Define maxNumRecords default value to Long.MAX_VALUE in JmsIO [dhalperi] Address comments of Flink Side-Input PR [dhalperi] Fix condition in FlinkStreamingPipelineTranslator [dhalperi] Correct some accidental renames [dhalperi] Test that multiple instances of TestStream are supported [dhalperi] Remove empty unused method in TestStreamEvaluatorFactory [dhalperi] Add Latest CombineFn and PTransforms [dhalperi] DatastoreIO SplitQueryFn integration test [dhalperi] Cloud Datastore naming clean-up [dhalperi] Fixed Combine display data [dhalperi] Delegate populateDipslayData to wrapped combineFn's [dhalperi] Put classes in runners-core package into runners.core namespace [dhalperi] Remove the DataflowRunner instructions from examples [dhalperi] FluentBackoff: a replacement for a variety of custom backoff [dhalperi] [BEAM-456] Add MongoDbIO [dhalperi] [BEAM-242] Enable checkstyle and fix checkstyle errors in Flink runner [dhalperi] BigQuery: limit max job polling time to 1 minute [dhalperi] Be more accepting in UnboundedReadDeduplicatorTest [dhalperi] Remove timeout in JAXBCoderTest [dhalperi] [BEAM-242] Enable and fix checkstyle in Flink runner examples [dhalperi] Add header/footer support to TextIO.Write [dhalperi] Revised according to comments following a code review. [dhalperi] Reverted header and footer to be of type String. [dhalperi] Added javadoc to TextIO#withHeader and TextIO#withFooter. [dhalperi] Added even more javadoc to TextIO#withHeader and TextIO#withFooter. [dhalperi] Added even more javadoc to TextIO#withHeader and TextIO#withFooter (2). [dhalperi] !fixup Minor javadoc clean-up [dhalperi] fix import order [owenzhang1990] [BEAM-79] fix integration-test failure [owenzhang1990] post-merge fix [owenzhang1990] remove "pipeline" in runner name [owenzhang1990] upgrade gearpump-runner to 0.4.0-incubating-SNAPSHOT [klk] [BEAM-79] Port Gearpump runner from OldDoFn to new DoFn [owenzhang1990] [BEAM-79] update GearpumpPipelineResult [owenzhang1990] [BEAM-79] fix gearpump runner build failure [owenzhang1990] Upgrade Gearpump version [owenzhang1990] Add Window.Bound translator [owenzhang1990] Skip window assignment when windows don't change [owenzhang1990] Remove print to stdout [owenzhang1990] Fix NoOpAggregatorFactory [owenzhang1990] [BEAM-79] Update to latest Gearpump API [owenzhang1990] [BEAM-79] Upgrade to beam-0.5.0-incubating-SNAPSHOT [owenzhang1990] [BEAM-1180] Implement GearpumpPipelineResult [owenzhang1990] update ROS configurations [owenzhang1990] activate ROS on Gearpump by default [owenzhang1990] fix group by window [owenzhang1990] update to latest gearpump dsl function interface [owenzhang1990] support OutputTimeFn [owenzhang1990] return encoded key for GroupByKey translation [owenzhang1990] fix ParDo.BoundMulti translation [owenzhang1990] reduce timeout to wait for result [owenzhang1990] Remove cache for Gearpump on travis [owenzhang1990] note thread is interrupted on InterruptedException [owenzhang1990] [BEAM-79] Fix PostCommit test confs for Gearpump runner [owenzhang1990] [BEAM-79] Support merging windows in GearpumpRunner [owenzhang1990] [BEAM-79] Add SideInput support for GearpumpRunner [owenzhang1990] enable ParDoTest [owenzhang1990] [BEAM-79] Fix gearpump-runner merge conflicts and test failure [huafengw] [BEAM-972] Add unit tests to Gearpump runner [huafengw] [BEAM-972] Add more unit test to Gearpump runner [owenzhang1990] Update gearpump-runner against master changes. [owenzhang1990] Update gearpump-runner against master changes [owenzhang1990] Update gearpump-runner against master changes [owenzhang1990] Update against master changes [owenzhang1990] Activate Gearpump local-validates-runner-tests in precommit [owenzhang1990] Respect WindowFn#getOutputTime in gearpump-runner [owenzhang1990] Fix side input handling in DoFnFunction [owenzhang1990] upgrade to gearpump 0.8.4-SNAPSHOT [owenzhang1990] Fix PCollectionView translation [owenzhang1990] Fix kryo exception [owenzhang1990] Remove unused codes [owenzhang1990] Upgrade to gearpump 0.8.4 [owenzhang1990] Fix ParDoTest#testPipelineOptionsParameter [owenzhang1990] Revert accidental changes to sdks/java/pom.xml [owenzhang1990] Upgrade BEAM version to 2.2.0-SNAPSHOT in gearpump-runner [owenzhang1990] Add beam-runners-gearpump dependency to javadoc [owenzhang1990] Deactivate integration-tests for gearpump-runner by default [owenzhang1990] Require java 8 for precommit tests and add gearpump-runner [owenzhang1990] Override maven-enforcer-plugin for precommit tests [owenzhang1990] Remove gearpump-runner in precommit tests [tgroh] Suppress Attempted Metrics tests in Dataflow Batch [tgroh] Add GRPC to Compilation of the Runner API [tgroh] Delete list job creation -- creates in wrong place. ------------------------------------------ [...truncated 3.74 MB...] 2017-08-08T08:17:05.461 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/github/jnr/jnr-ffi/2.0.9/jnr-ffi-2.0.9.jar (638 KB at 2278.2 KB/sec) 2017-08-08T08:17:05.462 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-actor_2.11/2.4.16/akka-actor_2.11-2.4.16.jar 2017-08-08T08:17:05.487 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/jakewharton/byteunits/byteunits/0.9.1/byteunits-0.9.1.jar (23 KB at 74.5 KB/sec) 2017-08-08T08:17:05.487 [INFO] Downloading: https://repo.maven.apache.org/maven2/org/scala-lang/modules/scala-java8-compat_2.11/0.7.0/scala-java8-compat_2.11-0.7.0.jar 2017-08-08T08:17:05.488 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/github/jnr/jnr-constants/0.9.3/jnr-constants-0.9.3.jar (316 KB at 1026.8 KB/sec) 2017-08-08T08:17:05.488 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-agent_2.11/2.4.16/akka-agent_2.11-2.4.16.jar 2017-08-08T08:17:05.493 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/github/jnr/jffi/1.2.11/jffi-1.2.11-native.jar (446 KB at 1428.7 KB/sec) 2017-08-08T08:17:05.493 [INFO] Downloading: https://repo.maven.apache.org/maven2/org/scala-stm/scala-stm_2.11/0.8/scala-stm_2.11-0.8.jar 2017-08-08T08:17:05.514 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-agent_2.11/2.4.16/akka-agent_2.11-2.4.16.jar (17 KB at 50.9 KB/sec) 2017-08-08T08:17:05.514 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-slf4j_2.11/2.4.16/akka-slf4j_2.11-2.4.16.jar 2017-08-08T08:17:05.546 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-slf4j_2.11/2.4.16/akka-slf4j_2.11-2.4.16.jar (20 KB at 52.1 KB/sec) 2017-08-08T08:17:05.546 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-kernel_2.11/2.4.16/akka-kernel_2.11-2.4.16.jar 2017-08-08T08:17:05.556 [INFO] Downloaded: https://repo.maven.apache.org/maven2/org/scala-lang/modules/scala-java8-compat_2.11/0.7.0/scala-java8-compat_2.11-0.7.0.jar (569 KB at 1516.6 KB/sec) 2017-08-08T08:17:05.556 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-http_2.11/10.0.1/akka-http_2.11-10.0.1.jar 2017-08-08T08:17:05.565 [INFO] Downloaded: https://repo.maven.apache.org/maven2/org/scala-stm/scala-stm_2.11/0.8/scala-stm_2.11-0.8.jar (632 KB at 1645.0 KB/sec) 2017-08-08T08:17:05.565 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-http-core_2.11/10.0.1/akka-http-core_2.11-10.0.1.jar 2017-08-08T08:17:05.572 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-kernel_2.11/2.4.16/akka-kernel_2.11-2.4.16.jar (15 KB at 37.1 KB/sec) 2017-08-08T08:17:05.572 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-parsing_2.11/10.0.1/akka-parsing_2.11-10.0.1.jar 2017-08-08T08:17:05.597 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-stream_2.11/2.4.16/akka-stream_2.11-2.4.16.jar (4297 KB at 10303.9 KB/sec) 2017-08-08T08:17:05.597 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-http-spray-json_2.11/10.0.1/akka-http-spray-json_2.11-10.0.1.jar 2017-08-08T08:17:05.632 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-http-spray-json_2.11/10.0.1/akka-http-spray-json_2.11-10.0.1.jar (24 KB at 52.4 KB/sec) 2017-08-08T08:17:05.632 [INFO] Downloading: https://repo.maven.apache.org/maven2/io/spray/spray-json_2.11/1.3.2/spray-json_2.11-1.3.2.jar 2017-08-08T08:17:05.671 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-parsing_2.11/10.0.1/akka-parsing_2.11-10.0.1.jar (953 KB at 1943.6 KB/sec) 2017-08-08T08:17:05.671 [INFO] Downloading: https://repo.maven.apache.org/maven2/org/scala-lang/scala-reflect/2.11.8/scala-reflect-2.11.8.jar 2017-08-08T08:17:05.684 [INFO] Downloaded: https://repo.maven.apache.org/maven2/io/spray/spray-json_2.11/1.3.2/spray-json_2.11-1.3.2.jar (280 KB at 556.0 KB/sec) 2017-08-08T08:17:05.684 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/typesafe/config/1.3.0/config-1.3.0.jar 2017-08-08T08:17:05.739 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-actor_2.11/2.4.16/akka-actor_2.11-2.4.16.jar (3258 KB at 5838.6 KB/sec) 2017-08-08T08:17:05.739 [INFO] Downloading: https://repo.maven.apache.org/maven2/org/scala-lang/scala-library/2.11.8/scala-library-2.11.8.jar 2017-08-08T08:17:05.742 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/config/1.3.0/config-1.3.0.jar (272 KB at 483.5 KB/sec) 2017-08-08T08:17:05.791 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-http_2.11/10.0.1/akka-http_2.11-10.0.1.jar (2660 KB at 4359.4 KB/sec) 2017-08-08T08:17:05.856 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/typesafe/akka/akka-http-core_2.11/10.0.1/akka-http-core_2.11-10.0.1.jar (3365 KB at 4984.0 KB/sec) 2017-08-08T08:17:06.003 [INFO] Downloaded: https://repo.maven.apache.org/maven2/org/scala-lang/scala-reflect/2.11.8/scala-reflect-2.11.8.jar (4467 KB at 5433.8 KB/sec) 2017-08-08T08:17:06.186 [INFO] Downloaded: https://repo.maven.apache.org/maven2/org/scala-lang/scala-library/2.11.8/scala-library-2.11.8.jar (5611 KB at 5582.4 KB/sec) 2017-08-08T08:17:06.194 [INFO] 2017-08-08T08:17:06.194 [INFO] --- maven-clean-plugin:3.0.0:clean (default-clean) @ beam-runners-gearpump --- 2017-08-08T08:17:06.196 [INFO] Deleting <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump> (includes = [**/*.pyc, **/*.egg-info/, **/sdks/python/LICENSE, **/sdks/python/NOTICE, **/sdks/python/README.md], excludes = []) 2017-08-08T08:17:06.304 [INFO] 2017-08-08T08:17:06.304 [INFO] --- maven-enforcer-plugin:3.0.0-M1:enforce (enforce) @ beam-runners-gearpump --- 2017-08-08T08:17:08.591 [INFO] 2017-08-08T08:17:08.591 [INFO] --- maven-enforcer-plugin:3.0.0-M1:enforce (enforce-banned-dependencies) @ beam-runners-gearpump --- 2017-08-08T08:17:08.711 [INFO] 2017-08-08T08:17:08.711 [INFO] --- maven-remote-resources-plugin:1.5:process (process-resource-bundles) @ beam-runners-gearpump --- 2017-08-08T08:17:09.069 [INFO] 2017-08-08T08:17:09.069 [INFO] --- maven-resources-plugin:3.0.2:resources (default-resources) @ beam-runners-gearpump --- 2017-08-08T08:17:09.071 [INFO] Using 'UTF-8' encoding to copy filtered resources. 2017-08-08T08:17:09.071 [INFO] skip non existing resourceDirectory <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/resources> 2017-08-08T08:17:09.071 [INFO] Copying 3 resources 2017-08-08T08:17:09.178 [INFO] 2017-08-08T08:17:09.178 [INFO] --- maven-compiler-plugin:3.6.2:compile (default-compile) @ beam-runners-gearpump --- 2017-08-08T08:17:09.185 [INFO] Changes detected - recompiling the module! 2017-08-08T08:17:09.185 [INFO] Compiling 29 source files to <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/target/classes> 2017-08-08T08:17:09.683 [INFO] <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java>: Some input files use or override a deprecated API. 2017-08-08T08:17:09.683 [INFO] <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java>: Recompile with -Xlint:deprecation for details. 2017-08-08T08:17:09.683 [INFO] <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/utils/TranslatorUtils.java>: Some input files use unchecked or unsafe operations. 2017-08-08T08:17:09.683 [INFO] <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/utils/TranslatorUtils.java>: Recompile with -Xlint:unchecked for details. 2017-08-08T08:17:09.683 [INFO] ------------------------------------------------------------- 2017-08-08T08:17:09.683 [ERROR] COMPILATION ERROR : 2017-08-08T08:17:09.683 [INFO] ------------------------------------------------------------- 2017-08-08T08:17:09.683 [ERROR] <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java>:[126,25] method createPrimitiveOutputInternal in class org.apache.beam.sdk.values.PCollection<T> cannot be applied to given types; required: org.apache.beam.sdk.Pipeline,org.apache.beam.sdk.values.WindowingStrategy<?,?>,org.apache.beam.sdk.values.PCollection.IsBounded,org.apache.beam.sdk.coders.Coder<T> found: org.apache.beam.sdk.Pipeline,org.apache.beam.sdk.values.WindowingStrategy<capture#1 of ?,capture#2 of ?>,org.apache.beam.sdk.values.PCollection.IsBounded reason: actual and formal argument lists differ in length 2017-08-08T08:17:09.683 [INFO] 1 error 2017-08-08T08:17:09.683 [INFO] ------------------------------------------------------------- [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled 2017-08-08T08:18:11.927 [INFO] ------------------------------------------------------------------------ 2017-08-08T08:18:11.927 [INFO] Reactor Summary: 2017-08-08T08:18:11.927 [INFO] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 37.631 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 16.130 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 7.268 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 4.596 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Common :: Runner API ........ SUCCESS [ 30.848 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 21.232 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 4.657 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:09 min] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 4.745 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 32.812 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 46.924 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [04:28 min] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 4.897 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: AMQP .......... SUCCESS [ 27.647 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Common ........ SUCCESS [ 11.831 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Cassandra ..... SUCCESS [ 28.289 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Elasticsearch . SUCCESS [ 37.878 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 4.881 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [ 29.236 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 24.195 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:24 min] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Hadoop Common . SUCCESS [ 25.204 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Hadoop File System SUCCESS [ 37.168 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Hadoop ........ SUCCESS [ 7.348 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Hadoop :: input-format SUCCESS [ 24.212 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [07:56 min] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Hadoop :: jdk1.8-tests SUCCESS [01:37 min] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: HBase ......... SUCCESS [01:19 min] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: HCatalog ...... SUCCESS [01:21 min] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: JDBC .......... SUCCESS [ 50.613 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: JMS ........... SUCCESS [ 32.732 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Kafka ......... SUCCESS [ 47.610 s] 2017-08-08T08:18:11.927 [INFO] Apache Beam :: SDKs :: Java :: IO :: Kinesis ....... SUCCESS [ 32.922 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: IO :: MongoDB ....... SUCCESS [ 46.823 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: IO :: MQTT .......... SUCCESS [ 39.777 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: IO :: XML ........... SUCCESS [ 37.604 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Maven Archetypes .... SUCCESS [ 4.239 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Maven Archetypes :: Starter SUCCESS [ 20.443 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: Examples ............................ SUCCESS [ 4.571 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: Examples :: Java .................... SUCCESS [05:38 min] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Maven Archetypes :: Examples SUCCESS [ 42.336 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: Examples :: Java 8 .................. SUCCESS [ 40.047 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Maven Archetypes :: Examples - Java 8 SUCCESS [ 50.877 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Jackson SUCCESS [ 29.528 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Join library SUCCESS [ 32.751 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Sorter SUCCESS [ 50.738 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Harness ............. SUCCESS [ 51.493 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Java 8 Tests ........ SUCCESS [ 20.210 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Python ...................... SUCCESS [25:15 min] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: Runners :: Flink .................... SUCCESS [ 58.776 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: Runners :: Spark .................... SUCCESS [02:42 min] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: Runners :: Apex ..................... SUCCESS [01:12 min] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: Runners :: Gearpump ................. FAILURE [ 14.538 s] 2017-08-08T08:18:11.928 [INFO] Apache Beam :: SDKs :: Java :: Aggregated Javadoc .. SKIPPED 2017-08-08T08:18:11.928 [INFO] ------------------------------------------------------------------------ 2017-08-08T08:18:11.928 [INFO] BUILD FAILURE 2017-08-08T08:18:11.928 [INFO] ------------------------------------------------------------------------ 2017-08-08T08:18:11.928 [INFO] Total time: 01:17 h 2017-08-08T08:18:11.928 [INFO] Finished at: 2017-08-08T08:18:11+00:00 2017-08-08T08:18:12.712 [INFO] Final Memory: 486M/1667M 2017-08-08T08:18:12.712 [INFO] ------------------------------------------------------------------------ 2017-08-08T08:18:12.718 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.6.2:compile (default-compile) on project beam-runners-gearpump: Compilation failure 2017-08-08T08:18:12.718 [ERROR] <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java>:[126,25] method createPrimitiveOutputInternal in class org.apache.beam.sdk.values.PCollection<T> cannot be applied to given types; 2017-08-08T08:18:12.718 [ERROR] required: org.apache.beam.sdk.Pipeline,org.apache.beam.sdk.values.WindowingStrategy<?,?>,org.apache.beam.sdk.values.PCollection.IsBounded,org.apache.beam.sdk.coders.Coder<T> 2017-08-08T08:18:12.718 [ERROR] found: org.apache.beam.sdk.Pipeline,org.apache.beam.sdk.values.WindowingStrategy<capture#1 of ?,capture#2 of ?>,org.apache.beam.sdk.values.PCollection.IsBounded 2017-08-08T08:18:12.718 [ERROR] reason: actual and formal argument lists differ in length 2017-08-08T08:18:12.718 [ERROR] -> [Help 1] org.apache.maven.lifecycle.LifecycleExecutionException: Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.6.2:compile (default-compile) on project beam-runners-gearpump: Compilation failure <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java>:[126,25] method createPrimitiveOutputInternal in class org.apache.beam.sdk.values.PCollection<T> cannot be applied to given types; required: org.apache.beam.sdk.Pipeline,org.apache.beam.sdk.values.WindowingStrategy<?,?>,org.apache.beam.sdk.values.PCollection.IsBounded,org.apache.beam.sdk.coders.Coder<T> found: org.apache.beam.sdk.Pipeline,org.apache.beam.sdk.values.WindowingStrategy<capture#1 of ?,capture#2 of ?>,org.apache.beam.sdk.values.PCollection.IsBounded reason: actual and formal argument lists differ in length at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:212) at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:153) at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:145) at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:116) at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:80) at org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build(SingleThreadedBuilder.java:51) at org.apache.maven.lifecycle.internal.LifecycleStarter.execute(LifecycleStarter.java:128) at org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:307) at org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:193) at org.apache.maven.DefaultMaven.execute(DefaultMaven.java:106) at org.jvnet.hudson.maven3.launcher.Maven33Launcher.main(Maven33Launcher.java:129) 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.codehaus.plexus.classworlds.launcher.Launcher.launchStandard(Launcher.java:330) at org.codehaus.plexus.classworlds.launcher.Launcher.launch(Launcher.java:238) at jenkins.maven3.agent.Maven33Main.launch(Maven33Main.java:176) 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 hudson.maven.Maven3Builder.call(Maven3Builder.java:139) at hudson.maven.Maven3Builder.call(Maven3Builder.java:70) at hudson.remoting.UserRequest.perform(UserRequest.java:153) at hudson.remoting.UserRequest.perform(UserRequest.java:50) at hudson.remoting.Request$2.run(Request.java:336) at hudson.remoting.InterceptingExecutorService$1.call(InterceptingExecutorService.java:68) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.maven.plugin.compiler.CompilationFailureException: Compilation failure <https://builds.apache.org/job/beam_Release_NightlySnapshot/ws/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java>:[126,25] method createPrimitiveOutputInternal in class org.apache.beam.sdk.values.PCollection<T> cannot be applied to given types; required: org.apache.beam.sdk.Pipeline,org.apache.beam.sdk.values.WindowingStrategy<?,?>,org.apache.beam.sdk.values.PCollection.IsBounded,org.apache.beam.sdk.coders.Coder<T> found: org.apache.beam.sdk.Pipeline,org.apache.beam.sdk.values.WindowingStrategy<capture#1 of ?,capture#2 of ?>,org.apache.beam.sdk.values.PCollection.IsBounded reason: actual and formal argument lists differ in length at org.apache.maven.plugin.compiler.AbstractCompilerMojo.execute(AbstractCompilerMojo.java:1038) at org.apache.maven.plugin.compiler.CompilerMojo.execute(CompilerMojo.java:158) at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo(DefaultBuildPluginManager.java:134) at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:208) ... 31 more 2017-08-08T08:18:12.719 [ERROR] 2017-08-08T08:18:12.719 [ERROR] Re-run Maven using the -X switch to enable full debug logging. 2017-08-08T08:18:12.719 [ERROR] 2017-08-08T08:18:12.719 [ERROR] For more information about the errors and possible solutions, please read the following articles: 2017-08-08T08:18:12.719 [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException 2017-08-08T08:18:12.719 [ERROR] 2017-08-08T08:18:12.719 [ERROR] After correcting the problems, you can resume the build with the command 2017-08-08T08:18:12.719 [ERROR] mvn <goals> -rf :beam-runners-gearpump channel stopped Not sending mail to unregistered user k...@google.com Not sending mail to unregistered user owenzhang1...@gmail.com
