[jira] [Updated] (FLINK-23353) UDTAGG can't execute in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-23353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-23353: Description: {code:java} public class Top2Test { public static void main(String[] args) {

[jira] [Created] (FLINK-23353) UDTAGG can't execute in Batch mode

hayden zhou created FLINK-23353: --- Summary: UDTAGG can't execute in Batch mode Key: FLINK-23353 URL: https://issues.apache.org/jira/browse/FLINK-23353 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321916#comment-17321916 ] hayden zhou edited comment on FLINK-22054 at 4/15/21, 5:53 AM: ---

[jira] [Comment Edited] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321916#comment-17321916 ] hayden zhou edited comment on FLINK-22054 at 4/15/21, 5:48 AM: ---

[jira] [Commented] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321916#comment-17321916 ] hayden zhou commented on FLINK-22054: - [~trohrmann] [~yittg] I can't submit batch jobs more than

[jira] [Comment Edited] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320693#comment-17320693 ] hayden zhou edited comment on FLINK-22047 at 4/14/21, 4:30 AM: ---

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320693#comment-17320693 ] hayden zhou commented on FLINK-22047: - [~trohrmann] thanks for your reply, hopes to see the fixed

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320017#comment-17320017 ] hayden zhou commented on FLINK-22047: - the amount of jobs a cluster can submit is almost 70, if

[jira] [Comment Edited] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319469#comment-17319469 ] hayden zhou edited comment on FLINK-22047 at 4/12/21, 2:16 PM: --- can't

[jira] [Comment Edited] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319467#comment-17319467 ] hayden zhou edited comment on FLINK-22047 at 4/12/21, 2:12 PM: ---

[jira] [Comment Edited] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319469#comment-17319469 ] hayden zhou edited comment on FLINK-22047 at 4/12/21, 2:10 PM: --- can't

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319469#comment-17319469 ] hayden zhou commented on FLINK-22047: - can't submit to Kubernetes native session mode cluster after

[jira] [Comment Edited] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319469#comment-17319469 ] hayden zhou edited comment on FLINK-22047 at 4/12/21, 2:06 PM: --- can't

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319467#comment-17319467 ] hayden zhou commented on FLINK-22047: - [~TsReaper] I am using Kubernetes native session mode submit

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311476#comment-17311476 ] hayden zhou commented on FLINK-22047: - 2021-03-30 09:36:52,903 INFO

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311475#comment-17311475 ] hayden zhou commented on FLINK-22047: - can not attach log。 !screenshot-1.png! > Could not find

[jira] [Updated] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-22047: Attachment: screenshot-1.png > Could not find FLINSHED Flink job and can't submit job >

[jira] [Created] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

hayden zhou created FLINK-22047: --- Summary: Could not find FLINSHED Flink job and can't submit job Key: FLINK-22047 URL: https://issues.apache.org/jira/browse/FLINK-22047 Project: Flink Issue

[jira] [Commented] (FLINK-21840) can't submit flink k8s session job with kubernetes.rest-service.exposed.type=NodePort

