biandou1313
biandou1313
> 我们目前没有1.15版本呐。。 master分支
09:37:27.169 [cluster-io-thread-1] INFO com.dtstack.flinkx.connector.jdbc.source.JdbcInputFormat - createInputSplitsInternal success, splits is [ { "mod": 0, "startLocationOfSplit": "1", "endLocationOfSplit": "6172840374662", "partitionNumber": 0, "totalNumberOfPartitions": 20 }, { "mod": 1, "startLocationOfSplit": "6172840374662", "endLocationOfSplit": "12345680749323", "partitionNumber":...
akka.actor.default-dispatcher-3] DEBUG org.apache.flink.api.common.io.DefaultInputSplitAssigner - Assigning split JdbcInputSplit{mod=19, endLocation='null', startLocation='null', startLocationOfSplit='117283967118544', endLocationOfSplit='null'} to hadoop03 09:37:39.667 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Send next input split JdbcInputSplit{mod=19, endLocation='null', startLocation='null', startLocationOfSplit='117283967118544', endLocationOfSplit='null'}. 09:37:39.669 [flink-akka.actor.default-dispatcher-3] DEBUG...
k-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: mysqlsourcefactory -> Sink: hivesinkfactory (7/20) (bec53728dcff8f7b86b270f30a9d96b4) switched from RUNNING to FINISHED. 09:37:50.271 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph - Ignoring transition of vertex Source: mysqlsourcefactory -> Sink: hivesinkfactory...
C:\develop\jdk8\bin\java.exe -agentlib:jdwp=transport=dt_socket,address=127.0.0.1:55801,suspend=y,server=n -javaagent:C:\Users\admin\AppData\Local\JetBrains\IntelliJIdea2020.3\captureAgent\debugger-agent.jar -Dfile.encoding=UTF-8 -classpath C:\Users\admin\AppData\Local\Temp\classpath1169876339.jar com.dtstack.chunjun.local.test.LocalTest Connected to the target VM, address: '127.0.0.1:55801', transport: 'socket' 2022-08-23 15:45:59,516 - 0 WARN [main] com.dtstack.chunjun.local.test.LocalTest:----- 2022-08-23 15:45:59,760 - 244 INFO [main] com.dtstack.chunjun.Main:------------program...
2022-08-23 11:22:17,512 INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - -------------------------------------------------------------------------------- 2022-08-23 11:22:17,516 INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - Preconfiguration: 2022-08-23 11:22:17,516 INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - TM_RESOURCE_PARAMS extraction logs: jvm_params: -Xmx8294655496 -Xms8294655496 -XX:MaxDirectMemorySize=1207959552 -XX:MaxMetaspaceSize=268435456 dynamic_configs: -D...
 
> 看图上并行度是10 可以提供一下具体的报错信息么 大佬 微信多少 一起解决这个性能问题 我的微信biandou1l1111
   