INSERT INTO `dlink_job_history` VALUES (16, 1, '{\"jid\": \"fcd82f4089fe1d7fbd4f6b36b61e13e3\", \"now\": 1703755098927, \"name\": \"Mysql to es\", \"plan\": {\"jid\": \"fcd82f4089fe1d7fbd4f6b36b61e13e3\", \"name\": \"Mysql to es\", \"type\": \"STREAMING\", \"nodes\": [{\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"inputs\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"num\": 1, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[9]:Join(joinType=[LeftOuterJoin], where=[(id = product_id)], select=[id, name, description, product_id, EXPR$0], leftInputSpec=[JoinKeyContainsUniqueKey], rightInputSpec=[JoinKeyContainsUniqueKey])<br/>+- [10]:Calc(select=[id, name, description, EXPR$0])<br/>   +- [11]:ConstraintEnforcer[NotNullEnforcer(fields=[product_id])]<br/>      +- [11]:Sink(table=[default_catalog.default_database.enriched_orders], fields=[id, name, description, EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"operator\": \"\", \"description\": \"[1]:TableSourceScan(table=[[default_catalog, default_database, products]], fields=[id, name, description])<br/>+- [2]:DropUpdateBefore<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"inputs\": [{\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[7]:GroupAggregate(groupBy=[product_id], select=[product_id, ARRAY_AGGR_RETRACT($f0) AS EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"operator\": \"\", \"description\": \"[4]:TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[order_id, order_date, customer_name, price, product_id, order_status])<br/>+- [5]:Calc(select=[product_id, ROW(order_id, order_date, customer_name, price, order_status) AS $f0], where=[product_id IS NOT NULL])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}]}, \"state\": \"CANCELED\", \"duration\": 10632, \"end-time\": 1703755096809, \"vertices\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"name\": \"Source: products[1] -> DropUpdateBefore[2]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 1531, \"end-time\": 1703755096707, \"start-time\": 1703755095176, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"name\": \"Source: orders[4] -> Calc[5]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 1529, \"end-time\": 1703755096707, \"start-time\": 1703755095178, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"name\": \"GroupAggregate[7]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 1630, \"end-time\": 1703755096809, \"start-time\": 1703755095179, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"name\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 1529, \"end-time\": 1703755096708, \"start-time\": 1703755095179, \"parallelism\": 1, \"maxParallelism\": 128}], \"start-time\": 1703755086177, \"timestamps\": {\"FAILED\": 0, \"CREATED\": 1703755086343, \"FAILING\": 0, \"RUNNING\": 1703755086551, \"CANCELED\": 1703755096809, \"FINISHED\": 0, \"SUSPENDED\": 0, \"CANCELLING\": 1703755095964, \"RESTARTING\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 1703755086177}, \"isStoppable\": false, \"status-counts\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 4, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"maxParallelism\": -1}', '{\"timestamp\": null, \"truncated\": false, \"all-exceptions\": [], \"root-exception\": null, \"exceptionHistory\": {\"entries\": [], \"truncated\": false}}', '{\"counts\": {\"total\": 0, \"failed\": 0, \"restored\": 0, \"completed\": 0, \"in_progress\": 0}, \"latest\": {\"failed\": null, \"restored\": null, \"completed\": null, \"savepoint\": null}, \"history\": [], \"summary\": {\"state_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"persisted_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"processed_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"checkpointed_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"alignment_buffered\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": 0, \"p90\": 0, \"p95\": 0, \"p99\": 0, \"p999\": 0}, \"end_to_end_duration\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}}}', '{\"mode\": \"exactly_once\", \"timeout\": 600000, \"interval\": 3600000, \"min_pause\": 0, \"state_backend\": \"HashMapStateBackend\", \"max_concurrent\": 1, \"externalization\": {\"enabled\": false, \"delete_on_cancellation\": true}, \"checkpoint_storage\": \"JobManagerCheckpointStorage\", \"unaligned_checkpoints\": false, \"aligned_checkpoint_timeout\": 0, \"tolerable_failed_checkpoints\": 0, \"checkpoints_after_tasks_finish\": true}', '{\"jid\": \"fcd82f4089fe1d7fbd4f6b36b61e13e3\", \"name\": \"Mysql to es\", \"execution-config\": {\"user-config\": {}, \"execution-mode\": \"PIPELINED\", \"job-parallelism\": 1, \"restart-strategy\": \"Cluster level default restart strategy\", \"object-reuse-mode\": false}}', NULL, '{\"id\": 2, \"name\": \"Flink-on-k8s\", \"note\": null, \"type\": \"kubernetes-session\", \"alias\": \"Flink on k8s\", \"hosts\": \"flink-cluster-rest:8081\", \"status\": 1, \"taskId\": null, \"enabled\": true, \"version\": \"1.15.3\", \"tenantId\": 1, \"createTime\": [2023, 12, 28, 5, 0, 18], \"updateTime\": [2023, 12, 28, 5, 0, 18], \"applicationId\": null, \"autoRegisters\": false, \"jobManagerHost\": \"flink-cluster-rest:8081\", \"resourceManagerAddr\": null, \"clusterConfigurationId\": null}', NULL, '2023-12-28 17:18:19');
INSERT INTO `dlink_job_history` VALUES (17, 1, '{\"jid\": \"7cbc0826d2993bcf33c82292ce4d796f\", \"now\": 1703755270286, \"name\": \"Mysql to es\", \"plan\": {\"jid\": \"7cbc0826d2993bcf33c82292ce4d796f\", \"name\": \"Mysql to es\", \"type\": \"STREAMING\", \"nodes\": [{\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"inputs\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"num\": 1, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[9]:Join(joinType=[LeftOuterJoin], where=[(id = product_id)], select=[id, name, description, product_id, EXPR$0], leftInputSpec=[JoinKeyContainsUniqueKey], rightInputSpec=[JoinKeyContainsUniqueKey])<br/>+- [10]:Calc(select=[id, name, description, EXPR$0])<br/>   +- [11]:ConstraintEnforcer[NotNullEnforcer(fields=[product_id])]<br/>      +- [11]:Sink(table=[default_catalog.default_database.enriched_orders], fields=[id, name, description, EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"operator\": \"\", \"description\": \"[1]:TableSourceScan(table=[[default_catalog, default_database, products]], fields=[id, name, description])<br/>+- [2]:DropUpdateBefore<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"inputs\": [{\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[7]:GroupAggregate(groupBy=[product_id], select=[product_id, ARRAY_AGGR_RETRACT($f0) AS EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"operator\": \"\", \"description\": \"[4]:TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[order_id, order_date, customer_name, price, product_id, order_status])<br/>+- [5]:Calc(select=[product_id, ROW(order_id, order_date, customer_name, price, order_status) AS $f0], where=[product_id IS NOT NULL])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}]}, \"state\": \"CANCELED\", \"duration\": 11264, \"end-time\": 1703755267908, \"vertices\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"name\": \"Source: products[1] -> DropUpdateBefore[2]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 795, \"end-time\": 1703755267904, \"start-time\": 1703755267109, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"name\": \"Source: orders[4] -> Calc[5]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 796, \"end-time\": 1703755267905, \"start-time\": 1703755267109, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"name\": \"GroupAggregate[7]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 4, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 798, \"end-time\": 1703755267908, \"start-time\": 1703755267110, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"name\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 796, \"end-time\": 1703755267906, \"start-time\": 1703755267110, \"parallelism\": 1, \"maxParallelism\": 128}], \"start-time\": 1703755256644, \"timestamps\": {\"FAILED\": 0, \"CREATED\": 1703755256714, \"FAILING\": 0, \"RUNNING\": 1703755267109, \"CANCELED\": 1703755267908, \"FINISHED\": 0, \"SUSPENDED\": 0, \"CANCELLING\": 1703755267216, \"RESTARTING\": 1703755266108, \"RECONCILING\": 0, \"INITIALIZING\": 1703755256644}, \"isStoppable\": false, \"status-counts\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 4, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"maxParallelism\": -1}', '{\"timestamp\": 1703755266107, \"truncated\": false, \"all-exceptions\": [], \"root-exception\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionHistory\": {\"entries\": [{\"location\": \"10.10.7.7:40285\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #0\", \"timestamp\": 1703755266107, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}], \"truncated\": false}}', '{\"counts\": {\"total\": 0, \"failed\": 0, \"restored\": 0, \"completed\": 0, \"in_progress\": 0}, \"latest\": {\"failed\": null, \"restored\": null, \"completed\": null, \"savepoint\": null}, \"history\": [], \"summary\": {\"state_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"persisted_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"processed_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"checkpointed_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"alignment_buffered\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": 0, \"p90\": 0, \"p95\": 0, \"p99\": 0, \"p999\": 0}, \"end_to_end_duration\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}}}', '{\"mode\": \"exactly_once\", \"timeout\": 600000, \"interval\": 3600000, \"min_pause\": 0, \"state_backend\": \"HashMapStateBackend\", \"max_concurrent\": 1, \"externalization\": {\"enabled\": false, \"delete_on_cancellation\": true}, \"checkpoint_storage\": \"JobManagerCheckpointStorage\", \"unaligned_checkpoints\": false, \"aligned_checkpoint_timeout\": 0, \"tolerable_failed_checkpoints\": 0, \"checkpoints_after_tasks_finish\": true}', '{\"jid\": \"7cbc0826d2993bcf33c82292ce4d796f\", \"name\": \"Mysql to es\", \"execution-config\": {\"user-config\": {}, \"execution-mode\": \"PIPELINED\", \"job-parallelism\": 1, \"restart-strategy\": \"Cluster level default restart strategy\", \"object-reuse-mode\": false}}', NULL, '{\"id\": 2, \"name\": \"Flink-on-k8s\", \"note\": null, \"type\": \"kubernetes-session\", \"alias\": \"Flink on k8s\", \"hosts\": \"flink-cluster-rest:8081\", \"status\": 1, \"taskId\": null, \"enabled\": true, \"version\": \"1.15.3\", \"tenantId\": 1, \"createTime\": [2023, 12, 28, 5, 0, 18], \"updateTime\": [2023, 12, 28, 5, 0, 18], \"applicationId\": null, \"autoRegisters\": false, \"jobManagerHost\": \"flink-cluster-rest:8081\", \"resourceManagerAddr\": null, \"clusterConfigurationId\": null}', NULL, '2023-12-28 17:21:10');
INSERT INTO `dlink_job_history` VALUES (18, 1, '{\"jid\": \"298b3247f1c4bddfd0b4f3ffb09f2e91\", \"now\": 1703760451324, \"name\": \"Mysql to es\", \"plan\": {\"jid\": \"298b3247f1c4bddfd0b4f3ffb09f2e91\", \"name\": \"Mysql to es\", \"type\": \"STREAMING\", \"nodes\": [{\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"inputs\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"num\": 1, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[20]:Join(joinType=[LeftOuterJoin], where=[(id = product_id)], select=[id, name, description, product_id, EXPR$0], leftInputSpec=[JoinKeyContainsUniqueKey], rightInputSpec=[JoinKeyContainsUniqueKey])<br/>+- [21]:Calc(select=[id, name, description, EXPR$0])<br/>   +- [22]:ConstraintEnforcer[NotNullEnforcer(fields=[product_id])]<br/>      +- [22]:Sink(table=[default_catalog.default_database.enriched_orders], fields=[id, name, description, EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"operator\": \"\", \"description\": \"[12]:TableSourceScan(table=[[default_catalog, default_database, products]], fields=[id, name, description])<br/>+- [13]:DropUpdateBefore<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"inputs\": [{\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[18]:GroupAggregate(groupBy=[product_id], select=[product_id, ARRAY_AGGR_RETRACT($f0) AS EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"operator\": \"\", \"description\": \"[15]:TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[order_id, order_date, customer_name, price, product_id, order_status])<br/>+- [16]:Calc(select=[product_id, ROW(order_id, order_date, customer_name, price, order_status) AS $f0], where=[product_id IS NOT NULL])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}]}, \"state\": \"RUNNING\", \"duration\": 426352, \"end-time\": -1, \"vertices\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"name\": \"Source: products[12] -> DropUpdateBefore[13]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 1}, \"status\": \"INITIALIZING\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 894, \"end-time\": -1, \"start-time\": 1703760450430, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"name\": \"Source: orders[15] -> Calc[16]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 1, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CREATED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 894, \"end-time\": -1, \"start-time\": 1703760450430, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"name\": \"GroupAggregate[18]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 1, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CREATED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 894, \"end-time\": -1, \"start-time\": 1703760450430, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"name\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 1, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CREATED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 894, \"end-time\": -1, \"start-time\": 1703760450430, \"parallelism\": 1, \"maxParallelism\": 128}], \"start-time\": 1703760024972, \"timestamps\": {\"FAILED\": 0, \"CREATED\": 1703760024974, \"FAILING\": 0, \"RUNNING\": 1703760450429, \"CANCELED\": 0, \"FINISHED\": 0, \"SUSPENDED\": 0, \"CANCELLING\": 0, \"RESTARTING\": 1703760449375, \"RECONCILING\": 0, \"INITIALIZING\": 1703760024972}, \"isStoppable\": false, \"status-counts\": {\"FAILED\": 0, \"CREATED\": 3, \"RUNNING\": 0, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 1}, \"maxParallelism\": -1}', '{\"timestamp\": 1703760449375, \"truncated\": false, \"all-exceptions\": [], \"root-exception\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionHistory\": {\"entries\": [{\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #410\", \"timestamp\": 1703760449375, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #409\", \"timestamp\": 1703760448242, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #408\", \"timestamp\": 1703760447173, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #407\", \"timestamp\": 1703760446056, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #406\", \"timestamp\": 1703760445009, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #405\", \"timestamp\": 1703760443968, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #404\", \"timestamp\": 1703760442913, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #403\", \"timestamp\": 1703760441863, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #402\", \"timestamp\": 1703760440819, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}, {\"location\": \"localhost:44863\", \"taskName\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22] (1/1) - execution #401\", \"timestamp\": 1703760439728, \"stacktrace\": \"java.lang.RuntimeException: error while performing request\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:889)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Thread.java:834)\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ProtocolException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:209)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:245)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:81)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:39)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:114)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)\\n\\t... 1 more\\nCaused by: org.apache.flink.elasticsearch7.shaded.org.apache.http.ParseException: Not a valid protocol version: This is not an HTTP port\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseProtocolVersion(BasicLineParser.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.message.BasicLineParser.parseStatusLine(BasicLineParser.java:366)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:112)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.DefaultHttpResponseParser.createMessage(DefaultHttpResponseParser.java:50)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parseHeadLine(AbstractMessageParser.java:156)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:207)\\n\\t... 11 more\\n\", \"exceptionName\": \"java.lang.RuntimeException\", \"concurrentExceptions\": []}], \"truncated\": true}}', '{\"counts\": {\"total\": 0, \"failed\": 0, \"restored\": 0, \"completed\": 0, \"in_progress\": 0}, \"latest\": {\"failed\": null, \"restored\": null, \"completed\": null, \"savepoint\": null}, \"history\": [], \"summary\": {\"state_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"persisted_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"processed_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"checkpointed_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"alignment_buffered\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": 0, \"p90\": 0, \"p95\": 0, \"p99\": 0, \"p999\": 0}, \"end_to_end_duration\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}}}', '{\"mode\": \"exactly_once\", \"timeout\": 600000, \"interval\": 3600000, \"min_pause\": 0, \"state_backend\": \"HashMapStateBackend\", \"max_concurrent\": 1, \"externalization\": {\"enabled\": false, \"delete_on_cancellation\": true}, \"checkpoint_storage\": \"JobManagerCheckpointStorage\", \"unaligned_checkpoints\": false, \"aligned_checkpoint_timeout\": 0, \"tolerable_failed_checkpoints\": 0, \"checkpoints_after_tasks_finish\": true}', '{\"jid\": \"298b3247f1c4bddfd0b4f3ffb09f2e91\", \"name\": \"Mysql to es\", \"execution-config\": {\"user-config\": {}, \"execution-mode\": \"PIPELINED\", \"job-parallelism\": 1, \"restart-strategy\": \"Cluster level default restart strategy\", \"object-reuse-mode\": false}}', NULL, '{\"id\": 1, \"name\": \"Flink-63.102\", \"note\": null, \"type\": \"standalone\", \"alias\": \"Flink.15.3\", \"hosts\": \"192.168.63.102:8081\", \"status\": 1, \"taskId\": null, \"enabled\": true, \"version\": \"1.15.3\", \"tenantId\": 1, \"createTime\": [2023, 12, 28, 4, 58, 13], \"updateTime\": [2023, 12, 28, 4, 58, 13], \"applicationId\": null, \"autoRegisters\": false, \"jobManagerHost\": \"192.168.63.102:8081\", \"resourceManagerAddr\": null, \"clusterConfigurationId\": null}', '{\"id\": 1, \"name\": \"flink-on-native-k8s\", \"note\": null, \"type\": \"Kubernetes\", \"alias\": \"flink-on-native-k8s\", \"config\": {\"flinkConfig\": {\"taskmanager.numberOfTaskSlots\": \"3\", \"jobmanager.memory.process.size\": \"1024m\", \"taskmanager.memory.process.size\": \"1024m\", \"taskmanager.memory.framework.heap.size\": \"1024m\"}, \"dockerConfig\": {\"kubernetes.cluster-id\": \"flink-application-cluster\", \"env.java.opts.jobmanager\": \"-Duser.timezone=GMT+08\", \"env.java.opts.taskmanager\": \"-Duser.timezone=GMT+08\", \"kubernetes.container.image.pull-secrets\": \"registry-private-secret\"}, \"flinkConfigPath\": \"/opt/flink/conf\", \"kubernetesConfig\": {\"kubernetes.namespace\": \"flink-test\", \"kubernetes.cluster-id\": \"flink-application-cluster\", \"env.java.opts.jobmanager\": \"-Duser.timezone=GMT+08\", \"env.java.opts.taskmanager\": \"-Duser.timezone=GMT+08\", \"kubernetes.jobmanager.cpu\": \"0.2\", \"kubernetes.container.image\": \"registry.zerofinance.net/library/dinky-flink:1.15.3\", \"kubernetes.taskmanager.cpu\": \"0.2\", \"kubernetes.rest-service.exposed.type\": \"NodePort\", \"kubernetes.container.image.pull-secrets\": \"registry-private-secret\"}}, \"enabled\": true, \"tenantId\": 1, \"configJson\": \"{\\\"flinkConfigPath\\\":\\\"/opt/flink/conf\\\",\\\"kubernetesConfig\\\":{\\\"kubernetes.namespace\\\":\\\"flink-test\\\",\\\"kubernetes.container.image\\\":\\\"registry.zerofinance.net/library/dinky-flink:1.15.3\\\",\\\"kubernetes.rest-service.exposed.type\\\":\\\"NodePort\\\",\\\"kubernetes.jobmanager.cpu\\\":\\\"0.2\\\",\\\"kubernetes.taskmanager.cpu\\\":\\\"0.2\\\",\\\"kubernetes.cluster-id\\\":\\\"flink-application-cluster\\\",\\\"kubernetes.container.image.pull-secrets\\\":\\\"registry-private-secret\\\",\\\"env.java.opts.jobmanager\\\":\\\"-Duser.timezone=GMT+08\\\",\\\"env.java.opts.taskmanager\\\":\\\"-Duser.timezone=GMT+08\\\"},\\\"dockerConfig\\\":{\\\"kubernetes.cluster-id\\\":\\\"flink-application-cluster\\\",\\\"kubernetes.container.image.pull-secrets\\\":\\\"registry-private-secret\\\",\\\"env.java.opts.jobmanager\\\":\\\"-Duser.timezone=GMT+08\\\",\\\"env.java.opts.taskmanager\\\":\\\"-Duser.timezone=GMT+08\\\"},\\\"flinkConfig\\\":{\\\"jobmanager.memory.process.size\\\":\\\"1024m\\\",\\\"taskmanager.memory.process.size\\\":\\\"1024m\\\",\\\"taskmanager.memory.framework.heap.size\\\":\\\"1024m\\\",\\\"taskmanager.numberOfTaskSlots\\\":\\\"3\\\"}}\", \"createTime\": [2023, 12, 28, 18, 37, 48], \"updateTime\": [2023, 12, 28, 18, 39, 55], \"isAvailable\": true}', '2023-12-28 18:58:52');
INSERT INTO `dlink_job_history` VALUES (19, 1, '{\"jid\": \"0488bc0ec0edac07e8138a16803506ed\", \"now\": 1703821092239, \"name\": \"udf_sub_test\", \"plan\": {\"jid\": \"0488bc0ec0edac07e8138a16803506ed\", \"name\": \"udf_sub_test\", \"type\": \"STREAMING\", \"nodes\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"operator\": \"\", \"description\": \"[1]:TableSourceScan(table=[[default_catalog, default_database, sourceTable]], fields=[id, java_c])<br/>+- [2]:Calc(select=[id, sb_j(java_c) AS EXPR$1])<br/>   +- [3]:Sink(table=[default_catalog.default_database.sinkTable], fields=[id, EXPR$1])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}]}, \"state\": \"CANCELED\", \"duration\": 248569, \"end-time\": 1703821090514, \"vertices\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"name\": \"Source: sourceTable[1] -> Calc[2] -> Sink: sinkTable[3]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 169899, \"end-time\": 1703821090513, \"start-time\": 1703820920614, \"parallelism\": 1, \"maxParallelism\": 128}], \"start-time\": 1703820841945, \"timestamps\": {\"FAILED\": 0, \"CREATED\": 1703820842156, \"FAILING\": 0, \"RUNNING\": 1703820842337, \"CANCELED\": 1703821090514, \"FINISHED\": 0, \"SUSPENDED\": 0, \"CANCELLING\": 1703821090354, \"RESTARTING\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 1703820841945}, \"isStoppable\": false, \"status-counts\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"maxParallelism\": -1}', '{\"timestamp\": null, \"truncated\": false, \"all-exceptions\": [], \"root-exception\": null, \"exceptionHistory\": {\"entries\": [], \"truncated\": false}}', '{\"counts\": {\"total\": 0, \"failed\": 0, \"restored\": 0, \"completed\": 0, \"in_progress\": 0}, \"latest\": {\"failed\": null, \"restored\": null, \"completed\": null, \"savepoint\": null}, \"history\": [], \"summary\": {\"state_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"persisted_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"processed_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"checkpointed_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"alignment_buffered\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": 0, \"p90\": 0, \"p95\": 0, \"p99\": 0, \"p999\": 0}, \"end_to_end_duration\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}}}', '{\"mode\": \"at_least_once\", \"timeout\": 600000, \"interval\": 9223372036854775807, \"min_pause\": 0, \"state_backend\": \"HashMapStateBackend\", \"max_concurrent\": 1, \"externalization\": {\"enabled\": false, \"delete_on_cancellation\": true}, \"checkpoint_storage\": \"JobManagerCheckpointStorage\", \"unaligned_checkpoints\": false, \"aligned_checkpoint_timeout\": 0, \"tolerable_failed_checkpoints\": 0, \"checkpoints_after_tasks_finish\": true}', '{\"jid\": \"0488bc0ec0edac07e8138a16803506ed\", \"name\": \"udf_sub_test\", \"execution-config\": {\"user-config\": {}, \"execution-mode\": \"PIPELINED\", \"job-parallelism\": 1, \"restart-strategy\": \"Cluster level default restart strategy\", \"object-reuse-mode\": false}}', NULL, '{\"id\": 2, \"name\": \"Flink-on-k8s\", \"note\": null, \"type\": \"kubernetes-session\", \"alias\": \"Flink on k8s\", \"hosts\": \"flink-cluster-rest:8081\", \"status\": 1, \"taskId\": null, \"enabled\": true, \"version\": \"1.15.3\", \"tenantId\": 1, \"createTime\": [2023, 12, 28, 5, 0, 18], \"updateTime\": [2023, 12, 28, 5, 0, 18], \"applicationId\": null, \"autoRegisters\": false, \"jobManagerHost\": \"flink-cluster-rest:8081\", \"resourceManagerAddr\": null, \"clusterConfigurationId\": null}', NULL, '2023-12-29 11:38:12');
INSERT INTO `dlink_job_history` VALUES (20, 1, '{\"jid\": \"89d5894a5258c212d7ea15affe0b1fe7\", \"now\": 1703825633146, \"name\": \"mysql-to-es-session\", \"plan\": {\"jid\": \"89d5894a5258c212d7ea15affe0b1fe7\", \"name\": \"mysql-to-es-session\", \"type\": \"STREAMING\", \"nodes\": [{\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"inputs\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"num\": 1, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[9]:Join(joinType=[LeftOuterJoin], where=[(id = product_id)], select=[id, name, description, product_id, EXPR$0], leftInputSpec=[JoinKeyContainsUniqueKey], rightInputSpec=[JoinKeyContainsUniqueKey])<br/>+- [10]:Calc(select=[id, name, description, EXPR$0])<br/>   +- [11]:ConstraintEnforcer[NotNullEnforcer(fields=[product_id])]<br/>      +- [11]:Sink(table=[default_catalog.default_database.enriched_orders], fields=[id, name, description, EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"operator\": \"\", \"description\": \"[1]:TableSourceScan(table=[[default_catalog, default_database, products]], fields=[id, name, description])<br/>+- [2]:DropUpdateBefore<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"inputs\": [{\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[7]:GroupAggregate(groupBy=[product_id], select=[product_id, ARRAY_AGGR_RETRACT($f0) AS EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"operator\": \"\", \"description\": \"[4]:TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[order_id, order_date, customer_name, price, product_id, order_status])<br/>+- [5]:Calc(select=[product_id, ROW(order_id, order_date, customer_name, price, order_status) AS $f0], where=[product_id IS NOT NULL])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}]}, \"state\": \"CANCELED\", \"duration\": 261101, \"end-time\": 1703825631035, \"vertices\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"name\": \"Source: products[1] -> DropUpdateBefore[2]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 1122, \"end-time\": 1703825631034, \"start-time\": 1703825629912, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"name\": \"Source: orders[4] -> Calc[5]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 1023, \"end-time\": 1703825630935, \"start-time\": 1703825629912, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"name\": \"GroupAggregate[7]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 1, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"CANCELED\", \"metrics\": {\"read-bytes\": 4, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 797, \"end-time\": 1703825630709, \"start-time\": 1703825629912, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"name\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11]\", \"tasks\": {\"FAILED\": 1, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"FAILED\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 0, \"read-records\": 0, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 597, \"end-time\": 1703825630509, \"start-time\": 1703825629912, \"parallelism\": 1, \"maxParallelism\": 128}], \"start-time\": 1703825369934, \"timestamps\": {\"FAILED\": 0, \"CREATED\": 1703825370342, \"FAILING\": 0, \"RUNNING\": 1703825629910, \"CANCELED\": 1703825631035, \"FINISHED\": 0, \"SUSPENDED\": 0, \"CANCELLING\": 1703825630562, \"RESTARTING\": 1703825630511, \"RECONCILING\": 0, \"INITIALIZING\": 1703825369934}, \"isStoppable\": false, \"status-counts\": {\"FAILED\": 1, \"CREATED\": 0, \"RUNNING\": 0, \"CANCELED\": 3, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"maxParallelism\": -1}', '{\"timestamp\": 1703825630510, \"truncated\": false, \"all-exceptions\": [{\"task\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1)\", \"location\": \"10.10.1.83:35933\", \"exception\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"timestamp\": 1703825630509}], \"root-exception\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionHistory\": {\"entries\": [{\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #74\", \"timestamp\": 1703825628908, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #73\", \"timestamp\": 1703825627510, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #72\", \"timestamp\": 1703825626012, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #71\", \"timestamp\": 1703825624508, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #70\", \"timestamp\": 1703825622908, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #69\", \"timestamp\": 1703825621209, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #68\", \"timestamp\": 1703825619512, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #67\", \"timestamp\": 1703825617809, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #66\", \"timestamp\": 1703825616209, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}, {\"location\": \"10.10.1.83:35933\", \"taskName\": \"Join[9] -> Calc[10] -> ConstraintEnforcer[11] -> Sink: enriched_orders[11] (1/1) - execution #65\", \"timestamp\": 1703825614408, \"stacktrace\": \"java.net.ConnectException: Connection refused\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:879)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1632)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1617)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.elasticsearch.client.RestHighLevelClient.ping(RestHighLevelClient.java:775)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:144)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7ApiCallBridge.verifyClientConnection(Elasticsearch7ApiCallBridge.java:46)\\n\\tat org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.open(ElasticsearchSinkBase.java:317)\\n\\tat org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)\\n\\tat org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)\\n\\tat org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58)\\n\\tat org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:703)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:679)\\n\\tat org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:646)\\n\\tat org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)\\n\\tat org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)\\n\\tat org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)\\n\\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by: java.net.ConnectException: Connection refused\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\\n\\tat java.base/sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\\n\\tat org.apache.flink.elasticsearch7.shaded.org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\\n\\t... 1 more\\n\", \"exceptionName\": \"java.net.ConnectException\", \"concurrentExceptions\": []}], \"truncated\": true}}', '{\"counts\": {\"total\": 0, \"failed\": 0, \"restored\": 0, \"completed\": 0, \"in_progress\": 0}, \"latest\": {\"failed\": null, \"restored\": null, \"completed\": null, \"savepoint\": null}, \"history\": [], \"summary\": {\"state_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"persisted_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"processed_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"checkpointed_size\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}, \"alignment_buffered\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": 0, \"p90\": 0, \"p95\": 0, \"p99\": 0, \"p999\": 0}, \"end_to_end_duration\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": \"NaN\", \"p90\": \"NaN\", \"p95\": \"NaN\", \"p99\": \"NaN\", \"p999\": \"NaN\"}}}', '{\"mode\": \"exactly_once\", \"timeout\": 600000, \"interval\": 3600000, \"min_pause\": 0, \"state_backend\": \"HashMapStateBackend\", \"max_concurrent\": 1, \"externalization\": {\"enabled\": false, \"delete_on_cancellation\": true}, \"checkpoint_storage\": \"JobManagerCheckpointStorage\", \"unaligned_checkpoints\": false, \"aligned_checkpoint_timeout\": 0, \"tolerable_failed_checkpoints\": 0, \"checkpoints_after_tasks_finish\": true}', '{\"jid\": \"89d5894a5258c212d7ea15affe0b1fe7\", \"name\": \"mysql-to-es-session\", \"execution-config\": {\"user-config\": {}, \"execution-mode\": \"PIPELINED\", \"job-parallelism\": 1, \"restart-strategy\": \"Cluster level default restart strategy\", \"object-reuse-mode\": false}}', NULL, '{\"id\": 2, \"name\": \"Flink-on-session-k8s\", \"note\": null, \"type\": \"kubernetes-session\", \"alias\": \"Flink on session k8s\", \"hosts\": \"flink-cluster-rest:8081\", \"status\": 1, \"taskId\": null, \"enabled\": true, \"version\": \"1.15.3\", \"tenantId\": 1, \"createTime\": [2023, 12, 28, 5, 0, 18], \"updateTime\": [2023, 12, 29, 11, 56, 10], \"applicationId\": null, \"autoRegisters\": false, \"jobManagerHost\": \"flink-cluster-rest:8081\", \"resourceManagerAddr\": null, \"clusterConfigurationId\": null}', '{\"id\": 1, \"name\": \"flink-on-native-k8s\", \"note\": null, \"type\": \"Kubernetes\", \"alias\": \"flink on native k8s\", \"config\": {\"flinkConfig\": {\"fs.oss.endpoint\": \"https://oss-cn-hongkong.aliyuncs.com\", \"high-availability\": \"org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory\", \"fs.oss.accessKeyId\": \"LTAI2pFx7EflElP7\", \"fs.oss.accessKeySecret\": \"unsebaUQA23EqZyBq80rldSeHFDKuO\", \"env.java.opts.jobmanager\": \"-Duser.timezone=GMT+08\", \"env.java.opts.taskmanager\": \"-Duser.timezone=GMT+08\", \"high-availability.storageDir\": \"oss://flink-ha-test/native-recovery\", \"taskmanager.numberOfTaskSlots\": \"3\", \"jobmanager.memory.process.size\": \"1024m\", \"kubernetes.jobmanager.replicas\": \"1\", \"taskmanager.memory.process.size\": \"1024m\", \"resourcemanager.taskmanager-timeout\": \"86400000\", \"taskmanager.memory.framework.heap.size\": \"\"}, \"dockerConfig\": {\"docker.instance\": \"\", \"dinky.remote.addr\": \"\", \"docker.registry.url\": \"\", \"kubernetes.cluster-id\": \"flink-application-cluster\", \"docker.image.namespace\": \"\", \"docker.image.storehouse\": \"\", \"docker.registry.password\": \"\", \"docker.registry.username\": \"\", \"docker.image.dinkyVersion\": \"\", \"kubernetes.taskmanager.node-selector\": \"flink-env:test\", \"kubernetes.container.image.pull-policy\": \"Always\", \"kubernetes.container.image.pull-secrets\": \"registry-private-secret\"}, \"flinkConfigPath\": \"/opt/dinky/conf\", \"kubernetesConfig\": {\"kubernetes.namespace\": \"flink-test\", \"kubernetes.cluster-id\": \"flink-application-cluster\", \"kubernetes.jobmanager.cpu\": \"0.2\", \"kubernetes.container.image\": \"registry.zerofinance.net/library/dinky-flink-application:1.15.3\", \"kubernetes.taskmanager.cpu\": \"0.2\", \"kubernetes.rest-service.exposed.type\": \"NodePort\", \"kubernetes.taskmanager.node-selector\": \"flink-env:test\", \"kubernetes.container.image.pull-policy\": \"Always\", \"kubernetes.container.image.pull-secrets\": \"registry-private-secret\"}}, \"enabled\": true, \"tenantId\": 1, \"configJson\": \"{\\\"flinkConfigPath\\\":\\\"/opt/dinky/conf\\\",\\\"kubernetesConfig\\\":{\\\"kubernetes.namespace\\\":\\\"flink-test\\\",\\\"kubernetes.container.image\\\":\\\"registry.zerofinance.net/library/dinky-flink-application:1.15.3\\\",\\\"kubernetes.rest-service.exposed.type\\\":\\\"NodePort\\\",\\\"kubernetes.jobmanager.cpu\\\":\\\"0.2\\\",\\\"kubernetes.taskmanager.cpu\\\":\\\"0.2\\\",\\\"kubernetes.cluster-id\\\":\\\"flink-application-cluster\\\",\\\"kubernetes.container.image.pull-secrets\\\":\\\"registry-private-secret\\\",\\\"kubernetes.taskmanager.node-selector\\\":\\\"flink-env:test\\\",\\\"kubernetes.container.image.pull-policy\\\":\\\"Always\\\"},\\\"dockerConfig\\\":{\\\"docker.instance\\\":\\\"\\\",\\\"docker.registry.url\\\":\\\"\\\",\\\"docker.registry.username\\\":\\\"\\\",\\\"docker.registry.password\\\":\\\"\\\",\\\"docker.image.namespace\\\":\\\"\\\",\\\"docker.image.storehouse\\\":\\\"\\\",\\\"docker.image.dinkyVersion\\\":\\\"\\\",\\\"dinky.remote.addr\\\":\\\"\\\",\\\"kubernetes.cluster-id\\\":\\\"flink-application-cluster\\\",\\\"kubernetes.container.image.pull-secrets\\\":\\\"registry-private-secret\\\",\\\"kubernetes.taskmanager.node-selector\\\":\\\"flink-env:test\\\",\\\"kubernetes.container.image.pull-policy\\\":\\\"Always\\\"},\\\"flinkConfig\\\":{\\\"jobmanager.memory.process.size\\\":\\\"1024m\\\",\\\"taskmanager.memory.process.size\\\":\\\"1024m\\\",\\\"taskmanager.memory.framework.heap.size\\\":\\\"\\\",\\\"taskmanager.numberOfTaskSlots\\\":\\\"3\\\",\\\"fs.oss.endpoint\\\":\\\"https://oss-cn-hongkong.aliyuncs.com\\\",\\\"fs.oss.accessKeyId\\\":\\\"LTAI2pFx7EflElP7\\\",\\\"fs.oss.accessKeySecret\\\":\\\"unsebaUQA23EqZyBq80rldSeHFDKuO\\\",\\\"high-availability\\\":\\\"org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory\\\",\\\"high-availability.storageDir\\\":\\\"oss://flink-ha-test/native-recovery\\\",\\\"env.java.opts.jobmanager\\\":\\\"-Duser.timezone=GMT+08\\\",\\\"env.java.opts.taskmanager\\\":\\\"-Duser.timezone=GMT+08\\\",\\\"resourcemanager.taskmanager-timeout\\\":\\\"86400000\\\",\\\"kubernetes.jobmanager.replicas\\\":\\\"1\\\"}}\", \"createTime\": [2023, 12, 28, 18, 37, 48], \"updateTime\": [2023, 12, 29, 11, 56, 25], \"isAvailable\": true}', '2023-12-29 12:53:53');
INSERT INTO `dlink_job_history` VALUES (21, 1, '{\"jid\": \"ccded83cc23eaca491fcd3939f96ec02\", \"now\": 1703829685051, \"name\": \"mysql-to-es-session\", \"plan\": {\"jid\": \"ccded83cc23eaca491fcd3939f96ec02\", \"name\": \"mysql-to-es-session\", \"type\": \"STREAMING\", \"nodes\": [{\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"inputs\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"num\": 1, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[20]:Join(joinType=[LeftOuterJoin], where=[(id = product_id)], select=[id, name, description, product_id, EXPR$0], leftInputSpec=[JoinKeyContainsUniqueKey], rightInputSpec=[JoinKeyContainsUniqueKey])<br/>+- [21]:Calc(select=[id, name, description, EXPR$0])<br/>   +- [22]:ConstraintEnforcer[NotNullEnforcer(fields=[product_id])]<br/>      +- [22]:Sink(table=[default_catalog.default_database.enriched_orders], fields=[id, name, description, EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"operator\": \"\", \"description\": \"[12]:TableSourceScan(table=[[default_catalog, default_database, products]], fields=[id, name, description])<br/>+- [13]:DropUpdateBefore<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"inputs\": [{\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"num\": 0, \"exchange\": \"pipelined_bounded\", \"ship_strategy\": \"HASH\"}], \"operator\": \"\", \"description\": \"[18]:GroupAggregate(groupBy=[product_id], select=[product_id, ARRAY_AGGR_RETRACT($f0) AS EXPR$0])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"operator\": \"\", \"description\": \"[15]:TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[order_id, order_date, customer_name, price, product_id, order_status])<br/>+- [16]:Calc(select=[product_id, ROW(order_id, order_date, customer_name, price, order_status) AS $f0], where=[product_id IS NOT NULL])<br/>\", \"parallelism\": 1, \"operator_strategy\": \"\", \"optimizer_properties\": {}}]}, \"state\": \"RUNNING\", \"duration\": 4000808, \"end-time\": -1, \"vertices\": [{\"id\": \"cbc357ccb763df2852fee8c4fc7d55f2\", \"name\": \"Source: products[12] -> DropUpdateBefore[13]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 1, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"RUNNING\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 283, \"read-records\": 0, \"write-records\": 3, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 3990232, \"end-time\": -1, \"start-time\": 1703825694819, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"6cdc5bb954874d922eaee11a8e7b5dd5\", \"name\": \"Source: orders[15] -> Calc[16]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 1, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"RUNNING\", \"metrics\": {\"read-bytes\": 0, \"write-bytes\": 340, \"read-records\": 0, \"write-records\": 4, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 3990229, \"end-time\": -1, \"start-time\": 1703825694822, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"5b0aee73f63c0af694c4357edc32a3e0\", \"name\": \"GroupAggregate[18]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 1, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"RUNNING\", \"metrics\": {\"read-bytes\": 382, \"write-bytes\": 460, \"read-records\": 4, \"write-records\": 4, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 3990229, \"end-time\": -1, \"start-time\": 1703825694822, \"parallelism\": 1, \"maxParallelism\": 128}, {\"id\": \"b8728af571f7a2955489b16d54ef3dd7\", \"name\": \"Join[20] -> Calc[21] -> ConstraintEnforcer[22] -> Sink: enriched_orders[22]\", \"tasks\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 1, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"status\": \"RUNNING\", \"metrics\": {\"read-bytes\": 827, \"write-bytes\": 0, \"read-records\": 7, \"write-records\": 0, \"read-bytes-complete\": true, \"write-bytes-complete\": true, \"read-records-complete\": true, \"write-records-complete\": true}, \"duration\": 3990229, \"end-time\": -1, \"start-time\": 1703825694822, \"parallelism\": 1, \"maxParallelism\": 128}], \"start-time\": 1703825684243, \"timestamps\": {\"FAILED\": 0, \"CREATED\": 1703825684363, \"FAILING\": 0, \"RUNNING\": 1703825685036, \"CANCELED\": 0, \"FINISHED\": 0, \"SUSPENDED\": 0, \"CANCELLING\": 0, \"RESTARTING\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 1703825684243}, \"isStoppable\": false, \"status-counts\": {\"FAILED\": 0, \"CREATED\": 0, \"RUNNING\": 4, \"CANCELED\": 0, \"FINISHED\": 0, \"CANCELING\": 0, \"DEPLOYING\": 0, \"SCHEDULED\": 0, \"RECONCILING\": 0, \"INITIALIZING\": 0}, \"maxParallelism\": -1}', '{\"timestamp\": null, \"truncated\": false, \"all-exceptions\": [], \"root-exception\": null, \"exceptionHistory\": {\"entries\": [], \"truncated\": false}}', '{\"counts\": {\"total\": 1, \"failed\": 0, \"restored\": 0, \"completed\": 1, \"in_progress\": 0}, \"latest\": {\"failed\": null, \"restored\": null, \"completed\": {\"id\": 1, \"tasks\": {}, \"status\": \"COMPLETED\", \"className\": \"completed\", \"discarded\": false, \"state_size\": 31581, \"is_savepoint\": false, \"num_subtasks\": 4, \"external_path\": \"<checkpoint-not-externally-addressable>\", \"persisted_data\": 0, \"processed_data\": 0, \"checkpoint_type\": \"CHECKPOINT\", \"checkpointed_size\": 31581, \"trigger_timestamp\": 1703827223472, \"alignment_buffered\": 0, \"end_to_end_duration\": 1441, \"latest_ack_timestamp\": 1703827224913, \"num_acknowledged_subtasks\": 4}, \"savepoint\": null}, \"history\": [{\"id\": 1, \"tasks\": {}, \"status\": \"COMPLETED\", \"className\": \"completed\", \"discarded\": false, \"state_size\": 31581, \"is_savepoint\": false, \"num_subtasks\": 4, \"external_path\": \"<checkpoint-not-externally-addressable>\", \"persisted_data\": 0, \"processed_data\": 0, \"checkpoint_type\": \"CHECKPOINT\", \"checkpointed_size\": 31581, \"trigger_timestamp\": 1703827223472, \"alignment_buffered\": 0, \"end_to_end_duration\": 1441, \"latest_ack_timestamp\": 1703827224913, \"num_acknowledged_subtasks\": 4}], \"summary\": {\"state_size\": {\"avg\": 31581, \"max\": 31581, \"min\": 31581, \"p50\": 31581, \"p90\": 31581, \"p95\": 31581, \"p99\": 31581, \"p999\": 31581}, \"persisted_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": 0, \"p90\": 0, \"p95\": 0, \"p99\": 0, \"p999\": 0}, \"processed_data\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": 0, \"p90\": 0, \"p95\": 0, \"p99\": 0, \"p999\": 0}, \"checkpointed_size\": {\"avg\": 31581, \"max\": 31581, \"min\": 31581, \"p50\": 31581, \"p90\": 31581, \"p95\": 31581, \"p99\": 31581, \"p999\": 31581}, \"alignment_buffered\": {\"avg\": 0, \"max\": 0, \"min\": 0, \"p50\": 0, \"p90\": 0, \"p95\": 0, \"p99\": 0, \"p999\": 0}, \"end_to_end_duration\": {\"avg\": 1441, \"max\": 1441, \"min\": 1441, \"p50\": 1441, \"p90\": 1441, \"p95\": 1441, \"p99\": 1441, \"p999\": 1441}}}', '{\"mode\": \"exactly_once\", \"timeout\": 600000, \"interval\": 3600000, \"min_pause\": 0, \"state_backend\": \"HashMapStateBackend\", \"max_concurrent\": 1, \"externalization\": {\"enabled\": false, \"delete_on_cancellation\": true}, \"checkpoint_storage\": \"JobManagerCheckpointStorage\", \"unaligned_checkpoints\": false, \"aligned_checkpoint_timeout\": 0, \"tolerable_failed_checkpoints\": 0, \"checkpoints_after_tasks_finish\": true}', '{\"jid\": \"ccded83cc23eaca491fcd3939f96ec02\", \"name\": \"mysql-to-es-session\", \"execution-config\": {\"user-config\": {}, \"execution-mode\": \"PIPELINED\", \"job-parallelism\": 1, \"restart-strategy\": \"Cluster level default restart strategy\", \"object-reuse-mode\": false}}', NULL, '{\"id\": 2, \"name\": \"Flink-on-session-k8s\", \"note\": null, \"type\": \"kubernetes-session\", \"alias\": \"Flink on session k8s\", \"hosts\": \"flink-cluster-rest:8081\", \"status\": 1, \"taskId\": null, \"enabled\": true, \"version\": \"1.15.3\", \"tenantId\": 1, \"createTime\": [2023, 12, 28, 5, 0, 18], \"updateTime\": [2023, 12, 29, 11, 56, 10], \"applicationId\": null, \"autoRegisters\": false, \"jobManagerHost\": \"flink-cluster-rest:8081\", \"resourceManagerAddr\": null, \"clusterConfigurationId\": null}', '{\"id\": 1, \"name\": \"flink-on-native-k8s\", \"note\": null, \"type\": \"Kubernetes\", \"alias\": \"flink on native k8s\", \"config\": {\"flinkConfig\": {\"fs.oss.endpoint\": \"https://oss-cn-hongkong.aliyuncs.com\", \"high-availability\": \"org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory\", \"fs.oss.accessKeyId\": \"LTAI2pFx7EflElP7\", \"fs.oss.accessKeySecret\": \"unsebaUQA23EqZyBq80rldSeHFDKuO\", \"env.java.opts.jobmanager\": \"-Duser.timezone=GMT+08\", \"env.java.opts.taskmanager\": \"-Duser.timezone=GMT+08\", \"high-availability.storageDir\": \"oss://flink-ha-test/native-recovery\", \"taskmanager.numberOfTaskSlots\": \"3\", \"jobmanager.memory.process.size\": \"1024m\", \"kubernetes.jobmanager.replicas\": \"1\", \"taskmanager.memory.process.size\": \"1024m\", \"resourcemanager.taskmanager-timeout\": \"86400000\", \"taskmanager.memory.framework.heap.size\": \"\"}, \"dockerConfig\": {\"docker.instance\": \"\", \"dinky.remote.addr\": \"\", \"docker.registry.url\": \"\", \"kubernetes.cluster-id\": \"flink-application-cluster\", \"docker.image.namespace\": \"\", \"docker.image.storehouse\": \"\", \"docker.registry.password\": \"\", \"docker.registry.username\": \"\", \"docker.image.dinkyVersion\": \"\", \"kubernetes.taskmanager.node-selector\": \"flink-env:test\", \"kubernetes.container.image.pull-policy\": \"Always\", \"kubernetes.container.image.pull-secrets\": \"registry-private-secret\"}, \"flinkConfigPath\": \"/opt/dinky/conf\", \"kubernetesConfig\": {\"kubernetes.namespace\": \"flink-test\", \"kubernetes.cluster-id\": \"flink-application-cluster\", \"kubernetes.jobmanager.cpu\": \"0.2\", \"kubernetes.container.image\": \"registry.zerofinance.net/library/dinky-flink-application:1.15.3\", \"kubernetes.taskmanager.cpu\": \"0.2\", \"kubernetes.rest-service.exposed.type\": \"NodePort\", \"kubernetes.taskmanager.node-selector\": \"flink-env:test\", \"kubernetes.container.image.pull-policy\": \"Always\", \"kubernetes.container.image.pull-secrets\": \"registry-private-secret\"}}, \"enabled\": true, \"tenantId\": 1, \"configJson\": \"{\\\"flinkConfigPath\\\":\\\"/opt/dinky/conf\\\",\\\"kubernetesConfig\\\":{\\\"kubernetes.namespace\\\":\\\"flink-test\\\",\\\"kubernetes.container.image\\\":\\\"registry.zerofinance.net/library/dinky-flink-application:1.15.3\\\",\\\"kubernetes.rest-service.exposed.type\\\":\\\"NodePort\\\",\\\"kubernetes.jobmanager.cpu\\\":\\\"0.2\\\",\\\"kubernetes.taskmanager.cpu\\\":\\\"0.2\\\",\\\"kubernetes.cluster-id\\\":\\\"flink-application-cluster\\\",\\\"kubernetes.container.image.pull-secrets\\\":\\\"registry-private-secret\\\",\\\"kubernetes.taskmanager.node-selector\\\":\\\"flink-env:test\\\",\\\"kubernetes.container.image.pull-policy\\\":\\\"Always\\\"},\\\"dockerConfig\\\":{\\\"docker.instance\\\":\\\"\\\",\\\"docker.registry.url\\\":\\\"\\\",\\\"docker.registry.username\\\":\\\"\\\",\\\"docker.registry.password\\\":\\\"\\\",\\\"docker.image.namespace\\\":\\\"\\\",\\\"docker.image.storehouse\\\":\\\"\\\",\\\"docker.image.dinkyVersion\\\":\\\"\\\",\\\"dinky.remote.addr\\\":\\\"\\\",\\\"kubernetes.cluster-id\\\":\\\"flink-application-cluster\\\",\\\"kubernetes.container.image.pull-secrets\\\":\\\"registry-private-secret\\\",\\\"kubernetes.taskmanager.node-selector\\\":\\\"flink-env:test\\\",\\\"kubernetes.container.image.pull-policy\\\":\\\"Always\\\"},\\\"flinkConfig\\\":{\\\"jobmanager.memory.process.size\\\":\\\"1024m\\\",\\\"taskmanager.memory.process.size\\\":\\\"1024m\\\",\\\"taskmanager.memory.framework.heap.size\\\":\\\"\\\",\\\"taskmanager.numberOfTaskSlots\\\":\\\"3\\\",\\\"fs.oss.endpoint\\\":\\\"https://oss-cn-hongkong.aliyuncs.com\\\",\\\"fs.oss.accessKeyId\\\":\\\"LTAI2pFx7EflElP7\\\",\\\"fs.oss.accessKeySecret\\\":\\\"unsebaUQA23EqZyBq80rldSeHFDKuO\\\",\\\"high-availability\\\":\\\"org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory\\\",\\\"high-availability.storageDir\\\":\\\"oss://flink-ha-test/native-recovery\\\",\\\"env.java.opts.jobmanager\\\":\\\"-Duser.timezone=GMT+08\\\",\\\"env.java.opts.taskmanager\\\":\\\"-Duser.timezone=GMT+08\\\",\\\"resourcemanager.taskmanager-timeout\\\":\\\"86400000\\\",\\\"kubernetes.jobmanager.replicas\\\":\\\"1\\\"}}\", \"createTime\": [2023, 12, 28, 18, 37, 48], \"updateTime\": [2023, 12, 29, 11, 56, 25], \"isAvailable\": true}', '2023-12-29 14:01:25');

