See
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/6254/display/redirect?page=changes>
Changes:
[nflavour] Initial commit of boilerplate setup of change stream pipeline for
[ahmedabualsaud] Fix SchemaTransform identifiers
[noreply] Update chromedriver-binary requirement in /sdks/python (#25178)
[noreply] Bump google.golang.org/grpc from 1.52.0 to 1.52.3 in /sdks (#25181)
------------------------------------------
[...truncated 1.24 GB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 23 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 62 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 3 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 95 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 51 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 12 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 49 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 57 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 63 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 25 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 97 for
PTransform{id=external_1Write-to-Spanner-SpannerIO-Write-Write-mutations-to-Cloud-Spanner-Read-information-schema-ParMultiDo,
name=Write to Spanner/SpannerIO.Write/Write mutations to Cloud Spanner/Read
information schema/ParMultiDo(ReadSpannerSchema), state=process} for at least
22m40s without outputting or completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$GrpcStreamIterator.computeNext(AbstractResultSet.java:881)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$GrpcStreamIterator.computeNext(AbstractResultSet.java:826)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$ResumableStreamIterator.computeNext(AbstractResultSet.java:1077)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$ResumableStreamIterator.computeNext(AbstractResultSet.java:949)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$GrpcValueIterator.ensureReady(AbstractResultSet.java:276)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$GrpcValueIterator.getMetadata(AbstractResultSet.java:252)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$GrpcResultSet.next(AbstractResultSet.java:120)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.ForwardingResultSet.next(ForwardingResultSet.java:55)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.SessionPool$AutoClosingReadContext$1.internalNext(SessionPool.java:273)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.SessionPool$AutoClosingReadContext$1.next(SessionPool.java:253)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.io.gcp.spanner.ReadSpannerSchema.processElement(ReadSpannerSchema.java:66)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.io.gcp.spanner.ReadSpannerSchema$DoFnInvoker.invokeProcessElement(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnApiDoFnRunner.processElementForWindowObservingParDo(FnApiDoFnRunner.java:813)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnApiDoFnRunner$$Lambda$623/61326256.accept(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:313)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.data.PCollectionConsumerRegistry$MetricTrackingFnDataReceiver.accept(PCollectionConsumerRegistry.java:245)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.BeamFnDataReadRunner.forwardElementToConsumer(BeamFnDataReadRunner.java:213)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.BeamFnDataReadRunner$Factory$$Lambda$517/1252693491.accept(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.multiplexElements(BeamFnDataInboundObserver.java:158)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:123)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
> Task :sdks:python:test-suites:dataflow:py37:postCommitIT
[gw0] [32mPASSED[0m
apache_beam/io/gcp/dicomio_integration_test.py::DICOMIoIntegrationTest::test_dicom_store_instance_from_gcs
apache_beam/io/gcp/datastore/v1new/datastore_write_it_test.py::DatastoreWriteIT::test_datastore_write_limit
> Task :sdks:python:test-suites:portable:py37:xlangSpannerIOIT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 22 for at least 22m42s without outputting or
completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.misc.Unsafe.park(Native Method)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.CancellableQueue.take(CancellableQueue.java:94)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver.awaitCompletion(BeamFnDataInboundObserver.java:122)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:546)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.FnHarness$$Lambda$110/890160158.apply(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:151)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:116)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$117/441445471.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:162)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Jan 26,
2023 8:03:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
java.lang.OutOfMemoryError: GC overhead limit exceeded
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]
