问题一:大数据计算MaxCompute有什么方法可以解决吗 比如开启什么配置?
大数据计算MaxCompute在执行select的时候 遇到 特殊字符 不支持, 有什么方法可以解决吗 比如开启什么配置?
参考答案:
没有参数配置,需要排查下特殊字符。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/566581
问题二:想问一下大数据计算MaxCompute这个报错是为啥呀?
想问一下大数据计算MaxCompute这个报错是为啥呀? 项目名应该是对的
参考答案:
楼主你好,看了你的问题,我觉得你应该检查你使用的连接信息是否正确,如Endpoint、AccessKeyId、AccessKeySecret等,还有就是你的项目权限问题。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/566580
问题三:大数据计算MaxCompute今天出现批量任务挂掉的情况,帮忙看下?
大数据计算MaxCompute今天出现批量任务挂掉的情况,帮忙看下,报错信息如下:org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:591)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:326)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:229)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: org.apache.kafka.connect.errors.ConnectException: org.apache.kafka.connect.errors.ConnectException: RequestId=20231031095938d3d9c20b0cd9bcf3, ErrorCode=InternalServerError, ErrorMessage=Service internal error, please try again later.
at io.confluent.connect.odps.sink.OdpsSinkTask.put(OdpsSinkTask.java:109)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:563)
... 10 more
Caused by: org.apache.kafka.connect.errors.ConnectException: RequestId=20231031095938d3d9c20b0cd9bcf3, ErrorCode=InternalServerError, ErrorMessage=Service internal error, please try again later.
at io.confluent.connect.odps.util.CachedConnectionProvider.getConnection(CachedConnectionProvider.java:73)
at io.confluent.connect.odps.sink.OdpsWriter.write(OdpsWriter.java:98)
at io.confluent.connect.odps.sink.OdpsSinkTask.put(OdpsSinkTask.java:80)
... 11 more
Caused by: RequestId=20231031095938d3d9c20b0cd9bcf3, ErrorCode=InternalServerError, ErrorMessage=Service internal error, please try again later.
at com.aliyun.odps.tunnel.StreamUploadSessionImpl.initiate(StreamUploadSessionImpl.java:81)
at com.aliyun.odps.tunnel.StreamUploadSessionImpl.(StreamUploadSessionImpl.java:49)
at com.aliyun.odps.tunnel.TableTunnel.createStreamUploadSession(TableTunnel.java:684)
at com.aliyun.odps.tunnel.TableTunnel.createStreamUploadSession(TableTunnel.java:673)
at io.confluent.connect.odps.dialect.OdpsStreamDialect.getConnection(OdpsStreamDialect.java:73)
at io.confluent.connect.odps.util.CachedConnectionProvider.newConnection(CachedConnectionProvider.java:97)
at io.confluent.connect.odps.util.CachedConnectionProvider.getConnection(CachedConnectionProvider.java:62)
2023-10-31 02:29:42,556 INFO || Attempting to open connection #1 to io.confluent.connect.odps.dialect.OdpsStreamDialect@56e4e5e6 [io.confluent.connect.odps.util.CachedConnectionProvider]
2023-10-31 02:29:43,463 INFO || Unable to connect to database on attempt 1/3. Will retry in 10000 ms. [io.confluent.connect.odps.util.CachedConnectionProvider]
RequestId=20231031102942d61569640cdbe987, ErrorCode=InternalServerError, ErrorMessage=Service internal error, please try again later.
at com.aliyun.odps.tunnel.StreamUploadSessionImpl.initiate(StreamUploadSessionImpl.java:81)
at com.aliyun.odps.tunnel.StreamUploadSessionImpl.(StreamUploadSessionImpl.java:49)
at com.aliyun.odps.tunnel.TableTunnel.createStreamUploadSession(TableTunnel.java:684)
at com.aliyun.odps.tunnel.TableTunnel.createStreamUploadSession(TableTunnel.java:673)
at io.confluent.connect.odps.dialect.OdpsStreamDialect.getConnection(OdpsStreamDialect.java:73)
at io.confluent.connect.odps.util.CachedConnectionProvider.newConnection(CachedConnectionProvider.java:97)
at io.confluent.connect.odps.util.CachedConnectionProvider.getConnection(CachedConnectionProvider.java:62)
at io.confluent.connect.odps.sink.OdpsWriter.write(OdpsWriter.java:98)
at io.confluent.connect.odps.sink.OdpsSinkTask.put(OdpsSinkTask.java:80)
at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:563)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:326)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:229)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
参考答案:
从报错信息来看,这是一个Kafka Connect的批量任务挂掉的问题。具体原因可能是由于MaxCompute服务内部错误导致的。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/566576
问题四:大数据计算MaxCompute配置参数在开发环境进行调度,参数解析不出来,这是需要额外做什么配置吗?
大数据计算MaxCompute配置参数在开发环境进行调度,参数解析不出来,这是需要额外做什么配置吗?
参考答案:
关于本问题的更多回答可点击进行查看: