[
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
[
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
[
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
> -
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:
[
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
[
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]
[
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
[
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
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
[
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
[
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
[
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
[
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
[
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:
[
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
*
[
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:
---
[
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
[
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
[
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:
[
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
[
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
[
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
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
[
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
[
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
[
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
[
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:
---
[
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
[
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:
---
[
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
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
[
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
[
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
[
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:
---
[
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
[
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:
---
[
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
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
[
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
[
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
[
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:
[
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:
[
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
[
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:
[
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:
[
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
[
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
[
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
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:
[
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
[
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
[
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:
---
[
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
[
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
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
[
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
[
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:
[
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:
[
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:
[
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:
[
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:
[
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
[
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
[
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
[
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
[
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
[
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:
---
[
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
[
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
[
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:
--
[
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
[
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
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
[
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:
[
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
[
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:
[
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
[
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:
[
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:
[
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
[
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
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
[
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
[
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
[
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:
[
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:
[
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:
[
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:
[
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:
[
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:
---
[
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
[
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
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
[
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
[
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
[
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
[
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:
---
[
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
> --
[
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
[
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:
101 - 200 of 277 matches
Mail list logo