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

Changes:

[bvolpato] Fix pull_licenses_java returning 404 from opensource.org

[noreply] [#24789][prism] internal/jobservices metrics + tests (#25497)

[noreply] [Go SDK]: Allow SDF methods to have context param and error return 
value

[noreply] Move closing milestone out of PMC-only tasks (#25516)

[noreply] update GCP cloud libraries BOM to 26.8.0 (#25470)

[noreply] Fix interface{} in iter& emit type of DoFn in Go (#25203)

[noreply] Task #25064: Python SDK Data sampling implementation (#25093)

[noreply] Add support for all Java based portable runners to consume elements


------------------------------------------
[...truncated 1.18 MB...]
        at 
org.apache.beam.runners.fnexecution.control.FnApiControlClient$ResponseStreamObserver.onNext(FnApiControlClient.java:180)
        at 
org.apache.beam.runners.fnexecution.control.FnApiControlClient$ResponseStreamObserver.onNext(FnApiControlClient.java:160)
        at 
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onMessage(ServerCalls.java:262)
        at 
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.ForwardingServerCallListener.onMessage(ForwardingServerCallListener.java:33)
        at 
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.Contexts$ContextualizedServerCallListener.onMessage(Contexts.java:76)
        at 
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailableInternal(ServerCallImpl.java:332)
        at 
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:315)
        at 
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:834)
        at 
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
        at 
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        ... 1 more

Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager 
shutdown
INFO: Shutting down TaskExecutorStateChangelogStoragesManager.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.resourcemanager.ResourceManager 
closeTaskManagerConnection
INFO: Closing TaskExecutor connection 5c5c0898-3dd9-4607-a7bc-6c90cbfccec3 
because: The TaskExecutor is shutting down.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=512.000gb (549755813888 bytes), 
taskOffHeapMemory=512.000gb (549755813888 bytes), managedMemory=4.532gb 
(4866362368 bytes), networkMemory=32.000mb (33554432 bytes)}, allocationId: 
014dc25cfb8580f054199ad3276d8084, jobId: 4c18651a472c0a94d9c902dcef094944).
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl freeSlotInternal
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: 
ResourceProfile{taskHeapMemory=512.000gb (549755813888 bytes), 
taskOffHeapMemory=512.000gb (549755813888 bytes), managedMemory=4.532gb 
(4866362368 bytes), networkMemory=32.000mb (33554432 bytes)}, allocationId: 
acf973575e30991de2bb23405ba96212, jobId: 4c18651a472c0a94d9c902dcef094944).
------------------------------ Captured log call -------------------------------
ERROR    root:portable_runner.py:584 java.lang.RuntimeException: Error received 
from SDK harness for instruction 1: org.apache.beam.sdk.util.UserCodeException: 
java.lang.ClassCastException: 
org.apache.beam.sdk.io.CountingSource$BoundedCountingSource cannot be cast to 
org.apache.beam.sdk.values.KV
        at 
org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:39)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner.outputTo(FnApiDoFnRunner.java:1790)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner.access$3000(FnApiDoFnRunner.java:142)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner$NonWindowObservingProcessBundleContext.output(FnApiDoFnRunner.java:2380)
        at 
org.apache.beam.sdk.io.Read$BoundedSourceAsSDFWrapperFn.splitRestriction(Read.java:300)
        at 
org.apache.beam.sdk.io.Read$BoundedSourceAsSDFWrapperFn$DoFnInvoker.invokeSplitRestriction(Unknown
 Source)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForSplitRestriction(FnApiDoFnRunner.java:887)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:284)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:225)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner.outputTo(FnApiDoFnRunner.java:1788)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForPairWithRestriction(FnApiDoFnRunner.java:824)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:284)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:225)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner.outputTo(FnApiDoFnRunner.java:1788)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner.access$3000(FnApiDoFnRunner.java:142)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner$NonWindowObservingProcessBundleContext.output(FnApiDoFnRunner.java:2380)
        at 
org.apache.beam.sdk.io.Read$OutputSingleSource.processElement(Read.java:1018)
        at 
org.apache.beam.sdk.io.Read$OutputSingleSource$DoFnInvoker.invokeProcessElement(Unknown
 Source)
        at 
org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForParDo(FnApiDoFnRunner.java:799)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:284)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:225)
        at 
