See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/718/display/redirect?page=changes>
Changes: [sidhom] Add reference to ArtifactSourcePool implementation [sidhom] Clean up FlinkExecutableStageFunction and tests [sidhom] [BEAM-4523] Implement batch flink executable stage context ------------------------------------------ [...truncated 85.03 KB...] > Task :beam-sdks-java-core:testClasses Skipping task ':beam-sdks-java-core:testClasses' as it has no actions. :beam-sdks-java-core:testClasses (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 0.0 secs. :beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':' Thread 5,5,main]) started. > Task :beam-sdks-java-harness:compileJava Build cache key for task ':beam-sdks-java-harness:compileJava' is 03403b86d687342a5bb85ed281f7feae Task ':beam-sdks-java-harness:compileJava' is not up-to-date because: No history is available. Custom actions are attached to task ':beam-sdks-java-harness:compileJava'. All input files are considered out-of-date for incremental task ':beam-sdks-java-harness:compileJava'. Compiling with error-prone compiler <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation': class file for edu.umd.cs.findbugs.annotations.DefaultAnnotation not found <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/coders/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/transforms/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/core-construction-java/build/libs/beam-runners-core-construction-java-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/runners/core/construction/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/core-java/build/libs/beam-runners-core-java-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/runners/core/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/transforms/windowing/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/state/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/transforms/reflect/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/transforms/splittabledofn/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/values/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java>:141: warning: [InconsistentCapitalization] Found the field 'ptransformId' with the same name as the parameter 'pTransformId' but with different capitalization. String pTransformId, ^ (see http://errorprone.info/bugpattern/InconsistentCapitalization) Did you mean 'String ptransformId,'? <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java>:202: warning: [InconsistentCapitalization] Found the field 'ptransformId' with the same name as the parameter 'pTransformId' but with different capitalization. String pTransformId, ^ (see http://errorprone.info/bugpattern/InconsistentCapitalization) Did you mean 'String ptransformId,'? <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java>:976: warning: [TypeParameterShadowing] Found aliased type parameters: InputT declared in FnApiDoFnRunner public <InputT, AccumT, OutputT> CombiningState<InputT, AccumT, OutputT> bindCombining( ^ OutputT declared in FnApiDoFnRunner (see http://errorprone.info/bugpattern/TypeParameterShadowing) Did you mean 'public <InputT2, AccumT, OutputT2> CombiningState<InputT2, AccumT, OutputT2> bindCombining('? <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java>:1055: warning: [TypeParameterShadowing] Found aliased type parameters: InputT declared in FnApiDoFnRunner bindCombiningWithContext( ^ OutputT declared in FnApiDoFnRunner (see http://errorprone.info/bugpattern/TypeParameterShadowing) Did you mean 'public <InputT2, AccumT, OutputT2> CombiningState<InputT2, AccumT, OutputT2>'? <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java>:1187: warning: [TypeParameterUnusedInFormals] Declaring a type parameter that is only used in the return type is a misuse of generics: operations on the type parameter are unchecked, it hides unsafe casts at invocations of the method, and it interacts badly with method overload resolution. private <T, K, V> T bindSideInputView(TupleTag<?> view) { ^ (see http://errorprone.info/bugpattern/TypeParameterUnusedInFormals) <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/build/libs/beam-sdks-java-core-2.6.0-SNAPSHOT-shaded.jar(/org/apache/beam/sdk/io/package-info.class)>: warning: Cannot find annotation method 'value()' in type 'DefaultAnnotation' <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java>:159: warning: [CatchAndPrintStackTrace] Logging or rethrowing exceptions should usually be preferred to catching and calling printStackTrace t.printStackTrace(); ^ (see http://errorprone.info/bugpattern/CatchAndPrintStackTrace) <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java>:304: warning: [FutureReturnValueIgnored] Return value of methods returning Future must be checked. Ignoring returned Futures suppresses exceptions thrown from the code that completes the Future. response.whenComplete((stateResponse, throwable) -> phaser.arriveAndDeregister()); ^ (see http://errorprone.info/bugpattern/FutureReturnValueIgnored) Did you mean 'response = response.whenComplete((stateResponse, throwable) -> phaser.arriveAndDeregister());'? <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java>:332: warning: [ClassCanBeStatic] Inner class is non-static but does not reference enclosing class private abstract class HandleStateCallsForBundle implements AutoCloseable, BeamFnStateClient { ^ (see http://errorprone.info/bugpattern/ClassCanBeStatic) Did you mean 'private abstract static class HandleStateCallsForBundle implements AutoCloseable, BeamFnStateClient {'? <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/BeamFnControlClient.java>:144: warning: [ReferenceEquality] Comparison using reference equality instead of value equality while ((request = bufferedInstructions.take()) != POISON_PILL) { ^ (see http://errorprone.info/bugpattern/ReferenceEquality) Did you mean 'while (!Objects.equals((request = bufferedInstructions.take()), POISON_PILL)) {' or 'while (!(request = bufferedInstructions.take()).equals(POISON_PILL)) {'? <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/RegisterHandler.java>:48: warning: [TypeParameterUnusedInFormals] Declaring a type parameter that is only used in the return type is a misuse of generics: operations on the type parameter are unchecked, it hides unsafe casts at invocations of the method, and it interacts badly with method overload resolution. public <T extends Message> T getById(String id) { ^ (see http://errorprone.info/bugpattern/TypeParameterUnusedInFormals) Note: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java> uses or overrides a deprecated API. Note: Recompile with -Xlint:deprecation for details. Note: Some input files use unchecked or unsafe operations. Note: Recompile with -Xlint:unchecked for details. 21 warnings Packing task ':beam-sdks-java-harness:compileJava' :beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 6.135 secs. :beam-sdks-java-harness:classes (Thread[Task worker for ':' Thread 13,5,main]) started. > Task :beam-sdks-java-harness:classes Skipping task ':beam-sdks-java-harness:classes' as it has no actions. :beam-sdks-java-harness:classes (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 0.0 secs. :beam-sdks-java-harness:jar (Thread[Task worker for ':' Thread 13,5,main]) started. > Task :beam-sdks-java-core:shadowTestJar Build cache key for task ':beam-sdks-java-core:shadowTestJar' is 6629484ad4dd32ad8c1ceaef44b537ec Caching disabled for task ':beam-sdks-java-core:shadowTestJar': Caching has not been enabled for the task Task ':beam-sdks-java-core:shadowTestJar' is not up-to-date because: No history is available. > Task :beam-sdks-java-harness:jar Build cache key for task ':beam-sdks-java-harness:jar' is 3c4c024ab4528a64eb15c9cf57977829 Caching disabled for task ':beam-sdks-java-harness:jar': Caching has not been enabled for the task Task ':beam-sdks-java-harness:jar' is not up-to-date because: No history is available. :beam-sdks-java-harness:jar (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 0.035 secs. :beam-sdks-java-harness:shadowJar (Thread[Task worker for ':' Thread 13,5,main]) started. > Task :beam-sdks-java-harness:shadowJar Build cache key for task ':beam-sdks-java-harness:shadowJar' is 22bdb6bf997c5ba823feaeaaeb947f77 Caching disabled for task ':beam-sdks-java-harness:shadowJar': Caching has not been enabled for the task Task ':beam-sdks-java-harness:shadowJar' is not up-to-date because: No history is available. > Task :beam-sdks-java-core:shadowTestJar ******************* GRADLE SHADOW STATS Total Jars: 6 (includes project) Total Time: 6.836s [6836ms] Average Time/Jar: 1.1393333333333s [1139.3333333333ms] ******************* :beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 10.112 secs. :beam-runners-core-java:compileTestJava (Thread[Task worker for ':' Thread 5,5,main]) started. > Task :beam-runners-core-java:compileTestJava Build cache key for task ':beam-runners-core-java:compileTestJava' is 09da06e27dd9358a4c55e1a302ff9e3d Task ':beam-runners-core-java:compileTestJava' is not up-to-date because: No history is available. Custom actions are attached to task ':beam-runners-core-java:compileTestJava'. All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileTestJava'. Compiling with error-prone compiler Note: Some input files use or override a deprecated API. Note: Recompile with -Xlint:deprecation for details. Note: Some input files use unchecked or unsafe operations. Note: Recompile with -Xlint:unchecked for details. Packing task ':beam-runners-core-java:compileTestJava' :beam-runners-core-java:compileTestJava (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 7.899 secs. :beam-runners-core-java:testClasses (Thread[Task worker for ':' Thread 5,5,main]) started. > Task :beam-runners-core-java:testClasses Skipping task ':beam-runners-core-java:testClasses' as it has no actions. :beam-runners-core-java:testClasses (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 0.0 secs. :beam-runners-core-java:shadowTestJar (Thread[Task worker for ':' Thread 5,5,main]) started. > Task :beam-runners-core-java:shadowTestJar Build cache key for task ':beam-runners-core-java:shadowTestJar' is 3bdee10d42a01338c7003490793413f8 Caching disabled for task ':beam-runners-core-java:shadowTestJar': Caching has not been enabled for the task Task ':beam-runners-core-java:shadowTestJar' is not up-to-date because: No history is available. ******************* GRADLE SHADOW STATS Total Jars: 2 (includes project) Total Time: 2.086s [2086ms] Average Time/Jar: 1.043s [1043.0ms] ******************* :beam-runners-core-java:shadowTestJar (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 2.326 secs. > Task :beam-sdks-java-harness:shadowJar ******************* GRADLE SHADOW STATS Total Jars: 66 (includes project) Total Time: 30.592s [30592ms] Average Time/Jar: 0.4635151515152s [463.5151515152ms] ******************* :beam-sdks-java-harness:shadowJar (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 31.221 secs. :beam-runners-java-fn-execution:compileJava (Thread[Task worker for ':' Thread 13,5,main]) started. > Task :beam-runners-java-fn-execution:compileJava Build cache key for task ':beam-runners-java-fn-execution:compileJava' is b0ca4ff22c05f9a1fdc195575219b63a Task ':beam-runners-java-fn-execution:compileJava' is not up-to-date because: No history is available. Custom actions are attached to task ':beam-runners-java-fn-execution:compileJava'. All input files are considered out-of-date for incremental task ':beam-runners-java-fn-execution:compileJava'. Compiling with error-prone compiler <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/InProcessEnvironmentFactory.java>:110: warning: [FutureReturnValueIgnored] Return value of methods returning Future must be checked. Ignoring returned Futures suppresses exceptions thrown from the code that completes the Future. executor.submit( ^ (see http://errorprone.info/bugpattern/FutureReturnValueIgnored) Did you mean to remove this line? Note: Some input files use unchecked or unsafe operations. Note: Recompile with -Xlint:unchecked for details. 1 warning Packing task ':beam-runners-java-fn-execution:compileJava' :beam-runners-java-fn-execution:compileJava (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 8.86 secs. :beam-runners-java-fn-execution:classes (Thread[Task worker for ':' Thread 13,5,main]) started. > Task :beam-runners-java-fn-execution:classes Skipping task ':beam-runners-java-fn-execution:classes' as it has no actions. :beam-runners-java-fn-execution:classes (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 0.0 secs. :beam-runners-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 13,5,main]) started. > Task :beam-runners-java-fn-execution:shadowJar Build cache key for task ':beam-runners-java-fn-execution:shadowJar' is 048c31dfcb61a7151a5d0912292695d6 Caching disabled for task ':beam-runners-java-fn-execution:shadowJar': Caching has not been enabled for the task Task ':beam-runners-java-fn-execution:shadowJar' is not up-to-date because: No history is available. ******************* GRADLE SHADOW STATS Total Jars: 2 (includes project) Total Time: 2.104s [2104ms] Average Time/Jar: 1.052s [1052.0ms] ******************* :beam-runners-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 2.25 secs. :beam-runners-flink_2.11:compileJava (Thread[Task worker for ':' Thread 13,5,main]) started. > Task :beam-runners-flink_2.11:compileJava Build cache key for task ':beam-runners-flink_2.11:compileJava' is 75e144226a4f2574ee18132a18e712d0 Task ':beam-runners-flink_2.11:compileJava' is not up-to-date because: No history is available. Custom actions are attached to task ':beam-runners-flink_2.11:compileJava'. All input files are considered out-of-date for incremental task ':beam-runners-flink_2.11:compileJava'. Compiling with error-prone compiler <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/BatchFlinkExecutableStageContext.java>:77: warning: [ImmutableEnumChecker] enums should be immutable: 'BatchFactory' has field 'cachedContexts' of type 'com.google.common.cache.LoadingCache<org.apache.beam.runners.fnexecution.provisioning.JobInfo,org.apache.beam.runners.flink.translation.functions.BatchFlinkExecutableStageContext>', the declaration of type 'com.google.common.cache.LoadingCache<org.apache.beam.runners.fnexecution.provisioning.JobInfo,org.apache.beam.runners.flink.translation.functions.BatchFlinkExecutableStageContext>' is not annotated with @com.google.errorprone.annotations.Immutable or @javax.annotation.concurrent.Immutable private final LoadingCache<JobInfo, BatchFlinkExecutableStageContext> cachedContexts; ^ (see http://errorprone.info/bugpattern/ImmutableEnumChecker) error: warnings found and -Werror specified Note: Some input files use or override a deprecated API. Note: Recompile with -Xlint:deprecation for details. Note: Some input files use unchecked or unsafe operations. Note: Recompile with -Xlint:unchecked for details. 1 error 1 warning > Task :beam-runners-flink_2.11:compileJava FAILED :beam-runners-flink_2.11:compileJava (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 10.416 secs. FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':beam-runners-flink_2.11:compileJava'. > Compilation failed with exit code 1; see the compiler error output for > details. * 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.7/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 1m 42s 41 actionable tasks: 37 executed, 4 from cache Publishing build scan... https://gradle.com/s/ienyxgwmdpgjm Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure Recording test results ERROR: Step ‘Publish JUnit test result report’ failed: No test report files were found. Configuration error? Not sending mail to unregistered user [email protected]
