apache / apache/linkis

[Bug] ERROR org.apache.linkis.engineconnplugin.flink.client.sql.operation.AbstractJobOperation 102 cancelJob - No job has been submitted. This is a bug

Open
#2,608 2 comments 0 reactions 0 assignees View on GitHub
bug
Dominant language
Java
Stars
3.4k
Forks
1.2k
PR merge metrics
No merged PRs in 30d

Description

### Search before asking

- [X] I searched the [issues](https://github.com/apache/incubator-linkis/issues) and found no similar issues.

### Linkis Component

linkis-cg-engineConnplugin

### What happened + What you expected to happen

参照文档 [DSS1.0.0与Linkis1.0.2——Flink引擎相关问题汇总](https://mp.weixin.qq.com/s/VxZ16IPMd1CvcrvHFuU4RQ) https://mp.weixin.qq.com/s/VxZ16IPMd1CvcrvHFuU4RQ,
flink整合hive,整合kafka,kafka生产数据,flink消费数据ok,往hive中插入数据ok,就是执行如下命令,命令不会结束
sh ./bin/linkis-cli -engineType flink-1.12.2 -codeType sql -code "INSERT INTO myhive.db_test.test_target_tab SELECT user_id, order_amount, DATE_FORMAT(log_ts, 'yyyy-MM-dd'), DATE_FORMAT(log_ts, 'HH') FROM myhive.db_test.test_source;" -submitUser hadoop -proxyUser hadoop

并且日志中报:ERROR org.apache.linkis.engineconnplugin.flink.client.sql.operation.AbstractJobOperation 102 cancelJob - No job has been submitted. This is a bug
![image](https://user-images.githubusercontent.com/63526456/183028205-90feb90a-e5f5-45da-ad0c-743d014113cf.png)

![flink sql命令不结束](https://user-images.githubusercontent.com/63526456/183027097-4a143b7c-a196-4568-ba47-84210f689185.png)
![flink sql命令持续很长时间,且状态为0](https://user-images.githubusercontent.com/63526456/183027822-f70b112b-2b76-4707-9341-30d73b38efe2.jpg)

### Relevent platform

link1.1.2
flink1.12.2

### Reproduction script

flink1.12.2的catalog是myhive
sh ./bin/linkis-cli -engineType flink-1.12.2 -codeType sql -code "DROP TABLE IF EXISTS myhive.db_test.test_source;CREATE TABLE myhive.db_test.test_source (
user_id STRING,
order_amount DOUBLE,
log_ts TIMESTAMP(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
'topic' = 'test_kafka_01',
'properties.bootstrap.servers' = 'bigdata01:9092',
'properties.group.id' = 'group_test_01',
'scan.startup.mode' = 'earliest-offset',
'format' = 'json',
'json.ignore-parse-errors' = 'true'
);" -submitUser hadoop -proxyUser hadoop

sh ./bin/linkis-cli -engineType flink-1.12.2 -codeType sql -code "INSERT INTO myhive.db_test.test_target_tab SELECT user_id, order_amount, DATE_FORMAT(log_ts, 'yyyy-MM-dd'), DATE_FORMAT(log_ts, 'HH') FROM myhive.db_test.test_source;" -submitUser hadoop -proxyUser hadoop

### Anything else

_No response_

### Are you willing to submit a PR?

- [ ] Yes I am willing to submit a PR!

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.