[
https://issues.apache.org/jira/browse/FLINK-35426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848801#comment-17848801
]
Zhu Zhu commented on FLINK-35426:
-
Good point! [~xiasun]
The task is assigned to you. Feel free to open
[
https://issues.apache.org/jira/browse/FLINK-35426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-35426:
---
Assignee: xingbe
> Change the distribution of DynamicFilteringDataCollector to Broadcast
>
[
https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848126#comment-17848126
]
Zhu Zhu commented on FLINK-35384:
-
Enabling metrics for partitioners makes sense and the proposed
Zhu Zhu created FLINK-35399:
---
Summary: Add documents for batch job master failure recovery
Key: FLINK-35399
URL: https://issues.apache.org/jira/browse/FLINK-35399
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33983.
---
Fix Version/s: 1.20.0
Resolution: Done
master: c7c1d78752836b96591e31422c65b85eca38bd50
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-33986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-33986:
Component/s: Runtime / Coordination
> Extend shuffleMaster to support batch snapshot.
>
[
https://issues.apache.org/jira/browse/FLINK-33986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33986.
---
Fix Version/s: 1.20.0
Resolution: Done
65d31e26534836909f6b8139c6bd6cd45b91bba4
> Extend
[
https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846177#comment-17846177
]
Zhu Zhu commented on FLINK-35293:
-
The change is merged. Could you add release notes for it and close
[
https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846137#comment-17846137
]
Zhu Zhu commented on FLINK-35293:
-
master: ddb5a5355f9aca3d223f1fff6581d83dd317c2de
> FLIP-445: Support
[
https://issues.apache.org/jira/browse/FLINK-34661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34661.
---
Fix Version/s: 1.20.0
Resolution: Done
4e6b42046adbe2f337460d2e50f1fee12cff21a5
> TaskExecutor
[
https://issues.apache.org/jira/browse/FLINK-35270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-35270.
---
Resolution: Fixed
547e4b53ebe36c39066adcf3a98123a1f7890c15
> Enrich information in logs, making it easier
[
https://issues.apache.org/jira/browse/FLINK-35270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-35270:
---
Assignee: Haifei Chen
> Enrich information in logs, making it easier for debugging
>
[
https://issues.apache.org/jira/browse/FLINK-35270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-35270:
Component/s: API / Core
> Enrich information in logs, making it easier for debugging
>
[
https://issues.apache.org/jira/browse/FLINK-35270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-35270:
Labels: pull-request-available starter (was: pull-request-available)
> Enrich information in logs,
[
https://issues.apache.org/jira/browse/FLINK-35270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-35270:
Fix Version/s: 1.20.0
> Enrich information in logs, making it easier for debugging
>
[
https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-35293:
---
Assignee: xingbe
> FLIP-445: Support dynamic parallelism inference for HiveSource
>
[
https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835577#comment-17835577
]
Zhu Zhu commented on FLINK-35009:
-
[~martijnvisser] Thanks for monitoring the kafka connector builds and
[
https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834799#comment-17834799
]
Zhu Zhu commented on FLINK-35009:
-
Thanks for looking into the issue. [~Weijie Guo]
So it is just a test
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834798#comment-17834798
]
Zhu Zhu edited comment on FLINK-32513 at 4/8/24 6:27 AM:
-
{{Transformation}} is
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834798#comment-17834798
]
Zhu Zhu commented on FLINK-32513:
-
{{Transformation}} is not a public interface, it is an @Internal
[
https://issues.apache.org/jira/browse/FLINK-34661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34661:
---
Assignee: Junrui Li
> TaskExecutor supports retain partitions after JM crashed.
>
[
https://issues.apache.org/jira/browse/FLINK-33983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-33983:
---
Assignee: Junrui Li
> Introduce JobEvent and JobEventStore for Batch Job Recovery
>
[
https://issues.apache.org/jira/browse/FLINK-33986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-33986:
---
Assignee: Junrui Li
> Extend shuffleMaster to support batch snapshot.
>
[
https://issues.apache.org/jira/browse/FLINK-33984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33984.
---
Fix Version/s: 1.20.0
Resolution: Done
master:
38255652406becbfbcb7cbec557aa5ba9a1ebbb3
[
https://issues.apache.org/jira/browse/FLINK-34945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34945:
---
Assignee: Junrui Li
> Support recover shuffle descriptor and partition metrics from tiered storage
[
https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33985.
---
Fix Version/s: 1.20.0
Resolution: Done
master: a44709662956b306fe686623d00358a6b076f637
> Support
[
https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-33985:
Component/s: Runtime / Coordination
> Support obtain all partitions existing in cluster through
[
https://issues.apache.org/jira/browse/FLINK-33982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33982.
---
Fix Version/s: 1.20.0
Resolution: Done
master: ec1311c8eb805f91b3b8d7d7cbe192e8cad05a76
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-34565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831336#comment-17831336
]
Zhu Zhu commented on FLINK-34565:
-
IIUC, the requirement is to ship more user files, which may be needed
[
https://issues.apache.org/jira/browse/FLINK-33984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-33984:
---
Assignee: Junrui Li
> Introduce SupportsBatchSnapshot for operator coordinator
>
[
https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-33985:
---
Assignee: Junrui Li
> Support obtain all partitions existing in cluster through ShuffleMaster.
>
[
https://issues.apache.org/jira/browse/FLINK-33982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-33982:
---
Assignee: Junrui Li
> Introduce new config options for Batch Job Recovery
>
[
https://issues.apache.org/jira/browse/FLINK-33892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-33892:
Summary: FLIP-383: Support Job Recovery from JobMaster Failures for Batch
Jobs (was: FLIP-383: Support
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-32513.
---
Fix Version/s: 1.18.2
1.20.0
1.19.1
Resolution: Fixed
master:
[
https://issues.apache.org/jira/browse/FLINK-34731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34731.
---
Resolution: Done
master: cf0d75c4bb324825a057dc72243bb6a2046f8479
> Remove SpeculativeScheduler and
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-32513:
---
Assignee: Jeyhun Karimov
> Job in BATCH mode with a significant number of transformations freezes
[
https://issues.apache.org/jira/browse/FLINK-34725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34725.
---
Resolution: Fixed
master: 3f4a80989fe7243983926f09fac2283f6fa63693
release-1.19:
[
https://issues.apache.org/jira/browse/FLINK-34731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34731:
---
Assignee: Junrui Li
> Remove SpeculativeScheduler and incorporate its features into
>
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34105.
---
Fix Version/s: 1.19.0
Assignee: dizhou cao (was: Yangze Guo)
Resolution: Fixed
1.19:
[
https://issues.apache.org/jira/browse/FLINK-34377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820553#comment-17820553
]
Zhu Zhu commented on FLINK-34377:
-
Thanks for volunteering! [~xiasun]
I have assigned you the ticket.
>
[
https://issues.apache.org/jira/browse/FLINK-34377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34377:
---
Assignee: xingbe
> Release Testing: Verify FLINK-33297 Support standard YAML for FLINK
>
[
https://issues.apache.org/jira/browse/FLINK-34383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34383.
---
Resolution: Won't Fix
> Modify the comment with incorrect syntax
>
[
https://issues.apache.org/jira/browse/FLINK-34356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34356:
---
Assignee: Junrui Li
> Release Testing: Verify FLINK-33768 Support dynamic source parallelism
>
[
https://issues.apache.org/jira/browse/FLINK-34356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819142#comment-17819142
]
Zhu Zhu commented on FLINK-34356:
-
Assigned. Thanks for volunteering! [~JunRuiLi]
> Release Testing:
[
https://issues.apache.org/jira/browse/FLINK-33241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33241.
---
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed via 8fe005cf1325b7477d7e1808a46bd80798165029
> Align
[
https://issues.apache.org/jira/browse/FLINK-34247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34247.
---
Assignee: Junrui Li
Resolution: Done
master/release-1.19:
5b61baadd02ccdfa702834e2e63aeb8d1d9e1250
[
https://issues.apache.org/jira/browse/FLINK-33768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reopened FLINK-33768:
-
> FLIP-379: Support dynamic source parallelism inference for batch jobs
>
[
https://issues.apache.org/jira/browse/FLINK-34145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34145:
Parent: FLINK-33768
Issue Type: Sub-task (was: Improvement)
> File source connector support
[
https://issues.apache.org/jira/browse/FLINK-34144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34144:
Parent: FLINK-33768
Issue Type: Sub-task (was: Improvement)
> Update the documentation and
[
https://issues.apache.org/jira/browse/FLINK-34143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34143:
Parent: FLINK-33768
Issue Type: Sub-task (was: Improvement)
> Modify the effective strategy of
[
https://issues.apache.org/jira/browse/FLINK-33768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-33768:
Summary: FLIP-379: Support dynamic source parallelism inference for batch
jobs (was: [FLIP-379] Support
[
https://issues.apache.org/jira/browse/FLINK-33768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-33768:
Summary: [FLIP-379] Support dynamic source parallelism inference for batch
jobs (was: Support dynamic
[
https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813095#comment-17813095
]
Zhu Zhu commented on FLINK-34132:
-
We should also migrate the existing batch examples from DataSet to
[
https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34132:
Component/s: Documentation
> Batch WordCount job fails when run with AdaptiveBatch scheduler
>
[
https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34132.
---
Fix Version/s: 1.19.0
Assignee: Junrui Li
Resolution: Fixed
The documentation is updated
[
https://issues.apache.org/jira/browse/FLINK-34126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34126.
---
Fix Version/s: 1.19.0
Assignee: Junrui Li
Resolution: Fixed
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34206.
---
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed via b737b71859672e8020881ce2abf998735ee98abb
>
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812123#comment-17812123
]
Zhu Zhu commented on FLINK-34105:
-
Thanks for the updates! [~guoyangze]
> Akka timeout happens in
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34257.
---
Resolution: Fixed
Fixed via 081051a2cacaddf6dfe613da061f15f28a015a41
> Update Flink YAML Parser to
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34257:
Affects Version/s: 1.19.0
> Update Flink YAML Parser to Support YAML 1.2 Specification
>
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811867#comment-17811867
]
Zhu Zhu commented on FLINK-34105:
-
Hi [~lsdy], what's the status of the fix?
> Akka timeout happens in
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34257:
---
Assignee: Junrui Li
> Update Flink YAML Parser to Support YAML 1.2 Specification
>
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34257:
Component/s: Runtime / Configuration
> Update Flink YAML Parser to Support YAML 1.2 Specification
>
[
https://issues.apache.org/jira/browse/FLINK-34245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34245.
---
Fix Version/s: 1.19.0
Assignee: Junrui Li
Resolution: Fixed
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811633#comment-17811633
]
Zhu Zhu commented on FLINK-34200:
-
[
https://issues.apache.org/jira/browse/FLINK-34145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34145.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
11631cb59568df60d40933fb13c8433062ed9290
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811231#comment-17811231
]
Zhu Zhu commented on FLINK-34206:
-
Disabled {{CacheITCase.testRetryOnCorruptedClusterDataset}}
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34206:
---
Assignee: xingbe
> CacheITCase.testRetryOnCorruptedClusterDataset(Path) failed
>
[
https://issues.apache.org/jira/browse/FLINK-34223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34223.
---
Assignee: Junrui Li
Resolution: Done
master/release-1.19:
8fceb101e7e45f3fdc9357019757230bd8c16aa7
>
[
https://issues.apache.org/jira/browse/FLINK-34232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34232.
---
Assignee: Junrui Li
Resolution: Fixed
Fixed in master/release-1.19:
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811084#comment-17811084
]
Zhu Zhu commented on FLINK-34206:
-
We will take a look.
>
[
https://issues.apache.org/jira/browse/FLINK-33577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33577.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
9721ce835f5a7f28f2ad187346e009633307097b
[
https://issues.apache.org/jira/browse/FLINK-34144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34144.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
78e31f0dcc4da65d88e18560f3374a47cc0a7c9b
[
https://issues.apache.org/jira/browse/FLINK-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810856#comment-17810856
]
Zhu Zhu commented on FLINK-34229:
-
[~FrankZou] the query plan can be different between q35 of
[
https://issues.apache.org/jira/browse/FLINK-34205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34205.
---
Fix Version/s: 1.19.0
Resolution: Done
dev-master:
44f058287cc956a620b12b6f8ed214e44dc3db77
>
[
https://issues.apache.org/jira/browse/FLINK-34205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34205:
---
Assignee: Junrui Li
> Update flink-docker's Dockerfile and docker-entrypoint.sh to use
>
[
https://issues.apache.org/jira/browse/FLINK-34143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34143.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
97caa3c251e416640a6f54ea103912839c346f70
[
https://issues.apache.org/jira/browse/FLINK-34144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34144:
---
Assignee: xingbe
> Update the documentation and configuration description about dynamic source
>
[
https://issues.apache.org/jira/browse/FLINK-34145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34145:
---
Assignee: xingbe
> File source connector support dynamic source parallelism inference in batch
>
[
https://issues.apache.org/jira/browse/FLINK-33721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33721.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
1f7622d4d23bfcb76f466469ec36585054864f04
[
https://issues.apache.org/jira/browse/FLINK-33768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33768.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
c3c836216eaaaf24c1add3b490c8f425fda01d7c
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808457#comment-17808457
]
Zhu Zhu commented on FLINK-34105:
-
[~lsdy] Sounds good to me. Feel free to open a PR for it.
> Akka
[
https://issues.apache.org/jira/browse/FLINK-34144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808424#comment-17808424
]
Zhu Zhu commented on FLINK-34144:
-
[~xiasun] Assigned. Feel free to open a PR for it.
> Update the
[
https://issues.apache.org/jira/browse/FLINK-34143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808423#comment-17808423
]
Zhu Zhu commented on FLINK-34143:
-
[~xiasun]Assigned. Feel free to open a PR for it.
> Modify the
[
https://issues.apache.org/jira/browse/FLINK-34143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808423#comment-17808423
]
Zhu Zhu edited comment on FLINK-34143 at 1/19/24 1:54 AM:
--
[~xiasun] Assigned.
[
https://issues.apache.org/jira/browse/FLINK-34143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34143:
---
Assignee: xingbe
> Modify the effective strategy of
>
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807554#comment-17807554
]
Zhu Zhu commented on FLINK-34105:
-
I think it is a regression because existing jobs can become unstable.
[
https://issues.apache.org/jira/browse/FLINK-34116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34116.
---
Fix Version/s: 1.19.0
Assignee: Junrui Li
Resolution: Fixed
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807505#comment-17807505
]
Zhu Zhu commented on FLINK-34105:
-
We tried increasing {{pekko.ask.timeout}} to {{1min}}(from the
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807203#comment-17807203
]
Zhu Zhu commented on FLINK-34105:
-
[~guoyangze] pekko.framesize is not configured and the default value
[
https://issues.apache.org/jira/browse/FLINK-33980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33980.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
06b37089f0c1cdf70ca21970a40d15c3eaba07ed
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34105:
Priority: Critical (was: Major)
> Akka timeout happens in TPC-DS benchmarks
>
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807052#comment-17807052
]
Zhu Zhu edited comment on FLINK-34105 at 1/16/24 6:06 AM:
--
[~lsdy] [~guoyangze]
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34105:
Description:
We noticed akka timeout happens in 10TB TPC-DS benchmarks in 1.19. The problem
did not
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34105:
Description:
We noticed akka timeout happens in 10TB TPC-DS benchmarks in 1.19. The problem
did not
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34105:
Description:
We noticed akka timeout happens in 10TB TPC-DS benchmarks in 1.19. The problem
did not
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807052#comment-17807052
]
Zhu Zhu commented on FLINK-34105:
-
[~lsdy] [~guoyangze] would you help to take a look?
> Akka timeout
Zhu Zhu created FLINK-34105:
---
Summary: Akka timeout happens in TPC-DS benchmarks
Key: FLINK-34105
URL: https://issues.apache.org/jira/browse/FLINK-34105
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-33576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33576.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
[
https://issues.apache.org/jira/browse/FLINK-33968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33968.
---
Fix Version/s: 1.19.0
Resolution: Done
master/1.19: b25dfaee80727d6662a5fd445fe51cc139a8b9eb
>
1 - 100 of 2391 matches
Mail list logo