[jira] [Comment Edited] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

[ https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928279#comment-16928279 ] Zhilong Hong edited comment on FLINK-14065 at 9/12/19 6:41 AM: --- It would

[jira] [Commented] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

[ https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928279#comment-16928279 ] Zhilong Hong commented on FLINK-14065: -- It would be my pleasure if I can help to fix this issue.  

[jira] [Updated] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

[ https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-14065: - Description: When MetricGroup registers Metrics in MetricRegistryImpl, sometimes the

[jira] [Created] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

Zhilong Hong created FLINK-14065: Summary: Log metric name when the metric fails on registration/unregistration Key: FLINK-14065 URL: https://issues.apache.org/jira/browse/FLINK-14065 Project: Flink

[jira] [Commented] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

[ https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16929784#comment-16929784 ] Zhilong Hong commented on FLINK-14065: -- Thanks, Till. I've already came up with a pull request. >

[jira] [Commented] (FLINK-19540) How to reduce or disable checkpoint logs in Flink

[ https://issues.apache.org/jira/browse/FLINK-19540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213530#comment-17213530 ] Zhilong Hong commented on FLINK-19540: -- [~jeromexlee] How about run the Flink compiled by yourself?

[jira] [Commented] (FLINK-19540) How to reduce or disable checkpoint logs in Flink

[ https://issues.apache.org/jira/browse/FLINK-19540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210734#comment-17210734 ] Zhilong Hong commented on FLINK-19540: -- Hello [~jeromexlee], thanks for your question. It would be

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162767#comment-17162767 ] Zhilong Hong commented on FLINK-18496: -- I'm interested in this task and would like to work on this

[jira] [Commented] (FLINK-18355) Simplify tests of SlotPoolImpl

[ https://issues.apache.org/jira/browse/FLINK-18355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139230#comment-17139230 ] Zhilong Hong commented on FLINK-18355: -- I'm interested in completing this task and would like to

[jira] [Comment Edited] (FLINK-18355) Simplify tests of SlotPoolImpl

[ https://issues.apache.org/jira/browse/FLINK-18355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139230#comment-17139230 ] Zhilong Hong edited comment on FLINK-18355 at 6/18/20, 8:58 AM: I'm

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166374#comment-17166374 ] Zhilong Hong commented on FLINK-18496: -- I think in fact the plugin is conflict with the excerpt

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166815#comment-17166815 ] Zhilong Hong commented on FLINK-18496: -- I try to use the Gemfile in flink/docs, but it doesn't

[jira] [Comment Edited] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166815#comment-17166815 ] Zhilong Hong edited comment on FLINK-18496 at 7/29/20, 2:36 AM: I try to

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167107#comment-17167107 ] Zhilong Hong commented on FLINK-18496: -- Thank you for your concern, Jark. The plugin works in

[jira] [Comment Edited] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167107#comment-17167107 ] Zhilong Hong edited comment on FLINK-18496 at 7/29/20, 10:18 AM: - Thank

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165379#comment-17165379 ] Zhilong Hong commented on FLINK-18496: -- I try to upgrade the version of Jekyll from 3.0.5 to 4.0.1.

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165660#comment-17165660 ] Zhilong Hong commented on FLINK-18496: -- I think the issue is related to the posts. 1. In

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165414#comment-17165414 ] Zhilong Hong commented on FLINK-18496: -- Now I'm trying to remove the document files one by one to

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166049#comment-17166049 ] Zhilong Hong commented on FLINK-18496: -- Change `_post` into another folder name works. The build

[jira] [Comment Edited] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165660#comment-17165660 ] Zhilong Hong edited comment on FLINK-18496 at 7/28/20, 1:43 AM: I think

[jira] [Comment Edited] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166049#comment-17166049 ] Zhilong Hong edited comment on FLINK-18496 at 7/28/20, 2:52 AM: Change

[jira] [Comment Edited] (FLINK-20547) Batch job fails due to the exception in network stack

[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247174#comment-17247174 ] Zhilong Hong edited comment on FLINK-20547 at 12/10/20, 12:35 PM: --

[jira] [Commented] (FLINK-20547) Batch job fails due to the exception in network stack

[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247174#comment-17247174 ] Zhilong Hong commented on FLINK-20547: -- [~roman_khachatryan] This is issue can be reproduced.  The

[jira] [Created] (FLINK-20547) Batch job fails due to the exception in network stack

Zhilong Hong created FLINK-20547: Summary: Batch job fails due to the exception in network stack Key: FLINK-20547 URL: https://issues.apache.org/jira/browse/FLINK-20547 Project: Flink Issue

[jira] [Updated] (FLINK-20547) Batch job fails due to the exception in network stack

[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-20547: - Description: I run a simple batch job with only two job vertices: a source and a sink. The

[jira] [Commented] (FLINK-20612) Add benchmarks for scheduler

[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251022#comment-17251022 ] Zhilong Hong commented on FLINK-20612: -- Thank you [~trohrmann]. I can't agree more. I wonder

[jira] [Comment Edited] (FLINK-20547) Batch job fails due to the exception in network stack

[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250894#comment-17250894 ] Zhilong Hong edited comment on FLINK-20547 at 12/17/20, 10:39 AM: --

[jira] [Commented] (FLINK-20755) proctime 在yaml配置中启动sql-clinet报错

[ https://issues.apache.org/jira/browse/FLINK-20755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254373#comment-17254373 ] Zhilong Hong commented on FLINK-20755: -- Hi [~yunsky], thank you for proposing this issue. Please

[jira] [Comment Edited] (FLINK-20747) max 函数冲突报ClassCastException异常

[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254378#comment-17254378 ] Zhilong Hong edited comment on FLINK-20747 at 12/24/20, 2:59 AM: - Hi,

[jira] [Commented] (FLINK-20747) max 函数冲突报ClassCastException异常

[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254378#comment-17254378 ] Zhilong Hong commented on FLINK-20747: -- Hi, [~zengjinbo], thank you for proposing this issue. Would

[jira] [Updated] (FLINK-20612) Add benchmarks for scheduler

[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-20612: - Description: With Flink 1.12, we failed to run large-scale jobs on our cluster. When we were

[jira] [Updated] (FLINK-20612) Add benchmarks for scheduler

[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-20612: - Description: With Flink 1.12, we failed to run large-scale jobs on our cluster. When we were

[jira] [Updated] (FLINK-20612) Add benchmarks for scheduler

[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-20612: - Description: With Flink 1.12, we failed to run large-scale jobs on our cluster. When we were

[jira] [Created] (FLINK-20612) Add benchmarks for scheduler

Zhilong Hong created FLINK-20612: Summary: Add benchmarks for scheduler Key: FLINK-20612 URL: https://issues.apache.org/jira/browse/FLINK-20612 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-20612) Add benchmarks for scheduler

[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-20612: - Description: With Flink 1.12, we failed to run large-scale jobs on our cluster. When we were

[jira] [Commented] (FLINK-20612) Add benchmarks for scheduler

[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250775#comment-17250775 ] Zhilong Hong commented on FLINK-20612: -- Thank you for your reply, [~trohrmann]. We implemented two

[jira] [Comment Edited] (FLINK-20612) Add benchmarks for scheduler

[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250775#comment-17250775 ] Zhilong Hong edited comment on FLINK-20612 at 12/17/20, 3:38 AM: - Thank

[jira] [Commented] (FLINK-20547) Batch job fails due to the exception in network stack

[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250894#comment-17250894 ] Zhilong Hong commented on FLINK-20547: -- Sorry for the late reply, [~roman_khachatryan]. At present,

[jira] [Commented] (FLINK-20878) Flink 1.12作业job Name修改

[ https://issues.apache.org/jira/browse/FLINK-20878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264812#comment-17264812 ] Zhilong Hong commented on FLINK-20878: -- Hello, [~HideOnBush]. If you encounter any question, please

[jira] [Updated] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs

[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21110: - Description: According to the result of scheduler benchmarks we implemented in FLINK-20612,

[jira] [Updated] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs

[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21110: - Description: According to the result of scheduler benchmarks we implemented in FLINK-20612,

[jira] [Created] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs

Zhilong Hong created FLINK-21110: Summary: Optimize Scheduler Performance for Large-Scale Jobs Key: FLINK-21110 URL: https://issues.apache.org/jira/browse/FLINK-21110 Project: Flink Issue

[jira] [Updated] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs

[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21110: - Description: According to the result of scheduler benchmarks we implemented in

[jira] [Commented] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs

[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271272#comment-17271272 ] Zhilong Hong commented on FLINK-21110: -- cc [~sewen] and [~trohrmann] > Optimize Scheduler

[jira] [Updated] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21201: - Description: When we are trying to run batch jobs with 8k parallelism, it takes a long time to

[jira] [Updated] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21201: - Description: When we are trying to run batch jobs with 8k parallelism, it takes a long time to

[jira] [Updated] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21201: - Description: When we are trying to run batch jobs with 8k parallelism, it takes a long time to

[jira] [Updated] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21201: - Description: When we are trying to run batch jobs with 8k parallelism, it takes a long time to

[jira] [Commented] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276211#comment-17276211 ] Zhilong Hong commented on FLINK-21201: -- cc [~pnowojski], [~gaoyunhaii] and [~kevin.cyj] > Creating

[jira] [Commented] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278518#comment-17278518 ] Zhilong Hong commented on FLINK-21201: -- Thanks for providing the ideas, Piotr. After discussing

[jira] [Updated] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs

[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21110: - Description: According to the result of scheduler benchmarks we implemented in FLINK-20612,

[jira] [Created] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

Zhilong Hong created FLINK-21201: Summary: Creating BoundedBlockingSubpartition blocks TaskManager’s main thread Key: FLINK-21201 URL: https://issues.apache.org/jira/browse/FLINK-21201 Project: Flink

[jira] [Updated] (FLINK-23005) Optimize the deployment of tasks

[ https://issues.apache.org/jira/browse/FLINK-23005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23005: - Description: h3. Introduction The optimizations introduced in FLINK-21110 so far have improved

[jira] [Created] (FLINK-23005) Optimize the deployment of tasks

Zhilong Hong created FLINK-23005: Summary: Optimize the deployment of tasks Key: FLINK-23005 URL: https://issues.apache.org/jira/browse/FLINK-23005 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-22922) Migrate flink website to hugo

[ https://issues.apache.org/jira/browse/FLINK-22922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359736#comment-17359736 ] Zhilong Hong commented on FLINK-22922: -- +1 Issues like FLINK-18496 may get resolved after migrating

[jira] [Updated] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22284: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Null address

[jira] [Commented] (FLINK-23078) Scheduler Benchmarks not compiling

[ https://issues.apache.org/jira/browse/FLINK-23078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367520#comment-17367520 ] Zhilong Hong commented on FLINK-23078: -- I agree. I'll do it at once. > Scheduler Benchmarks not

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367833#comment-17367833 ] Zhilong Hong commented on FLINK-22643: -- Only tasks that belong to the same JobVertex on the same

[jira] [Comment Edited] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367833#comment-17367833 ] Zhilong Hong edited comment on FLINK-22643 at 6/23/21, 3:23 AM: Only

[jira] [Commented] (FLINK-23078) Scheduler Benchmarks not compiling

[ https://issues.apache.org/jira/browse/FLINK-23078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367954#comment-17367954 ] Zhilong Hong commented on FLINK-23078: -- Hi [~pnowojski], I've came up with a pull request that

[jira] [Commented] (FLINK-23077) Running nexmark q5 with 1.13.1 of pipeline.object-reuse=true, the taskmanager will be killed and produce failover.

[ https://issues.apache.org/jira/browse/FLINK-23077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367190#comment-17367190 ] Zhilong Hong commented on FLINK-23077: -- It seems that the resource is not enough for the job to

[jira] [Commented] (FLINK-23078) Scheduler Benchmarks not compiling

[ https://issues.apache.org/jira/browse/FLINK-23078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367185#comment-17367185 ] Zhilong Hong commented on FLINK-23078: -- Thank you for reminding me, [~pnowojski]. I noticed that

[jira] [Updated] (FLINK-23153) Benchmark not compiling

[ https://issues.apache.org/jira/browse/FLINK-23153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23153: - Description: In FLINK-23085, FutureUtils is moved from flink-runtime to flink-core. The

[jira] [Created] (FLINK-23153) Benchmark not compiling

Zhilong Hong created FLINK-23153: Summary: Benchmark not compiling Key: FLINK-23153 URL: https://issues.apache.org/jira/browse/FLINK-23153 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

Zhilong Hong created FLINK-22643: Summary: Too many TCP connections among TaskManagers for large scale jobs Key: FLINK-22643 URL: https://issues.apache.org/jira/browse/FLINK-22643 Project: Flink

[jira] [Commented] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346004#comment-17346004 ] Zhilong Hong commented on FLINK-22284: -- Yes, please assign it to me. Thank you, [~pnowojski] >

[jira] [Commented] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17345991#comment-17345991 ] Zhilong Hong commented on FLINK-22284: -- Sorry that I missed the {{request}}. I prefer to print the

[jira] [Commented] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343681#comment-17343681 ] Zhilong Hong commented on FLINK-22284: -- Sorry for the late reply, [~pnowojski]. Recently my outlook

[jira] [Updated] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22284: - Description: In NettyPartitionRequestClient#requestSubpartition, when a channel is closed, the

[jira] [Updated] (FLINK-21920) Optimize ExecutionGraphToInputsLocationsRetrieverAdapter

[ https://issues.apache.org/jira/browse/FLINK-21920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21920: - Labels: pull-request-available (was: auto-unassigned pull-request-available stale-assigned) >

[jira] [Updated] (FLINK-21920) Optimize DefaultScheduler#allocateSlots

[ https://issues.apache.org/jira/browse/FLINK-21920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21920: - Description: Based on the scheduler benchmark introduced in FLINK-21731, we find that there's

[jira] [Updated] (FLINK-21920) Optimize ExecutionGraphToInputsLocationsRetrieverAdapter

[ https://issues.apache.org/jira/browse/FLINK-21920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21920: - Summary: Optimize ExecutionGraphToInputsLocationsRetrieverAdapter (was: Optimize

[jira] [Created] (FLINK-22767) Optimize the initialization of ExecutionSlotSharingGroupBuilder

Zhilong Hong created FLINK-22767: Summary: Optimize the initialization of ExecutionSlotSharingGroupBuilder Key: FLINK-22767 URL: https://issues.apache.org/jira/browse/FLINK-22767 Project: Flink

[jira] [Created] (FLINK-22773) Optimize the construction of pipelined regions

Zhilong Hong created FLINK-22773: Summary: Optimize the construction of pipelined regions Key: FLINK-22773 URL: https://issues.apache.org/jira/browse/FLINK-22773 Project: Flink Issue Type:

[jira] [Created] (FLINK-22863) ArrayIndexOutOfBoundsException may happen when building rescale edges

Zhilong Hong created FLINK-22863: Summary: ArrayIndexOutOfBoundsException may happen when building rescale edges Key: FLINK-22863 URL: https://issues.apache.org/jira/browse/FLINK-22863 Project: Flink

[jira] [Commented] (FLINK-22863) ArrayIndexOutOfBoundsException may happen when building rescale edges

[ https://issues.apache.org/jira/browse/FLINK-22863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17356248#comment-17356248 ] Zhilong Hong commented on FLINK-22863: -- cc [~zhuzh], [~trohrmann] > ArrayIndexOutOfBoundsException

[jira] [Commented] (FLINK-23218) Distribute the ShuffleDescriptors via blob server

[ https://issues.apache.org/jira/browse/FLINK-23218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17376501#comment-17376501 ] Zhilong Hong commented on FLINK-23218: -- Thank you so much for your suggestion, [~trohrmann]. The

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17374672#comment-17374672 ] Zhilong Hong commented on FLINK-22643: -- Thank you for your reply, [~pnowojski].  ??1. Does this

[jira] [Comment Edited] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17374672#comment-17374672 ] Zhilong Hong edited comment on FLINK-22643 at 7/5/21, 8:45 AM: --- Thank you

[jira] [Commented] (FLINK-23300) Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager

[ https://issues.apache.org/jira/browse/FLINK-23300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17376966#comment-17376966 ] Zhilong Hong commented on FLINK-23300: -- I think FLINK-23202 and FLINK-23209 are working on solving

[jira] [Updated] (FLINK-23005) Cache the compressed serialized value of ShuffleDescriptors

[ https://issues.apache.org/jira/browse/FLINK-23005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23005: - Summary: Cache the compressed serialized value of ShuffleDescriptors (was: Optimize the

[jira] [Created] (FLINK-23218) Distribute the ShuffleDescriptors via blob server

Zhilong Hong created FLINK-23218: Summary: Distribute the ShuffleDescriptors via blob server Key: FLINK-23218 URL: https://issues.apache.org/jira/browse/FLINK-23218 Project: Flink Issue

[jira] [Commented] (FLINK-23196) JobMasterITCase fail on azure due to BindException

[ https://issues.apache.org/jira/browse/FLINK-23196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372437#comment-17372437 ] Zhilong Hong commented on FLINK-23196: --

[jira] [Created] (FLINK-23172) Links of restart strategy in configuration page is broken

Zhilong Hong created FLINK-23172: Summary: Links of restart strategy in configuration page is broken Key: FLINK-23172 URL: https://issues.apache.org/jira/browse/FLINK-23172 Project: Flink

[jira] [Updated] (FLINK-22017) Regions may never be scheduled when there are cross-region blocking edges

[ https://issues.apache.org/jira/browse/FLINK-22017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22017: - Priority: Critical (was: Major) > Regions may never be scheduled when there are cross-region

[jira] [Updated] (FLINK-22017) Regions may never be scheduled when there are cross-region blocking edges

[ https://issues.apache.org/jira/browse/FLINK-22017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22017: - Labels: (was: auto-deprioritized-critical stale-major) > Regions may never be scheduled when

[jira] [Updated] (FLINK-22017) Regions may never be scheduled when there are cross-region blocking edges

[ https://issues.apache.org/jira/browse/FLINK-22017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22017: - Fix Version/s: 1.14.0 > Regions may never be scheduled when there are cross-region blocking

[jira] [Commented] (FLINK-23218) Distribute the ShuffleDescriptors via blob server

[ https://issues.apache.org/jira/browse/FLINK-23218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377977#comment-17377977 ] Zhilong Hong commented on FLINK-23218: -- Thank you so much for your suggestions, [~trohrmann] and

[jira] [Created] (FLINK-23354) Limit the size of blob cache on TaskExecutor

Zhilong Hong created FLINK-23354: Summary: Limit the size of blob cache on TaskExecutor Key: FLINK-23354 URL: https://issues.apache.org/jira/browse/FLINK-23354 Project: Flink Issue Type:

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17374773#comment-17374773 ] Zhilong Hong commented on FLINK-22643: -- In practice we set the default value in our configuration

[jira] [Comment Edited] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17374773#comment-17374773 ] Zhilong Hong edited comment on FLINK-22643 at 7/5/21, 11:43 AM: In

[jira] [Commented] (FLINK-23218) Distribute the ShuffleDescriptors via blob server

[ https://issues.apache.org/jira/browse/FLINK-23218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375416#comment-17375416 ] Zhilong Hong commented on FLINK-23218: -- Thank you for your reply, [~trohrmann].  # As for the

[jira] [Commented] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280903#comment-17280903 ] Zhilong Hong commented on FLINK-21201: -- Sorry for making it confusing. I mean moving the

[jira] [Comment Edited] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280903#comment-17280903 ] Zhilong Hong edited comment on FLINK-21201 at 2/8/21, 12:22 PM: Sorry

[jira] [Updated] (FLINK-21328) Optimize the initialization of DefaultExecutionTopology

[ https://issues.apache.org/jira/browse/FLINK-21328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21328: - Description: Based on FLINK-21326, the {{consumedResults}} in {{DefaultExecutionVertex}} and

[jira] [Updated] (FLINK-21330) Optimize the initialization of PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-21330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21330: - Summary: Optimize the initialization of PipelinedRegionSchedulingStrategy (was: Optimization

[jira] [Created] (FLINK-21326) Optimize building topology when initializing ExecutionGraph

Zhilong Hong created FLINK-21326: Summary: Optimize building topology when initializing ExecutionGraph Key: FLINK-21326 URL: https://issues.apache.org/jira/browse/FLINK-21326 Project: Flink

[jira] [Updated] (FLINK-21110) Optimize scheduler performance for large-scale jobs

[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21110: - Summary: Optimize scheduler performance for large-scale jobs (was: Optimize Scheduler

[jira] [Created] (FLINK-21332) Optimize releasing result partitions in RegionPartitionReleaseStrategy

Zhilong Hong created FLINK-21332: Summary: Optimize releasing result partitions in RegionPartitionReleaseStrategy Key: FLINK-21332 URL: https://issues.apache.org/jira/browse/FLINK-21332 Project:

[jira] [Created] (FLINK-21328) Optimize the initialization of DefaultExecutionTopology

Zhilong Hong created FLINK-21328: Summary: Optimize the initialization of DefaultExecutionTopology Key: FLINK-21328 URL: https://issues.apache.org/jira/browse/FLINK-21328 Project: Flink

  1   2   3   >