zengqinchris opened a new issue, #3336: URL: https://github.com/apache/incubator-seatunnel/issues/3336
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened Failed to pull data in http mode ![Uploading image.png…]() ### SeaTunnel Version v1 ### SeaTunnel Config ```conf env { execution.parallelism = 1 # execution.checkpoint.interval = 10000 # execution.checkpoint.data-uri = "hdfs://hadoop102:9092/checkpoint" } source { Http { url = "http://xxxxx/xxxxx/ecenterprise/list"; result_table_name= "response_body" method = "POST" header = "{\"Content-Type\":\"application/json\",\"traceId\":\"xxx\",\"ticket\":\"TGT-5945-xxxx-cas-78bbff794b-tddqt\"}" request_params = "{\"startTime\":\"2020-01-01\",\"endTime\":\"2020-02-01\",\"vtenantCode\":\"yundee\"}" } } transform { sql { sql = "select * from response_body" result_table_name = test_csv2 }} sink { ConsoleSink { } } ``` ### Running Command ```shell ../bin/start-seatunnel-flink.sh --config ./flink.batch.httptokafka.conf ``` ### Error Exception ```log 2022-11-09 09:48:20,826 INFO org.apache.flink.runtime.taskmanager.Task [] - CHAIN DataSource (at translateToPlan(DataSetValues.scala:96) (org.apache.flink.table.runtime.io.ValuesInputFormat)) -> FlatMap (select: (_UTF-16LE'{"trace":"DBA5BA1067C24DC39485895EA1526448","success":false,"data":null,"message":"接口错误","errorCode":18000}':VARCHAR(65536) CHARACTER SET "UTF-16LE" AS rawMsg)) -> Map (to: Row) (1/1)#0 (f492f16e896f6e2d1012352c9eb4fe60) switched from DEPLOYING to INITIALIZING. 2022-11-09 09:48:20,826 INFO org.apache.flink.runtime.taskmanager.Task [] - CHAIN DataSource (at translateToPlan(DataSetValues.scala:96) (org.apache.flink.table.runtime.io.ValuesInputFormat)) -> FlatMap (select: (_UTF-16LE'{"trace":"DBA5BA1067C24DC39485895EA1526448","success":false,"data":null,"message":"接口错误","errorCode":18000}':VARCHAR(65536) CHARACTER SET "UTF-16LE" AS rawMsg)) -> Map (to: Row) (1/1)#0 (f492f16e896f6e2d1012352c9eb4fe60) switched from INITIALIZING to RUNNING. 2022-11-09 09:48:20,826 INFO org.apache.flink.runtime.taskmanager.Task [] - GroupReduce (GroupReduce at first(DataSet.java:595)) (1/1)#0 (632dc6c3a3aefbe59d81bc6118cc2b8f) switched from DEPLOYING to INITIALIZING. 2022-11-09 09:48:20,826 INFO org.apache.flink.runtime.taskmanager.Task [] - GroupReduce (GroupReduce at first(DataSet.java:595)) (1/1)#0 (632dc6c3a3aefbe59d81bc6118cc2b8f) switched from INITIALIZING to RUNNING. 2022-11-09 09:48:20,846 WARN org.apache.flink.metrics.MetricGroup [] - The operator name FlatMap (select: (_UTF-16LE'{"trace":"DBA5BA1067C24DC39485895EA1526448","success":false,"data":null,"message":"接口错误","errorCode":18000}':VARCHAR(65536) CHARACTER SET "UTF-16LE" AS rawMsg)) exceeded the 80 characters length limit and was truncated. 2022-11-09 09:48:20,849 WARN org.apache.flink.metrics.MetricGroup [] - The operator name DataSource (at translateToPlan(DataSetValues.scala:96) (org.apache.flink.table.runtime.io.ValuesInputFormat)) exceeded the 80 characters length limit and was truncated. 2022-11-09 09:48:20,873 INFO org.apache.flink.runtime.taskmanager.Task [] - CHAIN DataSource (at translateToPlan(DataSetValues.scala:96) (org.apache.flink.table.runtime.io.ValuesInputFormat)) -> FlatMap (select: (_UTF-16LE'{"trace":"DBA5BA1067C24DC39485895EA1526448","success":false,"data":null,"message":"接口错误","errorCode":18000}':VARCHAR(65536) CHARACTER SET "UTF-16LE" AS rawMsg)) -> Map (to: Row) (1/1)#0 (f492f16e896f6e2d1012352c9eb4fe60) switched from RUNNING to FINISHED. 2022-11-09 09:48:20,873 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for CHAIN DataSource (at translateToPlan(DataSetValues.scala:96) (org.apache.flink.table.runtime.io.ValuesInputFormat)) -> FlatMap (select: (_UTF-16LE'{"trace":"DBA5BA1067C24DC39485895EA1526448","success":false,"data":null,"message":"接口错误","errorCode":18000}':VARCHAR(65536) CHARACTER SET "UTF-16LE" AS rawMsg)) -> Map (to: Row) (1/1)#0 (f492f16e896f6e2d1012352c9eb4fe60). 2022-11-09 09:48:20,874 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN DataSource (at translateToPlan(DataSetValues.scala:96) (org.apache.flink.table.runtime.io.ValuesInputFormat)) -> FlatMap (select: (_UTF-16LE'{"trace":"DBA5BA1067C24DC39485895EA1526448","success":false,"data":null,"message":"接口错误","errorCode":18000}':VARCHAR(65536) CHARACTER SET "UTF-16LE" AS rawMsg)) -> Map (to: Row) (1/1)#0 f492f16e896f6e2d1012352c9eb4fe60. 2022-11-09 09:48:20,876 INFO org.apache.flink.runtime.taskmanager.Task [] - GroupReduce (GroupReduce at first(DataSet.java:595)) (1/1)#0 (632dc6c3a3aefbe59d81bc6118cc2b8f) switched from RUNNING to FINISHED. ``` ### Flink or Spark Version flink 1.13 ### Java or Scala Version jdk8 scala11 ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
