[
https://issues.apache.org/jira/browse/FLINK-34953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833036#comment-17833036
]
Matthias Pohl commented on FLINK-34953:
---
Hi [~gongzhongqiang], it sounds like we r
flinkbot commented on PR #24603:
URL: https://github.com/apache/flink/pull/24603#issuecomment-2031207613
## CI report:
* ef216a4451c0d672ef0aa1920b8c17f78542615b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
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 ob
[
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 ShuffleMas
zhuzhurk closed pull request #24553: [FLINK-33985][runtime] Support obtain all
partitions existing in cluster through ShuffleMaster.
URL: https://github.com/apache/flink/pull/24553
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
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
zhuzhurk closed pull request #24026: [FLINK-33982][core] Introduce new config
options for Batch Job Recovery
URL: https://github.com/apache/flink/pull/24026
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
[
https://issues.apache.org/jira/browse/FLINK-34986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-34986:
Summary: Basic framework of async execution for state (was: Basic
framework for async execution o
Zakelly Lan created FLINK-34986:
---
Summary: Basic framework for async execution of state
Key: FLINK-34986
URL: https://issues.apache.org/jira/browse/FLINK-34986
Project: Flink
Issue Type: Sub-ta
[
https://issues.apache.org/jira/browse/FLINK-21943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833008#comment-17833008
]
Weijie Guo commented on FLINK-21943:
In fact, for this kind of issue there is no nee
[
https://issues.apache.org/jira/browse/FLINK-21943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-21943:
---
Summary: Redundant checkNotNull in Transformation#setResources (was:
Redundant checkNotNull)
> Red
reswqa commented on code in PR #24602:
URL: https://github.com/apache/flink/pull/24602#discussion_r1547097051
##
flink-core/src/test/java/org/apache/flink/api/dag/TransformationTest.java:
##
@@ -89,11 +91,12 @@ void testDeclareManagedMemoryUseCase() {
transformation.dec
[
https://issues.apache.org/jira/browse/FLINK-21943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-21943:
---
Affects Version/s: 1.20.0
(was: 1.12.2)
> Redundant checkNotNull
> --
[
https://issues.apache.org/jira/browse/FLINK-34967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-34967.
Resolution: Fixed
> Update Website copyright footer to 2024
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-34573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833007#comment-17833007
]
Weijie Guo commented on FLINK-34573:
1.14.3 has long been out of official support by
[
https://issues.apache.org/jira/browse/FLINK-34968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-34968.
--
Assignee: Yu Chen
Resolution: Fixed
merged in asf-site: 3cda9946df98f0d2abda396ac87f7bc192ec70e0
[
https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833005#comment-17833005
]
Weijie Guo commented on FLINK-34727:
This part of code shouldn't have changed in a l
Myasuka merged PR #730:
URL: https://github.com/apache/flink-web/pull/730
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apach
[
https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833005#comment-17833005
]
Weijie Guo edited comment on FLINK-34727 at 4/2/24 3:26 AM:
[
https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34727:
---
Priority: Critical (was: Blocker)
> RestClusterClient.requestJobResult throw ConnectionClosedExcept
[
https://issues.apache.org/jira/browse/FLINK-34951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34951:
---
Affects Version/s: 1.20.0
> Flink-ci-mirror stopped running for commits after 22nd of March
> --
[
https://issues.apache.org/jira/browse/FLINK-34951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34951:
---
Fix Version/s: 1.20.0
> Flink-ci-mirror stopped running for commits after 22nd of March
> --
[
https://issues.apache.org/jira/browse/FLINK-34951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34951.
--
Assignee: Jing Ge
Resolution: Fixed
> Flink-ci-mirror stopped running for commits after 22nd of
[
https://issues.apache.org/jira/browse/FLINK-34951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833004#comment-17833004
]
Weijie Guo commented on FLINK-34951:
I have reached out [~jingge]. Thanks to him for
[
https://issues.apache.org/jira/browse/FLINK-34970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34970:
---
Priority: Minor (was: Major)
> Translate architecture documents into Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-34971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34971:
---
Affects Version/s: 1.20.0
> Add the function of History Server cleaning job archives regularly
> ---
[
https://issues.apache.org/jira/browse/FLINK-34971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34971:
---
Component/s: Runtime / Coordination
> Add the function of History Server cleaning job archives regul
[
https://issues.apache.org/jira/browse/FLINK-34971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833000#comment-17833000
]
Weijie Guo commented on FLINK-34971:
The feature request should never be a blocker i
[
https://issues.apache.org/jira/browse/FLINK-34971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34971:
---
Priority: Minor (was: Blocker)
> Add the function of History Server cleaning job archives regularly
[
https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34379:
---
Component/s: Table SQL / Planner
> table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryErro
[
https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832999#comment-17832999
]
Weijie Guo commented on FLINK-34379:
I don't think this is a blocker, downgrade it t
[
https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34379:
---
Priority: Critical (was: Blocker)
> table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryEr
flinkbot commented on PR #24602:
URL: https://github.com/apache/flink/pull/24602#issuecomment-2030962818
## CI report:
* 42f79866ad72411a12ebbb4888139175dc4cc200 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuchen-ecnu commented on PR #730:
URL: https://github.com/apache/flink-web/pull/730#issuecomment-2030962244
> Thanks for creating this PR, please rebuild the website to resolve the
conflicts.
Hi @Myasuka , thanks for the review. I have rebuilt the website, and there
are no conflicts
[
https://issues.apache.org/jira/browse/FLINK-21943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21943:
---
Labels: pull-request-available (was: )
> Redundant checkNotNull
> --
>
[
https://issues.apache.org/jira/browse/FLINK-34978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-34978.
--
Resolution: Fixed
merged f38d8ca4 into master.
> Introduce Asynchronous State APIs
>
plugatarev opened a new pull request, #24602:
URL: https://github.com/apache/flink/pull/24602
## What is the purpose of the change
*Remove redundant checkNotNull in setResources*
## Brief change log
- *Remove redundant checkNotNull in setResources*
-
masteryhx closed pull request #24595: [FLINK-34978][State] Introduce
Asynchronous State APIs
URL: https://github.com/apache/flink/pull/24595
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the speci
spoon-lz commented on PR #24461:
URL: https://github.com/apache/flink/pull/24461#issuecomment-2030958637
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
boring-cyborg[bot] commented on PR #23:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/23#issuecomment-2030956597
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This
Dian Fu created FLINK-34985:
---
Summary: It doesn't support to access fields by name for map
function in thread mode
Key: FLINK-34985
URL: https://issues.apache.org/jira/browse/FLINK-34985
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832991#comment-17832991
]
Hangxiang Yu commented on FLINK-34975:
--
Hi, [~kkrugler].
Thanks a lot for sharing
[
https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-34975:
-
Summary: FLIP-427: ForSt - Disaggregated State Store (was: FLIP-427: ForSt
- Disaggregated stat
flinkbot commented on PR #24601:
URL: https://github.com/apache/flink/pull/24601#issuecomment-2030867410
## CI report:
* 877e048205c338daa8abf37c4a950e8a854f8ade UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
slfan1989 opened a new pull request, #24601:
URL: https://github.com/apache/flink/pull/24601
## What is the purpose of the change
ContainerId.getId() It is a deprecated method. Use getContainerId instead.
org.apache.hadoop.yarn.api.records#getContainerId
```
slfan1989 commented on PR #24580:
URL: https://github.com/apache/flink/pull/24580#issuecomment-2030824227
> LGTM, merging tomorrow if there are no objections.
Thank you very much for the review!
--
This is an automated message from the Apache Git Service.
To respond to the message,
jeyhunkarimov commented on code in PR #24600:
URL: https://github.com/apache/flink/pull/24600#discussion_r1546924713
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java:
##
@@ -115,7 +117,7 @@ private static cla
flinkbot commented on PR #24600:
URL: https://github.com/apache/flink/pull/24600#issuecomment-2030689199
## CI report:
* 06e59ca12ef6650b79e82fb513c47e53d90f052e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34379:
---
Labels: pull-request-available (was: )
> table.optimizer.dynamic-filtering.enabled lead to
jeyhunkarimov opened a new pull request, #24600:
URL: https://github.com/apache/flink/pull/24600
## What is the purpose of the change
Fix OutOfMemoryError with large queries and when
`table.optimizer.dynamic-filtering.enabled`.
## Brief change log
- Fix the OOM cause i
flinkbot commented on PR #24599:
URL: https://github.com/apache/flink/pull/24599#issuecomment-2030368469
## CI report:
* 0dfb5968d5a969501f7ea87d2ebe0b7613183520 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34338:
---
Labels: pull-request-available (was: )
> An exception is thrown when some named params chan
jeyhunkarimov opened a new pull request, #24599:
URL: https://github.com/apache/flink/pull/24599
## What is the purpose of the change
Exception message is not explanatory when named params are in wrong order.
This PR adds proper exceptions.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832917#comment-17832917
]
Kenneth William Krugler commented on FLINK-34975:
-
I'd previously explor
iemre commented on code in PR #24598:
URL: https://github.com/apache/flink/pull/24598#discussion_r1546394926
##
flink-runtime-web/web-dashboard/src/app/components/dagre/components/node/node.component.ts:
##
@@ -165,7 +167,7 @@ export class NodeComponent {
if (value === unde
[
https://issues.apache.org/jira/browse/FLINK-32673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832904#comment-17832904
]
Claire McCarthy commented on FLINK-32673:
-
That sounds good to me. Thanks, David
[
https://issues.apache.org/jira/browse/FLINK-34620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832890#comment-17832890
]
Artem commented on FLINK-34620:
---
[~libenchao] Hello!
Could you take a look on this small
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-7151.
-
Resolution: Fixed
Already implemented as discussed in
[FLIP-79.|https://cwiki.apache.org/conflue
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-7151:
-
Assignee: Zhenqiu Huang
> Support function DDL
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-7151:
--
Priority: Major (was: Not a Priority)
> Support function DDL
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-7151:
--
Fix Version/s: 1.10.0
> Support function DDL
>
>
> Key: FL
slfan1989 commented on PR #24580:
URL: https://github.com/apache/flink/pull/24580#issuecomment-2029901221
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
iemre commented on code in PR #24598:
URL: https://github.com/apache/flink/pull/24598#discussion_r1546394926
##
flink-runtime-web/web-dashboard/src/app/components/dagre/components/node/node.component.ts:
##
@@ -165,7 +167,7 @@ export class NodeComponent {
if (value === unde
flinkbot commented on PR #24598:
URL: https://github.com/apache/flink/pull/24598#issuecomment-2029848257
## CI report:
* 16a5ed34564aee79e81d5c0090cd32d2f1dea961 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34025:
---
Labels: dashboard pull-request-available (was: dashboard)
> Show data skew score on Flink D
iemre opened a new pull request, #24598:
URL: https://github.com/apache/flink/pull/24598
## What is the purpose of the change
This PR implements the discussed and accepted FLIP
[FLIP-418](https://cwiki.apache.org/confluence/display/FLINK/FLIP-418%3A+Show+data+skew+score+on+Flink+Dashb
slfan1989 commented on PR #24580:
URL: https://github.com/apache/flink/pull/24580#issuecomment-2029665321
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
reswqa merged PR #24596:
URL: https://github.com/apache/flink/pull/24596
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-34984:
-
Description:
The past decade has witnessed a dramatic shift in Flink's deployment mode,
workload patter
[
https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-34984:
-
Description:
The past decade has witnessed a dramatic shift in Flink's deployment mode,
workload patter
[
https://issues.apache.org/jira/browse/FLINK-34973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-34973:
Description:
This is a sub-FLIP for the disaggregated state management and its related work,
plea
[
https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-34984:
-
Description:
The past decade has witnessed a dramatic shift in Flink's deployment mode,
workload patter
[
https://issues.apache.org/jira/browse/FLINK-34973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-34973:
Summary: FLIP-425: Asynchronous Execution Model (was: FLIP-423:
Disaggregated State Storage and M
[
https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-34984:
Summary: FLIP-423: Disaggregated State Storage and Management (Umbrella
FLIP) (was: Disaggregated
[
https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-34984:
-
Description: The past decade has witnessed a dramatic shift in Flink's
deployment mode, workload pattern
[
https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-34984:
Description:
The past decade has witnessed a dramatic shift in Flink's deployment mode,
workload
Yuan Mei created FLINK-34984:
Summary: Disaggregated State Storage and Management (Umbrella FLIP)
Key: FLINK-34984
URL: https://issues.apache.org/jira/browse/FLINK-34984
Project: Flink
Issue Type
loserwang1024 commented on PR #3134:
URL: https://github.com/apache/flink-cdc/pull/3134#issuecomment-2029591998
For example: table A, B, C are finished, and each table includes two
snapshot infos.
1. Before stop the job, totalFinishedSplitSize of enumerator and reader is
both 6.
2.
slfan1989 commented on PR #24580:
URL: https://github.com/apache/flink/pull/24580#issuecomment-2029571599
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
flinkbot commented on PR #24597:
URL: https://github.com/apache/flink/pull/24597#issuecomment-2029535566
## CI report:
* c73815cd4433fefc45438636c088a6a9ccb58ebb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34979:
---
Labels: pull-request-available (was: )
> Implement State Future and related utilities
> ---
Zakelly opened a new pull request, #24597:
URL: https://github.com/apache/flink/pull/24597
## What is the purpose of the change
This PR implement the basic version of StateFuture and related utilities.
**Please ignore** the classes under `org.apache.flink.api.common.state.v2`,
masteryhx commented on PR #24595:
URL: https://github.com/apache/flink/pull/24595#issuecomment-2029526481
> @masteryhx Thanks for your suggestion! I modified accordingly, PTAL.
Thanks!
>
> By the way, the CI failure is caused by #24596
Thanks for the update. Overall LGTM.
Le
[
https://issues.apache.org/jira/browse/FLINK-30088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832804#comment-17832804
]
Roman Boyko commented on FLINK-30088:
-
I've updated the PR ([https://github.com/apac
[
https://issues.apache.org/jira/browse/FLINK-30088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Boyko updated FLINK-30088:
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Excessive state upd
reswqa closed pull request #24591: Update kafka.md
URL: https://github.com/apache/flink/pull/24591
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issue
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-34979:
Description:
Implement the StateFuture.
In the very first version, we leverage the CompletableFut
Gianzie closed pull request #23902: Fix abnormal prompt information: When
sorting in non-time attribute f…
URL: https://github.com/apache/flink/pull/23902
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to g
Zakelly commented on PR #24595:
URL: https://github.com/apache/flink/pull/24595#issuecomment-2029449911
@masteryhx Thanks for your suggestion! I modified accordingly, PTAL. Thanks!
By the way, the CI failure is caused by #24596
--
This is an automated message from the Apache Git S
slfan1989 commented on PR #24580:
URL: https://github.com/apache/flink/pull/24580#issuecomment-2029447145
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-34946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-34946.
---
Resolution: Fixed
> Flink Website Menu Adjustment
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-34946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832776#comment-17832776
]
Qingsheng Ren commented on FLINK-34946:
---
flink-web asf-site: 9d0761c266d29ae81efc9
PatrickRen merged PR #729:
URL: https://github.com/apache/flink-web/pull/729
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.ap
Zakelly commented on code in PR #24595:
URL: https://github.com/apache/flink/pull/24595#discussion_r1546115491
##
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/State.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
masteryhx commented on code in PR #24595:
URL: https://github.com/apache/flink/pull/24595#discussion_r1546073433
##
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/MapState.java:
##
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
yunfan created FLINK-34983:
--
Summary: Hive param sink.partition-commit.policy.kind default
value is not work in stream mode
Key: FLINK-34983
URL: https://issues.apache.org/jira/browse/FLINK-34983
Project: Fl
reswqa commented on PR #24596:
URL: https://github.com/apache/flink/pull/24596#issuecomment-2029355247
Emm, `TestingTransformation` also have the same problem. 😞
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Jinzhong Li created FLINK-34982:
---
Summary: FLIP-428: Fault Tolerance/Rescale Integration for
Disaggregated State
Key: FLINK-34982
URL: https://issues.apache.org/jira/browse/FLINK-34982
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832762#comment-17832762
]
xiaogang zhou commented on FLINK-34976:
---
[~yunta] Ok, Thanks for clarification
>
[
https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou closed FLINK-34976.
-
Resolution: Invalid
> LD_PRELOAD environment may not be effective after su to flink user
> -
1 - 100 of 103 matches
Mail list logo
