[Bug][SqlServer] sqlsevrer sync sqlserver error

[jim6745]

Search before asking

• I had searched in the issues and found no similar question.

• I had googled my question but i didn't get any help.

• I had read the documentation: ChunJun doc but it didn't help me.

Description

No response

Code of Conduct

• I agree to follow this project's Code of Conduct

[jim6745]

I try to create a task for sqlserver sync sqlserver , but example only have stream to sqlserver and sqlserver to stream ,
so I create a new json to refer to the two examples , but I try two run the json , I met below error

json

{
  "job": {
    "content": [{
      "reader": {
        "parameter" : {
          "column" : [ {
            "name" : "id",
            "type" : "int"
          }, {
            "name" : "name",
            "type" : "varchar"
          } ],
          "username" : "xx",
          "password" : "xx",
          "connection" : [ {
            "jdbcUrl" : ["jdbc:jtds:sqlserver://172.31.32.57:1433;databaseName=DW"],
            "table" : [ "test1" ],
                        "schema":"dbo"
          } ],
          "where": "",
          "splitPk": "id",
          "fetchSize": 1000,
          "queryTimeOut": 1000,
          "customSql": "",
          "requestAccumulatorInterval": 2
        },
        "name" : "sqlserverreader"
      },
      "writer": {
        "name": "sqlserverwriter",
        "parameter": {
          "connection": [{
            "jdbcUrl" : "jdbc:jtds:sqlserver://172.31.32.57:1433;databaseName=DW",
            "table" : [ "test2" ],
                        "schema":"dbo"
          } ],
          "username": "xx",
          "password": "xx",
          "column": [
            {
            "name": "id",
            "type": "int"
            },
            {
            "name": "name",
            "type": "varchar"
            }],
          "mode": "insert",
          "batchSize": 1024,
          "preSql": [],
          "postSql": [],
          "updateKey": []
        }
      }
    }],
    "setting": {
      "speed": {
        "channel": 1,
        "bytes": 0
      }
    }
}
}

---

log

[root@LYGVLSCHEAPP01 config]# sh bin/chunjun-local.sh  -job config/sqlserver_sqlserver.json
sh: bin/chunjun-local.sh: 没有那个文件或目录
[root@LYGVLSCHEAPP01 config]# cd ..
[root@LYGVLSCHEAPP01 chunjun]# sh bin/chunjun-local.sh  -job config/sqlserver_sqlserver.json

          #                               #
          #                               #
          #
  #####   ######   #     #  # ####     ####   #     #  # ####
 #        #     #  #     #  ##    #       #   #     #  ##    #
 #        #     #  #     #  #     #       #   #     #  #     #
 #        #     #  #    ##  #     #       #   #    ##  #     #
  #####   #     #   #### #  #     #       #    #### #  #     #
                                          #
                                      ####

Reference site: https://dtstack.github.io/chunjun

chunjun is starting ...
CHUNJUN_HOME is auto set /opt/soft2/chunjun/chunjun-dist
FLINK_HOME is empty!
HADOOP_HOME is empty!

