See
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/1086/display/redirect?page=changes>
Changes:
[ajhalaria] Create a custom hash paritioner that deals with arrays during
combines
[tweise] [flink] debug logging for state access
[github] [BEAM-6866]: SamzaRunner: support timers in ParDo (#8092)
[boyuanz] Reset Datasource counter to 0 in FinishBundle
[boyuanz] Reset count to 0 after all operations have finished bundle
------------------------------------------
[...truncated 1.06 MB...]
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformTranslator.java>:38:
warning: no @param for transform
default void translatePortable(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformTranslator.java>:38:
warning: no @param for pipeline
default void translatePortable(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformTranslator.java>:38:
warning: no @param for ctx
default void translatePortable(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformConfigGenerator.java>:29:
warning: no @param for transform
default Map<String, String> createConfig(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformConfigGenerator.java>:29:
warning: no @param for node
default Map<String, String> createConfig(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformConfigGenerator.java>:29:
warning: no @param for ctx
default Map<String, String> createConfig(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformConfigGenerator.java>:29:
warning: no @return
default Map<String, String> createConfig(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformConfigGenerator.java>:35:
warning: no @param for transform
default Map<String, String> createPortableConfig(PipelineNode.PTransformNode
transform) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformConfigGenerator.java>:35:
warning: no @return
default Map<String, String> createPortableConfig(PipelineNode.PTransformNode
transform) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PortableTranslationContext.java>:97:
warning: no @param for id
public void registerInputMessageStream(String id) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PortableTranslationContext.java>:102:
warning: no @param for <T>
public <T> OutputStream<T> getOutputStreamById(String outputStreamId) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PortableTranslationContext.java>:102:
warning: no @param for outputStreamId
public <T> OutputStream<T> getOutputStreamById(String outputStreamId) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PortableTranslationContext.java>:102:
warning: no @return
public <T> OutputStream<T> getOutputStreamById(String outputStreamId) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PortableTranslationContext.java>:112:
warning: no @param for <T>
public <T> void registerInputMessageStreamWithStreamId(String id, String
streamId) {
^
64 warnings
> Task :beam-sdks-java-core:spotbugsMain
> Task :beam-runners-direct-java:jar
> Task :beam-runners-direct-java:packageTests
> Task :beam-runners-direct-java:assemble
> Task :beam-runners-direct-java:analyzeClassesDependencies SKIPPED
> Task :beam-runners-direct-java:analyzeTestClassesDependencies SKIPPED
> Task :beam-runners-direct-java:analyzeDependencies SKIPPED
> Task :beam-runners-direct-java:checkstyleMain
> Task :beam-sdks-java-io-hadoop-common:test
> Task :beam-sdks-java-io-hadoop-common:spotbugsMain
> Task :beam-sdks-java-extensions-kryo:compileTestJava FROM-CACHE
> Task :beam-sdks-java-extensions-kryo:testClasses UP-TO-DATE
> Task :beam-sdks-java-extensions-kryo:packageTests
> Task :beam-sdks-java-extensions-kryo:assemble
> Task :beam-sdks-java-extensions-kryo:analyzeTestClassesDependencies SKIPPED
> Task :beam-sdks-java-extensions-kryo:analyzeDependencies SKIPPED
> Task :beam-sdks-java-extensions-kryo:checkstyleTest
> Task :beam-sdks-java-extensions-euphoria:compileTestJava FROM-CACHE
> Task :beam-sdks-java-extensions-euphoria:testClasses UP-TO-DATE
> Task :beam-sdks-java-extensions-euphoria:packageTests
> Task :beam-sdks-java-extensions-euphoria:assemble
> Task :beam-sdks-java-extensions-euphoria:analyzeTestClassesDependencies
> SKIPPED
> Task :beam-sdks-java-extensions-euphoria:analyzeDependencies SKIPPED
> Task :beam-runners-samza:spotbugsMain
> Task :beam-sdks-java-extensions-euphoria:checkstyleTest
> Task :beam-runners-direct-java:checkstyleTest
> Task :beam-sdks-java-harness:test
> Task :beam-sdks-java-core:test
> Task :beam-runners-flink-1.7:test
> Task :beam-sdks-java-harness:check
> Task :beam-sdks-java-harness:build
> Task
> :beam-sdks-java-io-hadoop-common:validateShadedJarDoesntLeakNonProjectClasses
> Task :beam-sdks-java-io-hadoop-common:check
> Task :beam-sdks-java-io-hadoop-common:build
> Task :beam-vendor-sdks-java-extensions-protobuf:test NO-SOURCE
> Task
> :beam-vendor-sdks-java-extensions-protobuf:validateShadedJarDoesntLeakNonProjectClasses
> Task :beam-vendor-sdks-java-extensions-protobuf:check
> Task :beam-vendor-sdks-java-extensions-protobuf:build
> Task :beam-sdks-java-extensions-kryo:test
> Task :beam-sdks-java-extensions-kryo:check
> Task :beam-sdks-java-extensions-kryo:build
> Task :beam-runners-direct-java:javadoc
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/ReferenceRunner.java>:119:
warning: no @return
public static ReferenceRunner forPipeline(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/ReferenceRunner.java>:168:
warning: no @throws for java.lang.Exception
public void execute() throws Exception {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/Clock.java>:28:
warning: no @return
Instant now();
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java>:135:
warning: no @param for options
public static DirectRunner fromOptions(PipelineOptions options) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java>:135:
warning: no @return
public static DirectRunner fromOptions(PipelineOptions options) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:841:
warning: no @param for <ExecutableT>
WatermarkManager<ExecutableT, ? super CollectionT> create(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:841:
warning: no @param for <CollectionT>
WatermarkManager<ExecutableT, ? super CollectionT> create(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:841:
warning: no @return
WatermarkManager<ExecutableT, ? super CollectionT> create(
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:941:
warning: no @param for executable
public TransformWatermarks getWatermarks(ExecutableT executable) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1140:
warning: no @return
public Collection<FiredTimers<ExecutableT>> extractFiredTimers() {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1575:
warning: no @return
public Collection<TimerData> getTimers() {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1408:
warning: no @return
public static TimerUpdate empty() {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1417:
warning: no @param for key
public static TimerUpdateBuilder builder(StructuralKey<?> key) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1417:
warning: no @return
public static TimerUpdateBuilder builder(StructuralKey<?> key) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1518:
warning: no @param for completedTimers
public TimerUpdate withCompletedTimers(Iterable<TimerData> completedTimers)
{
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1518:
warning: no @return
public TimerUpdate withCompletedTimers(Iterable<TimerData> completedTimers)
{
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1441:
warning: no @param for completedTimers
public TimerUpdateBuilder withCompletedTimers(Iterable<TimerData>
completedTimers) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1441:
warning: no @return
public TimerUpdateBuilder withCompletedTimers(Iterable<TimerData>
completedTimers) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1450:
warning: no @param for setTimer
public TimerUpdateBuilder setTimer(TimerData setTimer) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1450:
warning: no @return
public TimerUpdateBuilder setTimer(TimerData setTimer) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1465:
warning: no @param for deletedTimer
public TimerUpdateBuilder deletedTimer(TimerData deletedTimer) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1465:
warning: no @return
public TimerUpdateBuilder deletedTimer(TimerData deletedTimer) {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1475:
warning: no @return
public TimerUpdate build() {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1282:
warning: no @return
public Instant getInputWatermark() {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1287:
warning: no @return
public Instant getOutputWatermark() {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1297:
warning: no @return
public synchronized Instant getSynchronizedProcessingInputTime() {
^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java>:1311:
warning: no @return
public synchronized Instant getSynchronizedProcessingOutputTime() {
^
27 warnings
> Task :beam-sdks-java-javadoc:allJavadoc
> Task :beam-sdks-java-core:spotbugsMain
The following classes needed for analysis were missing:
com.google.auto.value.AutoValue$Builder
com.google.auto.value.AutoValue
> Task :beam-runners-samza:test
> Task :beam-sdks-java-extensions-euphoria:test
> Task :beam-sdks-java-io-redis:check
> Task :beam-sdks-java-io-redis:build
> Task :beam-sdks-java-io-redis:buildDependents
> Task :beam-runners-direct-java:spotbugsMain
The following classes needed for analysis were missing:
com.google.auto.value.AutoValue$Builder
com.google.auto.value.AutoValue
> Task :beam-sdks-java-extensions-sql-jdbc:shadowJarTest
> Task :beam-runners-direct-java:test
> Task :beam-sdks-java-extensions-sql-jdbc:preCommit
> Task :beam-runners-samza:shadowJar
> Task :beam-runners-samza:validateShadedJarDoesntLeakNonProjectClasses
> Task :beam-runners-samza:check
> Task :beam-runners-samza:build
> Task :beam-runners-samza:buildDependents
> Task :beam-sdks-java-extensions-euphoria:check
> Task :beam-sdks-java-extensions-euphoria:build
> Task :beam-sdks-java-extensions-euphoria:buildDependents
> Task :beam-sdks-java-extensions-kryo:buildDependents
> Task :beam-runners-direct-java:validateShadedJarDoesntLeakNonProjectClasses
> Task :beam-runners-direct-java:check
> Task :beam-runners-direct-java:build
> Task :beam-sdks-java-core:validateShadedJarDoesntLeakNonProjectClasses
> Task :beam-sdks-java-core:check
> Task :beam-sdks-java-core:build
> Task :beam-sdks-java-core:buildNeeded
> Task :beam-sdks-java-io-hbase:check
> Task :beam-sdks-java-io-hbase:build
> Task :beam-sdks-java-io-hbase:buildDependents
> Task :beam-sdks-java-io-hadoop-common:buildDependents
> Task :beam-sdks-java-io-common:buildDependents
> Task :beam-runners-flink-1.7:check
> Task :beam-runners-flink-1.7:build
> Task :beam-runners-flink-1.7:buildDependents
> Task :beam-sdks-java-nexmark:shadowJar
> Task :beam-sdks-java-nexmark:validateShadedJarDoesntLeakNonProjectClasses
> Task :beam-sdks-java-nexmark:check
> Task :beam-sdks-java-nexmark:build
> Task :beam-sdks-java-nexmark:buildDependents
> Task :beam-sdks-java-extensions-sql:buildDependents
> Task :beam-sdks-java-extensions-join-library:buildDependents
> Task :beam-sdks-java-io-kafka:buildDependents
> Task :beam-sdks-java-test-utils:buildDependents
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11:test'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/flink/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --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 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 19m 37s
916 actionable tasks: 794 executed, 122 from cache
Publishing build scan...
https://gradle.com/s/uaddxpdkmh3ee
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
