See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/27/display/redirect?page=changes>

Changes:

[nosacky] Fix up-to-date checking mechanism on Tox Task.

[noreply] [BEAM-10481] Ensure registration of the accumulator occurs. (#12850)


------------------------------------------
[...truncated 5.84 MB...]
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
        at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
        at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
        at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
        at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
        at akka.actor.ActorCell.invoke(ActorCell.scala:561)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
        at akka.dispatch.Mailbox.run(Mailbox.scala:225)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
        ... 4 more
Caused by: java.lang.RuntimeException: Failed to finish remote bundle
        at 
org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator$SdkHarnessDoFnRunner.finishBundle(ExecutableStageDoFnOperator.java:770)
        at 
org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate.finishBundle(DoFnRunnerWithMetricsUpdate.java:89)
        at 
org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.finishBundle(SimplePushbackSideInputDoFnRunner.java:124)
        at 
org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.invokeFinishBundle(DoFnOperator.java:878)
        at 
org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator.close(ExecutableStageDoFnOperator.java:490)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:618)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$afterInvoke$1(StreamTask.java:498)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:496)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:477)
        at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:708)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:533)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.ExecutionException: java.lang.RuntimeException: 
Error received from SDK harness for instruction 5: Traceback (most recent call 
last):
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 265, in _execute
    response = task()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 310, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 543, in do_instruction
    getattr(request, request_type), request.instruction_id)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 578, in process_bundle
    bundle_processor.process_bundle(instruction_id))
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,>
 line 985, in process_bundle
    element.data)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,>
 line 221, in process_encoded
    self.output(decoded_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 356, in output
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 218, in receive
    self.consumer.process(windowed_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 819, in process
    o)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 1224, in process_with_sized_restriction
    watermark_estimator_state=estimator_state)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 723, in invoke_process
    windowed_value, additional_args, additional_kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 872, in _invoke_process_per_window
    self.threadsafe_restriction_tracker.check_done()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/sdf_utils.py";,>
 line 115, in check_done
    return self._restriction_tracker.check_done()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/io/restriction_trackers.py";,>
 line 106, in check_done
    self._range.stop))
ValueError: OffsetRestrictionTracker is not done since work in range [0, 3) has 
not been claimed.

        at 
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
        at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
        at org.apache.beam.sdk.util.MoreFutures.get(MoreFutures.java:57)
        at 
org.apache.beam.runners.fnexecution.control.SdkHarnessClient$BundleProcessor$ActiveBundle.close(SdkHarnessClient.java:493)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory$1.close(DefaultJobBundleFactory.java:547)
        at 
org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator$SdkHarnessDoFnRunner.finishBundle(ExecutableStageDoFnOperator.java:764)
        ... 12 more
Caused by: java.lang.RuntimeException: Error received from SDK harness for 
instruction 5: Traceback (most recent call last):
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 265, in _execute
    response = task()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 310, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 543, in do_instruction
    getattr(request, request_type), request.instruction_id)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 578, in process_bundle
    bundle_processor.process_bundle(instruction_id))
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,>
 line 985, in process_bundle
    element.data)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,>
 line 221, in process_encoded
    self.output(decoded_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 356, in output
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 218, in receive
    self.consumer.process(windowed_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 819, in process
    o)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 1224, in process_with_sized_restriction
    watermark_estimator_state=estimator_state)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 723, in invoke_process
    windowed_value, additional_args, additional_kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 872, in _invoke_process_per_window
    self.threadsafe_restriction_tracker.check_done()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/sdf_utils.py";,>
 line 115, in check_done
    return self._restriction_tracker.check_done()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/io/restriction_trackers.py";,>
 line 106, in check_done
    self._range.stop))
ValueError: OffsetRestrictionTracker is not done since work in range [0, 3) has 
not been claimed.

        at 
org.apache.beam.runners.fnexecution.control.FnApiControlClient$ResponseStreamObserver.onNext(FnApiControlClient.java:177)
        at 
