--- Threads (148): [Thread[DataflowWorkUnits-2370:0b06242268aea6a3,5,main], Thread[DataflowWorkUnits-2465:0b06242268aea8c6,5,main], Thread[DataflowWorkUnits-2449:0b06242268aea8ce,5,main], Thread[DataflowWorkUnits-2122:0b06242268aea357,5,main], Thread[DataflowWorkUnits-2667:0b06242268aea7dc,5,main], Thread[DataflowWorkUnits-2645:0b06242268ae9e8e,5,main], Thread[DataflowWorkUnits-2646:0b06242268ae9e8f,5,main], Thread[DataflowWorkUnits-2505:0b06242268aea830,5,main], Thread[DataflowWorkUnits-2647:0b06242268ae9ef9,5,main], Thread[DataflowWorkUnits-2097:0b06242268aea8c2,5,main], Thread[DataflowWorkUnits-2688:0b06242268aea1a1,5,main], Thread[DataflowWorkUnits-2690:0b06242268ae9dcd,5,main], Thread[DataflowWorkUnits-2676:0b06242268aea1eb,5,main], Thread[DataflowWorkUnits-2469:0b06242268ae9e64,5,main], Thread[DataflowWorkUnits-2080:0b06242268ae9dd8,5,main], Thread[DataflowWorkUnits-2461:0b06242268aea887,5,main], Thread[DataflowWorkUnits-2632:0b06242268aea897,5,main], Thread[DataflowWorkUnits-2487:0b06242268ae9d86,5,main], Thread[DataflowWorkUnits-2569:0b06242268aea035,5,main], Thread[DataflowWorkUnits-2496:0b06242268aea29a,5,main], Thread[DataflowWorkUnits-2675:0b06242268aea8d5,5,main], Thread[DataflowWorkUnits-2677:0b06242268aea768,5,main], Thread[DataflowWorkUnits-2249:0b06242268ae9e92,5,main], Thread[DataflowWorkUnits-2593:0b06242268aea468,5,main], Thread[DataflowWorkUnits-2489:0b06242268aea943,5,main], Thread[DataflowWorkUnits-2679:0b06242268aea665,5,main], Thread[DataflowWorkUnits-2455:0b06242268aea8a4,5,main], Thread[DataflowWorkUnits-2470:0b06242268aea899,5,main], Thread[DataflowWorkUnits-2631:0b06242268aea772,5,main], Thread[DataflowWorkUnits-2221:0b06242268aea81f,5,main], Thread[DataflowWorkUnits-2619:0b06242268aea185,5,main], Thread[DataflowWorkUnits-2635:0b06242268aea523,5,main], Thread[DataflowWorkUnits-2200:0b06242268ae9dcf,5,main], Thread[DataflowWorkUnits-2608:0b06242268ae9de6,5,main], Thread[DataflowWorkUnits-2323:0b06242268aea875,5,main], Thread[DataflowWorkUnits-2445:0b06242268aea392,5,main], Thread[DataflowWorkUnits-2369:0b06242268aea74e,5,main], Thread[DataflowWorkUnits-2655:0b06242268aea789,5,main], Thread[DataflowWorkUnits-2508:0b06242268ae9d4c,5,main], Thread[DataflowWorkUnits-2348:0b06242268aea0d4,5,main], Thread[DataflowWorkUnits-2342:0b06242268aea78f,5,main], Thread[DataflowWorkUnits-2627:0b06242268aea307,5,main], Thread[DataflowWorkUnits-2207:0b06242268aea55d,5,main], Thread[DataflowWorkUnits-2181:0b06242268aea6b0,5,main], Thread[DataflowWorkUnits-2355:0b06242268ae9e23,5,main], Thread[DataflowWorkUnits-2366:0b06242268aea5a5,5,main], Thread[DataflowWorkUnits-2650:0b06242268aea8c3,5,main], Thread[DataflowWorkUnits-2051:0b06242268aea8d3,5,main], Thread[DataflowWorkUnits-2450:0b06242268aea812,5,main], Thread[DataflowWorkUnits-2187:0b06242268aea6d2,5,main], Thread[DataflowWorkUnits-2441:0b06242268aea0c6,5,main], Thread[DataflowWorkUnits-2529:0b06242268aea82c,5,main], Thread[DataflowWorkUnits-2658:0b06242268aea3ad,5,main], Thread[DataflowWorkUnits-2670:0b06242268aea76a,5,main], Thread[DataflowWorkUnits-2611:0b06242268aea6ff,5,main], Thread[DataflowWorkUnits-2642:0b06242268ae9f36,5,main], Thread[DataflowWorkUnits-2499:0b06242268aea657,5,main], Thread[DataflowWorkUnits-2186:0b06242268aea786,5,main], Thread[DataflowWorkUnits-2681:0b06242268aea44b,5,main], Thread[DataflowWorkUnits-2241:0b06242268aea869,5,main], Thread[DataflowWorkUnits-2460:0b06242268ae9d8b,5,main], Thread[DataflowWorkUnits-2360:0b06242268aea44a,5,main], Thread[DataflowWorkUnits-2239:0b06242268aea8a3,5,main], Thread[DataflowWorkUnits-2099:0b06242268aea807,5,main], Thread[DataflowWorkUnits-2512:0b06242268aea299,5,main], Thread[DataflowWorkUnits-2494:0b06242268aea777,5,main], Thread[DataflowWorkUnits-2691:0b06242268aea78a,5,main], Thread[DataflowWorkUnits-2625:0b06242268aea8a7,5,main], Thread[DataflowWorkUnits-2368:0b06242268aea387,5,main], Thread[DataflowWorkUnits-2532:0b06242268aea588,5,main], Thread[DataflowWorkUnits-2618:0b06242268aea878,5,main], Thread[DataflowWorkUnits-2458:0b06242268aea947,5,main], Thread[DataflowWorkUnits-2218:0b06242268ae9e70,5,main], Thread[DataflowWorkUnits-2693:0b06242268ae9dff,5,main], Thread[DataflowWorkUnits-2643:0b06242268ae9e8a,5,main], Thread[DataflowWorkUnits-2334:0b06242268aea735,5,main], Thread[DataflowWorkUnits-2185:0b06242268aea417,5,main], Thread[DataflowWorkUnits-2641:0b06242268ae9e2e,5,main], Thread[DataflowWorkUnits-2495:0b06242268aea727,5,main], Thread[DataflowWorkUnits-2226:0b06242268ae9d93,5,main], Thread[DataflowWorkUnits-2215:0b06242268aea865,5,main], Thread[DataflowWorkUnits-2533:0b06242268ae9d45,5,main], Thread[DataflowWorkUnits-2196:0b06242268aea7d7,5,main], Thread[DataflowWorkUnits-2633:0b06242268ae9fad,5,main], Thread[DataflowWorkUnits-2480:0b06242268aea85b,5,main], Thread[DataflowWorkUnits-2193:0b06242268aea275,5,main], Thread[DataflowWorkUnits-2244:0b06242268aea892,5,main], Thread[DataflowWorkUnits-2443:0b06242268ae9e90,5,main], Thread[DataflowWorkUnits-2511:0b06242268ae9d57,5,main], Thread[DataflowWorkUnits-2479:0b06242268ae9e99,5,main], Thread[DataflowWorkUnits-2613:0b06242268aea285,5,main], Thread[DataflowWorkUnits-2607:0b06242268ae9e09,5,main], Thread[DataflowWorkUnits-2229:0b06242268aea0a3,5,main], Thread[DataflowWorkUnits-2596:0b06242268aea84d,5,main], Thread[DataflowWorkUnits-2687:0b06242268ae9ddb,5,main], Thread[DataflowWorkUnits-2680:0b06242268aea92a,5,main], Thread[DataflowWorkUnits-2202:0b06242268aea941,5,main], Thread[DataflowWorkUnits-2615:0b06242268aea861,5,main], Thread[DataflowWorkUnits-2592:0b06242268aea410,5,main], Thread[DataflowWorkUnits-2238:0b06242268aea251,5,main], Thread[DataflowWorkUnits-2164:0b06242268aea3d6,5,main], Thread[DataflowWorkUnits-2500:0b06242268aea7a1,5,main], Thread[DataflowWorkUnits-2471:0b06242268aea82d,5,main], Thread[DataflowWorkUnits-2345:0b06242268aea296,5,main], Thread[DataflowWorkUnits-2689:0b06242268aea89e,5,main], Thread[DataflowWorkUnits-2199:0b06242268aea8a0,5,main], Thread[DataflowWorkUnits-2626:0b06242268ae9dc2,5,main], Thread[DataflowWorkUnits-2209:0b06242268ae9da4,5,main], Thread[DataflowWorkUnits-2098:0b06242268aea79d,5,main], Thread[DataflowWorkUnits-2106:0b06242268aea843,5,main], Thread[DataflowWorkUnits-2346:0b06242268aea894,5,main], Thread[DataflowWorkUnits-2620:0b06242268aea252,5,main], Thread[DataflowWorkUnits-2501:0b06242268aea668,5,main], Thread[DataflowWorkUnits-2504:0b06242268aea882,5,main], Thread[DataflowWorkUnits-2673:0b06242268aea8b6,5,main], Thread[DataflowWorkUnits-2233:0b06242268aea661,5,main], Thread[DataflowWorkUnits-2191:0b06242268ae9f1e,5,main], Thread[DataflowWorkUnits-2514:0b06242268aea4a4,5,main], Thread[DataflowWorkUnits-2190:0b06242268aea7e7,5,main], Thread[DataflowWorkUnits-2651:0b06242268aea356,5,main], Thread[DataflowWorkUnits-2219:0b06242268ae9fd5,5,main], Thread[DataflowWorkUnits-2629:0b06242268ae9fe8,5,main], Thread[DataflowWorkUnits-2621:0b06242268ae9e22,5,main], Thread[DataflowWorkUnits-2493:0b06242268aea8bb,5,main], Thread[DataflowWorkUnits-2605:0b06242268ae9e11,5,main], Thread[DataflowWorkUnits-2350:0b06242268aea8bf,5,main], Thread[DataflowWorkUnits-2492:0b06242268aea1ee,5,main], Thread[DataflowWorkUnits-2509:0b06242268aea232,5,main], Thread[DataflowWorkUnits-2198:0b06242268aea930,5,main], Thread[DataflowWorkUnits-2530:0b06242268ae9d71,5,main], Thread[DataflowWorkUnits-2609:0b06242268aea471,5,main], Thread[DataflowWorkUnits-2630:0b06242268ae9e1b,5,main], Thread[DataflowWorkUnits-2563:0b06242268ae9e08,5,main], Thread[DataflowWorkUnits-2507:0b06242268aea4b8,5,main], Thread[DataflowWorkUnits-2541:0b06242268ae9d4a,5,main], Thread[DataflowWorkUnits-2119:0b06242268ae9fb4,5,main], Thread[DataflowWorkUnits-2247:0b06242268ae9e95,5,main], Thread[DataflowWorkUnits-2637:0b06242268aea847,5,main], Thread[DataflowWorkUnits-2223:0b06242268ae9e93,5,main], Thread[DataflowWorkUnits-2660:0b06242268ae9e13,5,main], Thread[DataflowWorkUnits-2204:0b06242268aea788,5,main], Thread[DataflowWorkUnits-2121:0b06242268aea78b,5,main], Thread[DataflowWorkUnits-2606:0b06242268aea3f1,5,main], Thread[DataflowWorkUnits-2372:0b06242268ae9ea6,5,main], Thread[DataflowWorkUnits-2228:0b06242268ae9e91,5,main], Thread[DataflowWorkUnits-2617:0b06242268aea501,5,main], Thread[DataflowWorkUnits-2490:0b06242268aea977,5,main], Thread[DataflowWorkUnits-2502:0b06242268aea3e4,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) app//org.apache.iceberg.ClientPoolImpl.get(ClientPoolImpl.java:133) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:56) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:51) app//org.apache.iceberg.hive.CachedClientPool.run(CachedClientPool.java:122) app//org.apache.iceberg.hive.HiveTableOperations.doRefresh(HiveTableOperations.java:158) app//org.apache.iceberg.BaseMetastoreTableOperations.refresh(BaseMetastoreTableOperations.java:97) app//org.apache.iceberg.BaseMetastoreTableOperations.current(BaseMetastoreTableOperations.java:80) app//org.apache.iceberg.BaseMetastoreCatalog.loadTable(BaseMetastoreCatalog.java:47) app//org.apache.beam.sdk.io.iceberg.RecordWriter.(RecordWriter.java:49) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.createWriter(RecordWriterManager.java:175) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.fetchWriterForPartition(RecordWriterManager.java:159) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.write(RecordWriterManager.java:143) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.write(RecordWriterManager.java:234) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn.processElement(WriteUngroupedRowsToFiles.java:224) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:186) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1.processElement(AssignDestinations.java:57) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn.process(Select.java:144) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1.processElement(JsonToRow.java:114) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.JsonPreProcessorFn.processElement(JsonPreProcessorFn.java:22) app//com.revolut.beam.JsonPreProcessorFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.PubSubToIceberg$1.processElement(PubSubToIceberg.java:77) app//com.revolut.beam.PubSubToIceberg$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.AssignWindowsParDoFnFactory$AssignWindowsParDoFn.processElement(AssignWindowsParDoFnFactory.java:115) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.transforms.MapElements$2.processElement(MapElements.java:151) app//org.apache.beam.sdk.transforms.MapElements$2$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:218) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:169) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:83) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (139): [Thread[DataflowWorkUnits-2601:0b06242268aea088,5,main], Thread[DataflowWorkUnits-2614:0b06242268aea848,5,main], Thread[DataflowWorkUnits-2622:0b06242268aea91f,5,main], Thread[DataflowWorkUnits-2120:0b06242268aea895,5,main], Thread[DataflowWorkUnits-2661:0b06242268aea3bb,5,main], Thread[DataflowWorkUnits-2206:0b06242268aea73a,5,main], Thread[DataflowWorkUnits-2526:0b06242268aea1d9,5,main], Thread[DataflowWorkUnits-2477:0b06242268ae9e98,5,main], Thread[DataflowWorkUnits-2634:0b06242268aea86d,5,main], Thread[DataflowWorkUnits-2452:0b06242268ae9d99,5,main], Thread[DataflowWorkUnits-2517:0b06242268ae9ddd,5,main], Thread[DataflowWorkUnits-2640:0b06242268aea88e,5,main], Thread[DataflowWorkUnits-2096:0b06242268aea0c4,5,main], Thread[DataflowWorkUnits-2636:0b06242268aea6d5,5,main], Thread[DataflowWorkUnits-2568:0b06242268aea7e8,5,main], Thread[DataflowWorkUnits-2550:0b06242268ae9ea5,5,main], Thread[DataflowWorkUnits-2123:0b06242268ae9de7,5,main], Thread[DataflowWorkUnits-2599:0b06242268aea86c,5,main], Thread[DataflowWorkUnits-2656:0b06242268aea8aa,5,main], Thread[DataflowWorkUnits-2184:0b06242268aea88d,5,main], Thread[DataflowWorkUnits-2095:0b06242268ae9e54,5,main], Thread[DataflowWorkUnits-2652:0b06242268ae9e9e,5,main], Thread[DataflowWorkUnits-2358:0b06242268aea950,5,main], Thread[DataflowWorkUnits-2666:0b06242268aea8c5,5,main], Thread[DataflowWorkUnits-2089:0b06242268aea7ca,5,main], Thread[DataflowWorkUnits-2446:0b06242268aea976,5,main], Thread[DataflowWorkUnits-2663:0b06242268aea896,5,main], Thread[DataflowWorkUnits-2115:0b06242268aea89f,5,main], Thread[DataflowWorkUnits-2537:0b06242268aea806,5,main], Thread[DataflowWorkUnits-2195:0b06242268aea76f,5,main], Thread[DataflowWorkUnits-2654:0b06242268aea85a,5,main], Thread[DataflowWorkUnits-2337:0b06242268aea525,5,main], Thread[DataflowWorkUnits-2339:0b06242268ae9e06,5,main], Thread[DataflowWorkUnits-2669:0b06242268aea810,5,main], Thread[DataflowWorkUnits-2235:0b06242268ae9e8d,5,main], Thread[DataflowWorkUnits-2692:0b06242268aea8ac,5,main], Thread[DataflowWorkUnits-2600:0b06242268aea833,5,main], Thread[DataflowWorkUnits-2527:0b06242268aea884,5,main], Thread[DataflowWorkUnits-2365:0b06242268aea89b,5,main], Thread[DataflowWorkUnits-2457:0b06242268aea771,5,main], Thread[DataflowWorkUnits-2649:0b06242268ae9e9f,5,main], Thread[DataflowWorkUnits-2453:0b06242268ae9e94,5,main], Thread[DataflowWorkUnits-2664:0b06242268aea41d,5,main], Thread[DataflowWorkUnits-2544:0b06242268aea8a6,5,main], Thread[DataflowWorkUnits-2602:0b06242268ae9dc6,5,main], Thread[DataflowWorkUnits-2624:0b06242268aea25e,5,main], Thread[DataflowWorkUnits-2451:0b06242268ae9d54,5,main], Thread[DataflowWorkUnits-2333:0b06242268ae9dd3,5,main], Thread[DataflowWorkUnits-2220:0b06242268aea838,5,main], Thread[DataflowWorkUnits-2211:0b06242268ae9e5e,5,main], Thread[DataflowWorkUnits-2354:0b06242268aea8d2,5,main], Thread[DataflowWorkUnits-2340:0b06242268aea469,5,main], Thread[DataflowWorkUnits-2662:0b06242268ae9f45,5,main], Thread[DataflowWorkUnits-2362:0b06242268ae9fee,5,main], Thread[DataflowWorkUnits-2232:0b06242268ae9e82,5,main], Thread[DataflowWorkUnits-2491:0b06242268ae9d69,5,main], Thread[DataflowWorkUnits-2671:0b06242268aea857,5,main], Thread[DataflowWorkUnits-2579:0b06242268aea877,5,main], Thread[DataflowWorkUnits-2188:0b06242268aea8ad,5,main], Thread[DataflowWorkUnits-2231:0b06242268aea0b2,5,main], Thread[DataflowWorkUnits-2222:0b06242268aea6db,5,main], Thread[DataflowWorkUnits-2515:0b06242268ae9dac,5,main], Thread[DataflowWorkUnits-2685:0b06242268aea91d,5,main], Thread[DataflowWorkUnits-2344:0b06242268ae9e6b,5,main], Thread[DataflowWorkUnits-2361:0b06242268ae9e58,5,main], Thread[DataflowWorkUnits-2163:0b06242268aea80e,5,main], Thread[DataflowWorkUnits-2484:0b06242268ae9d9c,5,main], Thread[DataflowWorkUnits-2466:0b06242268aea862,5,main], Thread[DataflowWorkUnits-2467:0b06242268aea630,5,main], Thread[DataflowWorkUnits-2216:0b06242268ae9f1c,5,main], Thread[DataflowWorkUnits-2604:0b06242268aea29b,5,main], Thread[DataflowWorkUnits-2447:0b06242268ae9e9a,5,main], Thread[DataflowWorkUnits-2665:0b06242268aea8f5,5,main], Thread[DataflowWorkUnits-2638:0b06242268ae9dc7,5,main], Thread[DataflowWorkUnits-2234:0b06242268aea5da,5,main], Thread[DataflowWorkUnits-2108:0b06242268aea7d5,5,main], Thread[DataflowWorkUnits-2603:0b06242268aea465,5,main], Thread[DataflowWorkUnits-2351:0b06242268aea753,5,main], Thread[DataflowWorkUnits-2448:0b06242268aea83e,5,main], Thread[DataflowWorkUnits-2523:0b06242268ae9e61,5,main], Thread[DataflowWorkUnits-2227:0b06242268aea765,5,main], Thread[DataflowWorkUnits-2442:0b06242268aea8ab,5,main], Thread[DataflowWorkUnits-2456:0b06242268ae9eea,5,main], Thread[DataflowWorkUnits-2230:0b06242268aea87d,5,main], Thread[DataflowWorkUnits-2357:0b06242268aea458,5,main], Thread[DataflowWorkUnits-2201:0b06242268aea0bf,5,main], Thread[DataflowWorkUnits-2672:0b06242268aea990,5,main], Thread[DataflowWorkUnits-2329:0b06242268aea831,5,main], Thread[DataflowWorkUnits-2462:0b06242268ae9d72,5,main], Thread[DataflowWorkUnits-2205:0b06242268ae9fab,5,main], Thread[DataflowWorkUnits-2459:0b06242268aea905,5,main], Thread[DataflowWorkUnits-2343:0b06242268aea10b,5,main], Thread[DataflowWorkUnits-2674:0b06242268aea51a,5,main], Thread[DataflowWorkUnits-2506:0b06242268aea84a,5,main], Thread[DataflowWorkUnits-2503:0b06242268aea554,5,main], Thread[DataflowWorkUnits-2498:0b06242268aea6d6,5,main], Thread[DataflowWorkUnits-2464:0b06242268ae9d47,5,main], Thread[DataflowWorkUnits-2371:0b06242268ae9e89,5,main], Thread[DataflowWorkUnits-2212:0b06242268aea4ba,5,main], Thread[DataflowWorkUnits-2208:0b06242268aea0ad,5,main], Thread[DataflowWorkUnits-2203:0b06242268aea8d4,5,main], Thread[DataflowWorkUnits-2364:0b06242268aea0bc,5,main], Thread[DataflowWorkUnits-2497:0b06242268aea855,5,main], Thread[DataflowWorkUnits-2678:0b06242268aea8cd,5,main], Thread[DataflowWorkUnits-2183:0b06242268ae9f1a,5,main], Thread[DataflowWorkUnits-2684:0b06242268ae9e2b,5,main], Thread[DataflowWorkUnits-2214:0b06242268ae9e87,5,main], Thread[DataflowWorkUnits-2682:0b06242268aea8b2,5,main], Thread[DataflowWorkUnits-2359:0b06242268ae9e5d,5,main], Thread[DataflowWorkUnits-2213:0b06242268aea711,5,main], Thread[DataflowWorkUnits-2463:0b06242268aea8d0,5,main], Thread[DataflowWorkUnits-2353:0b06242268aea6b3,5,main], Thread[DataflowWorkUnits-2468:0b06242268ae9d48,5,main], Thread[DataflowWorkUnits-2623:0b06242268aea443,5,main], Thread[DataflowWorkUnits-2610:0b06242268aea842,5,main], Thread[DataflowWorkUnits-2194:0b06242268aea411,5,main], Thread[DataflowWorkUnits-2648:0b06242268aea773,5,main], Thread[DataflowWorkUnits-2352:0b06242268aea7d0,5,main], Thread[DataflowWorkUnits-2225:0b06242268aea851,5,main], Thread[DataflowWorkUnits-2686:0b06242268aea835,5,main], Thread[DataflowWorkUnits-2210:0b06242268aea8b1,5,main], Thread[DataflowWorkUnits-2644:0b06242268aea8b3,5,main], Thread[DataflowWorkUnits-2488:0b06242268aea84c,5,main], Thread[DataflowWorkUnits-2513:0b06242268ae9d81,5,main], Thread[DataflowWorkUnits-2536:0b06242268aea920,5,main], Thread[DataflowWorkUnits-2182:0b06242268aea06f,5,main], Thread[DataflowWorkUnits-2543:0b06242268aea0ba,5,main], Thread[DataflowWorkUnits-2518:0b06242268ae9dad,5,main], Thread[DataflowWorkUnits-2668:0b06242268aea0a6,5,main], Thread[DataflowWorkUnits-2653:0b06242268aea0af,5,main], Thread[DataflowWorkUnits-2486:0b06242268aea19a,5,main], Thread[DataflowWorkUnits-2454:0b06242268ae9e84,5,main], Thread[DataflowWorkUnits-2683:0b06242268aea985,5,main], Thread[DataflowWorkUnits-2330:0b06242268aea0c1,5,main], Thread[DataflowWorkUnits-2347:0b06242268aea82e,5,main], Thread[DataflowWorkUnits-2192:0b06242268aea011,5,main], Thread[DataflowWorkUnits-2628:0b06242268aea6c2,5,main], Thread[DataflowWorkUnits-2472:0b06242268ae9e8c,5,main], Thread[DataflowWorkUnits-2197:0b06242268aea969,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) app//org.apache.iceberg.ClientPoolImpl.get(ClientPoolImpl.java:133) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:56) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:51) app//org.apache.iceberg.hive.CachedClientPool.run(CachedClientPool.java:122) app//org.apache.iceberg.hive.HiveTableOperations.doRefresh(HiveTableOperations.java:158) app//org.apache.iceberg.BaseMetastoreTableOperations.refresh(BaseMetastoreTableOperations.java:97) app//org.apache.iceberg.BaseMetastoreTableOperations.current(BaseMetastoreTableOperations.java:80) app//org.apache.iceberg.BaseMetastoreCatalog.loadTable(BaseMetastoreCatalog.java:47) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.lambda$write$0(RecordWriterManager.java:229) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$$Lambda$684/0x0000000800a9bc40.apply(Unknown Source) java.base@11.0.20/java.util.HashMap.computeIfAbsent(HashMap.java:1134) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.write(RecordWriterManager.java:226) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn.processElement(WriteUngroupedRowsToFiles.java:224) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:186) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1.processElement(AssignDestinations.java:57) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn.process(Select.java:144) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1.processElement(JsonToRow.java:114) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.JsonPreProcessorFn.processElement(JsonPreProcessorFn.java:22) app//com.revolut.beam.JsonPreProcessorFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.PubSubToIceberg$1.processElement(PubSubToIceberg.java:77) app//com.revolut.beam.PubSubToIceberg$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.AssignWindowsParDoFnFactory$AssignWindowsParDoFn.processElement(AssignWindowsParDoFnFactory.java:115) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.transforms.MapElements$2.processElement(MapElements.java:151) app//org.apache.beam.sdk.transforms.MapElements$2$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:218) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:169) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:83) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (13): [Thread[grpc-default-executor-2,5,main], Thread[gcs-async-channel-pool-110,5,main], Thread[gcs-async-channel-pool-114,5,main], Thread[gcs-async-channel-pool-96,5,main], Thread[gcs-async-channel-pool-107,5,main], Thread[gcs-async-channel-pool-101,5,main], Thread[gcs-async-channel-pool-111,5,main], Thread[gcs-async-channel-pool-103,5,main], Thread[gcsfs-misc-200,5,main], Thread[grpc-default-executor-5,5,main], Thread[gcs-async-channel-pool-95,5,main], Thread[gcs-async-channel-pool-104,5,main], Thread[gcs-async-channel-pool-106,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) java.base@11.0.20/java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:462) java.base@11.0.20/java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:361) java.base@11.0.20/java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:937) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1053) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (9): [Thread[iceberg-worker-pool-3,5,main], Thread[iceberg-worker-pool-5,5,main], Thread[iceberg-worker-pool-7,5,main], Thread[iceberg-worker-pool-2,5,main], Thread[iceberg-worker-pool-6,5,main], Thread[iceberg-worker-pool-0,5,main], Thread[GetWorkStream-WindmillStream-thread,5,main], Thread[iceberg-worker-pool-4,5,main], Thread[iceberg-worker-pool-1,5,main]] State: WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) java.base@11.0.20/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) java.base@11.0.20/java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (8): [Thread[grpc-default-worker-ELG-1-4,5,main], Thread[grpc-default-worker-ELG-1-6,5,main], Thread[grpc-default-worker-ELG-1-7,5,main], Thread[grpc-default-worker-ELG-1-2,5,main], Thread[grpc-default-worker-ELG-1-8,5,main], Thread[grpc-default-worker-ELG-1-5,5,main], Thread[grpc-default-worker-ELG-1-3,5,main], Thread[grpc-default-worker-ELG-1-1,5,main]] State: RUNNABLE stack: --- app//org.apache.beam.vendor.grpc.v1p60p1.io.netty.channel.epoll.Native.epollWait0(Native Method) app//org.apache.beam.vendor.grpc.v1p60p1.io.netty.channel.epoll.Native.epollWait(Native.java:182) app//org.apache.beam.vendor.grpc.v1p60p1.io.netty.channel.epoll.EpollEventLoop.epollWait(EpollEventLoop.java:312) app//org.apache.beam.vendor.grpc.v1p60p1.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:376) app//org.apache.beam.vendor.grpc.v1p60p1.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) app//org.apache.beam.vendor.grpc.v1p60p1.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) app//org.apache.beam.vendor.grpc.v1p60p1.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (7): [Thread[GlobalWorkerUpdates,5,main], Thread[Connector-Scheduler-2bbb44da-1,5,main], Thread[pool-14-thread-1,5,main], Thread[RefreshWork,5,main], Thread[ReportWorkerMessage,5,main], Thread[hive-metastore-cleaner-0,5,main], Thread[GlobalPipelineConfigRefresher,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) java.base@11.0.20/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) java.base@11.0.20/java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1182) java.base@11.0.20/java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:899) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (5): [Thread[gcsfs-misc-183,5,main], Thread[gcsfs-misc-199,5,main], Thread[gcsfs-misc-190,5,main], Thread[gcsfs-misc-198,5,main], Thread[gcsfs-misc-196,5,main]] State: RUNNABLE stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) java.base@11.0.20/java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:462) java.base@11.0.20/java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:361) java.base@11.0.20/java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:937) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1053) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (4): [Thread[gcsfs-misc-188,5,main], Thread[gcsfs-misc-172,5,main], Thread[gcsfs-misc-197,5,main], Thread[gcsfs-misc-195,5,main]] State: WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) java.base@11.0.20/java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:462) java.base@11.0.20/java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:361) java.base@11.0.20/java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:937) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1053) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (4): [Thread[qtp1322907569-26,5,main], Thread[qtp1322907569-28,5,main], Thread[qtp1322907569-27,5,main], Thread[qtp1322907569-21,5,main]] State: RUNNABLE stack: --- java.base@11.0.20/sun.nio.ch.EPoll.wait(Native Method) java.base@11.0.20/sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) java.base@11.0.20/sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) java.base@11.0.20/sun.nio.ch.SelectorImpl.select(SelectorImpl.java:141) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.io.ManagedSelector.nioSelect(ManagedSelector.java:183) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.io.ManagedSelector.select(ManagedSelector.java:190) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.io.ManagedSelector$SelectorProducer.select(ManagedSelector.java:606) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.io.ManagedSelector$SelectorProducer.produce(ManagedSelector.java:543) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.produceTask(EatWhatYouKill.java:362) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:186) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (3): [Thread[ForkJoinPool.commonPool-worker-5,5,main], Thread[ForkJoinPool.commonPool-worker-3,5,main], Thread[ForkJoinPool.commonPool-worker-9,5,main]] State: WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) java.base@11.0.20/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1628) java.base@11.0.20/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) --- Threads (3): [Thread[DataflowWorkUnits-2659:0b06242268aea8af,5,main], Thread[DataflowWorkUnits-2189:0b06242268aea856,5,main], Thread[DataflowWorkUnits-2485:0b06242268aea86f,5,main]] State: RUNNABLE stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) app//org.apache.iceberg.ClientPoolImpl.get(ClientPoolImpl.java:133) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:56) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:51) app//org.apache.iceberg.hive.CachedClientPool.run(CachedClientPool.java:122) app//org.apache.iceberg.hive.HiveTableOperations.doRefresh(HiveTableOperations.java:158) app//org.apache.iceberg.BaseMetastoreTableOperations.refresh(BaseMetastoreTableOperations.java:97) app//org.apache.iceberg.BaseMetastoreTableOperations.current(BaseMetastoreTableOperations.java:80) app//org.apache.iceberg.BaseMetastoreCatalog.loadTable(BaseMetastoreCatalog.java:47) app//org.apache.beam.sdk.io.iceberg.RecordWriter.(RecordWriter.java:49) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.createWriter(RecordWriterManager.java:175) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.fetchWriterForPartition(RecordWriterManager.java:159) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.write(RecordWriterManager.java:143) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.write(RecordWriterManager.java:234) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn.processElement(WriteUngroupedRowsToFiles.java:224) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:186) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1.processElement(AssignDestinations.java:57) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn.process(Select.java:144) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1.processElement(JsonToRow.java:114) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.JsonPreProcessorFn.processElement(JsonPreProcessorFn.java:22) app//com.revolut.beam.JsonPreProcessorFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.PubSubToIceberg$1.processElement(PubSubToIceberg.java:77) app//com.revolut.beam.PubSubToIceberg$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.AssignWindowsParDoFnFactory$AssignWindowsParDoFn.processElement(AssignWindowsParDoFnFactory.java:115) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.transforms.MapElements$2.processElement(MapElements.java:151) app//org.apache.beam.sdk.transforms.MapElements$2$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:218) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:169) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:83) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (3): [Thread[DataflowWorkUnits-2639:0b06242268aea8f4,5,main], Thread[DataflowWorkUnits-2616:0b06242268aea853,5,main], Thread[DataflowWorkUnits-2367:0b06242268aea8c4,5,main]] State: WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) java.base@11.0.20/java.util.concurrent.FutureTask.awaitDone(FutureTask.java:447) java.base@11.0.20/java.util.concurrent.FutureTask.get(FutureTask.java:190) app//com.google.cloud.hadoop.util.BaseAbstractGoogleAsyncWriteChannel.waitForCompletionAndThrowIfUploadFailed(BaseAbstractGoogleAsyncWriteChannel.java:247) app//com.google.cloud.hadoop.util.BaseAbstractGoogleAsyncWriteChannel.close(BaseAbstractGoogleAsyncWriteChannel.java:168) java.base@11.0.20/java.nio.channels.Channels$1.close(Channels.java:177) java.base@11.0.20/java.io.FilterOutputStream.close(FilterOutputStream.java:188) app//com.google.cloud.hadoop.fs.gcs.GoogleHadoopOutputStream.close(GoogleHadoopOutputStream.java:119) app//org.apache.hadoop.fs.FSDataOutputStream$PositionCache.close(FSDataOutputStream.java:72) app//org.apache.hadoop.fs.FSDataOutputStream.close(FSDataOutputStream.java:101) app//org.apache.parquet.hadoop.util.HadoopPositionOutputStream.close(HadoopPositionOutputStream.java:64) app//org.apache.parquet.hadoop.ParquetFileWriter.end(ParquetFileWriter.java:1204) app//org.apache.iceberg.parquet.ParquetWriter.close(ParquetWriter.java:257) app//org.apache.iceberg.io.DataWriter.close(DataWriter.java:82) app//org.apache.beam.sdk.io.iceberg.RecordWriter.close(RecordWriter.java:110) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.lambda$new$0(RecordWriterManager.java:116) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState$$Lambda$1016/0x0000000800c64840.onRemoval(Unknown Source) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache.processPendingNotifications(LocalCache.java:1850) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.runUnlockedCleanup(LocalCache.java:3503) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.postWriteCleanup(LocalCache.java:3479) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.clear(LocalCache.java:3252) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache.clear(LocalCache.java:4343) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$LocalManualCache.invalidateAll(LocalCache.java:4960) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.close(RecordWriterManager.java:250) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn.finishBundle(WriteUngroupedRowsToFiles.java:241) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn$DoFnInvoker.invokeFinishBundle(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.finishBundle(SimpleDoFnRunner.java:222) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.finishBundle(SimpleParDoFn.java:433) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.finish(ParDoOperation.java:56) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:94) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (2): [Thread[gcs-async-channel-pool-98,5,main], Thread[gcs-async-channel-pool-115,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.net.SocketInputStream.socketRead0(Native Method) java.base@11.0.20/java.net.SocketInputStream.socketRead(SocketInputStream.java:115) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:168) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:140) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:484) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:478) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70) java.base@11.0.20/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1459) java.base@11.0.20/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1070) java.base@11.0.20/java.io.BufferedInputStream.fill(BufferedInputStream.java:252) java.base@11.0.20/java.io.BufferedInputStream.read1(BufferedInputStream.java:292) java.base@11.0.20/java.io.BufferedInputStream.read(BufferedInputStream.java:351) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:789) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:724) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1615) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1520) java.base@11.0.20/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:527) java.base@11.0.20/sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:334) app//com.google.api.client.http.javanet.NetHttpResponse.(NetHttpResponse.java:36) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:152) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:84) app//com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1012) app//com.google.api.client.googleapis.media.MediaHttpUploader.executeCurrentRequestWithoutGZip(MediaHttpUploader.java:519) app//com.google.api.client.googleapis.media.MediaHttpUploader.executeCurrentRequest(MediaHttpUploader.java:536) app//com.google.api.client.googleapis.media.MediaHttpUploader.resumableUpload(MediaHttpUploader.java:394) app//com.google.api.client.googleapis.media.MediaHttpUploader.upload(MediaHttpUploader.java:308) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:539) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:466) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:576) app//com.google.cloud.hadoop.util.AbstractGoogleAsyncWriteChannel$UploadOperation.call(AbstractGoogleAsyncWriteChannel.java:85) java.base@11.0.20/java.util.concurrent.FutureTask.run(FutureTask.java:264) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (2): [Thread[grpc-default-executor-4,5,main], Thread[grpc-default-executor-3,5,main]] State: WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) java.base@11.0.20/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitUninterruptibly(AbstractQueuedSynchronizer.java:2018) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.util.concurrent.Monitor.awaitUninterruptibly(Monitor.java:1200) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.util.concurrent.Monitor.enterWhenUninterruptibly(Monitor.java:581) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.execute(BoundedQueueExecutor.java:104) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationState.execute(ComputationState.java:142) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationState.activateWork(ComputationState.java:114) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.scheduleWork(StreamingWorkScheduler.java:211) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness.lambda$streamingEngineDispatchLoop$3(SingleSourceWorkerHarness.java:162) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness$$Lambda$424/0x00000008007f0440.accept(Unknown Source) java.base@11.0.20/java.util.Optional.ifPresent(Optional.java:183) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness.lambda$streamingEngineDispatchLoop$4(SingleSourceWorkerHarness.java:159) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness$$Lambda$363/0x00000008005db440.receiveWork(Unknown Source) app//org.apache.beam.runners.dataflow.worker.windmill.client.grpc.GrpcGetWorkStream.consumeAssembledWorkItem(GrpcGetWorkStream.java:168) app//org.apache.beam.runners.dataflow.worker.windmill.client.grpc.GrpcGetWorkStream$$Lambda$416/0x00000008007a2040.accept(Unknown Source) java.base@11.0.20/java.util.Optional.ifPresent(Optional.java:183) app//org.apache.beam.runners.dataflow.worker.windmill.client.grpc.GrpcGetWorkStream.onResponse(GrpcGetWorkStream.java:164) app//org.apache.beam.runners.dataflow.worker.windmill.client.grpc.GrpcGetWorkStream.onResponse(GrpcGetWorkStream.java:40) app//org.apache.beam.runners.dataflow.worker.windmill.client.AbstractWindmillStream$ResponseObserver.onNext(AbstractWindmillStream.java:309) app//org.apache.beam.runners.dataflow.worker.windmill.client.grpc.observers.ForwardingClientResponseObserver.onNext(ForwardingClientResponseObserver.java:47) app//org.apache.beam.vendor.grpc.v1p60p1.io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onMessage(ClientCalls.java:468) app//org.apache.beam.vendor.grpc.v1p60p1.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1MessagesAvailable.runInternal(ClientCallImpl.java:667) app//org.apache.beam.vendor.grpc.v1p60p1.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1MessagesAvailable.runInContext(ClientCallImpl.java:654) app//org.apache.beam.vendor.grpc.v1p60p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) app//org.apache.beam.vendor.grpc.v1p60p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (2): [Thread[DataflowWorkUnits-2510:0b06242268aea874,5,main], Thread[DataflowWorkUnits-2224:0b06242268aea8cc,5,main]] State: WAITING stack: --- java.base@11.0.20/java.net.SocketInputStream.socketRead0(Native Method) java.base@11.0.20/java.net.SocketInputStream.socketRead(SocketInputStream.java:115) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:168) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:140) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:484) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:478) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70) java.base@11.0.20/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1459) java.base@11.0.20/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1070) java.base@11.0.20/java.io.BufferedInputStream.fill(BufferedInputStream.java:252) java.base@11.0.20/java.io.BufferedInputStream.read1(BufferedInputStream.java:292) java.base@11.0.20/java.io.BufferedInputStream.read(BufferedInputStream.java:351) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:789) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:724) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1615) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1520) java.base@11.0.20/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:527) java.base@11.0.20/sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:334) app//com.google.api.client.http.javanet.NetHttpResponse.(NetHttpResponse.java:36) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:152) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:84) app//com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1012) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:525) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:466) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeMedia(AbstractGoogleClientRequest.java:490) app//com.google.api.services.storage.Storage$Objects$Get.executeMedia(Storage.java:6522) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageReadChannel.openStream(GoogleCloudStorageReadChannel.java:933) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageReadChannel.openContentChannel(GoogleCloudStorageReadChannel.java:724) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageReadChannel.performLazySeek(GoogleCloudStorageReadChannel.java:715) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageReadChannel.read(GoogleCloudStorageReadChannel.java:307) app//com.google.cloud.hadoop.fs.gcs.GoogleHadoopFSInputStream.read(GoogleHadoopFSInputStream.java:142) java.base@11.0.20/java.io.DataInputStream.read(DataInputStream.java:149) app//org.apache.iceberg.hadoop.HadoopStreams$HadoopSeekableInputStream.read(HadoopStreams.java:123) app//com.fasterxml.jackson.core.json.ByteSourceJsonBootstrapper.ensureLoaded(ByteSourceJsonBootstrapper.java:547) app//com.fasterxml.jackson.core.json.ByteSourceJsonBootstrapper.detectEncoding(ByteSourceJsonBootstrapper.java:137) app//com.fasterxml.jackson.core.json.ByteSourceJsonBootstrapper.constructParser(ByteSourceJsonBootstrapper.java:266) app//com.fasterxml.jackson.core.JsonFactory._createParser(JsonFactory.java:1874) app//com.fasterxml.jackson.core.JsonFactory.createParser(JsonFactory.java:1273) app//com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3885) app//org.apache.iceberg.TableMetadataParser.read(TableMetadataParser.java:273) app//org.apache.iceberg.TableMetadataParser.read(TableMetadataParser.java:266) app//org.apache.iceberg.BaseMetastoreTableOperations.lambda$refreshFromMetadataLocation$0(BaseMetastoreTableOperations.java:189) app//org.apache.iceberg.BaseMetastoreTableOperations$$Lambda$716/0x0000000800b2c440.apply(Unknown Source) app//org.apache.iceberg.BaseMetastoreTableOperations.lambda$refreshFromMetadataLocation$1(BaseMetastoreTableOperations.java:208) app//org.apache.iceberg.BaseMetastoreTableOperations$$Lambda$718/0x0000000800b29040.run(Unknown Source) app//org.apache.iceberg.util.Tasks$Builder.runTaskWithRetry(Tasks.java:413) app//org.apache.iceberg.util.Tasks$Builder.runSingleThreaded(Tasks.java:219) app//org.apache.iceberg.util.Tasks$Builder.run(Tasks.java:203) app//org.apache.iceberg.util.Tasks$Builder.run(Tasks.java:196) app//org.apache.iceberg.BaseMetastoreTableOperations.refreshFromMetadataLocation(BaseMetastoreTableOperations.java:208) app//org.apache.iceberg.BaseMetastoreTableOperations.refreshFromMetadataLocation(BaseMetastoreTableOperations.java:185) app//org.apache.iceberg.BaseMetastoreTableOperations.refreshFromMetadataLocation(BaseMetastoreTableOperations.java:180) app//org.apache.iceberg.hive.HiveTableOperations.doRefresh(HiveTableOperations.java:178) app//org.apache.iceberg.BaseMetastoreTableOperations.refresh(BaseMetastoreTableOperations.java:97) app//org.apache.iceberg.BaseMetastoreTableOperations.current(BaseMetastoreTableOperations.java:80) app//org.apache.iceberg.BaseMetastoreCatalog.loadTable(BaseMetastoreCatalog.java:47) app//org.apache.beam.sdk.io.iceberg.RecordWriter.(RecordWriter.java:49) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.createWriter(RecordWriterManager.java:175) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.fetchWriterForPartition(RecordWriterManager.java:159) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.write(RecordWriterManager.java:143) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.write(RecordWriterManager.java:234) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn.processElement(WriteUngroupedRowsToFiles.java:224) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:186) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1.processElement(AssignDestinations.java:57) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn.process(Select.java:144) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1.processElement(JsonToRow.java:114) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.JsonPreProcessorFn.processElement(JsonPreProcessorFn.java:22) app//com.revolut.beam.JsonPreProcessorFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.PubSubToIceberg$1.processElement(PubSubToIceberg.java:77) app//com.revolut.beam.PubSubToIceberg$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.AssignWindowsParDoFnFactory$AssignWindowsParDoFn.processElement(AssignWindowsParDoFnFactory.java:115) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.transforms.MapElements$2.processElement(MapElements.java:151) app//org.apache.beam.sdk.transforms.MapElements$2$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:218) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:169) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:83) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (2): [Thread[DestroyJavaVM,5,main], Thread[Signal Dispatcher,9,system]] State: RUNNABLE stack: --- --- Threads (2): [Thread[DataflowWorkUnits-2612:0b06242268aea891,5,main], Thread[DataflowWorkUnits-2363:0b06242268aea852,5,main]] State: RUNNABLE stack: --- java.base@11.0.20/java.net.SocketInputStream.socketRead0(Native Method) java.base@11.0.20/java.net.SocketInputStream.socketRead(SocketInputStream.java:115) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:168) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:140) java.base@11.0.20/java.io.BufferedInputStream.fill(BufferedInputStream.java:252) java.base@11.0.20/java.io.BufferedInputStream.read1(BufferedInputStream.java:292) java.base@11.0.20/java.io.BufferedInputStream.read(BufferedInputStream.java:351) app//org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:127) app//org.apache.thrift.transport.TTransport.readAll(TTransport.java:86) app//org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429) app//org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318) app//org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219) app//org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77) app//org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_get_table_req(ThriftHiveMetastore.java:2079) app//org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.get_table_req(ThriftHiveMetastore.java:2066) app//org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getTable(HiveMetaStoreClient.java:1578) app//org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getTable(HiveMetaStoreClient.java:1570) jdk.internal.reflect.GeneratedMethodAccessor428.invoke(Unknown Source) java.base@11.0.20/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.base@11.0.20/java.lang.reflect.Method.invoke(Method.java:566) app//org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:208) app//com.sun.proxy.$Proxy109.getTable(Unknown Source) app//org.apache.iceberg.hive.HiveTableOperations.lambda$doRefresh$0(HiveTableOperations.java:158) app//org.apache.iceberg.hive.HiveTableOperations$$Lambda$685/0x0000000800a9b040.run(Unknown Source) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:58) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:51) app//org.apache.iceberg.hive.CachedClientPool.run(CachedClientPool.java:122) app//org.apache.iceberg.hive.HiveTableOperations.doRefresh(HiveTableOperations.java:158) app//org.apache.iceberg.BaseMetastoreTableOperations.refresh(BaseMetastoreTableOperations.java:97) app//org.apache.iceberg.BaseMetastoreTableOperations.current(BaseMetastoreTableOperations.java:80) app//org.apache.iceberg.BaseMetastoreCatalog.loadTable(BaseMetastoreCatalog.java:47) app//org.apache.beam.sdk.io.iceberg.RecordWriter.(RecordWriter.java:49) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.createWriter(RecordWriterManager.java:175) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.fetchWriterForPartition(RecordWriterManager.java:159) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.write(RecordWriterManager.java:143) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.write(RecordWriterManager.java:234) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn.processElement(WriteUngroupedRowsToFiles.java:224) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:186) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1.processElement(AssignDestinations.java:57) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn.process(Select.java:144) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1.processElement(JsonToRow.java:114) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.JsonPreProcessorFn.processElement(JsonPreProcessorFn.java:22) app//com.revolut.beam.JsonPreProcessorFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.PubSubToIceberg$1.processElement(PubSubToIceberg.java:77) app//com.revolut.beam.PubSubToIceberg$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.AssignWindowsParDoFnFactory$AssignWindowsParDoFn.processElement(AssignWindowsParDoFnFactory.java:115) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.transforms.MapElements$2.processElement(MapElements.java:151) app//org.apache.beam.sdk.transforms.MapElements$2$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:218) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:169) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:83) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[qtp1322907569-22,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) java.base@11.0.20/java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:462) java.base@11.0.20/java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:361) java.base@11.0.20/java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:937) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.reservedWait(ReservedThreadExecutor.java:324) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:399) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[DispatchThread,1,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) java.base@11.0.20/java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1079) java.base@11.0.20/java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1369) java.base@11.0.20/java.util.concurrent.CountDownLatch.await(CountDownLatch.java:278) app//org.apache.beam.runners.dataflow.worker.windmill.client.AbstractWindmillStream.awaitTermination(AbstractWindmillStream.java:267) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness.streamingEngineDispatchLoop(SingleSourceWorkerHarness.java:182) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness.lambda$getDispatchLoop$2(SingleSourceWorkerHarness.java:120) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness$$Lambda$362/0x00000008005dbc40.run(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness.lambda$start$0(SingleSourceWorkerHarness.java:108) app//org.apache.beam.runners.dataflow.worker.streaming.harness.SingleSourceWorkerHarness$$Lambda$359/0x00000008005dc040.run(Unknown Source) java.base@11.0.20/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) java.base@11.0.20/java.util.concurrent.FutureTask.run(FutureTask.java:264) java.base@11.0.20/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[RMI TCP Accept-0,5,system]] State: RUNNABLE stack: --- java.base@11.0.20/java.net.PlainSocketImpl.socketAccept(Native Method) java.base@11.0.20/java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:474) java.base@11.0.20/java.net.ServerSocket.implAccept(ServerSocket.java:565) java.base@11.0.20/java.net.ServerSocket.accept(ServerSocket.java:533) jdk.management.agent@11.0.20/sun.management.jmxremote.LocalRMIServerSocketFactory$1.accept(LocalRMIServerSocketFactory.java:52) java.rmi@11.0.20/sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:394) java.rmi@11.0.20/sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:366) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[WindmillHealthCheckTimer,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) java.base@11.0.20/java.util.TimerThread.mainLoop(Timer.java:553) java.base@11.0.20/java.util.TimerThread.run(Timer.java:506) --- Threads (1): [Thread[DataflowWorkUnits-2657:0b06242268aea819,5,main]] State: WAITING stack: --- java.base@11.0.20/java.net.SocketInputStream.socketRead0(Native Method) java.base@11.0.20/java.net.SocketInputStream.socketRead(SocketInputStream.java:115) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:168) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:140) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:484) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:478) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70) java.base@11.0.20/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1459) java.base@11.0.20/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1070) java.base@11.0.20/java.io.BufferedInputStream.fill(BufferedInputStream.java:252) java.base@11.0.20/java.io.BufferedInputStream.read1(BufferedInputStream.java:292) java.base@11.0.20/java.io.BufferedInputStream.read(BufferedInputStream.java:351) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:789) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:724) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1615) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1520) java.base@11.0.20/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:527) java.base@11.0.20/sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:334) app//com.google.api.client.http.javanet.NetHttpResponse.(NetHttpResponse.java:36) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:152) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:84) app//com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1012) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:525) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:466) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:576) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl.getObject(GoogleCloudStorageImpl.java:2227) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl.getItemInfo(GoogleCloudStorageImpl.java:2120) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl.getWriteGeneration(GoogleCloudStorageImpl.java:2195) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl.create(GoogleCloudStorageImpl.java:566) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem.create(GoogleCloudStorageFileSystem.java:293) app//com.google.cloud.hadoop.fs.gcs.GoogleHadoopOutputStream.createChannel(GoogleHadoopOutputStream.java:78) app//com.google.cloud.hadoop.fs.gcs.GoogleHadoopOutputStream.(GoogleHadoopOutputStream.java:70) app//com.google.cloud.hadoop.fs.gcs.GoogleHadoopFileSystemBase.create(GoogleHadoopFileSystemBase.java:616) app//org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1169) app//org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1149) app//org.apache.parquet.hadoop.util.HadoopOutputFile.createOrOverwrite(HadoopOutputFile.java:81) app//org.apache.parquet.hadoop.ParquetFileWriter.(ParquetFileWriter.java:345) app//org.apache.parquet.hadoop.ParquetFileWriter.(ParquetFileWriter.java:323) app//org.apache.iceberg.parquet.ParquetWriter.ensureWriterInitialized(ParquetWriter.java:111) app//org.apache.iceberg.parquet.ParquetWriter.flushRowGroup(ParquetWriter.java:210) app//org.apache.iceberg.parquet.ParquetWriter.close(ParquetWriter.java:254) app//org.apache.iceberg.io.DataWriter.close(DataWriter.java:82) app//org.apache.beam.sdk.io.iceberg.RecordWriter.close(RecordWriter.java:110) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState.lambda$new$0(RecordWriterManager.java:116) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$DestinationState$$Lambda$1016/0x0000000800c64840.onRemoval(Unknown Source) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache.processPendingNotifications(LocalCache.java:1850) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.runUnlockedCleanup(LocalCache.java:3503) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.postWriteCleanup(LocalCache.java:3479) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$Segment.clear(LocalCache.java:3252) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache.clear(LocalCache.java:4343) app//org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.LocalCache$LocalManualCache.invalidateAll(LocalCache.java:4960) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.close(RecordWriterManager.java:250) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn.finishBundle(WriteUngroupedRowsToFiles.java:241) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn$DoFnInvoker.invokeFinishBundle(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.finishBundle(SimpleDoFnRunner.java:222) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.finishBundle(SimpleParDoFn.java:433) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.finish(ParDoOperation.java:56) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:94) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[RMI TCP Accept-5555,5,system]] State: RUNNABLE stack: --- java.base@11.0.20/java.net.PlainSocketImpl.socketAccept(Native Method) java.base@11.0.20/java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:474) java.base@11.0.20/java.net.ServerSocket.implAccept(ServerSocket.java:565) java.base@11.0.20/java.net.ServerSocket.accept(ServerSocket.java:533) java.rmi@11.0.20/sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:394) java.rmi@11.0.20/sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:366) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[DataflowWorkUnits-100:0b06242268ae7b89,5,main]] State: RUNNABLE stack: --- java.base@11.0.20/java.net.SocketInputStream.socketRead0(Native Method) java.base@11.0.20/java.net.SocketInputStream.socketRead(SocketInputStream.java:115) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:168) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:140) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:484) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:478) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70) java.base@11.0.20/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1459) java.base@11.0.20/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1070) java.base@11.0.20/java.io.BufferedInputStream.fill(BufferedInputStream.java:252) java.base@11.0.20/java.io.BufferedInputStream.read1(BufferedInputStream.java:292) java.base@11.0.20/java.io.BufferedInputStream.read(BufferedInputStream.java:351) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:789) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:724) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1615) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1520) java.base@11.0.20/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:527) java.base@11.0.20/sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:334) app//com.google.api.client.http.javanet.NetHttpResponse.(NetHttpResponse.java:36) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:152) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:84) app//com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1012) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:525) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:466) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:576) app//com.google.cloud.hadoop.gcsio.BatchHelper.execute(BatchHelper.java:177) app//com.google.cloud.hadoop.gcsio.BatchHelper.lambda$queue$0(BatchHelper.java:164) app//com.google.cloud.hadoop.gcsio.BatchHelper$$Lambda$1062/0x0000000800d09c40.call(Unknown Source) app//com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131) app//com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:74) app//com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82) app//com.google.common.util.concurrent.MoreExecutors$DirectExecutorService.execute(MoreExecutors.java:323) java.base@11.0.20/java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:140) app//com.google.common.util.concurrent.AbstractListeningExecutorService.submit(AbstractListeningExecutorService.java:69) app//com.google.common.util.concurrent.AbstractListeningExecutorService.submit(AbstractListeningExecutorService.java:36) app//com.google.cloud.hadoop.gcsio.BatchHelper.queue(BatchHelper.java:162) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl.queueSingleObjectDelete(GoogleCloudStorageImpl.java:1018) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl.deleteObjects(GoogleCloudStorageImpl.java:949) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem.deleteInternal(GoogleCloudStorageFileSystem.java:432) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem.delete(GoogleCloudStorageFileSystem.java:398) app//com.google.cloud.hadoop.fs.gcs.GoogleHadoopFileSystemBase.delete(GoogleHadoopFileSystemBase.java:824) app//org.apache.iceberg.hadoop.HadoopFileIO.deleteFile(HadoopFileIO.java:105) app//org.apache.iceberg.SnapshotProducer$1.accept(SnapshotProducer.java:79) app//org.apache.iceberg.SnapshotProducer$1.accept(SnapshotProducer.java:76) app//org.apache.iceberg.SnapshotProducer.deleteFile(SnapshotProducer.java:482) app//org.apache.iceberg.MergingSnapshotProducer.cleanUncommittedAppends(MergingSnapshotProducer.java:913) app//org.apache.iceberg.MergingSnapshotProducer.cleanUncommitted(MergingSnapshotProducer.java:935) app//org.apache.iceberg.SnapshotProducer.commit(SnapshotProducer.java:420) app//org.apache.beam.sdk.io.iceberg.AppendFilesToTables$AppendFilesToTablesDoFn.processElement(AppendFilesToTables.java:95) app//org.apache.beam.sdk.io.iceberg.AppendFilesToTables$AppendFilesToTablesDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:186) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.GroupAlsoByWindowsParDoFn$1.output(GroupAlsoByWindowsParDoFn.java:185) app//org.apache.beam.runners.dataflow.worker.GroupAlsoByWindowFnRunner$1.outputWindowedValue(GroupAlsoByWindowFnRunner.java:108) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.ReduceFnRunner.lambda$onTrigger$1(ReduceFnRunner.java:1058) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.ReduceFnRunner$$Lambda$1213/0x00000008008b0040.output(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.ReduceFnContextFactory$OnTriggerContextImpl.output(ReduceFnContextFactory.java:445) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SystemReduceFn.onTrigger(SystemReduceFn.java:130) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.ReduceFnRunner.onTrigger(ReduceFnRunner.java:1061) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.ReduceFnRunner.onTimers(ReduceFnRunner.java:771) app//org.apache.beam.runners.dataflow.worker.StreamingGroupAlsoByWindowViaWindowSetFn.processElement(StreamingGroupAlsoByWindowViaWindowSetFn.java:97) app//org.apache.beam.runners.dataflow.worker.StreamingGroupAlsoByWindowViaWindowSetFn.processElement(StreamingGroupAlsoByWindowViaWindowSetFn.java:43) app//org.apache.beam.runners.dataflow.worker.GroupAlsoByWindowFnRunner.invokeProcessElement(GroupAlsoByWindowFnRunner.java:121) app//org.apache.beam.runners.dataflow.worker.GroupAlsoByWindowFnRunner.processElement(GroupAlsoByWindowFnRunner.java:73) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.LateDataDroppingDoFnRunner.processElement(LateDataDroppingDoFnRunner.java:80) app//org.apache.beam.runners.dataflow.worker.GroupAlsoByWindowsParDoFn.processElement(GroupAlsoByWindowsParDoFn.java:137) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:218) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:169) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:83) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[gcsfs-misc-170,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) java.base@11.0.20/java.util.concurrent.FutureTask.awaitDone(FutureTask.java:447) java.base@11.0.20/java.util.concurrent.FutureTask.get(FutureTask.java:190) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem.getFromFuture(GoogleCloudStorageFileSystem.java:892) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem.getFileInfoInternal(GoogleCloudStorageFileSystem.java:1102) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem.lambda$delete$2(GoogleCloudStorageFileSystem.java:366) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem$$Lambda$1293/0x0000000800e53c40.call(Unknown Source) java.base@11.0.20/java.util.concurrent.FutureTask.run(FutureTask.java:264) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[ExportComponent.ServiceExporterThread-0,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) app//io.opencensus.implcore.trace.export.SpanExporterImpl$Worker.run(SpanExporterImpl.java:278) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[gcs-async-channel-pool-112,5,main]] State: RUNNABLE stack: --- java.base@11.0.20/java.net.SocketInputStream.socketRead0(Native Method) java.base@11.0.20/java.net.SocketInputStream.socketRead(SocketInputStream.java:115) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:168) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:140) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:484) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:478) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70) java.base@11.0.20/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1459) java.base@11.0.20/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1070) java.base@11.0.20/java.io.BufferedInputStream.fill(BufferedInputStream.java:252) java.base@11.0.20/java.io.BufferedInputStream.read1(BufferedInputStream.java:292) java.base@11.0.20/java.io.BufferedInputStream.read(BufferedInputStream.java:351) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:789) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:724) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1615) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1520) java.base@11.0.20/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:527) java.base@11.0.20/sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:334) app//com.google.api.client.http.javanet.NetHttpResponse.(NetHttpResponse.java:36) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:152) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:84) app//com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1012) app//com.google.api.client.googleapis.media.MediaHttpUploader.executeCurrentRequestWithoutGZip(MediaHttpUploader.java:519) app//com.google.api.client.googleapis.media.MediaHttpUploader.executeCurrentRequest(MediaHttpUploader.java:536) app//com.google.api.client.googleapis.media.MediaHttpUploader.resumableUpload(MediaHttpUploader.java:394) app//com.google.api.client.googleapis.media.MediaHttpUploader.upload(MediaHttpUploader.java:308) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:539) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:466) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:576) app//com.google.cloud.hadoop.util.AbstractGoogleAsyncWriteChannel$UploadOperation.call(AbstractGoogleAsyncWriteChannel.java:85) java.base@11.0.20/java.util.concurrent.FutureTask.run(FutureTask.java:264) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[MemoryMonitor,1,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) app//org.apache.beam.runners.dataflow.worker.util.MemoryMonitor.run(MemoryMonitor.java:594) java.base@11.0.20/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) java.base@11.0.20/java.util.concurrent.FutureTask.run(FutureTask.java:264) java.base@11.0.20/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[CommitThread-0,10,main]] State: WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) java.base@11.0.20/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) java.base@11.0.20/java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) app//org.apache.beam.runners.dataflow.worker.streaming.WeightedBoundedQueue.take(WeightedBoundedQueue.java:88) app//org.apache.beam.runners.dataflow.worker.windmill.client.commits.StreamingEngineWorkCommitter.streamingCommitLoop(StreamingEngineWorkCommitter.java:163) app//org.apache.beam.runners.dataflow.worker.windmill.client.commits.StreamingEngineWorkCommitter$$Lambda$358/0x00000008005dcc40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) java.base@11.0.20/java.util.concurrent.FutureTask.run(FutureTask.java:264) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[Keep-Alive-Timer,8,InnocuousThreadGroup]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.lang.Thread.sleep(Native Method) java.base@11.0.20/sun.net.www.http.KeepAliveCache.run(KeepAliveCache.java:222) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) java.base@11.0.20/jdk.internal.misc.InnocuousThread.run(InnocuousThread.java:161) --- Threads (1): [Thread[qtp1322907569-25-acceptor-0@3f1f19c6-ServerConnector@2bbb44da{HTTP/1.1, (http/1.1)}{0.0.0.0:8081},3,main]] State: RUNNABLE stack: --- java.base@11.0.20/sun.nio.ch.ServerSocketChannelImpl.accept0(Native Method) java.base@11.0.20/sun.nio.ch.ServerSocketChannelImpl.accept(ServerSocketChannelImpl.java:533) java.base@11.0.20/sun.nio.ch.ServerSocketChannelImpl.accept(ServerSocketChannelImpl.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.server.ServerConnector.accept(ServerConnector.java:388) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.server.AbstractConnector$Acceptor.run(AbstractConnector.java:704) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[OpenCensus.Disruptor-0,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:357) app//com.lmax.disruptor.SleepingWaitStrategy.applyWaitMethod(SleepingWaitStrategy.java:92) app//com.lmax.disruptor.SleepingWaitStrategy.waitFor(SleepingWaitStrategy.java:65) app//com.lmax.disruptor.ProcessingSequenceBarrier.waitFor(ProcessingSequenceBarrier.java:56) app//com.lmax.disruptor.BatchEventProcessor.processEvents(BatchEventProcessor.java:159) app//com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:125) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[Reference Handler,10,system]] State: RUNNABLE stack: --- java.base@11.0.20/java.lang.ref.Reference.waitForReferencePendingList(Native Method) java.base@11.0.20/java.lang.ref.Reference.processPendingReferences(Reference.java:241) java.base@11.0.20/java.lang.ref.Reference$ReferenceHandler.run(Reference.java:213) --- Threads (1): [Thread[state-sampler-0,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.lang.Thread.sleep(Native Method) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.metrics.ExecutionStateSampler.lambda$start$0(ExecutionStateSampler.java:114) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.metrics.ExecutionStateSampler$$Lambda$360/0x00000008005dc440.call(Unknown Source) java.base@11.0.20/java.util.concurrent.FutureTask.run(FutureTask.java:264) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[ForkJoinPool.commonPool-worker-7,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkUntil(LockSupport.java:275) java.base@11.0.20/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1619) java.base@11.0.20/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) --- Threads (1): [Thread[gcsfs-misc-179,5,main]] State: WAITING stack: --- java.base@11.0.20/java.net.SocketInputStream.socketRead0(Native Method) java.base@11.0.20/java.net.SocketInputStream.socketRead(SocketInputStream.java:115) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:168) java.base@11.0.20/java.net.SocketInputStream.read(SocketInputStream.java:140) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:484) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:478) java.base@11.0.20/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70) java.base@11.0.20/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1459) java.base@11.0.20/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1070) java.base@11.0.20/java.io.BufferedInputStream.fill(BufferedInputStream.java:252) java.base@11.0.20/java.io.BufferedInputStream.read1(BufferedInputStream.java:292) java.base@11.0.20/java.io.BufferedInputStream.read(BufferedInputStream.java:351) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:789) java.base@11.0.20/sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:724) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1615) java.base@11.0.20/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1520) java.base@11.0.20/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:527) java.base@11.0.20/sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:334) app//com.google.api.client.http.javanet.NetHttpResponse.(NetHttpResponse.java:36) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:152) app//com.google.api.client.http.javanet.NetHttpRequest.execute(NetHttpRequest.java:84) app//com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1012) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:525) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:466) app//com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:576) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl.getObject(GoogleCloudStorageImpl.java:2227) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl.getItemInfo(GoogleCloudStorageImpl.java:2120) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem.lambda$getFileInfoInternal$8(GoogleCloudStorageFileSystem.java:1087) app//com.google.cloud.hadoop.gcsio.GoogleCloudStorageFileSystem$$Lambda$1048/0x0000000800c7a040.call(Unknown Source) java.base@11.0.20/java.util.concurrent.FutureTask.run(FutureTask.java:264) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[Common-Cleaner,8,InnocuousThreadGroup]] State: TIMED_WAITING stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) java.base@11.0.20/java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:155) java.base@11.0.20/jdk.internal.ref.CleanerImpl.run(CleanerImpl.java:148) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) java.base@11.0.20/jdk.internal.misc.InnocuousThread.run(InnocuousThread.java:161) --- Threads (1): [Thread[org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner,5,main]] State: WAITING stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) java.base@11.0.20/java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:155) java.base@11.0.20/java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:176) app//org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner.run(FileSystem.java:3806) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[Finalizer,8,system]] State: WAITING stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) java.base@11.0.20/java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:155) java.base@11.0.20/java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:176) java.base@11.0.20/java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:170) --- Threads (1): [Thread[DataflowWorkUnits-2444:0b06242268aea8b0,5,main]] State: RUNNABLE stack: --- java.base@11.0.20/java.lang.Object.wait(Native Method) app//org.apache.iceberg.ClientPoolImpl.get(ClientPoolImpl.java:133) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:56) app//org.apache.iceberg.ClientPoolImpl.run(ClientPoolImpl.java:51) app//org.apache.iceberg.hive.CachedClientPool.run(CachedClientPool.java:122) app//org.apache.iceberg.hive.HiveTableOperations.doRefresh(HiveTableOperations.java:158) app//org.apache.iceberg.BaseMetastoreTableOperations.refresh(BaseMetastoreTableOperations.java:97) app//org.apache.iceberg.BaseMetastoreTableOperations.current(BaseMetastoreTableOperations.java:80) app//org.apache.iceberg.BaseMetastoreCatalog.loadTable(BaseMetastoreCatalog.java:47) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.lambda$write$0(RecordWriterManager.java:229) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager$$Lambda$684/0x0000000800a9bc40.apply(Unknown Source) java.base@11.0.20/java.util.HashMap.computeIfAbsent(HashMap.java:1134) app//org.apache.beam.sdk.io.iceberg.RecordWriterManager.write(RecordWriterManager.java:226) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn.processElement(WriteUngroupedRowsToFiles.java:224) app//org.apache.beam.sdk.io.iceberg.WriteUngroupedRowsToFiles$WriteUngroupedRowsToFilesDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:186) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1.processElement(AssignDestinations.java:57) app//org.apache.beam.sdk.io.iceberg.AssignDestinations$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn.process(Select.java:144) app//org.apache.beam.sdk.schemas.transforms.Select$SelectDoFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1.processElement(JsonToRow.java:114) app//org.apache.beam.sdk.transforms.JsonToRow$JsonToRowFn$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.JsonPreProcessorFn.processElement(JsonPreProcessorFn.java:22) app//com.revolut.beam.JsonPreProcessorFn$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:412) app//com.revolut.beam.PubSubToIceberg$1.processElement(PubSubToIceberg.java:77) app//com.revolut.beam.PubSubToIceberg$1$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.AssignWindowsParDoFnFactory$AssignWindowsParDoFn.processElement(AssignWindowsParDoFnFactory.java:115) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:285) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:276) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:86) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:432) app//org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:89) app//org.apache.beam.sdk.transforms.MapElements$2.processElement(MapElements.java:151) app//org.apache.beam.sdk.transforms.MapElements$2$DoFnInvoker.invokeProcessElement(Unknown Source) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:212) app//org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:189) app//org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:340) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) app//org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:54) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:218) app//org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:169) app//org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:83) app//org.apache.beam.runners.dataflow.worker.streaming.ComputationWorkExecutor.executeWork(ComputationWorkExecutor.java:81) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.executeWork(StreamingWorkScheduler.java:382) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.processWork(StreamingWorkScheduler.java:255) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler.lambda$scheduleWork$2(StreamingWorkScheduler.java:214) app//org.apache.beam.runners.dataflow.worker.windmill.work.processing.StreamingWorkScheduler$$Lambda$426/0x00000008007f1040.accept(Unknown Source) app//org.apache.beam.runners.dataflow.worker.streaming.ExecutableWork.run(ExecutableWork.java:38) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor.lambda$executeMonitorHeld$0(BoundedQueueExecutor.java:234) app//org.apache.beam.runners.dataflow.worker.util.BoundedQueueExecutor$$Lambda$428/0x00000008007f1c40.run(Unknown Source) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[pool-14-thread-2,5,main]] State: WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) java.base@11.0.20/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) java.base@11.0.20/java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1177) java.base@11.0.20/java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:899) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) java.base@11.0.20/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base@11.0.20/java.lang.Thread.run(Thread.java:829) --- Threads (1): [Thread[qtp1322907569-23,5,main]] State: TIMED_WAITING stack: --- java.base@11.0.20/jdk.internal.misc.Unsafe.park(Native Method) java.base@11.0.20/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) java.base@11.0.20/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:382) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.idleJobPoll(QueuedThreadPool.java:974) app//org.apache.beam.runners.dataflow.worker.repackaged.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1018) java.base@11.0.20/java.lang.Thread.run(Thread.java:829)