[
https://issues.apache.org/jira/browse/FLINK-33657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-33657:
Summary: Insert message in top n without row number didn't consider it's
number and may incorrect
[
https://issues.apache.org/jira/browse/FLINK-33657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-33657:
Description:
The new insert message in top n without row number didn't consider it's order
and
[
https://issues.apache.org/jira/browse/FLINK-33657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-33657:
Description:
The new insert message in top n without row number didn't consider it's order
and
zlzhang0122 created FLINK-33657:
---
Summary: Insert message in top n without row number didn't
consider it's number and may not correct
Key: FLINK-33657
URL: https://issues.apache.org/jira/browse/FLINK-33657
[
https://issues.apache.org/jira/browse/FLINK-31495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702988#comment-17702988
]
zlzhang0122 commented on FLINK-31495:
-
IMHO this is not a problem, if you mouseover the selection,
[
https://issues.apache.org/jira/browse/FLINK-31529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702617#comment-17702617
]
zlzhang0122 commented on FLINK-31529:
-
IMHO I agree with this, and we have implement an option to
[
https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692966#comment-17692966
]
zlzhang0122 commented on FLINK-31196:
-
Maybe duplicate with this?
[
https://issues.apache.org/jira/browse/FLINK-28283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686987#comment-17686987
]
zlzhang0122 edited comment on FLINK-28283 at 2/10/23 9:45 AM:
--
[~xtsong]
[
https://issues.apache.org/jira/browse/FLINK-28283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686987#comment-17686987
]
zlzhang0122 commented on FLINK-28283:
-
[~xtsong] Right you are, actually what I think is cache
[
https://issues.apache.org/jira/browse/FLINK-28909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579671#comment-17579671
]
zlzhang0122 commented on FLINK-28909:
-
[~Yanfei Lei] Thanks for your reply and yes, you are right.
zlzhang0122 created FLINK-28909:
---
Summary: Add ribbon filter policy option in
RocksDBConfiguredOptions
Key: FLINK-28909
URL: https://issues.apache.org/jira/browse/FLINK-28909
Project: Flink
zlzhang0122 created FLINK-28598:
---
Summary: ClusterEntryPoint can't get the real exit reason when
shutting down
Key: FLINK-28598
URL: https://issues.apache.org/jira/browse/FLINK-28598
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564148#comment-17564148
]
zlzhang0122 commented on FLINK-24306:
-
[~mvis...@pivotal.io] Hi, could you help to confirm and
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563173#comment-17563173
]
zlzhang0122 commented on FLINK-24306:
-
Hi, [~jark] I have found the reason and created a pr to fix
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24306:
Affects Version/s: 1.14.2
> group by index throw SqlValidatorException
>
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562941#comment-17562941
]
zlzhang0122 commented on FLINK-28386:
-
For bounded job in this scene, IMO, maybe savepoint is
Title: Message Title
zlzhang0122 created
zlzhang0122 created FLINK-28197:
---
Summary: Flink didn't deletes the YARN application files when the
submit is failed in application mode
Key: FLINK-28197
URL: https://issues.apache.org/jira/browse/FLINK-28197
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538931#comment-17538931
]
zlzhang0122 commented on FLINK-27608:
-
[~Thesharing] First, thanks for your quickly response and
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537500#comment-17537500
]
zlzhang0122 edited comment on FLINK-27608 at 5/16/22 12:01 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537500#comment-17537500
]
zlzhang0122 edited comment on FLINK-27608 at 5/16/22 11:59 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537500#comment-17537500
]
zlzhang0122 edited comment on FLINK-27608 at 5/16/22 11:58 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537500#comment-17537500
]
zlzhang0122 commented on FLINK-27608:
-
[~Thesharing] Thanks for your detailed reply. I think the
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-27608:
Attachment: exception.txt
> Flink may throw PartitionNotFound Exception if the downstream task
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-27608:
Component/s: Runtime / Network
> Flink may throw PartitionNotFound Exception if the downstream
zlzhang0122 created FLINK-27608:
---
Summary: Flink may throw PartitionNotFound Exception if the
downstream task reached Running state earlier than it's upstream task
Key: FLINK-27608
URL:
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529298#comment-17529298
]
zlzhang0122 commented on FLINK-25068:
-
[~gaoyunhaii] [~airblader] Can you help to review this pr?
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510417#comment-17510417
]
zlzhang0122 commented on FLINK-25068:
-
[~chesnay] can you help to review the pr?
> Show the maximum
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-25068:
Fix Version/s: 1.16.0
> Show the maximum parallelism (number of key groups) of a job in Web UI
>
[
https://issues.apache.org/jira/browse/FLINK-26788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-26788:
Description:
In the constructor method of the class AbstractDeserializationSchema which has
no
zlzhang0122 created FLINK-26788:
---
Summary: AbstractDeserializationSchema should add cause when thow
a FlinkRuntimeException
Key: FLINK-26788
URL: https://issues.apache.org/jira/browse/FLINK-26788
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500462#comment-17500462
]
zlzhang0122 commented on FLINK-25068:
-
[~airblader] can you help to review the pr?
> Show the
[
https://issues.apache.org/jira/browse/FLINK-26129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492968#comment-17492968
]
zlzhang0122 commented on FLINK-26129:
-
[~kkl0u] [~aljoscha] What do u think about this? Any
zlzhang0122 created FLINK-26129:
---
Summary: Using fail method instead of kill method when yarn
application deployment error occures
Key: FLINK-26129
URL: https://issues.apache.org/jira/browse/FLINK-26129
[
https://issues.apache.org/jira/browse/FLINK-25634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475295#comment-17475295
]
zlzhang0122 commented on FLINK-25634:
-
A lower version of yarn may have some bugs, such as YARN-6153
[
https://issues.apache.org/jira/browse/FLINK-25634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475265#comment-17475265
]
zlzhang0122 commented on FLINK-25634:
-
[~chenyu.mr] Which version of yarn do you use?
>
[
https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475155#comment-17475155
]
zlzhang0122 commented on FLINK-24207:
-
[~roman] ok, I will check for this, thx!!
> Add support of
[
https://issues.apache.org/jira/browse/FLINK-25634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475136#comment-17475136
]
zlzhang0122 commented on FLINK-25634:
-
You can find the config
[
https://issues.apache.org/jira/browse/FLINK-25634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475136#comment-17475136
]
zlzhang0122 edited comment on FLINK-25634 at 1/13/22, 7:04 AM:
---
You can
[
https://issues.apache.org/jira/browse/FLINK-25634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475096#comment-17475096
]
zlzhang0122 commented on FLINK-25634:
-
I have encountered similar case and found that the config
[
https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474472#comment-17474472
]
zlzhang0122 edited comment on FLINK-24207 at 1/12/22, 11:55 AM:
[~roman]
[
https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474472#comment-17474472
]
zlzhang0122 commented on FLINK-24207:
-
[~roman] Sorry for the late reply. In our use case, although
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474408#comment-17474408
]
zlzhang0122 edited comment on FLINK-25068 at 1/12/22, 10:07 AM:
Since
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474408#comment-17474408
]
zlzhang0122 commented on FLINK-25068:
-
Since the FLink-12067 have been merged and the implemention
[
https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474400#comment-17474400
]
zlzhang0122 commented on FLINK-12607:
-
_The parameter of the
[
https://issues.apache.org/jira/browse/FLINK-24694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464557#comment-17464557
]
zlzhang0122 commented on FLINK-24694:
-
@[~pnowojski] WDYT?
> Translate "Checkpointing under
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450809#comment-17450809
]
zlzhang0122 edited comment on FLINK-25068 at 11/30/21, 2:31 AM:
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450809#comment-17450809
]
zlzhang0122 commented on FLINK-25068:
-
[~trohrmann] Nice advice!!! +1 for expose maximum
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450242#comment-17450242
]
zlzhang0122 edited comment on FLINK-25068 at 11/29/21, 8:11 AM:
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450242#comment-17450242
]
zlzhang0122 commented on FLINK-25068:
-
[~Zhanghao Chen] Same as what i thought! We can add the max
zlzhang0122 created FLINK-25068:
---
Summary: Show the maximum parallelism (number of key groups) of a
job in Web UI
Key: FLINK-25068
URL: https://issues.apache.org/jira/browse/FLINK-25068
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447250#comment-17447250
]
zlzhang0122 commented on FLINK-24854:
-
[~sewen] Hi, what's your opinion? Any suggestion is very
[
https://issues.apache.org/jira/browse/FLINK-24694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441704#comment-17441704
]
zlzhang0122 commented on FLINK-24694:
-
[~pnowojski] I have done the work and have created a pr, can
[
https://issues.apache.org/jira/browse/FLINK-24854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441575#comment-17441575
]
zlzhang0122 commented on FLINK-24854:
-
I think we can just remove the assertFalse sentence and add
zlzhang0122 created FLINK-24854:
---
Summary: StateHandleSerializationTest unit test error
Key: FLINK-24854
URL: https://issues.apache.org/jira/browse/FLINK-24854
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-24694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435869#comment-17435869
]
zlzhang0122 commented on FLINK-24694:
-
[~pnowojski] I can help to do this, can you assign it to me?
[
https://issues.apache.org/jira/browse/FLINK-15358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435864#comment-17435864
]
zlzhang0122 edited comment on FLINK-15358 at 10/29/21, 9:10 AM:
[
https://issues.apache.org/jira/browse/FLINK-15358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435864#comment-17435864
]
zlzhang0122 commented on FLINK-15358:
-
[~chesnay] what the progress of this ticket? We have
[
https://issues.apache.org/jira/browse/FLINK-24542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431068#comment-17431068
]
zlzhang0122 commented on FLINK-24542:
-
[~renqs] Uhh, yes, it is a derived metric instead of a kafka
[
https://issues.apache.org/jira/browse/FLINK-24542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24542:
Description:
When we start a flink job to consume apache kafka, we usually use offsetLag,
which
[
https://issues.apache.org/jira/browse/FLINK-24542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24542:
Description:
When we start a flink job to consume apache kafka, we usually use offsetLag,
which
zlzhang0122 created FLINK-24542:
---
Summary: Expose the freshness metrics for kafka connector
Key: FLINK-24542
URL: https://issues.apache.org/jira/browse/FLINK-24542
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427431#comment-17427431
]
zlzhang0122 commented on FLINK-24122:
-
[~trohrmann] IMO the new option is the addition for the
[
https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426554#comment-17426554
]
zlzhang0122 commented on FLINK-24122:
-
[~trohrmann] [~pnowojski] [~jark] [~gyfora] what do you
[
https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24122:
Description:
Now, the history server can clean history jobs by two means:
# if users have
[
https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24122:
Description:
Now, the history server can clean history jobs by two means:
# if users have
[
https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24122:
Description:
Now, the history server can clean history jobs by two means:
# if users have
[
https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24122:
Description:
Now, the history server can clean history jobs by two means:
# if users have
[
https://issues.apache.org/jira/browse/FLINK-24377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420282#comment-17420282
]
zlzhang0122 commented on FLINK-24377:
-
We also have encountered this situation too.
> TM resource
[
https://issues.apache.org/jira/browse/FLINK-23189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418602#comment-17418602
]
zlzhang0122 edited comment on FLINK-23189 at 9/22/21, 1:52 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-23189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418602#comment-17418602
]
zlzhang0122 commented on FLINK-23189:
-
[~pnowojski] ok, I've seen the fix and found that it added
[
https://issues.apache.org/jira/browse/FLINK-23189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418420#comment-17418420
]
zlzhang0122 commented on FLINK-23189:
-
[~pnowojski] sure, I will check about it.
> Count and fail
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416576#comment-17416576
]
zlzhang0122 edited comment on FLINK-24306 at 9/17/21, 10:09 AM:
[~jark]
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416576#comment-17416576
]
zlzhang0122 edited comment on FLINK-24306 at 9/17/21, 9:35 AM:
---
[~jark] I
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416576#comment-17416576
]
zlzhang0122 commented on FLINK-24306:
-
[~jark] I have linked the Calcite issue but they thought that
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416576#comment-17416576
]
zlzhang0122 edited comment on FLINK-24306 at 9/17/21, 9:34 AM:
---
[~jark] I
[
https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416572#comment-17416572
]
zlzhang0122 commented on FLINK-24314:
-
[~shiwuliang] You can set like this:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416426#comment-17416426
]
zlzhang0122 edited comment on FLINK-24314 at 9/17/21, 3:54 AM:
---
In Flink
[
https://issues.apache.org/jira/browse/FLINK-24314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416426#comment-17416426
]
zlzhang0122 commented on FLINK-24314:
-
In Flink 1.13, the storage of the state and checkpoint was
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416000#comment-17416000
]
zlzhang0122 edited comment on FLINK-24306 at 9/16/21, 9:44 AM:
---
I have
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416000#comment-17416000
]
zlzhang0122 edited comment on FLINK-24306 at 9/16/21, 9:16 AM:
---
I have
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416000#comment-17416000
]
zlzhang0122 edited comment on FLINK-24306 at 9/16/21, 9:16 AM:
---
I have
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416000#comment-17416000
]
zlzhang0122 commented on FLINK-24306:
-
I have examined the latest apache calcite and found that it
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24306:
Attachment: calcite.png
> group by index throw SqlValidatorException
>
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24306:
Description:
We create a table using following DDL:
{code:java}
create table if not exists
zlzhang0122 created FLINK-24306:
---
Summary: group by index throw SqlValidatorException
Key: FLINK-24306
URL: https://issues.apache.org/jira/browse/FLINK-24306
Project: Flink
Issue Type: Bug
zlzhang0122 created FLINK-24207:
---
Summary: Add support of KeyedState in TwoPhaseCommitSinkFunction
Key: FLINK-24207
URL: https://issues.apache.org/jira/browse/FLINK-24207
Project: Flink
Issue
zlzhang0122 created FLINK-24201:
---
Summary: HistoryServer didn't contain TaskManager Logs
Key: FLINK-24201
URL: https://issues.apache.org/jira/browse/FLINK-24201
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-24122:
Issue Type: Bug (was: Improvement)
> Add support to do clean in history server
>
zlzhang0122 created FLINK-24122:
---
Summary: Add support to do clean in history server
Key: FLINK-24122
URL: https://issues.apache.org/jira/browse/FLINK-24122
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-23849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403761#comment-17403761
]
zlzhang0122 commented on FLINK-23849:
-
[~trohrmann] ok, I see, maybe community have much more
[
https://issues.apache.org/jira/browse/FLINK-23849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-23849:
Description: Now we are not interested in node updates in
zlzhang0122 created FLINK-23849:
---
Summary: Support react to the node decommissioning change state on
yarn and do graceful restart
Key: FLINK-23849
URL: https://issues.apache.org/jira/browse/FLINK-23849
[
https://issues.apache.org/jira/browse/FLINK-23622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 closed FLINK-23622.
---
Resolution: Not A Problem
> Default filesystem scheme improvement
>
[
https://issues.apache.org/jira/browse/FLINK-23561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397317#comment-17397317
]
zlzhang0122 commented on FLINK-23561:
-
[~trohrmann] sure, I'd like to give this a try.
> Detail the
[
https://issues.apache.org/jira/browse/FLINK-23564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393778#comment-17393778
]
zlzhang0122 edited comment on FLINK-23564 at 8/6/21, 11:05 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-23564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393778#comment-17393778
]
zlzhang0122 commented on FLINK-23564:
-
[~wangyang0918] Maybe using log4j2-iostreams is a better
zlzhang0122 created FLINK-23622:
---
Summary: Default filesystem scheme improvement
Key: FLINK-23622
URL: https://issues.apache.org/jira/browse/FLINK-23622
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-23564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391883#comment-17391883
]
zlzhang0122 commented on FLINK-23564:
-
[~Jiangang] It's easy to implemention if we redirect the .out
[
https://issues.apache.org/jira/browse/FLINK-23564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-23564:
Description: Now users can use
1 - 100 of 203 matches
Mail list logo