org.apache.beam.runners.fnexecution.control.FnApiControlClient$ResponseStreamObserver.onNext(FnApiControlClient.java:157)
        at 
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onMessage(ServerCalls.java:251)
        at 
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.ForwardingServerCallListener.onMessage(ForwardingServerCallListener.java:33)
        at 
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.Contexts$ContextualizedServerCallListener.onMessage(Contexts.java:76)
        at 
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailableInternal(ServerCallImpl.java:309)
        at 
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:292)
        at 
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:782)
        at 
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
        at 
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        ... 1 more
ERROR:root:java.lang.RuntimeException: Error received from SDK harness for 
instruction 5: Traceback (most recent call last):
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 265, in _execute
    response = task()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 310, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 543, in do_instruction
    getattr(request, request_type), request.instruction_id)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 578, in process_bundle
    bundle_processor.process_bundle(instruction_id))
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,>
 line 985, in process_bundle
    element.data)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,>
 line 221, in process_encoded
    self.output(decoded_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 356, in output
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 218, in receive
    self.consumer.process(windowed_value)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 819, in process
    o)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 1224, in process_with_sized_restriction
    watermark_estimator_state=estimator_state)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 723, in invoke_process
    windowed_value, additional_args, additional_kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 872, in _invoke_process_per_window
    self.threadsafe_restriction_tracker.check_done()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/sdf_utils.py";,>
 line 115, in check_done
    return self._restriction_tracker.check_done()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/io/restriction_trackers.py";,>
 line 106, in check_done
    self._range.stop))
ValueError: OffsetRestrictionTracker is not done since work in range [0, 3) has 
not been claimed.

INFO:apache_beam.runners.portability.portable_runner:Job state changed to FAILED
.sssssINFO:apache_beam.runners.worker.worker_pool_main:Listening for workers at 
localhost:43679
WARNING:root:Make sure that locally built Python SDK docker image has Python 
3.6 interpreter.
INFO:root:Using Python SDK docker image: apache/beam_python3.6_sdk:2.26.0.dev. 
If the image is not available at local, we will try to pull from hub.docker.com
INFO:apache_beam.runners.portability.portable_runner:Environment "LOOPBACK" has 
started a component necessary for the execution. Be sure to run the pipeline 
using
  with Pipeline() as p:
    p.apply(..)
