[Bug] Stale connections maintained inside the ClientPool

[junmuz]

Search before asking

• I searched in the issues and found nothing similar.

Paimon version

While using JdbcCatalog, we have observed stale connections being maintained inside the ClientPool. This results in failure leading to exceptions like below.

java.lang.RuntimeException: Commit failed after X millis with N retries, there maybe exist commit conflicts between multiple jobs.

Caused by: java.lang.RuntimeException: Exception occurs when committing snapshot .....

Caused by: java.sql.SQLNonTransientConnectionException: No operations allowed after connection closed.

Compute Engine

Flink

Minimal reproduce step

There is a test case added that produces the scenario.

What doesn't meet your expectations?

The connection should be validated before being returned for subsequent operational.

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!