Zhanghao Chen created FLINK-24223:
-
Summary: Client should throw exception to warn users when the
configurations set by program options conflict with those set by -D
Key: FLINK-24223
URL:
[
https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462069#comment-17462069
]
Zhanghao Chen commented on FLINK-25372:
---
[~xtsong] [~zjureel] Looking forward to hearing your
[
https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25372:
--
Description: Add thread dump feature for jobmanager in addition to the
previous work on TM
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Description:
*Problem*
Currently, the subtask detail panel on Web UI only displays the
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Description:
*Problem*
Currently, the subtask detail panel on Web UI only displays the
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Attachment: old.png
> Include port as part of the host info for subtask detail panel on Web
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Description:
*Problem*
Currently, the subtask detail panel on Web UI only displays the
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Attachment: (was: image-2021-12-18-17-57-13-674.png)
> Include port as part of the host
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Attachment: (was: image-2021-12-18-18-11-59-143.png)
> Include port as part of the host
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Attachment: new.png
> Include port as part of the host info for subtask detail panel on Web
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Description:
*Problem*
Currently, the subtask detail panel on Web UI only displays the
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25371:
--
Summary: Include data port as part of the host info for subtask detail
panel on Web UI (was:
Zhanghao Chen created FLINK-25371:
-
Summary: Include port as part of the host info for subtask detail
panel on Web UI
Key: FLINK-25371
URL: https://issues.apache.org/jira/browse/FLINK-25371
Project:
[
https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25372:
--
Description: Add thread dump feature for jobmanager in addition to the
previous work on TM
[
https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-25372:
--
Description: Add thread dump feature for jobmanager in addition to the
previous work on TM
Zhanghao Chen created FLINK-25372:
-
Summary: Add thread dump feature for jobmanager
Key: FLINK-25372
URL: https://issues.apache.org/jira/browse/FLINK-25372
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17449837#comment-17449837
]
Zhanghao Chen commented on FLINK-25068:
---
+1 for this feature
> Show the maximum parallelism
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17449837#comment-17449837
]
Zhanghao Chen edited comment on FLINK-25068 at 11/27/21, 1:45 PM:
--
+1
[
https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452957#comment-17452957
]
Zhanghao Chen commented on FLINK-12130:
---
[~victor-wong] What's the status of this issue right now?
[
https://issues.apache.org/jira/browse/FLINK-25586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476743#comment-17476743
]
Zhanghao Chen commented on FLINK-25586:
---
[~dmvk] I think the CANCELLED state be treated as a
Zhanghao Chen created FLINK-27056:
-
Summary: "pipeline.time-characteristic" should be deprecated and
have EVENT_TIME as default value
Key: FLINK-27056
URL: https://issues.apache.org/jira/browse/FLINK-27056
[
https://issues.apache.org/jira/browse/FLINK-27056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-27056:
--
Description:
*Background*
# pipeline.time-characteristic is the configuration option used to
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-27060:
--
Summary: Extending /jars/:jarid/run API to support setting Flink configs
(was: Extending
Zhanghao Chen created FLINK-27060:
-
Summary: Extending /jars/:jarid/run API to
Key: FLINK-27060
URL: https://issues.apache.org/jira/browse/FLINK-27060
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522170#comment-17522170
]
Zhanghao Chen commented on FLINK-27245:
---
[~hjw] Starting from Flink 1.14, there's a config option
[
https://issues.apache.org/jira/browse/FLINK-27245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522171#comment-17522171
]
Zhanghao Chen commented on FLINK-27245:
---
If you maintain an internal version of Flink 1.7.2, it's
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522718#comment-17522718
]
Zhanghao Chen commented on FLINK-27060:
---
[~martijnvisser] [~dmvk] I'd be willing to pushing
[
https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761941#comment-17761941
]
Zhanghao Chen commented on FLINK-32848:
---
Hi [~fanrui], if you have time, could you help check the
[
https://issues.apache.org/jira/browse/FLINK-32872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761944#comment-17761944
]
Zhanghao Chen commented on FLINK-32872:
---
[~huweihua] Looking forward to your suggestions on this
[
https://issues.apache.org/jira/browse/FLINK-33004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761151#comment-17761151
]
Zhanghao Chen commented on FLINK-33004:
---
[~lsy] big +1 for it. Could you collaborate a bit how you
[
https://issues.apache.org/jira/browse/FLINK-33288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776050#comment-17776050
]
Zhanghao Chen commented on FLINK-33288:
---
Hi [~xinchen147], thanks for reporting it, this is the
[
https://issues.apache.org/jira/browse/FLINK-33288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776113#comment-17776113
]
Zhanghao Chen commented on FLINK-33288:
---
[~xinchen147] you are right. But since the path to job
[
https://issues.apache.org/jira/browse/FLINK-33288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776058#comment-17776058
]
Zhanghao Chen commented on FLINK-33288:
---
[~xinchen147] Yes, the solution proposed in FLINK-30513
[
https://issues.apache.org/jira/browse/FLINK-33288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776077#comment-17776077
]
Zhanghao Chen commented on FLINK-33288:
---
[~xinchen147] Indeed, it seems that the job result store
[
https://issues.apache.org/jira/browse/FLINK-33288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776065#comment-17776065
]
Zhanghao Chen commented on FLINK-33288:
---
Job Result Store is added in Flink 1.15. Check
[
https://issues.apache.org/jira/browse/FLINK-33288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776183#comment-17776183
]
Zhanghao Chen commented on FLINK-33288:
---
HI [~mapohl], thanks for joining the discussion here. +1
[
https://issues.apache.org/jira/browse/FLINK-33262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781232#comment-17781232
]
Zhanghao Chen commented on FLINK-33262:
---
[~libenchao] Could you assign the task to me?
> Extend
[
https://issues.apache.org/jira/browse/FLINK-33264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781233#comment-17781233
]
Zhanghao Chen commented on FLINK-33264:
---
[~libenchao] Could you assign the task to me?
> Support
[
https://issues.apache.org/jira/browse/FLINK-33146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33146:
--
Description:
Umbrella ticket for [FLIP-363: Unify the Representation of TaskManager Location
Zhanghao Chen created FLINK-33146:
-
Summary: FLIP-363: Unify the Representation of TaskManager
Location in REST API and Web UI
Key: FLINK-33146
URL: https://issues.apache.org/jira/browse/FLINK-33146
Zhanghao Chen created FLINK-33147:
-
Summary: Introduce a new "endpoint" field in REST API to represent
TaskManager endpoint (host + port) and deprecate the "host" field
Key: FLINK-33147
URL:
[
https://issues.apache.org/jira/browse/FLINK-33146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33146:
--
Description: Umbrella ticket for [FLIP-363: Unify the Representation of
TaskManager Location
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768524#comment-17768524
]
Zhanghao Chen commented on FLINK-25371:
---
Since the scope is enlarged after discussion, I've
Zhanghao Chen created FLINK-33148:
-
Summary: Update Web UI to adopt the new "endpoint" field in REST
API
Key: FLINK-33148
URL: https://issues.apache.org/jira/browse/FLINK-33148
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen closed FLINK-25371.
-
Resolution: Later
Since the scope is enlarged after discussion, I've created a new issue:
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17767035#comment-17767035
]
Zhanghao Chen commented on FLINK-33123:
---
Hi [~gyfora] [~mxm] , please help take a look. I
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Summary: Wrong dynamic replacement of partitioner from FORWARD to REBLANCE
for autoscaler and
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Description:
*Background*
https://issues.apache.org/jira/browse/FLINK-30213 reported that
Zhanghao Chen created FLINK-33123:
-
Summary: Wrong dynamic replacement of partitioner from FORWARD to
REBLANCE for autoscaler and adaptive scheduler and
Key: FLINK-33123
URL:
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Attachment: image-2023-09-20-15-14-04-679.png
> Wrong dynamic replacement of partitioner from
[
https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17767191#comment-17767191
]
Zhanghao Chen commented on FLINK-31650:
---
[~wanglijie] [~JunRuiLi] Hi, I've created a PR that
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Attachment: image-2023-09-20-15-09-22-733.png
> Wrong dynamic replacement of partitioner from
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Description:
*Background*
https://issues.apache.org/jira/browse/FLINK-30213 reported that
[
https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769915#comment-17769915
]
Zhanghao Chen commented on FLINK-33166:
---
[~fangyong] Could you assign it to me if you think it
Zhanghao Chen created FLINK-33166:
-
Summary: Support setting root logger level by config
Key: FLINK-33166
URL: https://issues.apache.org/jira/browse/FLINK-33166
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33166:
--
Description:
Users currently cannot change logging level by config and have to modify the
[
https://issues.apache.org/jira/browse/FLINK-33160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769403#comment-17769403
]
Zhanghao Chen commented on FLINK-33160:
---
This is a useful feature for debugging network issues, +1
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17767397#comment-17767397
]
Zhanghao Chen commented on FLINK-33123:
---
Hi [~fanrui], thanks for sharing the issues. For issue 1:
[
https://issues.apache.org/jira/browse/FLINK-27056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773080#comment-17773080
]
Zhanghao Chen commented on FLINK-27056:
---
[~libenchao] I've updated the PR. Could you help take a
Zhanghao Chen created FLINK-33221:
-
Summary: Add config options for administrator JVM options
Key: FLINK-33221
URL: https://issues.apache.org/jira/browse/FLINK-33221
Project: Flink
Issue
Zhanghao Chen created FLINK-33204:
-
Summary: Add description for missing options in the all
jobmanager/taskmanager options section in document
Key: FLINK-33204
URL:
[
https://issues.apache.org/jira/browse/FLINK-33205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772927#comment-17772927
]
Zhanghao Chen commented on FLINK-33205:
---
[~chesnay] I've prepared a quick fix on it, could you
[
https://issues.apache.org/jira/browse/FLINK-33205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33205:
--
Description: Current description: "Turns on SSL for Akka’s remote
communication. This is
Zhanghao Chen created FLINK-33205:
-
Summary: Replace Akka with Pekko in the description of
"pekko.ssl.enabled"
Key: FLINK-33205
URL: https://issues.apache.org/jira/browse/FLINK-33205
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-30513:
--
Affects Version/s: 1.17.0
1.18.0
> HA storage dir leaks on cluster
[
https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-30513:
--
Labels: pull-request-available (was: pull-request-available stale-assigned)
> HA storage dir
[
https://issues.apache.org/jira/browse/FLINK-33236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773900#comment-17773900
]
Zhanghao Chen commented on FLINK-33236:
---
Hi [~mapohl], I've prepared a quick cleanup PR for it.
Zhanghao Chen created FLINK-33236:
-
Summary: Remove the unused
high-availability.zookeeper.path.running-registry option
Key: FLINK-33236
URL: https://issues.apache.org/jira/browse/FLINK-33236
Zhanghao Chen created FLINK-33240:
-
Summary: Generate docs for deprecated options as well
Key: FLINK-33240
URL: https://issues.apache.org/jira/browse/FLINK-33240
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33236:
--
Description: The running registry subcomponent of Flink HA has been removed
in FLINK-25430
[
https://issues.apache.org/jira/browse/FLINK-33204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772931#comment-17772931
]
Zhanghao Chen commented on FLINK-33204:
---
Hi [~xtsong], I've prepared a quick fix, could you help
[
https://issues.apache.org/jira/browse/FLINK-33240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774021#comment-17774021
]
Zhanghao Chen commented on FLINK-33240:
---
[~mapohl] Exactly. I'm thinking of adding a
Zhanghao Chen created FLINK-33264:
-
Summary: Support source parallelism setting for DataGen connector
Key: FLINK-33264
URL: https://issues.apache.org/jira/browse/FLINK-33264
Project: Flink
Zhanghao Chen created FLINK-33265:
-
Summary: Support source parallelism setting for Kafka connector
Key: FLINK-33265
URL: https://issues.apache.org/jira/browse/FLINK-33265
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33264:
--
Component/s: Connectors / Parent
> Support source parallelism setting for DataGen connector
>
Zhanghao Chen created FLINK-33261:
-
Summary: FLIP-367: Support Setting Parallelism for Table/SQL
Sources
Key: FLINK-33261
URL: https://issues.apache.org/jira/browse/FLINK-33261
Project: Flink
Zhanghao Chen created FLINK-33263:
-
Summary: Implement ParallelismProvider for sources in Blink planner
Key: FLINK-33263
URL: https://issues.apache.org/jira/browse/FLINK-33263
Project: Flink
Zhanghao Chen created FLINK-33262:
-
Summary: Extend source provider interfaces with the new
parallelism provider interface
Key: FLINK-33262
URL: https://issues.apache.org/jira/browse/FLINK-33262
[
https://issues.apache.org/jira/browse/FLINK-27056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754098#comment-17754098
]
Zhanghao Chen commented on FLINK-27056:
---
It's been a while but I think that the issue is still
[
https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-32821:
--
Description:
7 out of the 8 streaming examples failed to run:
* Iteration & SessionWindowing
Zhanghao Chen created FLINK-32868:
-
Summary: Document the need to backport FLINK-30213 for using
autoscaler with older version Flinks
Key: FLINK-32868
URL: https://issues.apache.org/jira/browse/FLINK-32868
[
https://issues.apache.org/jira/browse/FLINK-32868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen closed FLINK-32868.
-
Resolution: Fixed
> Document the need to backport FLINK-30213 for using autoscaler with older
[
https://issues.apache.org/jira/browse/FLINK-32872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-32872:
--
Description:
*Problem*
Currently, when the no partitioner is specified, FORWARD partitioner
[
https://issues.apache.org/jira/browse/FLINK-32872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754662#comment-17754662
]
Zhanghao Chen commented on FLINK-32872:
---
[~huwh] [~guoyangze] What do you think about this?
> Add
Zhanghao Chen created FLINK-32872:
-
Summary: Add option to control the default partitioner when the
parallelism of upstream and downstream operator does not match
Key: FLINK-32872
URL:
[
https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759546#comment-17759546
]
Zhanghao Chen commented on FLINK-32980:
---
Hi [~huweihua], do you think it valid? If so, could you
[
https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-32980:
--
Summary: Support env.java.opts.all & env.java.opts.cli config for starting
Session cluster
Zhanghao Chen created FLINK-32983:
-
Summary: Support setting env.java.opts.all & env.java.opts.cli
configs via dynamic properties on the CLI side
Key: FLINK-32983
URL:
Zhanghao Chen created FLINK-32980:
-
Summary: Support env.java.opts.all & env.java.opts.cli config for
starting Session clusters
Key: FLINK-32980
URL: https://issues.apache.org/jira/browse/FLINK-32980
[
https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-32980:
--
Description:
*Problem*
The following configs are supposed to be supported:
|h5.
[
https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759238#comment-17759238
]
Zhanghao Chen commented on FLINK-32848:
---
Hi [~fanrui], to simplify the code review, I've created 4
[
https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759239#comment-17759239
]
Zhanghao Chen commented on FLINK-32821:
---
Hi [~afedulov], there's already a test on StateMachine
[
https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-32821:
--
Description:
6 out of the 8 streaming examples failed to run:
* Iteration & SessionWindowing
[
https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759786#comment-17759786
]
Zhanghao Chen commented on FLINK-31650:
---
Hi [~JunRuiLi], we encountered the same problem. Are you
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518584#comment-17518584
]
Zhanghao Chen commented on FLINK-27060:
---
[~wangyang0918] The goal is that this API should try to
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518586#comment-17518586
]
Zhanghao Chen commented on FLINK-27060:
---
[~martijnvisser] I'm not sure if this needs a FLIP as I
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540792#comment-17540792
]
Zhanghao Chen commented on FLINK-27060:
---
I agree with [~ConradJam] . This is kind of irrelevant
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540794#comment-17540794
]
Zhanghao Chen commented on FLINK-27060:
---
[~martijnvisser] I was a bit busy before. I've created a
[
https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564772#comment-17564772
]
Zhanghao Chen commented on FLINK-28390:
---
Option "state.backend.rocksdb.compaction.style" already
[
https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564972#comment-17564972
]
Zhanghao Chen commented on FLINK-28390:
---
"assuming that the MAX_SIZE of the FIFO is configured to
1 - 100 of 308 matches
Mail list logo
