[I] [Bug] 作业运行状态显示-沉默，事实作业已经停掉了，在列表没法操作运行或停止 [incubator-streampark]

Tue, 13 Aug 2024 02:14:41 -0700 


Jetol opened a new issue, #3962:
URL: https://github.com/apache/incubator-streampark/issues/3962

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### Java Version
   
   1.8
   
   ### Scala Version
   
   2.12.x
   
   ### StreamPark Version
   
   2.1.4
   
   ### Flink Version
   
   1.16.3
   
   ### deploy mode
   
   kubernetes-session
   
   ### What happened
   
   1）新建flink sql，使用k8s-session运行模式，同步作业，flink SQL如下：
   `-- register a PostgreSQL table 'shipments' in Flink SQL
   CREATE TABLE t_user (
     id INT,
     name STRING,
     age INT
   ) WITH (
     'connector' = 'postgres-cdc',
     'hostname' = '192.168.231.151',
     'port' = '30028',
     'username' = 'test1',
     'password' = 'test123',
     'database-name' = 'xly_test_db',
     'schema-name' = 'public',
     'table-name' = 't_user',
     'slot.name' = 'flink',
      -- experimental feature: incremental snapshot (default off)
     'scan.incremental.snapshot.enabled' = 'true'
   );
   
   SET execution.checkpointing.interval = 10s;
   -- sink doris
   CREATE TABLE xie_t_user (
     id INT,
     name STRING,
     age INT
   ) WITH (
     'connector' = 'doris',
     -- 'sink.label-prefix' = 'mysql-sink-doris_label_2',
     'fenodes' = '192.168.231.151:8030',
     'table.identifier' = 'hq_demo.xie_t_user',
     'username' = 'admin',
     'password' = ''
   );
   
   insert into
     xie_t_user
   select
     id,
     name,
     age
   from
     t_user;`
   
   2）发布成功后，点击启动作业-其他正在运行的作业状态自动变为-沉默，见图2-1；
   3）k8s服务器上查询pod已经没有了；
   4）接着在streampark作业列表没法操作-停止或运行了。
   
   图2-1
   <img width="1172" alt="image" 
src="https://github.com/user-attachments/assets/41603128-49e4-4836-875d-d755137ed8ba";>
   
   
   
   ### Error Exception
   
   ```log
   作业运行一段时间后失败，状态显示-沉默；
   ```
   
   
   ### Screenshots
   
   作业内容详细：
   <img width="1277" alt="image" 
src="https://github.com/user-attachments/assets/ef0ebdf1-606d-48fe-9a43-bd950f4c1f61";>
   <img width="1196" alt="image" 
src="https://github.com/user-attachments/assets/88536ee3-08fd-4ea2-8312-4fe954eb6594";>
   <img width="1427" alt="image" 
src="https://github.com/user-attachments/assets/dc7f8e10-b346-4339-a439-aa87e7360500";>
   
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!(您是否要贡献这个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]

Reply via email to