This ensures that the pipeline finishes before this program exits.
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
RUNNING
[flink-runner-job-invoker] WARN 
org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment 
variable 'log.file' is not set.
[flink-runner-job-invoker] WARN 
org.apache.flink.runtime.webmonitor.WebMonitorUtils - JobManager log files are 
unavailable in the web dashboard. Log file location not found in environment 
variable 'log.file' or configuration key 'Key: 'web.log.path' , default: null 
(fallback keys: [{key=jobmanager.web.log.path, isDeprecated=true}])'.
[[4]{Create, Map(<lambda at fn_runner_test.py:487>), WindowInto(WindowIntoFn), 
Map(<lambda at fn_runner_test.py:490>)} (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - The operator name [4]{Create, 
Map(<lambda at fn_runner_test.py:487>), WindowInto(WindowIntoFn), Map(<lambda 
at fn_runner_test.py:490>)} exceeded the 80 characters length limit and was 
truncated.
[[4]{Create, Map(<lambda at fn_runner_test.py:487>), WindowInto(WindowIntoFn), 
Map(<lambda at fn_runner_test.py:490>)} (2/2)] WARN 
org.apache.flink.metrics.MetricGroup - The operator name [4]{Create, 
Map(<lambda at fn_runner_test.py:487>), WindowInto(WindowIntoFn), Map(<lambda 
at fn_runner_test.py:490>)} exceeded the 80 characters length limit and was 
truncated.
INFO:apache_beam.runners.worker.statecache:Creating state cache with size 0
INFO:apache_beam.runners.worker.sdk_worker:Creating insecure control channel 
for localhost:34333.
INFO:apache_beam.runners.worker.sdk_worker:Control channel established.
INFO:apache_beam.runners.worker.sdk_worker:Initializing SDKHarness with 
unbounded number of workers.
INFO:apache_beam.runners.worker.sdk_worker:Creating insecure state channel for 
localhost:39163.
INFO:apache_beam.runners.worker.sdk_worker:State channel established.
INFO:apache_beam.runners.worker.data_plane:Creating client data channel for 
localhost:35179
INFO:apache_beam.runners.worker.sdk_worker:No more requests from control plane
INFO:apache_beam.runners.worker.sdk_worker:SDK Harness waiting for in-flight 
requests to complete
INFO:apache_beam.runners.worker.data_plane:Closing all cached grpc data 
channels.
INFO:apache_beam.runners.worker.sdk_worker:Closing all cached gRPC state 
handlers.
[assert_that/Group/GroupByKey -> [3]assert_that/{Group, Unkey, Match} (1/2)] 
WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for 
unknown endpoint.
INFO:apache_beam.runners.worker.sdk_worker:Done consuming work.
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
.INFO:apache_beam.runners.worker.worker_pool_main:Listening for workers at 
localhost:33077
WARNING:root:Make sure that locally built Python SDK docker image has Python 
3.6 interpreter.
INFO:root:Using Python SDK docker image: apache/beam_python3.6_sdk:2.26.0.dev. 
If the image is not available at local, we will try to pull from hub.docker.com
INFO:apache_beam.runners.portability.portable_runner:Environment "LOOPBACK" has 
started a component necessary for the execution. Be sure to run the pipeline 
using
  with Pipeline() as p:
    p.apply(..)
This ensures that the pipeline finishes before this program exits.
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to 
RUNNING
[flink-runner-job-invoker] WARN 
org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment 
variable 'log.file' is not set.
[flink-runner-job-invoker] WARN 
org.apache.flink.runtime.webmonitor.WebMonitorUtils - JobManager log files are 
unavailable in the web dashboard. Log file location not found in environment 
variable 'log.file' or configuration key 'Key: 'web.log.path' , default: null 
(fallback keys: [{key=jobmanager.web.log.path, isDeprecated=true}])'.
INFO:apache_beam.runners.worker.statecache:Creating state cache with size 0
INFO:apache_beam.runners.worker.sdk_worker:Creating insecure control channel 
for localhost:33801.
INFO:apache_beam.runners.worker.sdk_worker:Control channel established.
INFO:apache_beam.runners.worker.sdk_worker:Initializing SDKHarness with 
unbounded number of workers.
INFO:apache_beam.runners.worker.sdk_worker:Creating insecure state channel for 
localhost:34593.
INFO:apache_beam.runners.worker.sdk_worker:State channel established.
INFO:apache_beam.runners.worker.data_plane:Creating client data channel for 
localhost:43889
INFO:apache_beam.runners.worker.sdk_worker:No more requests from control plane
INFO:apache_beam.runners.worker.sdk_worker:SDK Harness waiting for in-flight 
requests to complete
INFO:apache_beam.runners.worker.data_plane:Closing all cached grpc data 
channels.
INFO:apache_beam.runners.worker.sdk_worker:Closing all cached gRPC state 
handlers.
[grpc-default-executor-0] WARN 
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown 
endpoint.
INFO:apache_beam.runners.worker.sdk_worker:Done consuming work.
[assert_that/Group/GroupByKey -> [3]assert_that/{Group, Unkey, Match} (1/2)] 
WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for 
unknown endpoint.
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
.INFO:__main__:removing conf dir: /tmp/flinktest-confvz_jupyj

----------------------------------------------------------------------
Ran 100 tests in 534.177s

OK (skipped=26)

> Task :sdks:python:test-suites:portable:py36:flinkCompatibilityMatrixLoopback
> Task :sdks:python:test-suites:portable:py36:flinkValidatesRunner

FAILURE: Build completed with 2 failures.

1: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 57

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py38:flinkCompatibilityMatrixBatchLOOPBACK'.
> initialize must be called for meta class of class 
> common_8qvspnsohzqmnmy6ymzqq5pfa$_run_closure1$_closure17$_closure18(class 
> org.codehaus.groovy.runtime.metaclass.ClosureMetaClass) to complete 
> initialisation process before any invocation or field/property access can be 
> done

* 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.
==============================================================================

2: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 57

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py37:flinkCompatibilityMatrixBatchLOOPBACK'.
> initialize must be called for meta class of class 
> common_8qvspnsohzqmnmy6ymzqq5pfa$_run_closure1$_closure17$_closure18(class 
> org.codehaus.groovy.runtime.metaclass.ClosureMetaClass) to complete 
> initialisation process before any invocation or field/property access can be 
> done

* 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See 
https://docs.gradle.org/6.6.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 31m 40s
122 actionable tasks: 84 executed, 36 from cache, 2 up-to-date

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

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]

Reply via email to