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

Changes:

[lukasz.gajowy] apply spotless on master

[nielm] Add test case for BEAM-6407

[nielm] Revert "BEAM-5933: avoid memory allocation in hashCode call"

[33895511+aromanenko-dev] [BEAM-6334] Add throwing exception in case of invalid 
state or timeout

------------------------------------------
[...truncated 772.32 KB...]
                       ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java>:134:
 warning: no @return
  public ProtoCoder<T> withExtensionsFrom(Iterable<Class<?>> 
moreExtensionHosts) {
                       ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java>:163:
 warning: no @param for moreExtensionHosts
  public ProtoCoder<T> withExtensionsFrom(Class<?>... moreExtensionHosts) {
                       ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java>:163:
 warning: no @return
  public ProtoCoder<T> withExtensionsFrom(Class<?>... moreExtensionHosts) {
                       ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java>:223:
 warning: no @return
  public Class<T> getMessageType() {
                  ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java>:235:
 warning: no @return
  public ExtensionRegistry getExtensionRegistry() {
                           ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java>:300:
 warning: no @return
  public static CoderProvider getCoderProvider() {
                              ^
13 warnings

> Task :beam-sdks-java-io-hadoop-common:test
> 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-sdks-java-io-hadoop-common:buildDependents
> Task :beam-sdks-java-extensions-protobuf:test
> Task 
> :beam-sdks-java-extensions-protobuf:validateShadedJarDoesntLeakNonProjectClasses
> Task :beam-sdks-java-extensions-protobuf:check
> Task :beam-sdks-java-extensions-protobuf:build
> Task :beam-sdks-java-fn-execution:findbugsMain

> Task :beam-sdks-java-fn-execution:javadoc
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java>:51:
 warning: no @param for bytes
  public static InputStream inbound(Iterator<ByteString> bytes) {
                            ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java>:51:
 warning: no @return
  public static InputStream inbound(Iterator<ByteString> bytes) {
                            ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java>:65:
 warning: no @param for consumer
  public static ElementDelimitedOutputStream 
outbound(OutputChunkConsumer<ByteString> consumer) {
                                             ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java>:65:
 warning: no @return
  public static ElementDelimitedOutputStream 
outbound(OutputChunkConsumer<ByteString> consumer) {
                                             ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java>:79:
 warning: no @param for consumer
  public static ElementDelimitedOutputStream outbound(
                                             ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java>:79:
 warning: no @param for maximumChunkSize
  public static ElementDelimitedOutputStream outbound(
                                             ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java>:79:
 warning: no @return
  public static ElementDelimitedOutputStream outbound(
                                             ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:33:
 warning: no @param for executorService
  public static OutboundObserverFactory clientBuffered(ExecutorService 
executorService) {
                                        ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:33:
 warning: no @return
  public static OutboundObserverFactory clientBuffered(ExecutorService 
executorService) {
                                        ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:41:
 warning: no @param for executorService
  public static OutboundObserverFactory clientBuffered(
                                        ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:41:
 warning: no @param for bufferSize
  public static OutboundObserverFactory clientBuffered(
                                        ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:41:
 warning: no @return
  public static OutboundObserverFactory clientBuffered(
                                        ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:51:
 warning: no @return
  public static OutboundObserverFactory clientDirect() {
                                        ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:56:
 warning: no @return
  public static OutboundObserverFactory serverDirect() {
                                        ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:64:
 warning: no @return
  public static OutboundObserverFactory trivial() {
                                        ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:82:
 warning: no @param for <ReqT>
  public abstract <ReqT, RespT> StreamObserver<RespT> outboundObserverFor(
                                                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:82:
 warning: no @param for <RespT>
  public abstract <ReqT, RespT> StreamObserver<RespT> outboundObserverFor(
                                                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java>:82:
 warning: no @return
  public abstract <ReqT, RespT> StreamObserver<RespT> outboundObserverFor(
                                                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/SynchronizedStreamObserver.java>:39:
 warning: no @param for <V>
  public static <V> StreamObserver<V> wrapping(StreamObserver<V> underlying) {
                                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/SynchronizedStreamObserver.java>:39:
 warning: no @param for underlying
  public static <V> StreamObserver<V> wrapping(StreamObserver<V> underlying) {
                                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/SynchronizedStreamObserver.java>:39:
 warning: no @return
  public static <V> StreamObserver<V> wrapping(StreamObserver<V> underlying) {
                                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/IdGenerators.java>:26:
 warning: no @return
  public static IdGenerator incrementingLongs() {
                            ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/IdGenerators.java>:32:
 warning: no @return
  public static IdGenerator decrementingLongs() {
                            ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/CloseableFnDataReceiver.java>:32:
 warning: no description for @throws
   * @throws Exception
     ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/InboundDataClient.java>:39:
 warning: no @return
  boolean isDone();
          ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/CompletableFutureInboundDataClient.java>:28:
 warning: no @return
  public static InboundDataClient create() {
                                  ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortWrite.java>:43:
 warning: no @param for inputPCollectionId
  public static RemoteGrpcPortWrite writeToPort(String inputPCollectionId, 
RemoteGrpcPort port) {
                                    ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortWrite.java>:43:
 warning: no @param for port
  public static RemoteGrpcPortWrite writeToPort(String inputPCollectionId, 
RemoteGrpcPort port) {
                                    ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortWrite.java>:43:
 warning: no @return
  public static RemoteGrpcPortWrite writeToPort(String inputPCollectionId, 
RemoteGrpcPort port) {
                                    ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/ManagedChannelFactory.java>:48:
 warning: no @param for descriptor
  protected abstract ManagedChannelBuilder<?> builderFor(ApiServiceDescriptor 
descriptor);
                                              ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/ManagedChannelFactory.java>:48:
 warning: no @return
  protected abstract ManagedChannelBuilder<?> builderFor(ApiServiceDescriptor 
descriptor);
                                              ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/ManagedChannelFactory.java>:54:
 warning: no @param for interceptors
  public ManagedChannelFactory withInterceptors(List<ClientInterceptor> 
interceptors) {
                               ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/ManagedChannelFactory.java>:54:
 warning: no @return
  public ManagedChannelFactory withInterceptors(List<ClientInterceptor> 
interceptors) {
                               ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:31:
 warning: no @param for <T>
  public static <T> Builder<T> withOnNext(Consumer<T> onNext) {
                               ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:31:
 warning: no @param for onNext
  public static <T> Builder<T> withOnNext(Consumer<T> onNext) {
                               ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:31:
 warning: no @return
  public static <T> Builder<T> withOnNext(Consumer<T> onNext) {
                               ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:52:
 warning: no @param for isReady
    public Builder<T> withIsReady(Supplier<Boolean> isReady) {
                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:52:
 warning: no @return
    public Builder<T> withIsReady(Supplier<Boolean> isReady) {
                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:62:
 warning: no @param for onCompleted
    public Builder<T> withOnCompleted(Runnable onCompleted) {
                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:62:
 warning: no @return
    public Builder<T> withOnCompleted(Runnable onCompleted) {
                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:72:
 warning: no @param for onError
    public Builder<T> withOnError(final Runnable onError) {
                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:72:
 warning: no @return
    public Builder<T> withOnError(final Runnable onError) {
                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:82:
 warning: no @param for onError
    public Builder<T> withOnError(Consumer<Throwable> onError) {
                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java>:82:
 warning: no @return
    public Builder<T> withOnError(Consumer<Throwable> onError) {
                      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/SocketAddressFactory.java>:34:
 warning: no @param for value
  public static SocketAddress createFrom(String value) {
                              ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/SocketAddressFactory.java>:34:
 warning: no @return
  public static SocketAddress createFrom(String value) {
                              ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:126:
 warning: no @param for <RestrictionT>
  public static <RestrictionT, PositionT> RestrictionTracker<RestrictionT, 
PositionT> observe(
                                                                                
      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:126:
 warning: no @param for <PositionT>
  public static <RestrictionT, PositionT> RestrictionTracker<RestrictionT, 
PositionT> observe(
                                                                                
      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:126:
 warning: no @param for restrictionTracker
  public static <RestrictionT, PositionT> RestrictionTracker<RestrictionT, 
PositionT> observe(
                                                                                
      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:126:
 warning: no @param for claimObserver
  public static <RestrictionT, PositionT> RestrictionTracker<RestrictionT, 
PositionT> observe(
                                                                                
      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:126:
 warning: no @return
  public static <RestrictionT, PositionT> RestrictionTracker<RestrictionT, 
PositionT> observe(
                                                                                
      ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:31:
 warning: no @param for position
    void onClaimed(PositionT position);
         ^
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java>:34:
 warning: no @param for position
    void onClaimFailed(PositionT position);
         ^
53 warnings

> Task :beam-sdks-java-javadoc:allJavadoc
> Task :beam-sdks-java-harness:test
> Task :beam-sdks-java-harness:check
> Task :beam-sdks-java-harness: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-runners-samza:test
> 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-fn-execution:test
> Task :beam-sdks-java-fn-execution:validateShadedJarDoesntLeakNonProjectClasses
> Task :beam-sdks-java-fn-execution:check
> Task :beam-sdks-java-fn-execution:build
> 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-kafka:buildDependents
> Task :beam-sdks-java-io-google-cloud-platform:buildDependents
> Task :beam-sdks-java-test-utils:buildDependents
> Task :beam-sdks-java-extensions-protobuf:buildDependents
> Task :beam-sdks-java-extensions-join-library:buildDependents
> Task :beam-runners-direct-java:buildDependents
> Task :beam-runners-local-java-core:buildDependents

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 17m 26s
911 actionable tasks: 897 executed, 14 from cache

Publishing build scan...
https://gradle.com/s/dhfyzhjepncdw

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

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

Reply via email to