org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:213)
        at 
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.multiplexElements(BeamFnDataInboundObserver.java:158)
        at 
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:123)
        at 
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:544)
        at 
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
        at 
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at 
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.ClassCastException: 
org.apache.beam.sdk.io.CountingSource$BoundedCountingSource cannot be cast to 
org.apache.beam.sdk.values.KV
        at 
org.apache.beam.sdk.coders.KvCoder.registerByteSizeObserver(KvCoder.java:37)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$SampleByteSizeDistribution.tryUpdate(PCollectionConsumerRegistry.java:419)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:277)
        at 
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:225)
--------------------------- Captured stderr teardown ---------------------------
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool 
releaseSlots
INFO: Releasing slot [acf973575e30991de2bb23405ba96212].
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint 
lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool 
releaseSlots
INFO: Releasing slot [014dc25cfb8580f054199ad3276d8084].
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.rest.RestServerEndpoint 
lambda$closeAsync$1
INFO: Shut down complete.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.resourcemanager.ResourceManager deregisterApplication
INFO: Shut down cluster because application is in CANCELED, diagnostics 
DispatcherResourceManagerComponent has been closed..
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory 
/tmp/flink-io-0792a6f4-bc10-46c6-ab10-9f6b76aed124
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.jobmaster.JobMaster 
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 643ae564e82fee4737e6524d22c27a69: 
Stopping JobMaster for job 'test_external_transform_1676589088.3170254' 
(4c18651a472c0a94d9c902dcef094944).
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.io.network.NettyShuffleEnvironment close
INFO: Shutting down the network environment and its components.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
 closeAsyncInternal
INFO: Closing components.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess 
closeInternal
INFO: Stopping SessionDispatcherLeaderProcess.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl closeAsync
INFO: Stopping resource manager service.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0
INFO: FileChannelManager removed spill file directory 
/tmp/flink-netty-shuffle-3b2e90a0-0e22-4b99-aa18-7699cbb386c4
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.taskexecutor.KvStateService 
shutdown
INFO: Shutting down the kvState service and its components.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.resourcemanager.ResourceManager 
closeJobManagerConnection
INFO: Disconnect job manager 
b3c78d61a51395052f86795aa53548b8@akka://flink/user/rpc/jobmanager_67 for job 
4c18651a472c0a94d9c902dcef094944 from the resource manager.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop
INFO: Stop job leader service.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager 
close
INFO: Closing the slot manager.
Feb 16, 2023 11:11:56 PM 
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager 
suspend
INFO: Suspending the slot manager.
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.filecache.FileCache shutdown
INFO: removed file cache directory 
/tmp/flink-dist-cache-ded75e36-d6ab-4926-8026-8b00897d01a2
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.metrics.MetricRegistryImpl 
unregister
WARNING: Error while unregistering metric: RequestedMemoryUsage.
java.lang.ArithmeticException: / by zero
        at 
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.getRequestedSegmentsUsage(NetworkBufferPool.java:385)
        at 
org.apache.flink.runtime.io.network.metrics.NettyShuffleMetricFactory$RequestedMemoryUsageMetric.getValue(NettyShuffleMetricFactory.java:247)
        at 
org.apache.flink.runtime.io.network.metrics.NettyShuffleMetricFactory$RequestedMemoryUsageMetric.getValue(NettyShuffleMetricFactory.java:238)
        at 
org.apache.beam.runners.flink.metrics.Metrics.toString(Metrics.java:33)
        at 
org.apache.beam.runners.flink.metrics.FileReporter.notifyOfRemovedMetric(FileReporter.java:73)
        at 
org.apache.flink.runtime.metrics.MetricRegistryImpl.unregister(MetricRegistryImpl.java:436)
        at 
org.apache.flink.runtime.metrics.groups.AbstractMetricGroup.close(AbstractMetricGroup.java:333)
        at 
org.apache.flink.runtime.metrics.groups.AbstractMetricGroup.close(AbstractMetricGroup.java:327)
        at 
org.apache.flink.runtime.metrics.groups.AbstractMetricGroup.close(AbstractMetricGroup.java:327)
        at 
org.apache.flink.runtime.metrics.groups.AbstractMetricGroup.close(AbstractMetricGroup.java:327)
        at 
org.apache.flink.runtime.metrics.groups.ComponentMetricGroup.close(ComponentMetricGroup.java:62)
        at 
org.apache.flink.runtime.taskexecutor.TaskExecutor.stopTaskExecutorServices(TaskExecutor.java:537)
        at 
