You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampark.apache.org by GitBox <gi...@apache.org> on 2022/10/26 01:39:10 UTC

[GitHub] [incubator-streampark] huangkaiyan10 opened a new issue, #1902: restart flinksql The actual failed but option logs show start status success after last flinksql has error and run status failed

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

   ### Search before asking
   
   - [X] I had searched in the [issues](https://github.com/apache/streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues.
   
   
   ### What happened
   
   restart flinksql The actual failed but option logs show start status success after last flinksql has error and run status failed 。i use flink nactive on kubernetes ,In this scenario, there is no log to find out why actual failed. At the same time ,kubectl get pod -A can not find any flinksql k8s pod ,and cannot use kebectl logs podid to  find out why actual failed.
   
   ### StreamPark Version
   
   1.2.4-dev
   
   ### Java Version
   
   jdk8
   
   ### Flink Version
   
   1.14.5-2.12
   
   ### Scala Version of Flink
   
   2.12
   
   ### Error Exception
   
   ```log
   there is no log
   ```
   
   
   ### Screenshots
   
   ![image](https://user-images.githubusercontent.com/5146180/197914061-9f24a4d5-2378-4b5a-9ca3-c91f170d5a91.png)
   
   ![image](https://user-images.githubusercontent.com/5146180/197914188-66333e52-a49a-41c1-a134-446da4db8eb3.png)
   
   
   ### Are you willing to submit PR?
   
   - [X] 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: issues-unsubscribe@streampark.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [incubator-streampark] huangkaiyan10 commented on issue #1902: restart flinksql The actual failed but option logs show start status success after last flinksql has error and run status failed

Posted by GitBox <gi...@apache.org>.
huangkaiyan10 commented on issue #1902:
URL: https://github.com/apache/incubator-streampark/issues/1902#issuecomment-1291395643

   In this case(flink nactive on kubernetes), do not delete k8s pod. In the streampark web ui , add a button to force deletion to delete? Or delete the failed k8s pod before the next restart


-- 
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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [incubator-streampark] huangkaiyan10 commented on issue #1902: restart flinksql The actual failed but option logs show start status success after last flinksql has error and run status failed

Posted by GitBox <gi...@apache.org>.
huangkaiyan10 commented on issue #1902:
URL: https://github.com/apache/incubator-streampark/issues/1902#issuecomment-1291389531

   ![c9ef92f7f3156e6ed4008e0913c4781](https://user-images.githubusercontent.com/5146180/197916692-6fc686b5-35bc-400f-a222-117ddecc8242.jpg)
   According to the k8s event, the flinksql job is started. Maybe the flinksql job still has an error and failed to run. k8s pod was simply deleted.


-- 
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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [incubator-streampark] huangkaiyan10 commented on issue #1902: restart flinksql The actual failed but option logs show start status success after last flinksql has error and run status failed

Posted by GitBox <gi...@apache.org>.
huangkaiyan10 commented on issue #1902:
URL: https://github.com/apache/incubator-streampark/issues/1902#issuecomment-1291381995

   [root@server237 logs]# cat warn.2022-10-26.log 
   2022-10-26 09:11:45.310 StreamPark [streampark-deploy-executor-3] WARN  o.a.flink.core.plugin.PluginConfig:69 - The plugins directory [plugins] does not exist.
   2022-10-26 09:11:45.319 StreamPark [streampark-deploy-executor-3] WARN  o.a.flink.core.plugin.PluginConfig:69 - The plugins directory [plugins] does not exist.
   2022-10-26 09:11:50.230 StreamPark [ForkJoinPool-1-worker-51] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:11:50.409 StreamPark [ForkJoinPool-1-worker-51] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:56651 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:11:55.036 StreamPark [ForkJoinPool-1-worker-51] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:11:55.226 StreamPark [ForkJoinPool-1-worker-51] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:56651 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:12:00.035 StreamPark [ForkJoinPool-1-worker-30] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:12:00.203 StreamPark [ForkJoinPool-1-worker-30] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:56651 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:12:00.377 StreamPark [streampark-deploy-executor-4] WARN  o.a.flink.core.plugin.PluginConfig:69 - The plugins directory [plugins] does not exist.
   2022-10-26 09:12:00.385 StreamPark [streampark-deploy-executor-4] WARN  o.a.flink.core.plugin.PluginConfig:69 - The plugins directory [plugins] does not exist.
   2022-10-26 09:12:05.223 StreamPark [ForkJoinPool-1-worker-44] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:12:05.410 StreamPark [ForkJoinPool-1-worker-44] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:59745 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:12:10.039 StreamPark [ForkJoinPool-1-worker-51] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:12:10.232 StreamPark [ForkJoinPool-1-worker-51] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:59745 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:12:15.038 StreamPark [ForkJoinPool-1-worker-23] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:12:15.234 StreamPark [ForkJoinPool-1-worker-23] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:56651 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:12:20.035 StreamPark [ForkJoinPool-1-worker-51] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:12:20.220 StreamPark [ForkJoinPool-1-worker-51] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:56651 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:46:35.230 StreamPark [streampark-deploy-executor-5] WARN  o.a.flink.core.plugin.PluginConfig:69 - The plugins directory [plugins] does not exist.
   2022-10-26 09:46:35.237 StreamPark [streampark-deploy-executor-5] WARN  o.a.flink.core.plugin.PluginConfig:69 - The plugins directory [plugins] does not exist.
   2022-10-26 09:46:40.210 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:46:40.397 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:46:45.036 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:46:45.217 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:47:05.035 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:47:05.224 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:47:10.038 StreamPark [ForkJoinPool-1-worker-59] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:47:10.246 StreamPark [ForkJoinPool-1-worker-59] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:47:15.036 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:47:15.223 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:47:30.038 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:47:30.231 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:47:35.039 StreamPark [ForkJoinPool-1-worker-2] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:47:35.229 StreamPark [ForkJoinPool-1-worker-2] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:47:40.043 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:47:40.264 StreamPark [ForkJoinPool-1-worker-16] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   2022-10-26 09:47:45.035 StreamPark [ForkJoinPool-1-worker-2] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:220 - Failed to visit remote flink jobs on kubernetes-native-mode cluster, and the retry access logic is performed.
   2022-10-26 09:47:45.225 StreamPark [ForkJoinPool-1-worker-2] WARN  o.a.s.f.k.w.FlinkJobStatusWatcher:227 - The retry fetch failed, final status failed, errorStack=Connect to http://172.18.17.222:64399 [/172.18.17.222] failed: 拒绝连接.
   


-- 
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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [incubator-streampark] huangkaiyan10 commented on issue #1902: restart flinksql The actual failed but option logs show start status success after last flinksql has error and run status failed

Posted by GitBox <gi...@apache.org>.
huangkaiyan10 commented on issue #1902:
URL: https://github.com/apache/incubator-streampark/issues/1902#issuecomment-1291392971

   In this case, do not delete k8s pod. In the streampark web ui , add a button to force deletion to delete? Or delete the failed k8s pod before the next restart


-- 
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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [incubator-streampark] huangkaiyan10 commented on issue #1902: restart flinksql The actual failed but option logs show start status success after last flinksql has error and run status failed

Posted by GitBox <gi...@apache.org>.
huangkaiyan10 commented on issue #1902:
URL: https://github.com/apache/incubator-streampark/issues/1902#issuecomment-1291383608

   at this streampark deploy host,kubectl get node and kubectl logs  is ok 


-- 
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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [incubator-streampark] huangkaiyan10 commented on issue #1902: restart flinksql The actual failed but option logs show start status success after last flinksql has error and run status failed

Posted by GitBox <gi...@apache.org>.
huangkaiyan10 commented on issue #1902:
URL: https://github.com/apache/incubator-streampark/issues/1902#issuecomment-1291429977

   ![3d4e523d2e1ccc80181f73501e22cdf](https://user-images.githubusercontent.com/5146180/197923941-f270bbd1-1311-42a3-8b64-f9396bf1a38d.jpg)
   


-- 
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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org