XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308291020
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java:
##
@@ -152,9 +176,11 @@ private CoordinationRe
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308278198
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java:
##
@@ -83,7 +104,10 @@ public void start() thr
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308288979
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinatorTest.java:
##
@@ -173,72 +174,192 @@ private static v
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308287200
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinatorTest.java:
##
@@ -105,54 +102,147 @@ void testCloseAf
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308286524
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinatorTest.java:
##
@@ -105,54 +102,147 @@ void testCloseAf
[
https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759841#comment-17759841
]
Yangze Guo commented on FLINK-32488:
I reassign it to [~xiangyu0xf] since there is n
[
https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-32488:
--
Assignee: xiangyu feng
> Introduce configuration to control ExecutionGraph cache in REST API
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308284339
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinatorTest.java:
##
@@ -105,54 +102,147 @@ void testCloseAf
luoyuxia closed pull request #22824: Flink 32352
URL: https://github.com/apache/flink/pull/22824
--
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-
luoyuxia closed pull request #22885: Flink 31575 hive 3
URL: https://github.com/apache/flink/pull/22885
--
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:
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308281432
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinatorTest.java:
##
@@ -105,54 +102,147 @@ void testCloseAf
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308280794
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinatorTest.java:
##
@@ -105,54 +102,147 @@ void testCloseAf
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308279128
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java:
##
@@ -152,9 +176,11 @@ private CoordinationRe
[
https://issues.apache.org/jira/browse/FLINK-32955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759840#comment-17759840
]
Yun Tang commented on FLINK-32955:
--
+1 for this improvement, especially for setting the
[
https://issues.apache.org/jira/browse/FLINK-32955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-32955:
-
Priority: Major (was: Minor)
> Support state compatibility between enabling TTL and disabling TTL
> ---
XComp commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1308278198
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java:
##
@@ -83,7 +104,10 @@ public void start() thr
flinkbot commented on PR #23317:
URL: https://github.com/apache/flink/pull/23317#issuecomment-1696850102
## CI report:
* dff6f77de6706edc4dd5e246d118f51d93f2394d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-32749:
-
Assignee: Fang Yong
> Sql gateway supports default catalog loaded by CatalogStore
> ---
[
https://issues.apache.org/jira/browse/FLINK-32749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32749:
---
Labels: pull-request-available (was: )
> Sql gateway supports default catalog loaded by Cat
FangYongs opened a new pull request, #23317:
URL: https://github.com/apache/flink/pull/23317
## What is the purpose of the change
This PR aims to support default catalog which is loaded by catalog store in
sql-gateway
## Brief change log
- Get default catalog from catalog
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570
]
Yang Wang edited comment on FLINK-32678 at 8/29/23 6:13 AM:
[
https://issues.apache.org/jira/browse/FLINK-32805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-32805.
---
Resolution: Done
> Release Testing: Verify Support Java 17 (LTS)
>
JunRuiLee commented on PR #23181:
URL: https://github.com/apache/flink/pull/23181#issuecomment-1696796786
@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-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570
]
Yang Wang edited comment on FLINK-32678 at 8/29/23 5:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570
]
Yang Wang edited comment on FLINK-32678 at 8/29/23 5:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570
]
Yang Wang edited comment on FLINK-32678 at 8/29/23 5:15 AM:
gyfora commented on code in PR #648:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/648#discussion_r1308206545
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java:
##
@@ -185,6 +186,9 @@ public st
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-32678:
--
Attachment: (was: qos-configmap-get-115.png)
> Release Testing: Stress-Test to cover multiple low-
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-32678:
--
Attachment: (was: qos-configmap-put-115.png)
> Release Testing: Stress-Test to cover multiple low-
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-32678:
--
Attachment: qps-configmap-get-118.png
qps-configmap-get-115.png
qps-con
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-32678:
--
Attachment: (was: qos-configmap-patch-118.png)
> Release Testing: Stress-Test to cover multiple lo
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-32678:
--
Attachment: (was: qos-configmap-get-118.png)
> Release Testing: Stress-Test to cover multiple low-
lsyldliu commented on code in PR #23282:
URL: https://github.com/apache/flink/pull/23282#discussion_r1308172368
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/DynamicFilteringDependencyProcessor.java:
##
@@ -52,50 +55,91
WencongLiu closed pull request #23314: Test
URL: https://github.com/apache/flink/pull/23314
--
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-unsub
1996fanrui commented on code in PR #23219:
URL: https://github.com/apache/flink/pull/23219#discussion_r1308166223
##
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java:
##
@@ -543,22 +546,62 @@ void testExplicitFileShipping() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-32824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-32824.
---
Resolution: Fixed
> Port Calcite's fix for the sql like operator
> -
[
https://issues.apache.org/jira/browse/FLINK-32824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759797#comment-17759797
]
lincoln lee commented on FLINK-32824:
-
fixed in release-1.18: e9566267639a33adfd6ced
lincoln-lil merged PR #23312:
URL: https://github.com/apache/flink/pull/23312
--
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.a
flinkbot commented on PR #23316:
URL: https://github.com/apache/flink/pull/23316#issuecomment-1696726227
## CI report:
* f282ba755b54d24ef35730755918ecc9b8e169a2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-18445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18445:
---
Labels: auto-deprioritized-major auto-deprioritized-minor
pull-request-available (was: auto
lincoln-lil opened a new pull request, #23316:
URL: https://github.com/apache/flink/pull/23316
## What is the purpose of the change
As the issue shows there's some chance for optimizing the lookup join when
do a left join (maybe full outer join as well in future) which has filter
conditi
flinkbot commented on PR #23315:
URL: https://github.com/apache/flink/pull/23315#issuecomment-1696717433
## CI report:
* b84a51e67193e892c87fb8458d028abc22d4f57f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jiangxin369 opened a new pull request, #23315:
URL: https://github.com/apache/flink/pull/23315
## What is the purpose of the change
Fix NullPointerException when executing TopSpeedWindowing example with
checkpointing enabled.
The bug happens when some vertices have rea
hackergin commented on code in PR #23307:
URL: https://github.com/apache/flink/pull/23307#discussion_r1308135813
##
docs/content/docs/dev/table/catalogs.md:
##
@@ -801,10 +806,9 @@ env.executeSql("CREATE TABLE ...").wait();
```
For sql-gateway, you can add the option `table.
[
https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759786#comment-17759786
]
Zhanghao Chen commented on FLINK-31650:
---
Hi [~JunRuiLi], we encountered the same p
[
https://issues.apache.org/jira/browse/FLINK-32984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu closed FLINK-32984.
-
Resolution: Duplicate
> Display the host port information on the suttasks page of SubtaskExecution
> ---
[
https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu updated FLINK-32980:
--
Release Note: (was: Resolved in master:
6dbb9b8d3fcfe88a85b22e2f177e8fea7585702e)
> Support env.jav
[
https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759785#comment-17759785
]
Weihua Hu commented on FLINK-32980:
---
Resolved in master: 6dbb9b8d3fcfe88a85b22e2f177e8
[
https://issues.apache.org/jira/browse/FLINK-32980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu resolved FLINK-32980.
---
Release Note: Resolved in master: 6dbb9b8d3fcfe88a85b22e2f177e8fea7585702e
Resolution: Fixed
>
huwh merged PR #23308:
URL: https://github.com/apache/flink/pull/23308
--
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.o
[
https://issues.apache.org/jira/browse/FLINK-32780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759578#comment-17759578
]
dalongliu edited comment on FLINK-32780 at 8/29/23 2:40 AM:
lincoln lee created FLINK-32986:
---
Summary: The new createTemporaryFunction has some regression of
type inference compare to the deprecated registerFunction
Key: FLINK-32986
URL: https://issues.apache.org/jira/browse
hackergin commented on PR #23109:
URL: https://github.com/apache/flink/pull/23109#issuecomment-1696677420
@luoyuxia Thanks for the review, sorry for the late update, PTAL when your
are free.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
fredia commented on PR #22890:
URL: https://github.com/apache/flink/pull/22890#issuecomment-1696673932
@Zakelly Thanks for the review, I moved the initialization of file merging
into `initializeBaseLocationsForCheckpoint()` to address some failing tests,
file merging will only take effect i
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759777#comment-17759777
]
Dian Fu commented on FLINK-32758:
-
[~deepyaman] Actually the tests have passed on the CI
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-32758:
Attachment: image-2023-08-29-10-19-37-977.png
> PyFlink bounds are overly restrictive and outdated
> -
fredia commented on code in PR #22890:
URL: https://github.com/apache/flink/pull/22890#discussion_r1308123867
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorFileMergingManager.java:
##
@@ -0,0 +1,163 @@
+/*
+ * Licensed to the Apache Software Foundatio
jiexray commented on code in PR #21410:
URL: https://github.com/apache/flink/pull/21410#discussion_r1308122484
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackendTest.java:
##
@@ -46,18 +46,17 @@
jiexray commented on PR #23305:
URL: https://github.com/apache/flink/pull/23305#issuecomment-1696665750
@masteryhx Thank you for the review. I have added a new test in
`ChangelogMapStateTest`. In the test, I try to assert the following:
```
state1.iterate().next() equals expected; // a
[
https://issues.apache.org/jira/browse/FLINK-32965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32965:
---
Labels: pull-request-available (was: )
> Remove the deprecated MutableObjectMode
>
1996fanrui merged PR #23303:
URL: https://github.com/apache/flink/pull/23303
--
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
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759774#comment-17759774
]
Dian Fu commented on FLINK-32758:
-
[~Sergey Nuyanzin] [~deepyaman] I have submitted a h
[
https://issues.apache.org/jira/browse/FLINK-32965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-32965.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> Remove the deprecated MutableObjectMode
> -
[
https://issues.apache.org/jira/browse/FLINK-32965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759773#comment-17759773
]
Rui Fan commented on FLINK-32965:
-
Merged via 3fa046ef7c461554b50d2d791dc4846cd8ff75b7
flinkbot commented on PR #23314:
URL: https://github.com/apache/flink/pull/23314#issuecomment-1696659499
## CI report:
* 4e7859ec86f75ec9187a89210460c0d3b9782ffc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
WencongLiu opened a new pull request, #23314:
URL: https://github.com/apache/flink/pull/23314
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
xintongsong commented on PR #23292:
URL: https://github.com/apache/flink/pull/23292#issuecomment-1696654555
@YesOrNo828, please take a look into the CI failures. The failures are all
from the Yarn deployment, which are likely related to the changes of this PR.
--
This is an automated mess
flinkbot commented on PR #23313:
URL: https://github.com/apache/flink/pull/23313#issuecomment-1696630993
## CI report:
* 5470431742bf63292142aaa7c96b4c894b3a7c82 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20767:
---
Labels: pull-request-available (was: )
> add nested field support for SupportsFilterPushDow
venkata91 opened a new pull request, #23313:
URL: https://github.com/apache/flink/pull/23313
## What is the purpose of the change
Support filter push down on nested fields
For example:
`SELECT * FROM users WHERE user.age > 18`
In the above SQL, `user.age > 18` filter
[
https://issues.apache.org/jira/browse/FLINK-30630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-30630:
---
Labels: auto-deprioritized-critical test-stability (was: stale-critical
test-stability)
[
https://issues.apache.org/jira/browse/FLINK-32476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32476:
---
Labels: pull-request-available stale-major (was: pull-request-available)
I am the [Flink Ji
[
https://issues.apache.org/jira/browse/FLINK-32396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32396:
---
Labels: pull-request-available stale-major (was: pull-request-available)
I am the [Flink Ji
mananmangal commented on code in PR #648:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/648#discussion_r1291624743
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java:
##
@@ -1070,4
[
https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759693#comment-17759693
]
Sergey Nuyanzin commented on FLINK-32758:
-
> I'm not sure how I can verify that
[
https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759670#comment-17759670
]
Feng Jin edited comment on FLINK-32976 at 8/28/23 5:41 PM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759670#comment-17759670
]
Feng Jin commented on FLINK-32976:
--
[~martijnvisser] Sorry for the not clearly descrip
[
https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-32976:
-
Description:
It can be reproduced when starting flink cluster with hadoop configuration.
{code:java}
Jiabao-Sun commented on PR #23218:
URL: https://github.com/apache/flink/pull/23218#issuecomment-1696047403
Thanks @1996fanrui for the hard review and sorry for the oversight.
Please help review it again when you have time.
--
This is an automated message from the Apache Git Service.
To
flinkbot commented on PR #23312:
URL: https://github.com/apache/flink/pull/23312#issuecomment-1695987276
## CI report:
* 4505846115102c1e09ae495076f7d270f53f3da5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xishuaidelin opened a new pull request, #23312:
URL: https://github.com/apache/flink/pull/23312
## What is the purpose of the change
This pull request aims to port Calcite's fix for the sql like operator and
relates to FLINK-32824.
## Brief change log
Modifi
hlteoh37 opened a new pull request, #92:
URL: https://github.com/apache/flink-connector-aws/pull/92
## Purpose of the change
* [Text for ITCase MiniCluster ArchUnitTest has been changed for Flink
1.18](https://github.com/apache/flink/pull/22399). This PR removes the need for
this exc
[
https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-32976:
-
Description:
The error message as follows:
{code:java}
//代码占位符
Caused by: java.ang.NullPointerExc
[
https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-32976:
-
Summary: NullPointException when starting flink cluster (was:
NullpointException when starting flink cl
1996fanrui commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1307539956
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -144,6 +188,17 @@ private void maybeRescale() {
}
}
echauchot commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1307494302
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -144,6 +188,17 @@ private void maybeRescale() {
}
}
+
1996fanrui commented on code in PR #23218:
URL: https://github.com/apache/flink/pull/23218#discussion_r1307500363
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/OperatorStateOutputCheckpointStreamTest.java:
##
@@ -54,41 +55,40 @@ private OperatorStateHandle writeA
echauchot commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1307494302
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -144,6 +188,17 @@ private void maybeRescale() {
}
}
+
echauchot commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1307494302
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -144,6 +188,17 @@ private void maybeRescale() {
}
}
+
zentol commented on code in PR #23296:
URL: https://github.com/apache/flink/pull/23296#discussion_r1307474170
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java:
##
@@ -83,7 +104,10 @@ public void start() th
[
https://issues.apache.org/jira/browse/FLINK-32961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32961:
---
Fix Version/s: (was: 1.18.0)
> A new FileSystemFactory that support two high available h
[
https://issues.apache.org/jira/browse/FLINK-32970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759602#comment-17759602
]
Martijn Visser commented on FLINK-32970:
[~SpongebobZ] Can you please try this w
[
https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32976.
--
Resolution: Cannot Reproduce
[~hackergin] Please provide info on what you've tried and how to
echauchot commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1307494302
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -144,6 +188,17 @@ private void maybeRescale() {
}
}
+
[
https://issues.apache.org/jira/browse/FLINK-32981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-32981.
--
Fix Version/s: 1.19.0
Resolution: Fixed
63a4db2 in master
> Add python dynamic Flink h
echauchot commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1307486764
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -210,6 +265,15 @@ interface Context
* @return a ScheduledFu
X-czh commented on code in PR #23302:
URL: https://github.com/apache/flink/pull/23302#discussion_r1307486343
##
flink-runtime/src/test/java/org/apache/flink/runtime/shuffle/ShuffleMasterTest.java:
##
@@ -99,7 +95,7 @@ public void testStopTrackingPartition() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-32971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-32971.
--
Fix Version/s: 1.19.0
Resolution: Fixed
171524f in master
> Add pyflink proper develop
mbalassi merged PR #23304:
URL: https://github.com/apache/flink/pull/23304
--
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.apac
ferenc-csaky commented on PR #23304:
URL: https://github.com/apache/flink/pull/23304#issuecomment-1695757103
> > Any specific reason to be more lenient and not use \d+ instead?
>
> I personally don't think that Flink must re-implement the versioning
standard. I know this case it's jus
1 - 100 of 261 matches
Mail list logo
