[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-24624.
--
Resolution: Won't Fix
> Add clean up phase when kubernetes session start failed
>
[
https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480946#comment-17480946
]
Aitozi commented on FLINK-20830:
I have created the pull request, please take a look when you are free
[
https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480572#comment-17480572
]
Aitozi commented on FLINK-20830:
Hi [~chesnay], [~wangyang0918], Sorry for bring up discussion again.
[
https://issues.apache.org/jira/browse/FLINK-25660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-25660.
--
Resolution: Not A Bug
> Failed to build flink-runtime-web
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-25660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479140#comment-17479140
]
Aitozi commented on FLINK-25660:
[~guoyangze] , [~junhany] Thanks for your guidance, I have addressed
[
https://issues.apache.org/jira/browse/FLINK-25660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476591#comment-17476591
]
Aitozi commented on FLINK-25660:
Hi, [~junhany] Do you have any idea for this ?
> Failed to build
Aitozi created FLINK-25660:
--
Summary: Failed to build flink-runtime-web
Key: FLINK-25660
URL: https://issues.apache.org/jira/browse/FLINK-25660
Project: Flink
Issue Type: Bug
Reporter:
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472154#comment-17472154
]
Aitozi commented on FLINK-23031:
Hi [~wenlong.lwl] I have done the refactor work, and fill the Jira
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-23031:
---
Description:
Currently, Flink support early trigger for Window Operator, But it will trigger
periodically
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-23031:
---
Description:
Currently, Flink support early trigger for Window Operator, But it will trigger
periodically
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-23031:
---
Description:
Currently, Flink support early trigger for Window Operator, But it will trigger
periodically
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-23031:
---
Description:
Currently, Flink support early trigger for Window Operator, But it will trigger
periodically
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-23031:
---
Description:
Currently, Flink support early trigger for Window Operator, But it will trigger
periodically
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471920#comment-17471920
]
Aitozi commented on FLINK-23031:
[~wenlong.lwl] I lose sight of the Window Operator can eliminate same
[
https://issues.apache.org/jira/browse/FLINK-25580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-25580:
---
Description:
{{RocksDBIncrementalCheckpointUtils}} use
{{intersectGroup.getNumberOfKeyGroups() *
[
https://issues.apache.org/jira/browse/FLINK-25580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-25580:
---
Description: Res
> Minor improvements for RocksDBIncrementalCheckpointUtils
>
Aitozi created FLINK-25580:
--
Summary: Minor improvements for RocksDBIncrementalCheckpointUtils
Key: FLINK-25580
URL: https://issues.apache.org/jira/browse/FLINK-25580
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-24967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447881#comment-17447881
]
Aitozi commented on FLINK-24967:
[~pnowojski] Thanks for your detail explanation. I also not meant to
[
https://issues.apache.org/jira/browse/FLINK-24967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446954#comment-17446954
]
Aitozi commented on FLINK-24967:
I also notice some {{TODOs}} in {{StateBenchmarkConstants}}. Do you
[
https://issues.apache.org/jira/browse/FLINK-24967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446952#comment-17446952
]
Aitozi commented on FLINK-24967:
cc [~yunta]
> Make the IO pattern configureable in state benchmarks
>
Aitozi created FLINK-24967:
--
Summary: Make the IO pattern configureable in state benchmarks
Key: FLINK-24967
URL: https://issues.apache.org/jira/browse/FLINK-24967
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446944#comment-17446944
]
Aitozi commented on FLINK-24918:
I have create the two related pull request, please take a look when you
[
https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445983#comment-17445983
]
Aitozi commented on FLINK-24713:
Agree with your suggestion, I will work on it in this way. Could you
[
https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445738#comment-17445738
]
Aitozi commented on FLINK-24918:
Yes, I can work on this. Please assign this to me.
> Support to
[
https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444349#comment-17444349
]
Aitozi commented on FLINK-24918:
ps: I find I can use the \{{-Djava.io.tmpdir=/data/}} to change the
[
https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24918:
---
Component/s: Runtime / State Backends
> Support to specify the data dir for state benchmark
>
[
https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444327#comment-17444327
]
Aitozi commented on FLINK-24918:
Hi [~yunta] , do you have some inputs for this ?
> Support to specify
Aitozi created FLINK-24918:
--
Summary: Support to specify the data dir for state benchmark
Key: FLINK-24918
URL: https://issues.apache.org/jira/browse/FLINK-24918
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441779#comment-17441779
]
Aitozi commented on FLINK-24633:
emm... Do you think Flink community should provide a Flink operator
[
https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438783#comment-17438783
]
Aitozi commented on FLINK-24631:
I have open the PR for this, please help review when you are free :).
[
https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438711#comment-17438711
]
Aitozi commented on FLINK-24633:
Pod may stuck in some case:
1. allocate ip timeout
2. mount volume
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438592#comment-17438592
]
Aitozi commented on FLINK-24755:
The reason can refer to [JEP-247|https://openjdk.java.net/jeps/247].
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438576#comment-17438576
]
Aitozi commented on FLINK-24755:
Get it, thanks for explanation [~chesnay] . May be I met the problem
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438169#comment-17438169
]
Aitozi edited comment on FLINK-24755 at 11/4/21, 2:01 AM:
--
[~chesnay] You can
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438169#comment-17438169
]
Aitozi edited comment on FLINK-24755 at 11/4/21, 2:00 AM:
--
[~chesnay] You can
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438169#comment-17438169
]
Aitozi commented on FLINK-24755:
You can also refer to
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438158#comment-17438158
]
Aitozi commented on FLINK-24755:
Thanks for your quick reply, I found that it may caused by the idea
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24755:
---
Attachment: image-2021-11-03-23-42-30-441.png
> sun.misc doesn't exist
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438139#comment-17438139
]
Aitozi commented on FLINK-24713:
Thanks for your reply [~wangyang0918] [~trohrmann] . I will post a
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24755:
---
Description:
After FLINK-24634 , the default target is jdk8. When I running tests from IDE,
some compiler
Aitozi created FLINK-24755:
--
Summary: sun.misc doesn't exist
Key: FLINK-24755
URL: https://issues.apache.org/jira/browse/FLINK-24755
Project: Flink
Issue Type: Bug
Components: Build
[
https://issues.apache.org/jira/browse/FLINK-24739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437832#comment-17437832
]
Aitozi edited comment on FLINK-24739 at 11/3/21, 9:36 AM:
--
IMO, It makes a lot
[
https://issues.apache.org/jira/browse/FLINK-24739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437858#comment-17437858
]
Aitozi commented on FLINK-24739:
Get it, Thanks for explanation [~dmvk]
> State requirements for
[
https://issues.apache.org/jira/browse/FLINK-24739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437832#comment-17437832
]
Aitozi commented on FLINK-24739:
IMO, It makes a lot of sense to enable Flink to ship the user code jars
[
https://issues.apache.org/jira/browse/FLINK-24739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437786#comment-17437786
]
Aitozi commented on FLINK-24739:
It seems it has been point out [application-mode
[
https://issues.apache.org/jira/browse/FLINK-24543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24543:
---
Summary:Zookeeper connection issue causes inconsistent state in Flink
(was: jar)
> Zookeeper
[
https://issues.apache.org/jira/browse/FLINK-24543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24543:
---
Summary: jar (was: Zookeeper connection issue causes inconsistent state in
Flink)
> jar
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24713:
---
Description:
When ResourceManager started, JobManger will connect to the ResourceManager,
this means the
[
https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436628#comment-17436628
]
Aitozi commented on FLINK-24713:
I propose to add an interface in resourceManager to return the
[
https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436620#comment-17436620
]
Aitozi commented on FLINK-24713:
cc [~trohrmann] , looking forward to your opinions.
> Postpone
Aitozi created FLINK-24713:
--
Summary: Postpone resourceManager serving after the recovery phase
has finished
Key: FLINK-24713
URL: https://issues.apache.org/jira/browse/FLINK-24713
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24631:
---
Description:
We create deployment use the pod selector directly from labels, which is not
necessary and
[
https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436508#comment-17436508
]
Aitozi commented on FLINK-24631:
Hi [~wangyang0918], Do you have any inputs for this ?
> Avoiding
[
https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24631:
---
Description:
We create deployment use the pod selector directly from labels, which is not
necessary and
[
https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436505#comment-17436505
]
Aitozi commented on FLINK-24633:
I'am not sure whether it is the common behavior of kubernetes scheduler
[
https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435769#comment-17435769
]
Aitozi commented on FLINK-24633:
Yes, it's caused by the k8s can't not start pod eventually, this will
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435768#comment-17435768
]
Aitozi commented on FLINK-24624:
Thanks in advance [~wangyang0918] :)
> Add clean up phase when
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434081#comment-17434081
]
Aitozi commented on FLINK-24624:
[~wangyang0918] Besides that, I create this issue also want to discuss
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434076#comment-17434076
]
Aitozi commented on FLINK-24624:
Thanks for pointing that [~wangyang0918]. I think I can quickly update
Aitozi created FLINK-24633:
--
Summary: JobManager pod may stuck in containerCreating status
during failover
Key: FLINK-24633
URL: https://issues.apache.org/jira/browse/FLINK-24633
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24631:
---
Description:
We create deployment use the pod selector directly from labels, which is not
necessary and
Aitozi created FLINK-24631:
--
Summary: Avoiding directly use the labels as selector for
deployment and service
Key: FLINK-24631
URL: https://issues.apache.org/jira/browse/FLINK-24631
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433561#comment-17433561
]
Aitozi commented on FLINK-23031:
Hi [~jark] [~godfreyhe] [~twalthr] anyone could help review this PR ?
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433449#comment-17433449
]
Aitozi commented on FLINK-24624:
So the {{client.stopAndCleanupCluster(clusterId)}} should cover the
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433448#comment-17433448
]
Aitozi commented on FLINK-24624:
After looking into the failure, It's caused by the lack of permission
Aitozi created FLINK-24625:
--
Summary: Expose the required kubernetes permission from the shell
command
Key: FLINK-24625
URL: https://issues.apache.org/jira/browse/FLINK-24625
Project: Flink
Issue
Aitozi created FLINK-24624:
--
Summary: Add clean up phase when kubernetes session start failed
Key: FLINK-24624
URL: https://issues.apache.org/jira/browse/FLINK-24624
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-24138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425558#comment-17425558
]
Aitozi commented on FLINK-24138:
It looks very nice work (y)
> Automated architectural tests
>
[
https://issues.apache.org/jira/browse/FLINK-22594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-22594:
---
Fix Version/s: 1.15.0
> Report oom killed pod in k8s resource manager
>
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-23031:
---
Fix Version/s: 1.15.0
> Support to emit window result with periodic or non_periodic
>
[
https://issues.apache.org/jira/browse/FLINK-24167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425458#comment-17425458
]
Aitozi commented on FLINK-24167:
Thanks for your suggestion, I have done the minor refactor for this. It
[
https://issues.apache.org/jira/browse/FLINK-24167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425443#comment-17425443
]
Aitozi commented on FLINK-24167:
Yes, I have think over about the implementation yet, It's not easy to
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425399#comment-17425399
]
Aitozi edited comment on FLINK-24455 at 10/7/21, 8:13 AM:
--
I have created the
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425399#comment-17425399
]
Aitozi commented on FLINK-24455:
I have created the fix pull request, please help review when you are
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424840#comment-17424840
]
Aitozi commented on FLINK-24455:
Thanks for your detail explanation :) . I think I can volunteer to add
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424652#comment-17424652
]
Aitozi edited comment on FLINK-24455 at 10/6/21, 3:40 AM:
--
Finally, It turns
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424652#comment-17424652
]
Aitozi commented on FLINK-24455:
Finally, It turns out that it's my fault lead to this (I change the
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24455:
---
Attachment: image-2021-10-06-02-26-25-670.png
> Flink runtime test can't work with
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424643#comment-17424643
]
Aitozi commented on FLINK-24455:
BTW, the case fails here
!image-2021-10-06-02-26-25-670.png!
> Flink
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424642#comment-17424642
]
Aitozi commented on FLINK-24455:
More information about local debug the two case:
1. _run 'mvn package
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24455:
---
Attachment: screenshot-1.png
> Flink runtime test can't work with FallbackAkkaRpcSystemLoader
>
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424565#comment-17424565
]
Aitozi commented on FLINK-24455:
If I execute the {{mvn package -pl
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424563#comment-17424563
]
Aitozi commented on FLINK-24455:
>From the error msg, it seems caused by classloader problem.
> Flink
[
https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24455:
---
Summary: Flink runtime test can't work with FallbackAkkaRpcSystemLoader
(was: FallbackAkkaRpcSystemLoader
Aitozi created FLINK-24455:
--
Summary: FallbackAkkaRpcSystemLoader can't run through with
Key: FLINK-24455
URL: https://issues.apache.org/jira/browse/FLINK-24455
Project: Flink
Issue Type: Bug
Aitozi created FLINK-24451:
--
Summary: Replace the scattered objects with encapsulated
LeaderInformation in DefaultLeaderElectionService
Key: FLINK-24451
URL: https://issues.apache.org/jira/browse/FLINK-24451
[
https://issues.apache.org/jira/browse/FLINK-24437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423746#comment-17423746
]
Aitozi edited comment on FLINK-24437 at 10/4/21, 1:44 AM:
--
Thanks for creating
[
https://issues.apache.org/jira/browse/FLINK-24437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423746#comment-17423746
]
Aitozi commented on FLINK-24437:
Thanks for creating this ticket, I will fix this . Could assign this to
[
https://issues.apache.org/jira/browse/FLINK-24117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420468#comment-17420468
]
Aitozi commented on FLINK-24117:
Hi [~trohrmann], some other thoughts come to my mind that: we add an
[
https://issues.apache.org/jira/browse/FLINK-24167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410575#comment-17410575
]
Aitozi commented on FLINK-24167:
what do you think of this ? [~trohrm...@apache.org]
> Split
[
https://issues.apache.org/jira/browse/FLINK-24167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24167:
---
Description:
Currently, {{HeartbeatTarget}} is responsible for the {{receiveHeartbeat}} and
[
https://issues.apache.org/jira/browse/FLINK-24167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24167:
---
Description:
Currently, {{HeartbeatTarget}} is responsible for the {{receiveHeartbeat}} and
Aitozi created FLINK-24167:
--
Summary: Split HeartbeatTarget to HeartbeatReceiver and
HeartbeatSender
Key: FLINK-24167
URL: https://issues.apache.org/jira/browse/FLINK-24167
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-23415:
---
Comment: was deleted
(was: OK, closing this ticket)
> Shade kryo library to reduce class conflict
>
[
https://issues.apache.org/jira/browse/FLINK-23415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409003#comment-17409003
]
Aitozi commented on FLINK-23415:
OK, closing this ticket
> Shade kryo library to reduce class conflict
[
https://issues.apache.org/jira/browse/FLINK-24124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-24124.
--
Resolution: Duplicate
> Use explicit pool size to construct thread pool instead of
>
[
https://issues.apache.org/jira/browse/FLINK-24124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408998#comment-17408998
]
Aitozi commented on FLINK-24124:
Thanks for reminding me of that, close this one.
> Use explicit pool
[
https://issues.apache.org/jira/browse/FLINK-24117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408876#comment-17408876
]
Aitozi commented on FLINK-24117:
Yes, I will do this after the related issue done.
> Remove
[
https://issues.apache.org/jira/browse/FLINK-24124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-24124:
---
Description:
Same to this
Aitozi created FLINK-24124:
--
Summary: Use explicit pool size to construct thread pool instead
of Hardware.getNumberCPUCores()
Key: FLINK-24124
URL: https://issues.apache.org/jira/browse/FLINK-24124
Project:
501 - 600 of 803 matches
Mail list logo