start command: /usr/local/java/bin/java -cp /opt/soft2/chunjun/chunjun-dist/../lib/* com.dtstack.chunjun.client.Launcher -job config/sqlserver_sqlserver.json -mode local -jobType sync -chunjunDistDir /opt/soft2/chunjun/chunjun-dist

2023-01-04 14:46:02,444 - 0    INFO  [main] com.dtstack.chunjun.Main:------------program params-------------------------
2023-01-04 14:46:02,500 - 56   INFO  [main] com.dtstack.chunjun.Main:-p
2023-01-04 14:46:02,500 - 56   INFO  [main] com.dtstack.chunjun.Main:
2023-01-04 14:46:02,500 - 56   INFO  [main] com.dtstack.chunjun.Main:-job
2023-01-04 14:46:02,500 - 56   INFO  [main] com.dtstack.chunjun.Main:%7B%0A++%22job%22%3A+%7B%0A++++%22content%22%3A+%5B%7B%0A++++++%22reader%22%3A+%7B%0A++++++++%22parameter%22+%3A+%7B%0A++++++++++%22column%22+%3A+%5B+%7B%0A++++++++++++%22name%22+%3A+%22id%22%2C%0A++++++++++++%22type%22+%3A+%22int%22%0A++++++++++%7D%2C+%7B%0A++++++++++++%22name%22+%3A+%22name%22%2C%0A++++++++++++%22type%22+%3A+%22varchar%22%0A++++++++++%7D+%5D%2C%0A++++++++++%22username%22+%3A+%22hretl%22%2C%0A++++++++++%22password%22+%3A+%22Hengrui%40456%22%2C%0A++++++++++%22connection%22+%3A+%5B+%7B%0A++++++++++++%22jdbcUrl%22+%3A+%5B%22jdbc%3Ajtds%3Asqlserver%3A%2F%2F172.31.32.57%3A1433%3BdatabaseName%3DDW%22%5D%2C%0A++++++++++++%22table%22+%3A+%5B+%22test1%22+%5D%2C%0A%09%09%09%22schema%22%3A%22dbo%22%0A++++++++++%7D+%5D%2C%0A++++++++++%22where%22%3A+%22%22%2C%0A++++++++++%22splitPk%22%3A+%22id%22%2C%0A++++++++++%22fetchSize%22%3A+1000%2C%0A++++++++++%22queryTimeOut%22%3A+1000%2C%0A++++++++++%22customSql%22%3A+%22%22%2C%0A++++++++++%22requestAccumulatorInterval%22%3A+2%0A++++++++%7D%2C%0A++++++++%22name%22+%3A+%22sqlserverreader%22%0A++++++%7D%2C%0A++++++%22writer%22%3A+%7B%0A++++++++%22name%22%3A+%22sqlserverwriter%22%2C%0A++++++++%22parameter%22%3A+%7B%0A++++++++++%22connection%22%3A+%5B%7B%0A++++++++++++%22jdbcUrl%22+%3A+%22jdbc%3Ajtds%3Asqlserver%3A%2F%2F172.31.32.57%3A1433%3BdatabaseName%3DDW%22%2C%0A++++++++++++%22table%22+%3A+%5B+%22test2%22+%5D%2C%0A%09%09%09%22schema%22%3A%22dbo%22%0A++++++++++%7D+%5D%2C%0A++++++++++%22username%22%3A+%22hretl%22%2C%0A++++++++++%22password%22%3A+%22Hengrui%40456%22%2C%0A++++++++++%22column%22%3A+%5B%0A++++++++++++%7B%0A++++++++++++%22name%22%3A+%22id%22%2C%0A++++++++++++%22type%22%3A+%22int%22%0A++++++++++++%7D%2C%0A++++++++++++%7B%0A++++++++++++%22name%22%3A+%22name%22%2C%0A++++++++++++%22type%22%3A+%22varchar%22%0A++++++++++++%7D%5D%2C%0A++++++++++%22mode%22%3A+%22insert%22%2C%0A++++++++++%22batchSize%22%3A+1024%2C%0A++++++++++%22preSql%22%3A+%5B%5D%2C%0A++++++++++%22postSql%22%3A+%5B%5D%2C%0A++++++++++%22updateKey%22%3A+%5B%5D%0A++++++++%7D%0A++++++%7D%0A++++%7D%5D%2C%0A++++%22setting%22%3A+%7B%0A++++++%22speed%22%3A+%7B%0A++++++++%22channel%22%3A+1%2C%0A++++++++%22bytes%22%3A+0%0A++++++%7D%0A++++%7D%0A%7D%0A%7D
2023-01-04 14:46:02,500 - 56   INFO  [main] com.dtstack.chunjun.Main:-jobName
2023-01-04 14:46:02,500 - 56   INFO  [main] com.dtstack.chunjun.Main:Flink_Job
2023-01-04 14:46:02,500 - 56   INFO  [main] com.dtstack.chunjun.Main:-chunjunDistDir
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:/opt/soft2/chunjun/chunjun-dist
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:-jobType
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:sync
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:-confProp
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:{}
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:-pluginLoadMode
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:shipfile
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:-mode
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:local
2023-01-04 14:46:02,501 - 57   INFO  [main] com.dtstack.chunjun.Main:-------------------------------------------
2023-01-04 14:46:03,789 - 1345 INFO  [main] com.dtstack.chunjun.Main:Register to table configuration:{table.dynamic-table-options.enabled=true, pipeline.name=Flink_Job}
2023-01-04 14:46:03,838 - 1394 INFO  [main] com.dtstack.chunjun.util.PluginUtil:ChunJun executionMode: local
2023-01-04 14:46:03,838 - 1394 INFO  [main] com.dtstack.chunjun.util.PluginUtil:ChunJun reset pipeline.jars: [/opt/soft2/chunjun/chunjun-dist/chunjun-core.jar, /opt/soft2/chunjun/chunjun-dist/connector/sqlserver/chunjun-connector-sqlserver.jar, /opt/soft2/chunjun/chunjun-dist/metrics/prometheus/chunjun-metrics-prometheus.jar]
2023-01-04 14:46:03,843 - 1399 INFO  [main] com.dtstack.chunjun.classloader.ClassLoaderManager:jarUrl:file:/opt/soft2/chunjun/chunjun-dist/chunjun-core.jar_file:/opt/soft2/chunjun/chunjun-dist/connector/sqlserver/chunjun-connector-sqlserver.jar_file:/opt/soft2/chunjun/chunjun-dist/metrics/prometheus/chunjun-metrics-prometheus.jar create ClassLoad successful...
2023-01-04 14:46:04,413 - 1969 INFO  [main] org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils:The configuration option taskmanager.cpu.cores required for local execution is not set, setting it to the maximal possible value.
2023-01-04 14:46:04,413 - 1969 INFO  [main] org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils:The configuration option taskmanager.memory.task.heap.size required for local execution is not set, setting it to the maximal possible value.
2023-01-04 14:46:04,413 - 1969 INFO  [main] org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils:The configuration option taskmanager.memory.task.off-heap.size required for local execution is not set, setting it to the maximal possible value.
2023-01-04 14:46:04,415 - 1971 INFO  [main] org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils:The configuration option taskmanager.memory.network.min required for local execution is not set, setting it to its default value 64 mb.
2023-01-04 14:46:04,415 - 1971 INFO  [main] org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils:The configuration option taskmanager.memory.network.max required for local execution is not set, setting it to its default value 64 mb.
2023-01-04 14:46:04,415 - 1971 INFO  [main] com.dtstack.chunjun.environment.MyLocalStreamEnvironment:Running job on local embedded Flink mini cluster
2023-01-04 14:46:04,433 - 1989 INFO  [main] org.apache.flink.runtime.minicluster.MiniCluster:Starting Flink Mini Cluster
2023-01-04 14:46:04,436 - 1992 INFO  [main] org.apache.flink.runtime.minicluster.MiniCluster:Starting Metrics Registry
2023-01-04 14:46:04,484 - 2040 INFO  [main] org.apache.flink.runtime.metrics.MetricRegistryImpl:No metrics reporter configured, no metrics will be exposed/reported.
2023-01-04 14:46:04,485 - 2041 INFO  [main] org.apache.flink.runtime.minicluster.MiniCluster:Starting RPC Service(s)
2023-01-04 14:46:04,506 - 2062 INFO  [main] org.apache.flink.runtime.clusterframework.BootstrapTools:Trying to start local actor system
2023-01-04 14:46:04,927 - 2483 INFO  [flink-akka.actor.default-dispatcher-2] akka.event.slf4j.Slf4jLogger$$anonfun$receive$1:Slf4jLogger started
2023-01-04 14:46:05,035 - 2591 INFO  [main] org.apache.flink.runtime.clusterframework.BootstrapTools:Actor system started at akka://flink
2023-01-04 14:46:05,048 - 2604 INFO  [main] org.apache.flink.runtime.clusterframework.BootstrapTools:Trying to start local actor system
2023-01-04 14:46:05,064 - 2620 INFO  [flink-metrics-2] akka.event.slf4j.Slf4jLogger$$anonfun$receive$1:Slf4jLogger started
2023-01-04 14:46:05,075 - 2631 INFO  [main] org.apache.flink.runtime.clusterframework.BootstrapTools:Actor system started at akka://flink-metrics
2023-01-04 14:46:05,092 - 2648 INFO  [main] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService .
2023-01-04 14:46:05,109 - 2665 INFO  [main] org.apache.flink.runtime.minicluster.MiniCluster:Starting high-availability services
2023-01-04 14:46:05,119 - 2675 INFO  [main] org.apache.flink.runtime.blob.BlobServer:Created BLOB server storage directory /tmp/blobStore-b6c56c8d-2080-4c85-bd52-9318aeacbbe3
2023-01-04 14:46:05,124 - 2680 INFO  [main] org.apache.flink.runtime.blob.BlobServer:Started BLOB server at 0.0.0.0:33735 - max concurrent requests: 50 - max backlog: 1000
2023-01-04 14:46:05,127 - 2683 INFO  [main] org.apache.flink.runtime.blob.AbstractBlobCache:Created BLOB cache storage directory /tmp/blobStore-9b8897e6-626b-4532-92e4-52f54325d1c4
2023-01-04 14:46:05,128 - 2684 INFO  [main] org.apache.flink.runtime.blob.AbstractBlobCache:Created BLOB cache storage directory /tmp/blobStore-c29f2ec1-f8d4-4366-b197-713361c6b604
2023-01-04 14:46:05,129 - 2685 INFO  [main] org.apache.flink.runtime.minicluster.MiniCluster:Starting 1 TaskManger(s)
2023-01-04 14:46:05,132 - 2688 INFO  [main] org.apache.flink.runtime.taskexecutor.TaskManagerRunner:Starting TaskManager with ResourceID: 049b2ea1-8f7e-4f1c-bf7e-465f98861d92
2023-01-04 14:46:05,143 - 2699 INFO  [main] org.apache.flink.runtime.taskexecutor.TaskManagerServices:Temporary file directory '/tmp': total 490 GB, usable 463 GB (94.49% usable)
2023-01-04 14:46:05,145 - 2701 INFO  [main] org.apache.flink.runtime.io.disk.FileChannelManagerImpl:FileChannelManager uses directory /tmp/flink-io-691f358a-51e3-435f-955d-49da793d8a63 for spill files.
2023-01-04 14:46:05,153 - 2709 INFO  [main] org.apache.flink.runtime.io.disk.FileChannelManagerImpl:FileChannelManager uses directory /tmp/flink-netty-shuffle-3dbf52fd-c190-4f95-8153-075740342a84 for spill files.
2023-01-04 14:46:05,228 - 2784 INFO  [main] org.apache.flink.runtime.io.network.buffer.NetworkBufferPool:Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768).
2023-01-04 14:46:05,237 - 2793 INFO  [main] org.apache.flink.runtime.io.network.NettyShuffleEnvironment:Starting the network environment and its components.
2023-01-04 14:46:05,238 - 2794 INFO  [main] org.apache.flink.runtime.taskexecutor.KvStateService:Starting the kvState service and its components.
2023-01-04 14:46:05,259 - 2815 INFO  [main] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/rpc/taskmanager_0 .
2023-01-04 14:46:05,274 - 2830 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService:Start job leader service.
2023-01-04 14:46:05,276 - 2832 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.filecache.FileCache:User file cache uses directory /tmp/flink-dist-cache-80953a12-19a7-498f-8769-c9c1bdb0a5f8
2023-01-04 14:46:05,312 - 2868 INFO  [main] org.apache.flink.runtime.rest.RestServerEndpoint:Starting rest endpoint.
2023-01-04 14:46:05,393 - 2949 WARN  [main] org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation:Log file environment variable 'log.file' is not set.
2023-01-04 14:46:05,393 - 2949 WARN  [main] org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation:JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'.
2023-01-04 14:46:05,545 - 3101 INFO  [main] org.apache.flink.runtime.rest.RestServerEndpoint:Rest endpoint listening at localhost:46429
2023-01-04 14:46:05,546 - 3102 INFO  [main] org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService:Proposing leadership to contender http://localhost:46429
2023-01-04 14:46:05,549 - 3105 INFO  [main] org.apache.flink.runtime.webmonitor.WebMonitorEndpoint:Web frontend listening at http://localhost:46429.
2023-01-04 14:46:05,549 - 3105 INFO  [mini-cluster-io-thread-1] org.apache.flink.runtime.webmonitor.WebMonitorEndpoint:http://localhost:46429 was granted leadership with leaderSessionID=87b090d5-de9a-4e6a-8b64-9ccc5cdfa7f3
2023-01-04 14:46:05,550 - 3106 INFO  [mini-cluster-io-thread-1] org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService:Received confirmation of leadership for leader http://localhost:46429 , session=87b090d5-de9a-4e6a-8b64-9ccc5cdfa7f3
2023-01-04 14:46:05,565 - 3121 INFO  [main] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/rpc/resourcemanager_1 .
2023-01-04 14:46:05,583 - 3139 INFO  [main] org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService:Proposing leadership to contender LeaderContender: DefaultDispatcherRunner
2023-01-04 14:46:05,584 - 3140 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService:Proposing leadership to contender LeaderContender: StandaloneResourceManager
2023-01-04 14:46:05,587 - 3143 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.resourcemanager.ResourceManager:ResourceManager akka://flink/user/rpc/resourcemanager_1 was granted leadership with fencing token ad385fd6a646780de0e6eb781db54a0b
2023-01-04 14:46:05,591 - 3147 INFO  [mini-cluster-io-thread-2] org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess:Start SessionDispatcherLeaderProcess.
2023-01-04 14:46:05,591 - 3147 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl:Starting the SlotManager.
2023-01-04 14:46:05,591 - 3147 INFO  [main] org.apache.flink.runtime.minicluster.MiniCluster:Flink Mini Cluster started successfully
2023-01-04 14:46:05,593 - 3149 INFO  [mini-cluster-io-thread-5] org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess:Recover all persisted job graphs.
2023-01-04 14:46:05,594 - 3150 INFO  [mini-cluster-io-thread-5] org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess:Successfully recovered 0 persisted job graphs.
2023-01-04 14:46:05,595 - 3151 INFO  [mini-cluster-io-thread-6] org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService:Received confirmation of leadership for leader akka://flink/user/rpc/resourcemanager_1 , session=e0e6eb78-1db5-4a0b-ad38-5fd6a646780d
2023-01-04 14:46:05,600 - 3156 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.taskexecutor.TaskExecutor:Connecting to ResourceManager akka://flink/user/rpc/resourcemanager_1(ad385fd6a646780de0e6eb781db54a0b).
2023-01-04 14:46:05,603 - 3159 INFO  [mini-cluster-io-thread-5] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_2 .
2023-01-04 14:46:05,616 - 3172 INFO  [mini-cluster-io-thread-5] org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService:Received confirmation of leadership for leader akka://flink/user/rpc/dispatcher_2 , session=947bc204-104b-4d3b-b422-23149823f946
2023-01-04 14:46:05,620 - 3176 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.registration.RetryingRegistration:Resolved ResourceManager address, beginning registration
2023-01-04 14:46:05,627 - 3183 INFO  [flink-akka.actor.default-dispatcher-4] org.apache.flink.runtime.resourcemanager.ResourceManager:Registering TaskManager with ResourceID 049b2ea1-8f7e-4f1c-bf7e-465f98861d92 (akka://flink/user/rpc/taskmanager_0) at ResourceManager
2023-01-04 14:46:05,629 - 3185 INFO  [flink-akka.actor.default-dispatcher-6] org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection:Successful registration at resource manager akka://flink/user/rpc/resourcemanager_1 under registration id d6a4bb3a7f81242c740c6d1c87b11458.
2023-01-04 14:46:05,881 - 3437 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.dispatcher.Dispatcher:Received JobGraph submission 4f649ecae36b7474313e67650873e279 (Flink_Job).
2023-01-04 14:46:05,882 - 3438 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.dispatcher.Dispatcher:Submitting job 4f649ecae36b7474313e67650873e279 (Flink_Job).
2023-01-04 14:46:05,903 - 3459 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService:Proposing leadership to contender LeaderContender: JobManagerRunnerImpl
2023-01-04 14:46:05,913 - 3469 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/rpc/jobmanager_3 .
2023-01-04 14:46:05,922 - 3478 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.jobmaster.JobMaster:Initializing job Flink_Job (4f649ecae36b7474313e67650873e279).
2023-01-04 14:46:05,947 - 3503 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.scheduler.DefaultSchedulerFactory:Using restart back off time strategy NoRestartBackoffTimeStrategy for Flink_Job (4f649ecae36b7474313e67650873e279).
2023-01-04 14:46:05,962 - 3518 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder:start to buildGraph for job Flink_Job (4f649ecae36b7474313e67650873e279).
2023-01-04 14:46:05,993 - 3549 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder:trying to download shipFile from blobServer for job Flink_Job (4f649ecae36b7474313e67650873e279).
2023-01-04 14:46:05,993 - 3549 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder:Running initialization on master for job Flink_Job (4f649ecae36b7474313e67650873e279).
2023-01-04 14:46:06,004 - 3560 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder:Successfully ran initialization on master in 11 ms.
2023-01-04 14:46:06,016 - 3572 INFO  [mini-cluster-io-thread-12] com.dtstack.chunjun.connector.jdbc.source.JdbcInputFormat:createInputSplitsInternal success, splits is [
  {
    "mod": 0,
    "isPolling": false,
    "splitStrategy": "mod",
    "rangeEndLocationOperator": " < ",
    "partitionNumber": 0,
    "totalNumberOfPartitions": 1
  }
]
2023-01-04 14:46:06,021 - 3577 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology:Built 1 pipelined regions in 0 ms
2023-01-04 14:46:06,032 - 3588 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.state.StateBackendLoader:No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
2023-01-04 14:46:06,043 - 3599 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.checkpoint.CheckpointCoordinator:No checkpoint found during restore.
2023-01-04 14:46:06,046 - 3602 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.scheduler.DefaultScheduler:Using failover strategy org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@1a1b1872 for Flink_Job (4f649ecae36b7474313e67650873e279).
2023-01-04 14:46:06,056 - 3612 INFO  [mini-cluster-io-thread-12] org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl:JobManager runner for job Flink_Job (4f649ecae36b7474313e67650873e279) was granted leadership with session id 562b0f42-4db0-41f0-9d9f-89599ddbf245 at akka://flink/user/rpc/jobmanager_3.
2023-01-04 14:46:06,061 - 3617 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.jobmaster.JobMaster:Starting execution of job Flink_Job (4f649ecae36b7474313e67650873e279) under job master id 9d9f89599ddbf245562b0f424db041f0.
2023-01-04 14:46:06,062 - 3618 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.scheduler.DefaultScheduler:Starting scheduling with scheduling strategy [org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
2023-01-04 14:46:06,063 - 3619 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.executiongraph.ExecutionGraph:Job Flink_Job (4f649ecae36b7474313e67650873e279) switched from state CREATED to RUNNING.
2023-01-04 14:46:06,067 - 3623 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.executiongraph.Execution:Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1) (a77094848f840f2ec53568dcdbd41cc5) switched from CREATED to SCHEDULED.
2023-01-04 14:46:06,077 - 3633 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl:Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{209f84e2fdbc8b837618cd09fd081506}]
2023-01-04 14:46:06,086 - 3642 INFO  [jobmanager-future-thread-1] org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService:Received confirmation of leadership for leader akka://flink/user/rpc/jobmanager_3 , session=562b0f42-4db0-41f0-9d9f-89599ddbf245
2023-01-04 14:46:06,086 - 3642 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.jobmaster.JobMaster:Connecting to ResourceManager akka://flink/user/rpc/resourcemanager_1(ad385fd6a646780de0e6eb781db54a0b)
2023-01-04 14:46:06,089 - 3645 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.registration.RetryingRegistration:Resolved ResourceManager address, beginning registration
2023-01-04 14:46:06,091 - 3647 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.resourcemanager.ResourceManager:Registering job manager 9d9f89599ddbf245562b0f424db041f0@akka://flink/user/rpc/jobmanager_3 for job 4f649ecae36b7474313e67650873e279.
2023-01-04 14:46:06,098 - 3654 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.resourcemanager.ResourceManager:Registered job manager 9d9f89599ddbf245562b0f424db041f0@akka://flink/user/rpc/jobmanager_3 for job 4f649ecae36b7474313e67650873e279.
2023-01-04 14:46:06,100 - 3656 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.jobmaster.JobMaster:JobManager successfully registered at ResourceManager, leader id: ad385fd6a646780de0e6eb781db54a0b.
2023-01-04 14:46:06,101 - 3657 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl:Requesting new slot [SlotRequestId{209f84e2fdbc8b837618cd09fd081506}] and profile ResourceProfile{UNKNOWN} with allocation id b4f18663c5c6c4fbf6cd9681ca0cd9f9 from resource manager.
2023-01-04 14:46:06,102 - 3658 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.resourcemanager.ResourceManager:Request slot with profile ResourceProfile{UNKNOWN} for job 4f649ecae36b7474313e67650873e279 with allocation id b4f18663c5c6c4fbf6cd9681ca0cd9f9.
2023-01-04 14:46:06,105 - 3661 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.taskexecutor.TaskExecutor:Receive slot request b4f18663c5c6c4fbf6cd9681ca0cd9f9 for job 4f649ecae36b7474313e67650873e279 from resource manager with leader id ad385fd6a646780de0e6eb781db54a0b.
2023-01-04 14:46:06,110 - 3666 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.taskexecutor.TaskExecutor:Allocated slot for b4f18663c5c6c4fbf6cd9681ca0cd9f9.
2023-01-04 14:46:06,112 - 3668 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService:Add job 4f649ecae36b7474313e67650873e279 for job leader monitoring.
2023-01-04 14:46:06,114 - 3670 INFO  [mini-cluster-io-thread-18] org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService$JobManagerLeaderListener:Try to register at job manager akka://flink/user/rpc/jobmanager_3 with leader id 562b0f42-4db0-41f0-9d9f-89599ddbf245.
2023-01-04 14:46:06,115 - 3671 INFO  [flink-akka.actor.default-dispatcher-2] org.apache.flink.runtime.registration.RetryingRegistration:Resolved JobManager address, beginning registration
2023-01-04 14:46:06,120 - 3676 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService$JobManagerLeaderListener$JobManagerRegisteredRpcConnection:Successful registration at job manager akka://flink/user/rpc/jobmanager_3 for job 4f649ecae36b7474313e67650873e279.
2023-01-04 14:46:06,122 - 3678 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.taskexecutor.TaskExecutor:Establish JobManager connection for job 4f649ecae36b7474313e67650873e279.
2023-01-04 14:46:06,125 - 3681 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.taskexecutor.TaskExecutor:Offer reserved slots to the leader of job 4f649ecae36b7474313e67650873e279.
2023-01-04 14:46:06,130 - 3686 INFO  [flink-akka.actor.default-dispatcher-4] org.apache.flink.runtime.executiongraph.Execution:Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1) (a77094848f840f2ec53568dcdbd41cc5) switched from SCHEDULED to DEPLOYING.
2023-01-04 14:46:06,131 - 3687 INFO  [flink-akka.actor.default-dispatcher-4] org.apache.flink.runtime.executiongraph.Execution:Deploying Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1) (attempt #0) with attempt id a77094848f840f2ec53568dcdbd41cc5 to 049b2ea1-8f7e-4f1c-bf7e-465f98861d92 @ localhost (dataPort=-1) with allocation id b4f18663c5c6c4fbf6cd9681ca0cd9f9
2023-01-04 14:46:06,136 - 3692 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl:Activate slot b4f18663c5c6c4fbf6cd9681ca0cd9f9.
2023-01-04 14:46:06,161 - 3717 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.taskexecutor.TaskExecutor:Received task Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0 (a77094848f840f2ec53568dcdbd41cc5), deploy into slot with allocation id b4f18663c5c6c4fbf6cd9681ca0cd9f9.
2023-01-04 14:46:06,162 - 3718 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0 (a77094848f840f2ec53568dcdbd41cc5) switched from CREATED to DEPLOYING.
2023-01-04 14:46:06,164 - 3720 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl:Activate slot b4f18663c5c6c4fbf6cd9681ca0cd9f9.
2023-01-04 14:46:06,165 - 3721 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Loading JAR files for task Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0 (a77094848f840f2ec53568dcdbd41cc5) [DEPLOYING].
2023-01-04 14:46:06,167 - 3723 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Registering task at network: Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0 (a77094848f840f2ec53568dcdbd41cc5) [DEPLOYING].
2023-01-04 14:46:06,167 - 3723 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Obtaining local cache file for 'class_path_2'.
2023-01-04 14:46:06,169 - 3725 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Obtaining local cache file for 'class_path_1'.
2023-01-04 14:46:06,171 - 3727 INFO  [flink-file-cache-thread-1] org.apache.flink.runtime.blob.BlobClient:Downloading 4f649ecae36b7474313e67650873e279/p-cc4db2a4af7dd7dc4840c1064480c2d91b8c1b92-b869cd34f68d25db45ecd02e78b4a95d from localhost/127.0.0.1:33735
2023-01-04 14:46:06,171 - 3727 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Obtaining local cache file for 'class_path_0'.
2023-01-04 14:46:06,173 - 3729 INFO  [flink-file-cache-thread-2] org.apache.flink.runtime.blob.BlobClient:Downloading 4f649ecae36b7474313e67650873e279/p-96f7e06f381fe3c7571a5021cb9ad166d2eb46c2-446c6d9e31187666647e82dcfda1ee12 from localhost/127.0.0.1:33735
2023-01-04 14:46:06,173 - 3729 INFO  [flink-file-cache-thread-3] org.apache.flink.runtime.blob.BlobClient:Downloading 4f649ecae36b7474313e67650873e279/p-11c0cbd77e54fe526d0d8d3dc0eab81a48ef0687-57bc34e1843a2a9a0c9cc6d3c4e3e43f from localhost/127.0.0.1:33735
2023-01-04 14:46:06,181 - 3737 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.state.StateBackendLoader:No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
2023-01-04 14:46:06,187 - 3743 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0 (a77094848f840f2ec53568dcdbd41cc5) switched from DEPLOYING to RUNNING.
2023-01-04 14:46:06,189 - 3745 INFO  [flink-akka.actor.default-dispatcher-3] org.apache.flink.runtime.executiongraph.Execution:Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1) (a77094848f840f2ec53568dcdbd41cc5) switched from DEPLOYING to RUNNING.
2023-01-04 14:46:06,254 - 3810 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.sink.DtOutputFormatSinkFunction:Start initialize output format state
2023-01-04 14:46:06,283 - 3839 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.sink.DtOutputFormatSinkFunction:Is restored:false
2023-01-04 14:46:06,283 - 3839 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.sink.DtOutputFormatSinkFunction:End initialize output format state
2023-01-04 14:46:06,559 - 4115 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.sink.format.BaseRichOutputFormat:initTimingSubmitTask() ,initialDelay:10000, delay:10000, MILLISECONDS
2023-01-04 14:46:06,572 - 4128 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat:write sql:INSERT INTO "dbo"."test2"("id", "name") VALUES (:id, :name)
2023-01-04 14:46:06,593 - 4149 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat:subTask[0}] wait finished
2023-01-04 14:46:06,627 - 4183 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.sink.format.BaseRichOutputFormat:[SqlserverOutputFormat] open successfully,
checkpointMode = AT_LEAST_ONCE,
checkpointEnabled = false,
flushIntervalMills = 10000,
batchSize = 1024,
[JdbcConf]:
{
  "schema" : "dbo",
  "semantic" : "at-least-once",
  "errorRecord" : 0,
  "checkFormat" : true,
  "parallelism" : 1,
  "updateKey" : { },
  "executeDdlAble" : false,
  "pollingInterval" : 5000,
  "increment" : false,
  "orderBy" : true,
  "flushIntervalMills" : 10000,
  "polling" : false,
  "mode" : "insert",
  "password" : "******",
  "metricPluginRoot" : "/opt/soft2/chunjun/chunjun-dist/metrics",
  "restoreColumnIndex" : -1,
  "connection" : [ {
    "table" : [ "test2" ],
    "schema" : "dbo",
    "jdbcUrl" : "jdbc:jtds:sqlserver://172.31.32.57:1433;databaseName=DW",
    "allReplace" : false
  } ],
  "table" : "test2",
  "postSql" : [ ],
  "queryTimeOut" : 0,
  "fetchSize" : 0,
  "useMaxFunc" : false,
  "pollingFromMax" : false,
  "column" : [ {
    "name" : "id",
    "type" : "int",
    "index" : 0,
    "notNull" : false,
    "part" : false
  }, {
    "name" : "name",
    "type" : "varchar",
    "index" : 1,
    "notNull" : false,
    "part" : false
  } ],
  "errorPercentage" : -1,
  "fieldNameList" : [ ],
  "withNoLock" : false,
  "increColumnIndex" : -1,
  "allReplace" : false,
  "initReporter" : true,
  "jdbcUrl" : "jdbc:jtds:sqlserver://172.31.32.57:1433;databaseName=DW",
  "connectTimeOut" : 0,
  "batchSize" : 1024,
  "speedBytes" : 0,
  "rowSizeCalculatorType" : "objectSizeCalculator",
  "metricPluginName" : "prometheus",
  "properties" : {
    "user" : "hretl",
    "password" : "******"
  },
  "username" : "hretl",
  "preSql" : [ ]
}
2023-01-04 14:46:06,628 - 4184 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.source.DtInputFormatSourceFunction:Start initialize input format state, is restored:false
2023-01-04 14:46:06,629 - 4185 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.source.DtInputFormatSourceFunction:End initialize input format state
2023-01-04 14:46:06,649 - 4205 INFO  [Legacy Source Thread - Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.connector.jdbc.source.JdbcInputFormat:Executing sql is: 'SELECT "id", "name" FROM "dbo"."test1" WHERE  1=1 '
2023-01-04 14:46:06,654 - 4210 INFO  [Legacy Source Thread - Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.source.format.BaseRichInputFormat:[SqlserverInputFormat] open successfully,
inputSplit = JdbcInputSplit{mod=0, endLocation='null', startLocation='null', startLocationOfSplit='null', endLocationOfSplit='null', isPolling=false, splitStrategy='mod', rangeEndLocationOperator=' < '}GenericSplit (0/1),
[JdbcConf]:
{
  "schema" : "dbo",
  "semantic" : "at-least-once",
  "errorRecord" : 0,
  "checkFormat" : true,
  "parallelism" : 1,
  "executeDdlAble" : false,
  "pollingInterval" : 5000,
  "increment" : false,
  "orderBy" : true,
  "flushIntervalMills" : 10000,
  "polling" : false,
  "querySql" : "SELECT \"id\", \"name\" FROM \"dbo\".\"test1\" WHERE  1=1 ",
  "mode" : "INSERT",
  "password" : "******",
  "customSql" : "",
  "metricPluginRoot" : "/opt/soft2/chunjun/chunjun-dist/metrics",
  "restoreColumnIndex" : -1,
  "connection" : [ {
    "table" : [ "test1" ],
    "schema" : "dbo",
    "jdbcUrl" : [ "jdbc:jtds:sqlserver://172.31.32.57:1433;databaseName=DW" ]
  } ],
  "where" : "",
  "splitPk" : "id",
  "table" : "test1",
  "queryTimeOut" : 1000,
  "fetchSize" : 1000,
  "useMaxFunc" : false,
  "pollingFromMax" : false,
  "column" : [ {
    "name" : "id",
    "type" : "int",
    "index" : 0,
    "notNull" : false,
    "part" : false
  }, {
    "name" : "name",
    "type" : "varchar",
    "index" : 1,
    "notNull" : false,
    "part" : false
  } ],
  "errorPercentage" : -1,
  "fieldNameList" : [ ],
  "withNoLock" : false,
  "increColumnIndex" : -1,
  "allReplace" : false,
  "splitStrategy" : "range",
  "initReporter" : true,
  "jdbcUrl" : "jdbc:jtds:sqlserver://172.31.32.57:1433;databaseName=DW",
  "connectTimeOut" : 600,
  "batchSize" : 1,
  "speedBytes" : 0,
  "rowSizeCalculatorType" : "objectSizeCalculator",
  "metricPluginName" : "prometheus",
  "properties" : {
    "user" : "hretl",
    "password" : "******"
  },
  "username" : "hretl"
}
2023-01-04 14:46:26,656 - 24212 INFO  [Legacy Source Thread - Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.source.format.BaseRichInputFormat:subtask input close finished
2023-01-04 14:46:26,660 - 24216 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.sink.format.BaseRichOutputFormat:taskNumber[0] close()
2023-01-04 14:46:46,662 - 44218 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] com.dtstack.chunjun.sink.format.BaseRichOutputFormat:subtask[0}] close() finished
2023-01-04 14:46:46,666 - 44222 WARN  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0 (a77094848f840f2ec53568dcdbd41cc5) switched from RUNNING to FAILED.
java.lang.AbstractMethodError
        at net.sourceforge.jtds.jdbc.JtdsConnection.isValid(JtdsConnection.java:2833)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.checkConnValid(JdbcOutputFormat.java:193)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:186)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:61)
        at com.dtstack.chunjun.sink.DtOutputFormatSinkFunction.invoke(DtOutputFormatSinkFunction.java:117)
        at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:71)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:46)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:26)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:50)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:28)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:317)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:411)
        at com.dtstack.chunjun.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:135)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66)
        at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:267)
2023-01-04 14:46:46,670 - 44226 INFO  [Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0] org.apache.flink.runtime.taskmanager.Task:Freeing task resources for Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0 (a77094848f840f2ec53568dcdbd41cc5).
2023-01-04 14:46:46,678 - 44234 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.TaskExecutor:Un-registering task and sending final execution state FAILED to JobManager for task Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1)#0 a77094848f840f2ec53568dcdbd41cc5.
2023-01-04 14:46:46,682 - 44238 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.executiongraph.Execution:Source: sqlserversourcefactory -> Sink: sqlserversinkfactory (1/1) (a77094848f840f2ec53568dcdbd41cc5) switched from RUNNING to FAILED on 049b2ea1-8f7e-4f1c-bf7e-465f98861d92 @ localhost (dataPort=-1).
java.lang.AbstractMethodError
        at net.sourceforge.jtds.jdbc.JtdsConnection.isValid(JtdsConnection.java:2833)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.checkConnValid(JdbcOutputFormat.java:193)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:186)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:61)
        at com.dtstack.chunjun.sink.DtOutputFormatSinkFunction.invoke(DtOutputFormatSinkFunction.java:117)
        at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:71)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:46)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:26)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:50)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:28)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:317)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:411)
        at com.dtstack.chunjun.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:135)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66)
        at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:267)
2023-01-04 14:46:46,691 - 44247 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy:Calculating tasks to restart to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_0.
2023-01-04 14:46:46,691 - 44247 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy:1 tasks should be restarted to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_0.
2023-01-04 14:46:46,693 - 44249 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.executiongraph.ExecutionGraph:Job Flink_Job (4f649ecae36b7474313e67650873e279) switched from state RUNNING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
        at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:118)
        at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:80)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:233)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:224)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:215)
        at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:666)
        at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:89)
        at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:446)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
        at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
        at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
        at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
        at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
        at akka.actor.Actor.aroundReceive(Actor.scala:517)
        at akka.actor.Actor.aroundReceive$(Actor.scala:515)
        at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
        at akka.actor.ActorCell.invoke(ActorCell.scala:561)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
        at akka.dispatch.Mailbox.run(Mailbox.scala:225)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
        at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.AbstractMethodError
        at net.sourceforge.jtds.jdbc.JtdsConnection.isValid(JtdsConnection.java:2833)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.checkConnValid(JdbcOutputFormat.java:193)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:186)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:61)
        at com.dtstack.chunjun.sink.DtOutputFormatSinkFunction.invoke(DtOutputFormatSinkFunction.java:117)
        at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:71)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:46)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:26)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:50)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:28)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:317)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:411)
        at com.dtstack.chunjun.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:135)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66)
        at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:267)
2023-01-04 14:46:46,698 - 44254 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.executiongraph.ExecutionGraph:Job Flink_Job (4f649ecae36b7474313e67650873e279) switched from state FAILING to FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
        at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:118)
        at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:80)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:233)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:224)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:215)
        at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:666)
        at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:89)
        at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:446)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
        at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
        at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
        at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
        at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
        at akka.actor.Actor.aroundReceive(Actor.scala:517)
        at akka.actor.Actor.aroundReceive$(Actor.scala:515)
        at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
        at akka.actor.ActorCell.invoke(ActorCell.scala:561)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
        at akka.dispatch.Mailbox.run(Mailbox.scala:225)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
        at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.AbstractMethodError
        at net.sourceforge.jtds.jdbc.JtdsConnection.isValid(JtdsConnection.java:2833)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.checkConnValid(JdbcOutputFormat.java:193)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:186)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:61)
        at com.dtstack.chunjun.sink.DtOutputFormatSinkFunction.invoke(DtOutputFormatSinkFunction.java:117)
        at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:71)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:46)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:26)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:50)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:28)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:317)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:411)
        at com.dtstack.chunjun.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:135)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66)
        at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:267)
2023-01-04 14:46:46,700 - 44256 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.checkpoint.CheckpointCoordinator:Stopping checkpoint coordinator for job 4f649ecae36b7474313e67650873e279.
2023-01-04 14:46:46,704 - 44260 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore:Shutting down
2023-01-04 14:46:46,708 - 44264 INFO  [flink-akka.actor.default-dispatcher-12] org.apache.flink.runtime.dispatcher.Dispatcher:Job 4f649ecae36b7474313e67650873e279 reached terminal state FAILED.
2023-01-04 14:46:46,709 - 44265 INFO  [main] org.apache.flink.runtime.minicluster.MiniCluster:Shutting down Flink Mini Cluster
2023-01-04 14:46:46,709 - 44265 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.TaskExecutor:Stopping TaskExecutor akka://flink/user/rpc/taskmanager_0.
2023-01-04 14:46:46,710 - 44266 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.jobmaster.JobMaster:Stopping the JobMaster for job Flink_Job(4f649ecae36b7474313e67650873e279).
2023-01-04 14:46:46,709 - 44265 INFO  [main] org.apache.flink.runtime.rest.RestServerEndpoint:Shutting down rest endpoint.
2023-01-04 14:46:46,711 - 44267 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl:Suspending SlotPool.
2023-01-04 14:46:46,711 - 44267 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.jobmaster.JobMaster:Close ResourceManager connection 3140c34069b6ea2afa7bde98da275267: Stopping JobMaster for job Flink_Job(4f649ecae36b7474313e67650873e279)..
2023-01-04 14:46:46,712 - 44268 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl:Stopping SlotPool.
2023-01-04 14:46:46,710 - 44266 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.TaskExecutor:Close ResourceManager connection 3140c34069b6ea2afa7bde98da275267.
2023-01-04 14:46:46,712 - 44268 INFO  [flink-akka.actor.default-dispatcher-12] org.apache.flink.runtime.resourcemanager.ResourceManager:Disconnect job manager 9d9f89599ddbf245562b0f424db041f0@akka://flink/user/rpc/jobmanager_3 for job 4f649ecae36b7474313e67650873e279 from the resource manager.
2023-01-04 14:46:46,713 - 44269 INFO  [flink-akka.actor.default-dispatcher-12] org.apache.flink.runtime.resourcemanager.ResourceManager:Closing TaskExecutor connection 049b2ea1-8f7e-4f1c-bf7e-465f98861d92 because: The TaskExecutor is shutting down.
2023-01-04 14:46:46,715 - 44271 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.TaskExecutor:Close JobManager connection for job 4f649ecae36b7474313e67650873e279.
2023-01-04 14:46:46,725 - 44281 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl:Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{taskHeapMemory=1024.000gb (1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes), managedMemory=512.000mb (536870912 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationId: b4f18663c5c6c4fbf6cd9681ca0cd9f9, jobId: 4f649ecae36b7474313e67650873e279).
2023-01-04 14:46:46,727 - 44283 INFO  [mini-cluster-io-thread-19] org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl:JobManager for job 4f649ecae36b7474313e67650873e279 with leader id 9d9f89599ddbf245562b0f424db041f0 lost leadership.
2023-01-04 14:46:46,736 - 44292 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService:Stop job leader service.
2023-01-04 14:46:46,737 - 44293 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager:Shutting down TaskExecutorLocalStateStoresManager.
2023-01-04 14:46:46,737 - 44293 INFO  [ForkJoinPool.commonPool-worker-3] org.apache.flink.runtime.webmonitor.WebMonitorEndpoint:Removing cache directory /tmp/flink-web-ui
2023-01-04 14:46:46,742 - 44298 INFO  [ForkJoinPool.commonPool-worker-3] org.apache.flink.runtime.rest.RestServerEndpoint:Shut down complete.
2023-01-04 14:46:46,742 - 44298 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.io.disk.FileChannelManagerImpl:FileChannelManager removed spill file directory /tmp/flink-io-691f358a-51e3-435f-955d-49da793d8a63
2023-01-04 14:46:46,743 - 44299 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.io.network.NettyShuffleEnvironment:Shutting down the network environment and its components.
2023-01-04 14:46:46,744 - 44300 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.resourcemanager.ResourceManager:Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
2023-01-04 14:46:46,745 - 44301 INFO  [flink-akka.actor.default-dispatcher-12] org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent:Closing components.
2023-01-04 14:46:46,745 - 44301 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.io.disk.FileChannelManagerImpl:FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-3dbf52fd-c190-4f95-8153-075740342a84
2023-01-04 14:46:46,746 - 44302 INFO  [flink-akka.actor.default-dispatcher-12] org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess:Stopping SessionDispatcherLeaderProcess.
2023-01-04 14:46:46,746 - 44302 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.KvStateService:Shutting down the kvState service and its components.
2023-01-04 14:46:46,746 - 44302 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.dispatcher.Dispatcher:Stopping dispatcher akka://flink/user/rpc/dispatcher_2.
2023-01-04 14:46:46,746 - 44302 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService:Stop job leader service.
2023-01-04 14:46:46,747 - 44303 INFO  [flink-akka.actor.default-dispatcher-14] org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl:Closing the SlotManager.
2023-01-04 14:46:46,747 - 44303 INFO  [flink-akka.actor.default-dispatcher-14] org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl:Suspending the SlotManager.
2023-01-04 14:46:46,746 - 44302 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.dispatcher.Dispatcher:Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_2.
2023-01-04 14:46:46,748 - 44304 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator:Shutting down back pressure request coordinator.
2023-01-04 14:46:46,749 - 44305 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.dispatcher.Dispatcher:Stopped dispatcher akka://flink/user/rpc/dispatcher_2.
2023-01-04 14:46:51,748 - 49304 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.filecache.FileCache:removed file cache directory /tmp/flink-dist-cache-80953a12-19a7-498f-8769-c9c1bdb0a5f8
2023-01-04 14:46:51,750 - 49306 INFO  [flink-akka.actor.default-dispatcher-11] org.apache.flink.runtime.taskexecutor.TaskExecutor:Stopped TaskExecutor akka://flink/user/rpc/taskmanager_0.
2023-01-04 14:46:51,752 - 49308 INFO  [AkkaRpcService-Supervisor-Termination-Future-Executor-thread-1] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Stopping Akka RPC service.
2023-01-04 14:46:51,796 - 49352 INFO  [flink-metrics-2] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Stopping Akka RPC service.
2023-01-04 14:46:51,797 - 49353 INFO  [flink-metrics-2] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Stopped Akka RPC service.
2023-01-04 14:46:51,816 - 49372 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.blob.AbstractBlobCache:Shutting down BLOB cache
2023-01-04 14:46:51,819 - 49375 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.blob.AbstractBlobCache:Shutting down BLOB cache
2023-01-04 14:46:51,820 - 49376 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.blob.BlobServer:Stopped BLOB server at 0.0.0.0:33735
2023-01-04 14:46:51,820 - 49376 INFO  [flink-akka.actor.default-dispatcher-13] org.apache.flink.runtime.rpc.akka.AkkaRpcService:Stopped Akka RPC service.
Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
        at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
        at org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:811)
        at com.dtstack.chunjun.environment.MyLocalStreamEnvironment.execute(MyLocalStreamEnvironment.java:174)
        at com.dtstack.chunjun.Main.exeSyncJob(Main.java:224)
        at com.dtstack.chunjun.Main.main(Main.java:117)
        at com.dtstack.chunjun.client.local.LocalClusterClientHelper.submit(LocalClusterClientHelper.java:35)
        at com.dtstack.chunjun.client.Launcher.main(Launcher.java:119)
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
        at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:118)
        at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:80)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:233)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:224)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:215)
        at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:666)
        at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:89)
        at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:446)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
        at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
        at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
        at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
        at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
        at akka.actor.Actor.aroundReceive(Actor.scala:517)
        at akka.actor.Actor.aroundReceive$(Actor.scala:515)
        at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
        at akka.actor.ActorCell.invoke(ActorCell.scala:561)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
        at akka.dispatch.Mailbox.run(Mailbox.scala:225)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
        at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.AbstractMethodError
        at net.sourceforge.jtds.jdbc.JtdsConnection.isValid(JtdsConnection.java:2833)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.checkConnValid(JdbcOutputFormat.java:193)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:186)
        at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:61)
        at com.dtstack.chunjun.sink.DtOutputFormatSinkFunction.invoke(DtOutputFormatSinkFunction.java:117)
        at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:71)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:46)
        at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:26)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:50)
        at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:28)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:317)
        at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:411)
        at com.dtstack.chunjun.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:135)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66)
        at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:267)
[root@LYGVLSCHEAPP01 chunjun]#

[kinoxyz1]

From the exception information, it seems that the connection failed, can you check the connection information

[jim6745]

I just combine the two examples ， stream->sqlserver and sqlserver->stream , to make the json file for sqlsevrer -> sqlserver ,
the connection is pointed to the same database , and different tables(test1, test2) . when I try to use example for sqlserver->stream , it can be run success ,so I think the connection should be right

[FlechazoW]

PR merged. close #1465