[ https://issues.apache.org/jira/browse/FLINK-21840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303161#comment-17303161 ] hayden zhou commented on FLINK-21840: - Ok. thank for your answer. > can't submit flink k8s session

[jira] [Commented] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303160#comment-17303160 ] hayden zhou commented on FLINK-16601: - Yes， NodePort support is very useful for self-buit k8s

[jira] [Created] (FLINK-21840) can't submit flink k8s session job with kubernetes.rest-service.exposed.type=NodePort

hayden zhou created FLINK-21840: --- Summary: can't submit flink k8s session job with kubernetes.rest-service.exposed.type=NodePort Key: FLINK-21840 URL: https://issues.apache.org/jira/browse/FLINK-21840

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs or after running tow days

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Description: I have five stream jobs and want to clear all states in jobs, so I canceled all

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292561#comment-17292561 ] hayden zhou commented on FLINK-21325: - [~gvauvert] in my case, I found it always reports " Slot

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Attachment: clear.log > NoResourceAvailableException while cancel then resubmit jobs >

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291600#comment-17291600 ] hayden zhou commented on FLINK-21325: - I have submitted the full log in this site: link:

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Attachment: (was: flink--standalonesession-0-mta-flink-jobmanager-56cf5bbf6-2chwc.log) >

[jira] [Updated] (FLINK-21472) FencingTokenException: Fencing token mismatch

[ https://issues.apache.org/jira/browse/FLINK-21472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21472: Description: org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler [] - Unhandled

[jira] [Created] (FLINK-21472) encingTokenException: Fencing token mismatch

hayden zhou created FLINK-21472: --- Summary: encingTokenException: Fencing token mismatch Key: FLINK-21472 URL: https://issues.apache.org/jira/browse/FLINK-21472 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289456#comment-17289456 ] hayden zhou commented on FLINK-21325: - JobManager log is attached above just now. >

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Attachment: flink--standalonesession-0-mta-flink-jobmanager-56cf5bbf6-2chwc.log >

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288151#comment-17288151 ] hayden zhou commented on FLINK-21325: - this problem always occurs after cluster runed several days

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288150#comment-17288150 ] hayden zhou commented on FLINK-21325: - i found some exception like this {code:java} 2021-02-22

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288136#comment-17288136 ] hayden zhou commented on FLINK-21325: - how to get logs for the specific failed job?[~rmetzger] >

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Description: I have five stream jobs and want to clear all states in jobs, so I canceled all

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Description: I have five stream jobs and want to clear all states in jobs, so I canceled all

[jira] [Created] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

hayden zhou created FLINK-21325: --- Summary: NoResourceAvailableException while cancel then resubmit jobs Key: FLINK-21325 URL: https://issues.apache.org/jira/browse/FLINK-21325 Project: Flink

[jira] [Updated] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-20798: Description: When deploying standalone Flink on Kubernetes and configure the

[jira] [Created] (FLINK-20938) Implement Flink's own tencent COS filesystem

hayden zhou created FLINK-20938: --- Summary: Implement Flink's own tencent COS filesystem Key: FLINK-20938 URL: https://issues.apache.org/jira/browse/FLINK-20938 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou closed FLINK-20798. --- Resolution: Fixed > Using PVC as high-availability.storageDir could not work >

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256416#comment-17256416 ] hayden zhou commented on FLINK-20798: - great thanks to [~fly_in_gis], so patiently to help me debug

[jira] [Comment Edited] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256280#comment-17256280 ] hayden zhou edited comment on FLINK-20798 at 12/30/20, 4:39 AM:

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256281#comment-17256281 ] hayden zhou commented on FLINK-20798: - can we chat on wechat？ my wechat account `zmfk2009` > Using

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256280#comment-17256280 ] hayden zhou commented on FLINK-20798: - [^flink.log] this is the log > Using PVC as

[jira] [Updated] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-20798: Attachment: flink.log > Using PVC as high-availability.storageDir could not work >

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256246#comment-17256246 ] hayden zhou commented on FLINK-17598: - [~fly_in_gis] I am trying to deploy Flink on k8s with HA

[jira] [Comment Edited] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256246#comment-17256246 ] hayden zhou edited comment on FLINK-17598 at 12/30/20, 3:07 AM:

[jira] [Created] (FLINK-20798) Service temporarily unavailable due to an ongoing leader election. Please refresh.

hayden zhou created FLINK-20798: --- Summary: Service temporarily unavailable due to an ongoing leader election. Please refresh. Key: FLINK-20798 URL: https://issues.apache.org/jira/browse/FLINK-20798

[jira] [Created] (FLINK-20797) can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir

hayden zhou created FLINK-20797: --- Summary: can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir Key: FLINK-20797 URL: https://issues.apache.org/jira/browse/FLINK-20797 Project: