See <https://builds.apache.org/job/beam_PreCommit_Java_Cron/889/display/redirect?page=changes>
Changes: [mxm] [BEAM-6230] Clarify Flink version support on Flink Runner page [mxm] [website] Update list of FlinkPipelineOptions on FlinkRunner page [mxm] [website] Add switch for Java/Python options [iemejia] [BEAM-3667] Make embedded MongoDB instance per class and test code more [michal.walenia] [BEAM-6207] Added option to publish synthetic data to Kafka topic. [michal.walenia] [BEAM-6207] Added option to publish synthetic data to Kafka topic. [mxm] [website] Add note about the dashboard for embedded Flink clusters ------------------------------------------ [...truncated 665.26 KB...] <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:146: warning: no @return public abstract T decode(InputStream inStream) throws CoderException, IOException; ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:158: warning: no @param for inStream public T decode(InputStream inStream, Context context) throws CoderException, IOException { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:158: warning: no @param for context public T decode(InputStream inStream, Context context) throws CoderException, IOException { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:158: warning: no @return public T decode(InputStream inStream, Context context) throws CoderException, IOException { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:168: warning: no @return public abstract List<? extends Coder<?>> getCoderArguments(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:190: warning: no @param for target public static void verifyDeterministic(Coder<?> target, String message, Iterable<Coder<?>> coders) ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:190: warning: no @param for message public static void verifyDeterministic(Coder<?> target, String message, Iterable<Coder<?>> coders) ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:190: warning: no @param for coders public static void verifyDeterministic(Coder<?> target, String message, Iterable<Coder<?>> coders) ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:190: warning: no @throws for org.apache.beam.sdk.coders.Coder.NonDeterministicException public static void verifyDeterministic(Coder<?> target, String message, Iterable<Coder<?>> coders) ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:205: warning: no @param for target public static void verifyDeterministic(Coder<?> target, String message, Coder<?>... coders) ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:205: warning: no @param for message public static void verifyDeterministic(Coder<?> target, String message, Coder<?>... coders) ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:205: warning: no @param for coders public static void verifyDeterministic(Coder<?> target, String message, Coder<?>... coders) ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:205: warning: no @throws for org.apache.beam.sdk.coders.Coder.NonDeterministicException public static void verifyDeterministic(Coder<?> target, String message, Coder<?>... coders) ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:222: warning: no @return public boolean consistentWithEquals() { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:249: warning: no @param for value public Object structuralValue(T value) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:249: warning: no @return public Object structuralValue(T value) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:276: warning: no @param for value public boolean isRegisterByteSizeObserverCheap(T value) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:276: warning: no @return public boolean isRegisterByteSizeObserverCheap(T value) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:290: warning: no @param for value public void registerByteSizeObserver(T value, ElementByteSizeObserver observer) throws Exception { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:290: warning: no @param for observer public void registerByteSizeObserver(T value, ElementByteSizeObserver observer) throws Exception { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:290: warning: no @throws for java.lang.Exception public void registerByteSizeObserver(T value, ElementByteSizeObserver observer) throws Exception { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:295: warning: no @param for value protected long getEncodedElementByteSize(T value) throws Exception { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:295: warning: no @return protected long getEncodedElementByteSize(T value) throws Exception { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:295: warning: no @throws for java.lang.Exception protected long getEncodedElementByteSize(T value) throws Exception { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java>:307: warning: no @return public TypeDescriptor<T> getEncodedTypeDescriptor() { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/MetadataCoderV2.java>:40: warning: no @return public static MetadataCoderV2 of() { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceId.java>:88: warning: no @param for other ResourceId resolve(String other, ResolveOptions resolveOptions); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceId.java>:88: warning: no @param for resolveOptions ResourceId resolve(String other, ResolveOptions resolveOptions); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceId.java>:88: warning: no @return ResourceId resolve(String other, ResolveOptions resolveOptions); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceId.java>:96: warning: no @return ResourceId getCurrentDirectory(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceId.java>:104: warning: no @return String getScheme(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceId.java>:117: warning: no @return boolean isDirectory(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceIdCoder.java>:35: warning: no @return public static ResourceIdCoder of() { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceIdTester.java>:42: warning: no @param for baseDirectory public static void runResourceIdBattery(ResourceId baseDirectory) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Counter.java>:31: warning: no @param for n void inc(long n); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metric.java>:29: warning: no @return MetricName getName(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricResult.java>:32: warning: no @return MetricName getName(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricResult.java>:35: warning: no @return String getStep(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricResult.java>:43: warning: no @return T getCommitted(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricResult.java>:46: warning: no @return T getAttempted(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Distribution.java>:27: warning: no @param for value void update(long value); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Gauge.java>:31: warning: no @param for value void set(long value); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricName.java>:38: warning: no @return public abstract String getNamespace(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricName.java>:46: warning: no @return public String namespace() { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricName.java>:51: warning: no @return public abstract String getName(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricName.java>:59: warning: no @return public String name() { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricNameFilter.java>:33: warning: no @return public abstract String getNamespace(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricNameFilter.java>:37: warning: no @return public abstract String getName(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricQueryResults.java>:31: warning: no @return public abstract Iterable<MetricResult<Long>> getCounters(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricQueryResults.java>:34: warning: no @return public abstract Iterable<MetricResult<DistributionResult>> getDistributions(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricQueryResults.java>:37: warning: no @return public abstract Iterable<MetricResult<GaugeResult>> getGauges(); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricResults.java>:62: warning: no @param for filter public abstract MetricQueryResults queryMetrics(@Nullable MetricsFilter filter); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricResults.java>:62: warning: no @return public abstract MetricQueryResults queryMetrics(@Nullable MetricsFilter filter); ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:64: warning: no @param for namespace public static Counter counter(String namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:64: warning: no @param for name public static Counter counter(String namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:64: warning: no @return public static Counter counter(String namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:71: warning: no @param for namespace public static Counter counter(Class<?> namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:71: warning: no @param for name public static Counter counter(Class<?> namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:71: warning: no @return public static Counter counter(Class<?> namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:76: warning: no @param for namespace public static Distribution distribution(String namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:76: warning: no @param for name public static Distribution distribution(String namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:76: warning: no @return public static Distribution distribution(String namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:81: warning: no @param for namespace public static Distribution distribution(Class<?> namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:81: warning: no @param for name public static Distribution distribution(Class<?> namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:81: warning: no @return public static Distribution distribution(Class<?> namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:89: warning: no @param for namespace public static Gauge gauge(String namespace, String name) { ^ <https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java>:89: warning: no @param for name public static Gauge gauge(String namespace, String name) { ^ > 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-io-google-cloud-platform:buildDependents > Task :beam-sdks-java-io-kafka:buildDependents > Task :beam-sdks-java-test-utils:buildDependents > Task :beam-sdks-java-extensions-join-library:buildDependents > Task :beam-sdks-java-extensions-protobuf:buildDependents > Task :beam-runners-direct-java:buildDependents > Task :beam-runners-local-java-core:buildDependents > Task :beam-sdks-java-core:javadoc 100 warnings > Task :beam-sdks-java-javadoc:allJavadoc > Task :beam-sdks-java-core:test > Task :beam-sdks-java-core:validateShadedJarDoesntLeakNonProjectClasses > Task :beam-sdks-java-core:check > Task :beam-sdks-java-core:build > Task :beam-sdks-java-core:buildNeeded FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':beam-runners-java-fn-execution:test'. > There were failing tests. See the report at: > file://<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/java-fn-execution/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 5.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/4.10.3/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 16m 27s 911 actionable tasks: 863 executed, 48 from cache Publishing build scan... https://gradle.com/s/nmg4cicvnpjlu 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]
