0 votes
in Other Questions by (400 points)

Dear All,

Apakah ada yang pernah mengalami connection closed pada jdbc dengan flink streaming.

2021-04-23 04:28:01,961 ERROR org.apache.flink.streaming.runtime.tasks.StreamTask          [] - Error during disposal of stream operator.

java.sql.SQLNonTransientConnectionException: [Cloudera][JDBC](10060) Connection has been closed.

        at com.cloudera.impala.exceptions.ExceptionConverter.toSQLException(Unknown Source) ~[blob_p-19d3c90d1802a9729abca7523d7d07ac8197a8af-e8b470e071013cfa42544e62f0cedd81:?]

        at com.cloudera.impala.jdbc.common.SConnection.closeConnection(Unknown Source) ~[blob_p-19d3c90d1802a9729abca7523d7d07ac8197a8af-e8b470e071013cfa42544e62f0cedd81:?]

        at com.cloudera.impala.jdbc.common.SConnection.abortInternal(Unknown Source) ~[blob_p-19d3c90d1802a9729abca7523d7d07ac8197a8af-e8b470e071013cfa42544e62f0cedd81:?]

        at com.cloudera.impala.jdbc.common.SConnection.close(Unknown Source) ~[blob_p-19d3c90d1802a9729abca7523d7d07ac8197a8af-e8b470e071013cfa42544e62f0cedd81:?]

        at telkomsel.ns.common.jdbc.CustomJdbcSink.close(CustomJdbcSink.java:131) ~[blob_p-19d3c90d1802a9729abca7523d7d07ac8197a8af-e8b470e071013cfa42544e62f0cedd81:?]

        at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43) ~[flink-dist_2.12-1.11.3.jar:1.11.3]

        at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.dispose(AbstractUdfStreamOperator.java:117) ~[flink-dist_2.12-1.11.3.jar:1.11.3]

        at org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:732) [flink-dist_2.12-1.11.3.jar:1.11.3]

        at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUpInvoke(StreamTask.java:648) [flink-dist_2.12-1.11.3.jar:1.11.3]

        at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:547) [flink-dist_2.12-1.11.3.jar:1.11.3]

        at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721) [flink-dist_2.12-1.11.3.jar:1.11.3]

        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546) [flink-dist_2.12-1.11.3.jar:1.11.3]

        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_281]

Thanks,

1 Answer

0 votes
Welcome to Labs247 Community, where you can ask questions and receive answers from other members of the community.
...