Rexeh commented on issue #13593: URL: https://github.com/apache/iceberg/issues/13593#issuecomment-3112808455
Also getting the same issue, on 1.9.1 on MSK Connect using REST catalog setup. ` 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] [2025-07-24 09:45:44,209] INFO [iceberg-connector-latest\|task-0] Commit timeout reached. Commit ID: be2e26f0-9b92-4cb2-b591-27fdaf6d62bd (org.apache.iceberg.connect.channel.CommitState:106) -- | -- | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] [2025-07-24 09:45:44,219] WARN [iceberg-connector-latest\|task-0] Commit failed, will try again next cycle (org.apache.iceberg.connect.channel.Coordinator:135) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] java.lang.IllegalStateException: Connection pool shut down | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.core5.util.Asserts.check(Asserts.java:38) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.core5.pool.StrictConnPool.lease(StrictConnPool.java:175) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManager.lease(PoolingHttpClientConnectionManager.java:326) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.InternalExecRuntime.acquireEndpoint(InternalExecRuntime.java:105) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.ConnectExec.execute(ConnectExec.java:127) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.ProtocolExec.execute(ProtocolExec.java:192) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.ContentCompressionExec.execute(ContentCompressionExec.java:150) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.HttpRequestRetryExec.execute(HttpRequestRetryExec.java:113) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.RedirectExec.execute(RedirectExec.java:110) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.InternalHttpClient.doExecute(InternalHttpClient.java:183) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.hc.client5.http.impl.classic.CloseableHttpClient.execute(CloseableHttpClient.java:123) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.rest.HTTPClient.execute(HTTPClient.java:281) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.rest.BaseHTTPClient.get(BaseHTTPClient.java:77) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.rest.RESTSessionCatalog.loadInternal(RESTSessionCatalog.java:373) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.rest.RESTSessionCatalog.loadTable(RESTSessionCatalog.java:397) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.catalog.BaseSessionCatalog$AsCatalog.loadTable(BaseSessionCatalog.java:99) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.rest.RESTCatalog.loadTable(RESTCatalog.java:106) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.connect.channel.Coordinator.commitToTable(Coordinator.java:188) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.connect.channel.Coordinator.lambda$doCommit$1(Coordinator.java:152) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.util.Tasks$Builder.runTaskWithRetry(Tasks.java:413) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at org.apache.iceberg.util.Tasks$Builder$1.run(Tasks.java:315) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) | 2025-07-24T09:45:44.000Z | [Worker-0786d260f810b4b0d] at java.base/java.lang.Thread.run(Thread.java:840) ` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