-- ----------------------------
-- Table structure for dlink_job_instance
-- ----------------------------
CREATE TABLE `dlink_job_instance`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
  `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'job instance name',
  `tenant_id` int(11) NOT NULL DEFAULT 1 COMMENT 'tenant id',
  `task_id` int(11) NULL DEFAULT NULL COMMENT 'task ID',
  `step` int(11) NULL DEFAULT NULL COMMENT 'job lifecycle',
  `cluster_id` int(11) NULL DEFAULT NULL COMMENT 'cluster ID',
  `jid` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'Flink JobId',
  `status` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'job instance status',
  `history_id` int(11) NULL DEFAULT NULL COMMENT 'execution history ID',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  `finish_time` datetime NULL DEFAULT NULL COMMENT 'finish time',
  `duration` bigint(20) NULL DEFAULT NULL COMMENT 'job duration',
  `error` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'error logs',
  `failed_restart_count` int(11) NULL DEFAULT NULL COMMENT 'failed restart count',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_job_instance_un`(`tenant_id`, `name`, `task_id`, `history_id`) USING BTREE,
  INDEX `dlink_job_instance_task_id_IDX`(`task_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 22 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'job instance' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_job_instance
-- ----------------------------
INSERT INTO `dlink_job_instance` VALUES (1, 'Dave\'s Demo', 1, 2, NULL, 1, '1584e819e47499397d9ec67d0c62ae77', 'CANCELED', 1, '2023-12-28 04:59:05', '2023-12-28 04:59:15', '2023-12-28 04:59:15', 8, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (2, 'Dave\'s Demo', 1, 2, 2, 1, '23676f78f6fc729f98b23b2cc3adaa99', 'CANCELED', 2, '2023-12-28 04:59:16', '2023-12-28 05:00:41', '2023-12-28 05:00:41', 82, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (3, 'Dave\'s Demo', 1, 2, NULL, 2, 'd2a255b83a364e745a3809b5ebd48f67', 'CANCELED', 3, '2023-12-28 05:01:11', '2023-12-28 06:06:14', '2023-12-28 06:06:14', 3901, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (4, 'Mysql to es', 1, 3, NULL, 2, '63c260fc99a9cadbf8d69843e81ec349', 'CANCELED', 6, '2023-12-28 06:26:44', '2023-12-28 06:28:13', '2023-12-28 06:28:13', 87, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (5, 'Mysql to es', 1, 3, 2, 2, '3b66031dbff4010807ed14db94d891ac', 'CANCELED', 7, '2023-12-28 06:28:29', '2023-12-28 06:32:41', '2023-12-28 06:32:41', 253, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (6, 'Mysql to es', 1, 3, NULL, 2, 'c535b745f3810e73d46404c640b53c84', 'CANCELED', 8, '2023-12-28 14:37:38', '2023-12-28 15:56:09', '2023-12-28 15:56:09', 4710, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (7, 'Dave\'s Demo', 1, 2, NULL, 2, '4e223c09a7389668e48cb7dab6671892', 'CANCELED', 9, '2023-12-28 14:42:37', '2023-12-28 14:42:44', '2023-12-28 14:42:44', 8, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (8, 'udf_sub_test', 1, 5, NULL, 1, 'e537204761a17ac3a19f043993b841e8', 'UNKNOWN', 10, '2023-12-28 14:57:34', '2023-12-28 18:55:53', '2023-12-28 18:50:28', 13796, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (9, 'Mysql to es', 1, 3, NULL, 2, '04a724f6667c2d5f9db477f2783464ad', 'CANCELED', 13, '2023-12-28 15:56:21', '2023-12-28 15:56:39', '2023-12-28 15:56:39', 16, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (10, 'Mysql to es', 1, 3, NULL, 2, '84ffe5cfa8c93435a03a5dd72f7d676a', 'CANCELED', 14, '2023-12-28 15:57:21', '2023-12-28 15:58:22', '2023-12-28 15:58:22', 61, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (11, 'Mysql to es', 1, 3, NULL, 2, '68fb53c1010d57adf2a2873f99e2fbcd', 'CANCELED', 18, '2023-12-28 16:20:32', '2023-12-28 16:22:21', '2023-12-28 16:22:21', 108, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (12, 'Mysql to es', 1, 3, NULL, 2, 'f73449a72a54e7e60cb0e2264d00a668', 'CANCELED', 19, '2023-12-28 16:22:45', '2023-12-28 16:25:17', '2023-12-28 16:25:17', 151, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (13, 'Mysql to es', 1, 3, NULL, 2, 'f91dc12c8527d375ab99f8c3d80e9334', 'CANCELED', 20, '2023-12-28 16:25:33', '2023-12-28 16:26:56', '2023-12-28 16:26:56', 81, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (14, 'Mysql to es', 1, 3, 2, 2, 'af8effdc0e28d0e890c436d18448c4b7', 'CANCELED', 23, '2023-12-28 16:54:21', '2023-12-28 16:58:49', '2023-12-28 16:58:49', 266, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (15, 'Mysql to es', 1, 3, 2, 2, '1f7c3e73087a1591ff8dd2f580e1b26b', 'CANCELED', 25, '2023-12-28 17:00:09', '2023-12-28 17:17:32', '2023-12-28 17:17:32', 1044, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (16, 'Mysql to es', 1, 3, NULL, 2, 'fcd82f4089fe1d7fbd4f6b36b61e13e3', 'CANCELED', 26, '2023-12-28 17:18:07', '2023-12-28 17:18:19', '2023-12-28 17:18:19', 10, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (17, 'Mysql to es', 1, 3, NULL, 2, '7cbc0826d2993bcf33c82292ce4d796f', 'CANCELED', 28, '2023-12-28 17:20:57', '2023-12-28 17:21:10', '2023-12-28 17:21:10', 11, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (18, 'Mysql to es', 1, 3, 2, 1, '298b3247f1c4bddfd0b4f3ffb09f2e91', 'UNKNOWN', 31, '2023-12-28 18:40:28', '2023-12-28 18:59:24', '2023-12-28 18:58:12', 426, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (19, 'udf_sub_test', 1, 5, NULL, 2, '0488bc0ec0edac07e8138a16803506ed', 'CANCELED', 66, '2023-12-29 11:34:03', '2023-12-29 11:38:12', '2023-12-29 11:38:12', 248, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (20, 'mysql-to-es-session', 1, 6, NULL, 2, '89d5894a5258c212d7ea15affe0b1fe7', 'CANCELED', 67, '2023-12-29 12:49:34', '2023-12-29 12:53:53', '2023-12-29 12:53:53', 261, NULL, NULL);
INSERT INTO `dlink_job_instance` VALUES (21, 'mysql-to-es-session', 1, 6, NULL, 2, 'ccded83cc23eaca491fcd3939f96ec02', 'RUNNING', 68, '2023-12-29 12:54:48', '2023-12-29 12:54:48', NULL, 3, NULL, NULL);

-- ----------------------------
-- Table structure for dlink_namespace
-- ----------------------------
CREATE TABLE `dlink_namespace`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `tenant_id` int(11) NOT NULL COMMENT 'tenant id',
  `namespace_code` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'namespace code',
  `enabled` tinyint(1) NOT NULL DEFAULT 1 COMMENT 'is enable',
  `note` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'note',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_namespace_un`(`namespace_code`, `tenant_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'namespace' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_namespace
-- ----------------------------
INSERT INTO `dlink_namespace` VALUES (1, 1, 'DefaultNameSpace', 1, 'DefaultNameSpace', '2023-12-28 12:56:23', '2023-12-28 12:56:23');

-- ----------------------------
-- Table structure for dlink_role
-- ----------------------------
CREATE TABLE `dlink_role`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `tenant_id` int(11) NOT NULL COMMENT 'tenant id',
  `role_code` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'role code',
  `role_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'role name',
  `is_delete` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'is delete',
  `note` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'note',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_role_un`(`role_code`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'role' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_role
-- ----------------------------
INSERT INTO `dlink_role` VALUES (1, 1, 'SuperAdmin', 'SuperAdmin', 0, 'SuperAdmin of Role', '2023-12-28 12:56:23', '2023-12-29 13:41:32');
INSERT INTO `dlink_role` VALUES (2, 1, 'Developer', 'Developer', 0, 'Developer', '2023-12-29 13:32:06', '2023-12-29 13:41:24');

-- ----------------------------
-- Table structure for dlink_role_namespace
-- ----------------------------
CREATE TABLE `dlink_role_namespace`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `role_id` int(11) NOT NULL COMMENT 'user id',
  `namespace_id` int(11) NOT NULL COMMENT 'namespace id',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_role_namespace_un`(`role_id`, `namespace_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 14 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'Role and namespace relationship' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_role_namespace
-- ----------------------------
INSERT INTO `dlink_role_namespace` VALUES (12, 2, 1, '2023-12-29 13:41:24', '2023-12-29 13:41:24');
INSERT INTO `dlink_role_namespace` VALUES (13, 1, 1, '2023-12-29 13:41:32', '2023-12-29 13:41:32');

-- ----------------------------
-- Table structure for dlink_role_select_permissions
-- ----------------------------
CREATE TABLE `dlink_role_select_permissions`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `role_id` int(11) NOT NULL COMMENT '角色ID',
  `table_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '表名',
  `expression` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '表达式',
  `create_time` datetime NULL DEFAULT NULL COMMENT '创建时间',
  `update_time` datetime NULL DEFAULT NULL COMMENT '更新时间',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '角色数据查询权限' ROW_FORMAT = Dynamic;

-- ----------------------------
-- Records of dlink_role_select_permissions
-- ----------------------------

-- ----------------------------
-- Table structure for dlink_savepoints
-- ----------------------------
CREATE TABLE `dlink_savepoints`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `task_id` int(11) NOT NULL COMMENT 'task ID',
  `tenant_id` int(11) NOT NULL DEFAULT 1 COMMENT 'tenant id',
  `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'task name',
  `type` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'savepoint type',
  `path` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'savepoint path',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'job savepoint management' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_savepoints
-- ----------------------------

-- ----------------------------
-- Table structure for dlink_schema_history
-- ----------------------------
CREATE TABLE `dlink_schema_history`  (
  `installed_rank` int(11) NOT NULL,
  `version` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  `description` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
  `type` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
  `script` varchar(1000) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
  `checksum` int(11) NULL DEFAULT NULL,
  `installed_by` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
  `installed_on` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `execution_time` int(11) NOT NULL,
  `success` tinyint(1) NOT NULL,
  PRIMARY KEY (`installed_rank`) USING BTREE,
  INDEX `dlink_schema_history_s_idx`(`success`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_schema_history
-- ----------------------------

-- ----------------------------
-- Table structure for dlink_sys_config
-- ----------------------------
CREATE TABLE `dlink_sys_config`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'configuration name',
  `value` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'configuration value',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'system configuration' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_sys_config
-- ----------------------------
INSERT INTO `dlink_sys_config` VALUES (1, 'sqlSubmitJarPath', 'local:///opt/flink/lib/dlink-app-1.15-0.7.5-jar-with-dependencies.jar', '2023-12-28 21:04:53', '2023-12-29 08:28:12');
INSERT INTO `dlink_sys_config` VALUES (2, 'sqlSubmitJarParas', '--output /opt/flink/log ', '2023-12-29 08:28:33', '2023-12-29 08:45:16');

-- ----------------------------
-- Table structure for dlink_task
-- ----------------------------
CREATE TABLE `dlink_task`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'Job name',
  `tenant_id` int(11) NOT NULL DEFAULT 1 COMMENT 'tenant id',
  `alias` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'Job alias',
  `dialect` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'dialect',
  `type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'Job type',
  `check_point` int(11) NULL DEFAULT NULL COMMENT 'CheckPoint trigger seconds',
  `save_point_strategy` int(11) NULL DEFAULT NULL COMMENT 'SavePoint strategy',
  `save_point_path` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'SavePointPath',
  `parallelism` int(11) NULL DEFAULT NULL COMMENT 'parallelism',
  `fragment` tinyint(1) NULL DEFAULT 0 COMMENT 'fragment',
  `statement_set` tinyint(1) NULL DEFAULT 0 COMMENT 'enable statement set',
  `batch_model` tinyint(1) NULL DEFAULT 0 COMMENT 'use batch model',
  `cluster_id` int(11) NULL DEFAULT NULL COMMENT 'Flink cluster ID',
  `cluster_configuration_id` int(11) NULL DEFAULT NULL COMMENT 'cluster configuration ID',
  `database_id` int(11) NULL DEFAULT NULL COMMENT 'database ID',
  `jar_id` int(11) NULL DEFAULT NULL COMMENT 'Jar ID',
  `env_id` int(11) NULL DEFAULT NULL COMMENT 'env id',
  `alert_group_id` bigint(20) NULL DEFAULT NULL COMMENT 'alert group id',
  `config_json` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'configuration json',
  `note` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'Job Note',
  `step` int(11) NULL DEFAULT NULL COMMENT 'Job lifecycle',
  `job_instance_id` bigint(20) NULL DEFAULT NULL COMMENT 'job instance id',
  `enabled` tinyint(1) NOT NULL DEFAULT 1 COMMENT 'is enable',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  `version_id` int(11) NULL DEFAULT NULL COMMENT 'version id',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_task_un`(`name`, `tenant_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 7 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'Task' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_task
-- ----------------------------
INSERT INTO `dlink_task` VALUES (1, 'dlink_default_catalog', 1, 'DefaultCatalog', 'FlinkSqlEnv', NULL, NULL, NULL, NULL, NULL, 1, 0, 0, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, 1, '2023-12-28 04:57:13', '2023-12-28 04:57:13', NULL);
INSERT INTO `dlink_task` VALUES (2, 'demo', 1, 'dave-demo', 'FlinkSql', 'kubernetes-application', 0, NULL, NULL, 1, 0, 0, 0, 2, 1, NULL, NULL, NULL, 0, '[]', NULL, 2, 0, 1, '2023-12-28 04:58:32', '2023-12-28 22:22:53', NULL);
INSERT INTO `dlink_task` VALUES (3, 'mysql-to-es', 1, 'mysql-to-es', 'FlinkSql', 'kubernetes-application', 0, NULL, NULL, 1, 1, 0, 0, 1, 1, NULL, NULL, NULL, 0, '[]', NULL, 2, 0, 1, '2023-12-28 05:02:13', '2023-12-29 10:43:51', NULL);
INSERT INTO `dlink_task` VALUES (4, 'sub', 1, 'substring', 'Java', NULL, 0, NULL, 'com.test.SubFunction', 1, 0, 0, 0, 0, NULL, NULL, NULL, NULL, NULL, '[]', NULL, 2, 0, 1, '2023-12-28 14:55:22', '2023-12-28 14:56:40', NULL);
INSERT INTO `dlink_task` VALUES (5, 'udf_sub_test', 1, 'udf_sub_test', 'FlinkSql', 'kubernetes-session', 0, NULL, NULL, 1, 0, 0, 0, 2, NULL, NULL, NULL, NULL, NULL, '[]', NULL, 2, 0, 1, '2023-12-28 14:57:03', '2023-12-29 11:38:27', NULL);
INSERT INTO `dlink_task` VALUES (6, 'mysql-to-es-session', 1, 'mysql-to-es-session', 'FlinkSql', 'kubernetes-session', 0, NULL, NULL, 1, 1, 0, 0, 2, 1, NULL, NULL, NULL, 1, '[]', NULL, 2, 21, 1, '2023-12-28 05:02:13', '2023-12-29 12:54:48', NULL);

-- ----------------------------
-- Table structure for dlink_task_statement
-- ----------------------------
CREATE TABLE `dlink_task_statement`  (
  `id` int(11) NOT NULL COMMENT 'ID',
  `tenant_id` int(11) NOT NULL DEFAULT 1 COMMENT 'tenant id',
  `statement` longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'statement set',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_task_statement_un`(`tenant_id`, `id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'statement' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_task_statement
-- ----------------------------
INSERT INTO `dlink_task_statement` VALUES (1, 1, 'create catalog my_catalog with(\n    \'type\' = \'dlink_mysql\',\n    \'username\' = \'dinky\',\n    \'password\' = \'Aa123456\',\n    \'url\' = \'jdbc:mysql://192.168.63.102:3306/dinky?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&zeroDateTimeBehavior=convertToNull&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true\'\n);\nuse catalog my_catalog;\n');
INSERT INTO `dlink_task_statement` VALUES (2, 1, 'CREATE TABLE orders (\r\n    order_uid  BIGINT,\r\n    product_id BIGINT,\r\n    price      DECIMAL(32, 2),\r\n    order_time TIMESTAMP(3)\r\n) WITH (\r\n    \'connector\' = \'datagen\'\r\n);\r\n\r\nSELECT * FROM orders;');
INSERT INTO `dlink_task_statement` VALUES (3, 1, 'SET execution.checkpointing.interval = 1h;\r\n\r\nCREATE FUNCTION ARRAY_AGGR AS \'com.zerofinance.function.ArrayAggr\';\r\n\r\nCREATE TABLE products (\r\n    id INT,\r\n    name STRING,\r\n    description STRING,\r\n    PRIMARY KEY (id) NOT ENFORCED\r\n  ) WITH (\r\n    \'connector\' = \'mysql-cdc\',\r\n    \'hostname\' = \'192.168.63.102\',\r\n    \'port\' = \'3306\',\r\n    \'username\' = \'demo_db\',\r\n    \'password\' = \'Aa123456\',\r\n    \'database-name\' = \'demo_db\',\r\n    \'table-name\' = \'products\'\r\n  );\r\n  \r\nCREATE TABLE orders (\r\n   order_id INT,\r\n   order_date TIMESTAMP(0),\r\n   customer_name STRING,\r\n   price DECIMAL(10, 5),\r\n   product_id INT,\r\n   order_status BOOLEAN,\r\n   PRIMARY KEY (order_id) NOT ENFORCED\r\n ) WITH (\r\n   \'connector\' = \'mysql-cdc\',\r\n   \'hostname\' = \'192.168.63.102\',\r\n   \'port\' = \'3306\',\r\n   \'username\' = \'demo_db\',\r\n   \'password\' = \'Aa123456\',\r\n   \'database-name\' = \'demo_db\',\r\n   \'table-name\' = \'orders\'\r\n );\r\n \r\nCREATE TABLE enriched_orders (\r\n   product_id INT,\r\n   product_name STRING,\r\n   product_description STRING,\r\n   order_array ARRAY<ROW<order_id INT,order_date TIMESTAMP(0),customer_name STRING,price DECIMAL(10, 5),order_status BOOLEAN>>,\r\n   PRIMARY KEY (product_id) NOT ENFORCED\r\n ) WITH (\r\n     \'connector\' = \'elasticsearch-7\',\r\n     \'hosts\' = \'http://192.168.63.102:9200\',\r\n     \'index\' = \'enriched_orders_dave\'\r\n );\r\n \r\nINSERT INTO enriched_orders\r\n  SELECT p.id AS product_id, p.name AS product_name, p.description AS product_description,\r\n (select ARRAY_AGGR(ROW(order_id,order_date,customer_name,price,order_status)) \r\n   from orders o \r\n   where o.product_id=p.id) as order_array\r\n FROM products AS p;');
INSERT INTO `dlink_task_statement` VALUES (4, 1, 'package com.test;\n\nimport org.apache.flink.table.functions.ScalarFunction;\n\npublic class SubFunction extends ScalarFunction {\n    public String eval(String s) {\n        return \"This is java function: \"+s;\n    }\n}');
INSERT INTO `dlink_task_statement` VALUES (5, 1, 'create temporary function sb_j as \'com.test.SubFunction\';\r\n\r\n\r\nCREATE TABLE sourceTable (\r\n    id int,\r\n    java_c string\r\n) WITH (\r\n  \'connector\' = \'datagen\'\r\n);\r\n\r\nCREATE  TABLE sinkTable\r\nWITH (\r\n    \'connector\' = \'print\'\r\n)\r\nLIKE sourceTable (EXCLUDING ALL);\r\n\r\n\r\ninsert into sinkTable select id,sb_j(java_c) from sourceTable;\r\n');
INSERT INTO `dlink_task_statement` VALUES (6, 1, 'SET execution.checkpointing.interval = 1h;\r\n\r\nCREATE FUNCTION ARRAY_AGGR AS \'com.zerofinance.function.ArrayAggr\';\r\n\r\nCREATE TABLE products (\r\n    id INT,\r\n    name STRING,\r\n    description STRING,\r\n    PRIMARY KEY (id) NOT ENFORCED\r\n  ) WITH (\r\n    \'connector\' = \'mysql-cdc\',\r\n    \'hostname\' = \'192.168.63.102\',\r\n    \'port\' = \'3306\',\r\n    \'username\' = \'demo_db\',\r\n    \'password\' = \'Aa123456\',\r\n    \'database-name\' = \'demo_db\',\r\n    \'table-name\' = \'products\'\r\n  );\r\n  \r\nCREATE TABLE orders (\r\n   order_id INT,\r\n   order_date TIMESTAMP(0),\r\n   customer_name STRING,\r\n   price DECIMAL(10, 5),\r\n   product_id INT,\r\n   order_status BOOLEAN,\r\n   PRIMARY KEY (order_id) NOT ENFORCED\r\n ) WITH (\r\n   \'connector\' = \'mysql-cdc\',\r\n   \'hostname\' = \'192.168.63.102\',\r\n   \'port\' = \'3306\',\r\n   \'username\' = \'demo_db\',\r\n   \'password\' = \'Aa123456\',\r\n   \'database-name\' = \'demo_db\',\r\n   \'table-name\' = \'orders\'\r\n );\r\n \r\nCREATE TABLE enriched_orders (\r\n   product_id INT,\r\n   product_name STRING,\r\n   product_description STRING,\r\n   order_array ARRAY<ROW<order_id INT,order_date TIMESTAMP(0),customer_name STRING,price DECIMAL(10, 5),order_status BOOLEAN>>,\r\n   PRIMARY KEY (product_id) NOT ENFORCED\r\n ) WITH (\r\n     \'connector\' = \'elasticsearch-7\',\r\n     \'hosts\' = \'http://192.168.63.103:9200\',\r\n     \'index\' = \'enriched_orders_dave_session\'\r\n );\r\n \r\nINSERT INTO enriched_orders\r\n  SELECT p.id AS product_id, p.name AS product_name, p.description AS product_description,\r\n (select ARRAY_AGGR(ROW(order_id,order_date,customer_name,price,order_status)) \r\n   from orders o \r\n   where o.product_id=p.id) as order_array\r\n FROM products AS p;');

-- ----------------------------
-- Table structure for dlink_task_version
-- ----------------------------
CREATE TABLE `dlink_task_version`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `task_id` int(11) NOT NULL COMMENT 'task ID ',
  `tenant_id` int(11) NOT NULL DEFAULT 1 COMMENT 'tenant id',
  `version_id` int(11) NOT NULL COMMENT 'version ID ',
  `statement` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'flink sql statement',
  `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'version name',
  `alias` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'alisa',
  `dialect` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'dialect',
  `type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'type',
  `task_configure` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'task configuration',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_task_version_un`(`task_id`, `tenant_id`, `version_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'job history version' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_task_version
-- ----------------------------

-- ----------------------------
-- Table structure for dlink_tenant
-- ----------------------------
CREATE TABLE `dlink_tenant`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `tenant_code` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'tenant code',
  `is_delete` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'is delete',
  `note` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'note',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'tenant' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_tenant
-- ----------------------------
INSERT INTO `dlink_tenant` VALUES (1, 'DefaultTenant', 0, 'DefaultTenant', '2023-12-28 12:56:22', '2023-12-28 12:56:22');
INSERT INTO `dlink_tenant` VALUES (2, 'dev', 1, 'dev', '2023-12-29 13:32:52', '2023-12-29 13:34:41');
INSERT INTO `dlink_tenant` VALUES (3, 'DevTenant', 0, 'DevTenant', '2023-12-29 13:40:53', '2023-12-29 13:40:53');

-- ----------------------------
-- Table structure for dlink_udf
-- ----------------------------
CREATE TABLE `dlink_udf`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'udf name',
  `class_name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'Complete class name',
  `source_code` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'source code',
  `compiler_code` binary(255) NULL DEFAULT NULL COMMENT 'compiler product',
  `version_id` int(11) NULL DEFAULT NULL COMMENT 'version',
  `version_description` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'version description',
  `is_default` tinyint(1) NULL DEFAULT NULL COMMENT 'Is it default',
  `document_id` int(11) NULL DEFAULT NULL COMMENT 'corresponding to the document id',
  `from_version_id` int(11) NULL DEFAULT NULL COMMENT 'Based on udf version id',
  `code_md5` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'source code of md5',
  `dialect` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'dialect',
  `type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'type',
  `step` int(11) NULL DEFAULT NULL COMMENT 'job lifecycle step',
  `enable` tinyint(1) NULL DEFAULT NULL COMMENT 'is enable',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'udf' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_udf
-- ----------------------------

-- ----------------------------
-- Table structure for dlink_udf_template
-- ----------------------------
CREATE TABLE `dlink_udf_template`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '模板名称',
  `code_type` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '代码类型',
  `function_type` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '函数类型',
  `template_code` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT '模板代码',
  `enabled` tinyint(1) NULL DEFAULT NULL COMMENT 'is enable',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 6 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'udf template' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_udf_template
-- ----------------------------
INSERT INTO `dlink_udf_template` VALUES (1, 'java_udf', 'Java', 'UDF', '${(package==\'\')?string(\'\',\'package \'+package+\';\')}\n\nimport org.apache.flink.table.functions.ScalarFunction;\n\npublic class ${className} extends ScalarFunction {\n    public String eval(String s) {\n        return null;\n    }\n}', NULL, '2022-10-19 09:17:37', '2022-10-25 17:45:57');
INSERT INTO `dlink_udf_template` VALUES (2, 'java_udtf', 'Java', 'UDTF', '${(package==\'\')?string(\'\',\'package \'+package+\';\')}\n\nimport org.apache.flink.table.functions.ScalarFunction;\n\n@FunctionHint(output = @DataTypeHint(\"ROW<word STRING, length INT>\"))\npublic static class ${className} extends TableFunction<Row> {\n\n  public void eval(String str) {\n    for (String s : str.split(\" \")) {\n      // use collect(...) to emit a row\n      collect(Row.of(s, s.length()));\n    }\n  }\n}', NULL, '2022-10-19 09:22:58', '2022-10-25 17:49:30');
INSERT INTO `dlink_udf_template` VALUES (3, 'scala_udf', 'Scala', 'UDF', '${(package==\'\')?string(\'\',\'package \'+package+\';\')}\n\nimport org.apache.flink.table.api._\nimport org.apache.flink.table.functions.ScalarFunction\n\n// 定义可参数化的函数逻辑\nclass ${className} extends ScalarFunction {\n  def eval(s: String, begin: Integer, end: Integer): String = {\n    \"this is scala\"\n  }\n}', NULL, '2022-10-25 09:21:32', '2022-10-25 17:49:46');
INSERT INTO `dlink_udf_template` VALUES (4, 'python_udf_1', 'Python', 'UDF', 'from pyflink.table import ScalarFunction, DataTypes\nfrom pyflink.table.udf import udf\n\nclass ${className}(ScalarFunction):\n    def __init__(self):\n        pass\n\n    def eval(self, variable):\n        return str(variable)\n\n\n${attr!\'f\'} = udf(HashCode(), result_type=DataTypes.STRING())', NULL, '2022-10-25 09:23:07', '2022-10-25 09:34:01');
INSERT INTO `dlink_udf_template` VALUES (5, 'python_udf_2', 'Python', 'UDF', 'from pyflink.table import DataTypes\nfrom pyflink.table.udf import udf\n\n@udf(result_type=DataTypes.STRING())\ndef ${className}(variable1:str):\n  return \'\'', NULL, '2022-10-25 09:25:13', '2022-10-25 09:34:47');

-- ----------------------------
-- Table structure for dlink_upload_file_record
-- ----------------------------
CREATE TABLE `dlink_upload_file_record`  (
  `id` tinyint(4) NOT NULL AUTO_INCREMENT COMMENT 'id',
  `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'upload file name',
  `enabled` tinyint(1) NULL DEFAULT NULL COMMENT 'is enable',
  `file_type` tinyint(4) NULL DEFAULT -1 COMMENT 'upload file type ，such as：hadoop-conf(1)、flink-conf(2)、flink-lib(3)、user-jar(4)、dlink-jar(5)，default is -1 ',
  `target` tinyint(4) NOT NULL COMMENT 'upload file of target ，such as：local(1)、hdfs(2)',
  `file_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'file name',
  `file_parent_path` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'file parent path',
  `file_absolute_path` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'fila absolute path',
  `is_file` tinyint(1) NOT NULL DEFAULT 1 COMMENT 'is file',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'file upload history' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_upload_file_record
-- ----------------------------
INSERT INTO `dlink_upload_file_record` VALUES (1, NULL, NULL, -1, 1, 'flink-conf.yaml', '/opt/flink/conf', '/opt/flink/conf/flink-conf.yaml', 1, '2023-12-28 18:37:38', '2023-12-28 18:37:38');
INSERT INTO `dlink_upload_file_record` VALUES (2, NULL, NULL, -1, 1, NULL, '/opt/flink/conf', NULL, 0, '2023-12-28 18:37:38', '2023-12-28 18:37:38');

-- ----------------------------
-- Table structure for dlink_user
-- ----------------------------
CREATE TABLE `dlink_user`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `username` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'username',
  `password` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'password',
  `nickname` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'nickname',
  `worknum` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'worknum',
  `avatar` blob NULL COMMENT 'avatar',
  `mobile` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'mobile phone',
  `enabled` tinyint(1) NOT NULL DEFAULT 1 COMMENT 'is enable',
  `is_delete` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'is delete',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'user' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_user
-- ----------------------------
INSERT INTO `dlink_user` VALUES (1, 'admin', '21232f297a57a5a743894a0e4a801fc3', 'Admin', NULL, NULL, NULL, 1, 0, '2023-12-28 12:56:22', '2023-12-28 12:56:22');
INSERT INTO `dlink_user` VALUES (2, 'dev', 'e10adc3949ba59abbe56e057f20f883e', 'Dev', NULL, NULL, NULL, 1, 0, '2023-12-29 13:33:42', '2023-12-29 13:33:42');

-- ----------------------------
-- Table structure for dlink_user_role
-- ----------------------------
CREATE TABLE `dlink_user_role`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `user_id` int(11) NOT NULL COMMENT 'user id',
  `role_id` int(11) NOT NULL COMMENT 'role id',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_user_role_un`(`user_id`, `role_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'Relationship between users and roles' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_user_role
-- ----------------------------
INSERT INTO `dlink_user_role` VALUES (1, 1, 1, '2023-12-28 12:56:23', '2023-12-28 12:56:23');
INSERT INTO `dlink_user_role` VALUES (2, 2, 2, '2023-12-29 13:34:17', '2023-12-29 13:34:17');

-- ----------------------------
-- Table structure for dlink_user_tenant
-- ----------------------------
CREATE TABLE `dlink_user_tenant`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `user_id` int(11) NOT NULL COMMENT 'user id',
  `tenant_id` int(11) NOT NULL COMMENT 'tenant id',
  `create_time` datetime NULL DEFAULT NULL COMMENT 'create time',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `dlink_user_role_un`(`user_id`, `tenant_id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'Relationship between users and tenants' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of dlink_user_tenant
-- ----------------------------
INSERT INTO `dlink_user_tenant` VALUES (1, 1, 1, '2023-12-28 12:56:23', '2023-12-28 12:56:23');
INSERT INTO `dlink_user_tenant` VALUES (2, 2, 3, '2023-12-29 13:40:59', '2023-12-29 13:40:59');

-- ----------------------------
-- Table structure for metadata_column
-- ----------------------------
CREATE TABLE `metadata_column`  (
  `column_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'column name',
  `column_type` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'column type, such as : Physical , Metadata , Computed , WATERMARK',
  `data_type` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'data type',
  `expr` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'expression',
  `description` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'column description',
  `table_id` int(11) NOT NULL COMMENT 'table id',
  `primary` bit(1) NULL DEFAULT NULL COMMENT 'table primary key',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create time',
  PRIMARY KEY (`table_id`, `column_name`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'column informations' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of metadata_column
-- ----------------------------

-- ----------------------------
-- Table structure for metadata_database
-- ----------------------------
CREATE TABLE `metadata_database`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
  `database_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'database name',
  `description` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'database description',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  `create_time` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'metadata of database information' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of metadata_database
-- ----------------------------

-- ----------------------------
-- Table structure for metadata_database_property
-- ----------------------------
CREATE TABLE `metadata_database_property`  (
  `key` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'key',
  `value` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'value',
  `database_id` int(11) NOT NULL COMMENT 'database id',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create time',
  PRIMARY KEY (`key`, `database_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'metadata of database configurations' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of metadata_database_property
-- ----------------------------

-- ----------------------------
-- Table structure for metadata_function
-- ----------------------------
CREATE TABLE `metadata_function`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
  `function_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'function name',
  `class_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'class name',
  `database_id` int(11) NOT NULL COMMENT 'database id',
  `function_language` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'function language',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  `create_time` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'UDF informations' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of metadata_function
-- ----------------------------

-- ----------------------------
-- Table structure for metadata_table
-- ----------------------------
CREATE TABLE `metadata_table`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
  `table_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'table name',
  `table_type` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'type，such as：database,table,view',
  `database_id` int(11) NOT NULL COMMENT 'database id',
  `description` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT 'table description',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  `create_time` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create time',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'metadata of table information' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of metadata_table
-- ----------------------------

-- ----------------------------
-- Table structure for metadata_table_property
-- ----------------------------
CREATE TABLE `metadata_table_property`  (
  `key` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'key',
  `value` mediumtext CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT 'value',
  `table_id` int(11) NOT NULL COMMENT 'table id',
  `update_time` datetime NULL DEFAULT NULL COMMENT 'update time',
  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create tiime',
  PRIMARY KEY (`key`, `table_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = 'metadata of table configurations' ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- Records of metadata_table_property
-- ----------------------------