org.apache.flink.util.concurrent.FutureUtils.lambda$runAfterwardsAsync$18(FutureUtils.java:696)
        at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
        at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
        at 
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
        at 
org.apache.flink.util.concurrent.DirectExecutorService.execute(DirectExecutorService.java:217)
        at 
java.util.concurrent.CompletableFuture$UniCompletion.claim(CompletableFuture.java:543)
        at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:765)
        at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
        at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
        at 
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389)
        at 
org.apache.flink.util.concurrent.FutureUtils.lambda$forwardTo$24(FutureUtils.java:1372)
        at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
        at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
        at 
java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
        at 
java.util.concurrent.CompletableFuture$UniRun.tryFire(CompletableFuture.java:704)
        at 
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
        at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:443)
        at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
        at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:443)
        at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213)
        at 
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
        at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
        at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
        at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
        at akka.actor.Actor.aroundReceive(Actor.scala:537)
        at akka.actor.Actor.aroundReceive$(Actor.scala:535)
        at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
        at akka.actor.ActorCell.invoke(ActorCell.scala:548)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
        at akka.dispatch.Mailbox.run(Mailbox.scala:231)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
        at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
        at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
        at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
        at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)

Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
handleOnStopException
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_64.
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_66.
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.dispatcher.Dispatcher 
terminateRunningJobs
INFO: Stopping all currently running jobs of dispatcher 
akka://flink/user/rpc/dispatcher_66.
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.dispatcher.Dispatcher 
lambda$onStop$1
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_66.
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
stopService
INFO: Stopping Akka RPC service.
Feb 16, 2023 11:11:56 PM org.apache.beam.runners.flink.metrics.FileReporter 
close
INFO: wrote metrics to 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/test-suites/portable/py37/build/srcs/sdks/python/target/.tox-flink-runner-test/flink-runner-test/tmp/flinktest-conf16wqtrmz/test-metrics.txt>
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
stopService
INFO: Stopping Akka RPC service.
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
lambda$stopService$8
INFO: Stopped Akka RPC service.
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:40289
Feb 16, 2023 11:11:56 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
lambda$stopService$8
INFO: Stopped Akka RPC service.
=============================== warnings summary ===============================
target/.tox-flink-runner-test/flink-runner-test/lib/python3.7/site-packages/hdfs/config.py:15
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/test-suites/portable/py37/build/srcs/sdks/python/target/.tox-flink-runner-test/flink-runner-test/lib/python3.7/site-packages/hdfs/config.py>:15:
 DeprecationWarning: the imp module is deprecated in favour of importlib; see 
the module's documentation for alternative uses
    from imp import load_source

-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
- generated xml file: 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/test-suites/portable/py37/build/srcs/sdks/python/pytest_flink-runner-test.xml>
 -
=========================== short test summary info ============================
FAILED 
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTest::test_external_transform
FAILED 
apache_beam/runners/portability/flink_runner_test.py::FlinkRunnerTestStreaming::test_external_transform
======= 2 failed, 159 passed, 46 skipped, 1 warning in 906.65s (0:15:06) =======
ERROR: InvocationError for command 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/test-suites/portable/py37/build/srcs/sdks/python/scripts/pytest_validates_runner.sh>
 flink-runner-test apache_beam/runners/portability/flink_runner_test.py 
'--flink_job_server_jar=<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/runners/flink/1.15/job-server/build/libs/beam-runners-flink-1.15-job-server-2.46.0-SNAPSHOT.jar>
 --environment_type=LOOPBACK' (exited with code 1)
flink-runner-test run-test-post: commands[0] | bash 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/test-suites/portable/py37/build/srcs/sdks/python/scripts/run_tox_cleanup.sh>
___________________________________ summary 
____________________________________
ERROR:   flink-runner-test: commands failed

> Task :sdks:python:test-suites:portable:py37:flinkCompatibilityMatrixLOOPBACK 
> FAILED

FAILURE: Build completed with 2 failures.

1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py310:flinkCompatibilityMatrixLOOPBACK'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
==============================================================================

2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py37:flinkCompatibilityMatrixLOOPBACK'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
==============================================================================

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 8.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

See 
https://docs.gradle.org/7.5.1/userguide/command_line_interface.html#sec:command_line_warnings

Execution optimizations have been disabled for 1 invalid unit(s) of work during 
this build to ensure correctness.
Please consult deprecation warnings for more details.

BUILD FAILED in 48m 46s
150 actionable tasks: 122 executed, 24 from cache, 4 up-to-date

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

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