[jira] [Updated] (FLINK-20871) Make DataStream#executeAndCollectWithClient() public

[ https://issues.apache.org/jira/browse/FLINK-20871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-20871: --- Summary: Make DataStream#executeAndCollectWithClient() public (was: Make DataStream#execute

[jira] [Updated] (FLINK-20871) Make DataStream#executeAndCollectWithClient() public

[ https://issues.apache.org/jira/browse/FLINK-20871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-20871: --- Description: Right now, `DataStreamUtils#collectWithClient` is marked as deprecated in favor

[jira] [Closed] (FLINK-20871) Make DataStream#executeAndCollectWithClient() public

[ https://issues.apache.org/jira/browse/FLINK-20871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu closed FLINK-20871. -- Resolution: Invalid > Make DataStream#executeAndCollectWithClient() public > -

[jira] [Created] (FLINK-18350) [1.11.0] jobmanager complains `taskmanager.memory.process.size` missing

Steven Zhen Wu created FLINK-18350: -- Summary: [1.11.0] jobmanager complains `taskmanager.memory.process.size` missing Key: FLINK-18350 URL: https://issues.apache.org/jira/browse/FLINK-18350 Project:

[jira] [Updated] (FLINK-18350) [1.11.0] jobmanager loads taskmanager.memory.process.size config

[ https://issues.apache.org/jira/browse/FLINK-18350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-18350: --- Description:   Saw this failure in jobmanager startup. I know the exception said that task

[jira] [Updated] (FLINK-18350) [1.11.0] jobmanager requires taskmanager.memory.process.size config

[ https://issues.apache.org/jira/browse/FLINK-18350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-18350: --- Summary: [1.11.0] jobmanager requires taskmanager.memory.process.size config (was: [1.11.0]

[jira] [Updated] (FLINK-18350) [1.11.0] jobmanager requires taskmanager.memory.process.size config

[ https://issues.apache.org/jira/browse/FLINK-18350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-18350: --- Description:   Saw this failure in jobmanager startup. I know the exception said that task

[jira] [Updated] (FLINK-18350) [1.11.0] jobmanager requires taskmanager.memory.process.size config

[ https://issues.apache.org/jira/browse/FLINK-18350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-18350: --- Description:   Saw this failure in jobmanager startup. I know the exception said that task

[jira] [Created] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

Steven Zhen Wu created FLINK-18353: -- Summary: [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize Key: FLINK-18353 URL: https://issues.apache.org/jira/browse/FLINK-18353

[jira] [Updated] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-18353: --- Description: I know FLIP-116 (Unified Memory Configuration for Job Managers) is introduced

[jira] [Commented] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139541#comment-17139541 ] Steven Zhen Wu commented on FLINK-18353: [~sewen] that is a good question. It is

[jira] [Commented] (FLINK-18350) [1.11.0] jobmanager requires taskmanager.memory.process.size config

[ https://issues.apache.org/jira/browse/FLINK-18350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139553#comment-17139553 ] Steven Zhen Wu commented on FLINK-18350: [~xintongsong] thx. yeah, it is my mist

[jira] [Commented] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141154#comment-17141154 ] Steven Zhen Wu commented on FLINK-18353: > Regarding whether to limit direct mem

[jira] [Comment Edited] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141578#comment-17141578 ] Steven Zhen Wu edited comment on FLINK-18353 at 6/21/20, 9:31 PM:

[jira] [Commented] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141578#comment-17141578 ] Steven Zhen Wu commented on FLINK-18353: * +0.51 for keeping the direct limit *

[jira] [Comment Edited] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141578#comment-17141578 ] Steven Zhen Wu edited comment on FLINK-18353 at 6/21/20, 10:13 PM: ---

[jira] [Commented] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142215#comment-17142215 ] Steven Zhen Wu commented on FLINK-18353: > why do you plan to increase  >[jobman

[jira] [Commented] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142257#comment-17142257 ] Steven Zhen Wu commented on FLINK-18353: [~azagrebin] yeah. I get that. if we do

[jira] [Comment Edited] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

[ https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142257#comment-17142257 ] Steven Zhen Wu edited comment on FLINK-18353 at 6/22/20, 4:47 PM:

[jira] [Updated] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.runInCoordinatorThread(Runnable)

[ https://issues.apache.org/jira/browse/FLINK-19934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-19934: --- Summary: [FLIP-27 source] add new API: SplitEnumeratorContext.runInCoordinatorThread(Runnabl

[jira] [Commented] (FLINK-19802) Let BulkFormat createReader and restoreReader methods accept Splits directly

[ https://issues.apache.org/jira/browse/FLINK-19802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227644#comment-17227644 ] Steven Zhen Wu commented on FLINK-19802: [~sewen][~lzljs3620320] to make the `Bu

[jira] [Commented] (FLINK-19802) Let BulkFormat createReader and restoreReader methods accept Splits directly

[ https://issues.apache.org/jira/browse/FLINK-19802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228338#comment-17228338 ] Steven Zhen Wu commented on FLINK-19802: [~sewen] sorry, I didn't mean that we n

[jira] [Created] (FLINK-20174) Make BulkFormat more extensible

Steven Zhen Wu created FLINK-20174: -- Summary: Make BulkFormat more extensible Key: FLINK-20174 URL: https://issues.apache.org/jira/browse/FLINK-20174 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-20174: --- Description: Right now, BulkFormat has the generic `SpitT` type extending from `FileSourceS

[jira] [Updated] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-20174: --- Description: Right now, BulkFormat has the generic `SpitT` type extending from `FileSourceS

[jira] [Commented] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233260#comment-17233260 ] Steven Zhen Wu commented on FLINK-20174: [~lzljs3620320] thanks a lot for sharin

[jira] [Comment Edited] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233260#comment-17233260 ] Steven Zhen Wu edited comment on FLINK-20174 at 11/17/20, 5:20 AM: ---

[jira] [Commented] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233755#comment-17233755 ] Steven Zhen Wu commented on FLINK-20174: I tried the change of setting up InputF

[jira] [Comment Edited] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233755#comment-17233755 ] Steven Zhen Wu edited comment on FLINK-20174 at 11/17/20, 5:23 PM: ---

[jira] [Commented] (FLINK-20114) Test Kafka Source based on the new Source API 

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233762#comment-17233762 ] Steven Zhen Wu commented on FLINK-20114: [~rmetzger] sorry. it might be difficul

[jira] [Created] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

Steven Zhen Wu created FLINK-19816: -- Summary: Flink restored from a wrong checkpoint (a very old one and not the last completed one) Key: FLINK-19816 URL: https://issues.apache.org/jira/browse/FLINK-19816

[jira] [Updated] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-19816: --- Description: h2. Summary Upon failure, it seems that Flink didn't restore from the last com

[jira] [Updated] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-19816: --- Description: h2. Summary Upon failure, it seems that Flink didn't restore from the last com

[jira] [Comment Edited] (FLINK-19799) Make FileSource extensible

[ https://issues.apache.org/jira/browse/FLINK-19799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221102#comment-17221102 ] Steven Zhen Wu edited comment on FLINK-19799 at 10/27/20, 3:17 AM: ---

[jira] [Commented] (FLINK-19799) Make FileSource extensible

[ https://issues.apache.org/jira/browse/FLINK-19799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221102#comment-17221102 ] Steven Zhen Wu commented on FLINK-19799: We just went through a similar exercise

[jira] [Comment Edited] (FLINK-19799) Make FileSource extensible

[ https://issues.apache.org/jira/browse/FLINK-19799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221102#comment-17221102 ] Steven Zhen Wu edited comment on FLINK-19799 at 10/27/20, 3:17 AM: ---

[jira] [Updated] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-19816: --- Description: h2. Summary Upon failure, it seems that Flink didn't restore from the last com

[jira] [Created] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

Steven Zhen Wu created FLINK-19934: -- Summary: [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable) Key: FLINK-19934 URL: https://issues.apache.org/jira/browse/FLINK-19934 Project: F

[jira] [Updated] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

[ https://issues.apache.org/jira/browse/FLINK-19934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-19934: --- Description: Here is the motivation use case. We are implementing event-time alignment acro

[jira] [Commented] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

[ https://issues.apache.org/jira/browse/FLINK-19934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225572#comment-17225572 ] Steven Zhen Wu commented on FLINK-19934: [~sewen] we thought about that. the dif

[jira] [Comment Edited] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

[ https://issues.apache.org/jira/browse/FLINK-19934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225572#comment-17225572 ] Steven Zhen Wu edited comment on FLINK-19934 at 11/3/20, 5:43 PM:

[jira] [Comment Edited] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

[ https://issues.apache.org/jira/browse/FLINK-19934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225572#comment-17225572 ] Steven Zhen Wu edited comment on FLINK-19934 at 11/3/20, 5:46 PM:

[jira] [Commented] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226460#comment-17226460 ] Steven Zhen Wu commented on FLINK-19816: This happened again for the same job in

[jira] [Comment Edited] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226460#comment-17226460 ] Steven Zhen Wu edited comment on FLINK-19816 at 11/5/20, 3:53 AM:

[jira] [Comment Edited] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226460#comment-17226460 ] Steven Zhen Wu edited comment on FLINK-19816 at 11/5/20, 6:10 AM:

[jira] [Commented] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226740#comment-17226740 ] Steven Zhen Wu commented on FLINK-19816: [~trohrmann] thanks a lot for taking a

[jira] [Commented] (FLINK-19016) Checksum mismatch when restore from RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197779#comment-17197779 ] Steven Zhen Wu commented on FLINK-19016: We have seen a similar problem when the

[jira] [Commented] (FLINK-19016) Checksum mismatch when restore from RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199720#comment-17199720 ] Steven Zhen Wu commented on FLINK-19016: [~sewen] we didn't dig deeper and we do

[jira] [Created] (FLINK-19401) Job stuck in restart loop due to "Could not find registered job manager"

Steven Zhen Wu created FLINK-19401: -- Summary: Job stuck in restart loop due to "Could not find registered job manager" Key: FLINK-19401 URL: https://issues.apache.org/jira/browse/FLINK-19401 Project:

[jira] [Updated] (FLINK-19401) Job stuck in restart loop due to "Could not find registered job manager"

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-19401: --- Description: Flink job sometimes got into a restart loop for many hours and can't recover u

[jira] [Commented] (FLINK-19401) Job stuck in restart loop due to "Could not find registered job manager"

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203298#comment-17203298 ] Steven Zhen Wu commented on FLINK-19401: [~trohrmann] emailed you the JM logs wi

[jira] [Comment Edited] (FLINK-19401) Job stuck in restart loop due to "Could not find registered job manager"

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203298#comment-17203298 ] Steven Zhen Wu edited comment on FLINK-19401 at 9/29/20, 12:25 AM: ---

[jira] [Commented] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204031#comment-17204031 ] Steven Zhen Wu commented on FLINK-19401: [~trohrmann] thanks a lot for looking i

[jira] [Commented] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204732#comment-17204732 ] Steven Zhen Wu commented on FLINK-19401: [~trohrmann] just to clarify, do you me

[jira] [Created] (FLINK-18572) Flink web UI doesn't display unaligned checkpoint config

Steven Zhen Wu created FLINK-18572: -- Summary: Flink web UI doesn't display unaligned checkpoint config Key: FLINK-18572 URL: https://issues.apache.org/jira/browse/FLINK-18572 Project: Flink

[jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156363#comment-17156363 ] Steven Zhen Wu commented on FLINK-11143: [~trohrmann] I am seeing a similar prob

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156363#comment-17156363 ] Steven Zhen Wu edited comment on FLINK-11143 at 7/12/20, 6:39 PM:

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156363#comment-17156363 ] Steven Zhen Wu edited comment on FLINK-11143 at 7/12/20, 6:41 PM:

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156363#comment-17156363 ] Steven Zhen Wu edited comment on FLINK-11143 at 7/14/20, 5:37 PM:

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156363#comment-17156363 ] Steven Zhen Wu edited comment on FLINK-11143 at 7/14/20, 5:38 PM:

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156363#comment-17156363 ] Steven Zhen Wu edited comment on FLINK-11143 at 7/14/20, 5:38 PM:

[jira] [Updated] (FLINK-18572) Flink web UI doesn't display checkpoint configs like unaligned and tolerable-failed-checkpoints and

[ https://issues.apache.org/jira/browse/FLINK-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-18572: --- Summary: Flink web UI doesn't display checkpoint configs like unaligned and tolerable-faile

[jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162965#comment-17162965 ] Steven Zhen Wu commented on FLINK-11143: [~trohrmann] thanks a lot for looking i

[jira] [Commented] (FLINK-16867) Simplify default timeout configuration

[ https://issues.apache.org/jira/browse/FLINK-16867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163667#comment-17163667 ] Steven Zhen Wu commented on FLINK-16867: [~trohrmann] just to follow up on your

[jira] [Commented] (FLINK-16867) Simplify default timeout configuration

[ https://issues.apache.org/jira/browse/FLINK-16867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164519#comment-17164519 ] Steven Zhen Wu commented on FLINK-16867: I should clarify that web.timeout becom

[jira] [Commented] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208437#comment-17208437 ] Steven Zhen Wu commented on FLINK-19401: [~roman_khachatryan] I don't know if re

[jira] [Comment Edited] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208437#comment-17208437 ] Steven Zhen Wu edited comment on FLINK-19401 at 10/6/20, 12:42 AM: ---

[jira] [Commented] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217111#comment-17217111 ] Steven Zhen Wu commented on FLINK-19698: Since FLIP-27 is the unified source int

[jira] [Commented] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

[ https://issues.apache.org/jira/browse/FLINK-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217115#comment-17217115 ] Steven Zhen Wu commented on FLINK-18044: I agree with Stephan that code should a

[jira] [Comment Edited] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217111#comment-17217111 ] Steven Zhen Wu edited comment on FLINK-19698 at 10/20/20, 12:59 AM: --

[jira] [Commented] (FLINK-20390) Programmatic access to the back-pressure

[ https://issues.apache.org/jira/browse/FLINK-20390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239806#comment-17239806 ] Steven Zhen Wu commented on FLINK-20390: not sure what is the input/source. If i

[jira] [Commented] (FLINK-20575) flink application failed to restore from check-point

[ https://issues.apache.org/jira/browse/FLINK-20575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248056#comment-17248056 ] Steven Zhen Wu commented on FLINK-20575: Just from personal experience. Because

[jira] [Created] (FLINK-21000) set MetricGroup in SourceCoordinatorContext

Steven Zhen Wu created FLINK-21000: -- Summary: set MetricGroup in SourceCoordinatorContext Key: FLINK-21000 URL: https://issues.apache.org/jira/browse/FLINK-21000 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-21000) set MetricGroup in SourceCoordinatorContext

[ https://issues.apache.org/jira/browse/FLINK-21000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266679#comment-17266679 ] Steven Zhen Wu commented on FLINK-21000: I tried to trace the code up the chain:

[jira] [Commented] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267590#comment-17267590 ] Steven Zhen Wu commented on FLINK-20174: [~sewen] [~lzljs3620320] Can you take a

[jira] [Comment Edited] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267590#comment-17267590 ] Steven Zhen Wu edited comment on FLINK-20174 at 1/19/21, 6:59 PM:

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418400#comment-17418400 ] Steven Zhen Wu commented on FLINK-23886: Just to add another data point. We obse

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418400#comment-17418400 ] Steven Zhen Wu edited comment on FLINK-23886 at 9/22/21, 3:58 PM:

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418400#comment-17418400 ] Steven Zhen Wu edited comment on FLINK-23886 at 9/22/21, 3:58 PM:

[jira] [Updated] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-30035: --- Description: I used to be able to run the sql-client with iceberg-flink-runtime jar using t

[jira] [Updated] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-30035: --- Description: I used to be able to run the sql-client with iceberg-flink-runtime jar using t

[jira] [Created] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

Steven Zhen Wu created FLINK-30035: -- Summary: ./bin/sql-client.sh won't import external jar into the session Key: FLINK-30035 URL: https://issues.apache.org/jira/browse/FLINK-30035 Project: Flink

[jira] [Updated] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-30035: --- Description: I used to be able to run the sql-client with iceberg-flink-runtime jar using t

[jira] [Commented] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639718#comment-17639718 ] Steven Zhen Wu commented on FLINK-30035: [~fsk119] here are the steps to reprodu

[jira] [Comment Edited] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639718#comment-17639718 ] Steven Zhen Wu edited comment on FLINK-30035 at 11/27/22 8:53 PM:

[jira] [Comment Edited] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639718#comment-17639718 ] Steven Zhen Wu edited comment on FLINK-30035 at 11/27/22 8:54 PM:

[jira] [Comment Edited] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639718#comment-17639718 ] Steven Zhen Wu edited comment on FLINK-30035 at 11/27/22 8:55 PM:

[jira] [Comment Edited] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639718#comment-17639718 ] Steven Zhen Wu edited comment on FLINK-30035 at 11/27/22 8:55 PM:

[jira] [Comment Edited] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639718#comment-17639718 ] Steven Zhen Wu edited comment on FLINK-30035 at 11/27/22 8:56 PM:

[jira] [Comment Edited] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639718#comment-17639718 ] Steven Zhen Wu edited comment on FLINK-30035 at 11/27/22 10:02 PM: ---

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640306#comment-17640306 ] Steven Zhen Wu commented on FLINK-29801: This is an important missing part of co

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642050#comment-17642050 ] Steven Zhen Wu commented on FLINK-29801: @ruanhang1993 I am not sure if `numEven

[jira] [Created] (FLINK-21364) piggyback finishedSplitIds in RequestSplitEvent

Steven Zhen Wu created FLINK-21364: -- Summary: piggyback finishedSplitIds in RequestSplitEvent Key: FLINK-21364 URL: https://issues.apache.org/jira/browse/FLINK-21364 Project: Flink Issue Typ

[jira] [Commented] (FLINK-21364) piggyback finishedSplitIds in RequestSplitEvent

[ https://issues.apache.org/jira/browse/FLINK-21364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283152#comment-17283152 ] Steven Zhen Wu commented on FLINK-21364: cc [~sewen] [~jqin] [~thomasWeise] > p

[jira] [Updated] (FLINK-21364) piggyback finishedSplitIds in RequestSplitEvent

[ https://issues.apache.org/jira/browse/FLINK-21364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-21364: --- Description: For some split assignment strategy, the enumerator/assigner needs to track the

[jira] [Commented] (FLINK-21364) piggyback finishedSplitIds in RequestSplitEvent

[ https://issues.apache.org/jira/browse/FLINK-21364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284024#comment-17284024 ] Steven Zhen Wu commented on FLINK-21364: For pull based source (like file/Iceber

[jira] [Comment Edited] (FLINK-21364) piggyback finishedSplitIds in RequestSplitEvent

[ https://issues.apache.org/jira/browse/FLINK-21364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284024#comment-17284024 ] Steven Zhen Wu edited comment on FLINK-21364 at 2/12/21, 10:57 PM: ---

[jira] [Closed] (FLINK-10360) support timeout in savepoint REST api

[ https://issues.apache.org/jira/browse/FLINK-10360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu closed FLINK-10360. -- Resolution: Duplicate > support timeout in savepoint REST api > --

[jira] [Commented] (FLINK-21513) Rethink up-/down-/restartingTime metrics

[ https://issues.apache.org/jira/browse/FLINK-21513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329947#comment-17329947 ] Steven Zhen Wu commented on FLINK-21513: [~trohrmann] thanks for tagging me here

[jira] [Comment Edited] (FLINK-21513) Rethink up-/down-/restartingTime metrics

[ https://issues.apache.org/jira/browse/FLINK-21513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329947#comment-17329947 ] Steven Zhen Wu edited comment on FLINK-21513 at 4/27/21, 3:41 AM:

<    1   2   3   >