同步mysql到mysql报错！

[ceaserzh]

2020-09-28 15:54:15,883 INFO com.dtstack.flinkx.hive.writer.HiveOutputFormat - subtask[0] open start
2020-09-28 15:54:15,966 ERROR com.dtstack.flinkx.util.RetryUtil - Exception when calling callable, 异常Msg:http://szzb-bg-uat-etl-07:8088/proxy/application_1600944532255_1748/jobs/f45da2bb96ad26d14368a13ab45edb77/accumulators
java.io.FileNotFoundException: http://szzb-bg-uat-etl-07:8088/proxy/application_1600944532255_1748/jobs/f45da2bb96ad26d14368a13ab45edb77/accumulators
at sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1890)
at sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1492)
at java.net.URL.openStream(URL.java:1045)
at com.dtstack.flinkx.util.UrlUtil$2.call(UrlUtil.java:59)
at com.dtstack.flinkx.util.UrlUtil$2.call(UrlUtil.java:56)
at com.dtstack.flinkx.util.RetryUtil$Retry.call(RetryUtil.java:126)
at com.dtstack.flinkx.util.RetryUtil$Retry.doRetry(RetryUtil.java:73)
at com.dtstack.flinkx.util.RetryUtil.executeWithRetry(RetryUtil.java:53)
at com.dtstack.flinkx.util.UrlUtil.open(UrlUtil.java:56)
at com.dtstack.flinkx.metrics.AccumulatorCollector.checkMonitorUrlIsValid(AccumulatorCollector.java:140)
at com.dtstack.flinkx.metrics.AccumulatorCollector.(AccumulatorCollector.java:102)
at com.dtstack.flinkx.outputformat.BaseRichOutputFormat.initAccumulatorCollector(BaseRichOutputFormat.java:238)
at com.dtstack.flinkx.outputformat.BaseRichOutputFormat.open(BaseRichOutputFormat.java:217)
at com.dtstack.flinkx.streaming.api.functions.sink.DtOutputFormatSinkFunction.open(DtOutputFormatSinkFunction.java:88)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
at org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:48)
at org.apache.flink.streaming.runtime.tasks.StreamTask.initializeStateAndOpen(StreamTask.java:990)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:453)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:448)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:460)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:708)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:533)
at java.lang.Thread.run(Thread.java:748)
2020-09-28 15:54:16,370 WARN org.apache.hadoop.io.retry.RetryInvocationHandler - A failover has occurred since the start of call #4 ClientNamenodeProtocolTranslatorPB.getFileInfo over szzb-bg-uat-etl-07/10.83.192.7:8020
2020-09-28 15:54:16,370 WARN org.apache.hadoop.io.retry.RetryInvocationHandler - A failover has occurred since the start of call #2 ClientNamenodeProtocolTranslatorPB.getFileInfo over szzb-bg-uat-etl-07/10.83.192.7:8020
2020-09-28 15:54:16,370 WARN org.apache.hadoop.io.retry.RetryInvocationHandler - A failover has occurred since the start of call #1 ClientNamenodeProtocolTranslatorPB.getFileInfo over szzb-bg-uat-etl-07/10.83.192.7:8020
2020-09-28 15:54:16,371 WARN org.apache.hadoop.io.retry.RetryInvocationHandler - A failover has occurred since the start of call #0 ClientNamenodeProtocolTranslatorPB.getFileInfo over szzb-bg-uat-etl-07/10.83.192.7:8020
2020-09-28 15:54:17,970 ERROR com.dtstack.flinkx.util.RetryUtil - Exception when calling callable, 即将尝试执行第1次重试.本次重试计划等待[2000]ms,实际等待[2001]ms, 异常Msg:[http://szzb-bg-uat-etl-07:8088/proxy/application_1600944532255_1748/jobs/f45da2bb96ad26d14368a13ab45edb77/accumulators]