Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-9524

Missing OpenLineage Complete event during gracefully shutdown

XMLWordPrintable

      2025-10-02 11:10:29,842 ERROR [io.deb.ope.emi.DebeziumOpenLineageClient] (pool-10-thread-1) Failed to emit OpenLineage event:  [Error Occurred After Shutdown]: java.util.concurrent.Comp
              at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
              at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
              at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1770)
              at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
              at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
              at java.base/java.lang.Thread.run(Thread.java:1583)
      Caused by: java.lang.RuntimeException: java.lang.IllegalStateException: Connection pool shut down
              at io.debezium.openlineage.emitter.DebeziumOpenLineageClient.lambda$emit$1(DebeziumOpenLineageClient.java:66)
              at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1768)
              ... 3 more
      Caused by: java.lang.IllegalStateException: Connection pool shut down
              at org.apache.hc.core5.util.Asserts.check(Asserts.java:38)
              at org.apache.hc.core5.pool.StrictConnPool.lease(StrictConnPool.java:175)
              at org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManager.lease(PoolingHttpClientConnectionManager.java:326)
              at org.apache.hc.client5.http.impl.classic.InternalExecRuntime.acquireEndpoint(InternalExecRuntime.java:105)
              at org.apache.hc.client5.http.impl.classic.ConnectExec.execute(ConnectExec.java:127)
              at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51)
              at org.apache.hc.client5.http.impl.classic.ProtocolExec.execute(ProtocolExec.java:192)
              at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51)
              at org.apache.hc.client5.http.impl.classic.ContentCompressionExec.execute(ContentCompressionExec.java:150)
              at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51)
              at org.apache.hc.client5.http.impl.classic.HttpRequestRetryExec.execute(HttpRequestRetryExec.java:113)
              at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51)
              at org.apache.hc.client5.http.impl.classic.RedirectExec.execute(RedirectExec.java:110)
              at org.apache.hc.client5.http.impl.classic.ExecChainElement.execute(ExecChainElement.java:51)
              at org.apache.hc.client5.http.impl.classic.InternalHttpClient.doExecute(InternalHttpClient.java:183)
              at org.apache.hc.client5.http.impl.classic.CloseableHttpClient.execute(CloseableHttpClient.java:245)
              at org.apache.hc.client5.http.impl.classic.CloseableHttpClient.execute(CloseableHttpClient.java:188)
              at org.apache.hc.client5.http.impl.classic.CloseableHttpClient.execute(CloseableHttpClient.java:162)
              at io.openlineage.client.transports.HttpTransport.emit(HttpTransport.java:201)
              at io.openlineage.client.transports.HttpTransport.emit(HttpTransport.java:181)
              at io.openlineage.client.OpenLineageClient.lambda$emit$0(OpenLineageClient.java:86)
              at io.micrometer.core.instrument.composite.CompositeTimer.record(CompositeTimer.java:141)
              at io.openlineage.client.OpenLineageClient.emit(OpenLineageClient.java:86)
              at io.debezium.openlineage.emitter.DebeziumOpenLineageClient.lambda$emit$1(DebeziumOpenLineageClient.java:63)
              ... 4 more
       

              rh-ee-mvitale Mario Fiore Vitale
              rh-ee-mvitale Mario Fiore Vitale
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: