See
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/6253/display/redirect>
Changes:
------------------------------------------
[...truncated 1016.37 MB...]
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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 42 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 38 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 46 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 47 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 67 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 1 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 17 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 64 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 69 for at least 05m50s 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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 103 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
05m49s 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.parkNanos(LockSupport.java:215)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$ResumableStreamIterator.backoffSleep(AbstractResultSet.java:1017)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$ResumableStreamIterator.backoffSleep(AbstractResultSet.java:987)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
com.google.cloud.spanner.AbstractResultSet$ResumableStreamIterator.computeNext(AbstractResultSet.java:1119)
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$601/1228178216.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$488/1474910369.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)
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/21811247.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 1:40:09 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
Operation ongoing in bundle 24 for at least 05m50s 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/21811247.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 1:40:09 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 05m50s 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)
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]
