[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-29852:
--
Summary: Adaptive Scheduler duplicates operators for each parallel instance
in the Web UI
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-29852:
--
Component/s: Runtime / Coordination
> The operator is repeatedly displayed on the Flink Web
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-29852:
--
Priority: Major (was: Critical)
> The operator is repeatedly displayed on the Flink Web UI
>
dannycranmer commented on code in PR #611:
URL: https://github.com/apache/flink-web/pull/611#discussion_r1122714090
##
docs/content/posts/2023-02-23-release-1.15.4.md:
##
@@ -0,0 +1,144 @@
+---
+authors:
+- danny: null
+ name: Danny Cranmer
+date: "2023-02-23T17:00:00Z"
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-29852:
--
Fix Version/s: 1.17.0
1.16.2
> The operator is repeatedly displayed on the
dannycranmer commented on code in PR #611:
URL: https://github.com/apache/flink-web/pull/611#discussion_r1122714090
##
docs/content/posts/2023-02-23-release-1.15.4.md:
##
@@ -0,0 +1,144 @@
+---
+authors:
+- danny: null
+ name: Danny Cranmer
+date: "2023-02-23T17:00:00Z"
dannycranmer commented on code in PR #611:
URL: https://github.com/apache/flink-web/pull/611#discussion_r1122714090
##
docs/content/posts/2023-02-23-release-1.15.4.md:
##
@@ -0,0 +1,144 @@
+---
+authors:
+- danny: null
+ name: Danny Cranmer
+date: "2023-02-23T17:00:00Z"
flinkbot commented on PR #22067:
URL: https://github.com/apache/flink/pull/22067#issuecomment-1451441513
## CI report:
* dc1a58eb2e7966be6aed8b3cf3d21b047b5b4e53 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-30517.
--
Fix Version/s: 1.17.0
Resolution: Fixed
master(1.18) via
[
https://issues.apache.org/jira/browse/FLINK-30517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-30517:
--
Assignee: Weihua Hu
> Decrease log output interval while waiting for YARN JobManager be
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek reassigned FLINK-29852:
-
Assignee: Weihua Hu
> The operator is repeatedly displayed on the Flink Web UI
>
[
https://issues.apache.org/jira/browse/FLINK-31286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31286:
--
Fix Version/s: 1.15.5
(was: 1.15.4)
> Python processes are still alive
[
https://issues.apache.org/jira/browse/FLINK-31272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31272:
--
Fix Version/s: 1.15.5
(was: 1.15.4)
> Duplicate operators appear in
dmvk commented on code in PR #22066:
URL: https://github.com/apache/flink/pull/22066#discussion_r1122709873
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java:
##
@@ -128,10 +129,10 @@ private void
reswqa merged PR #21569:
URL: https://github.com/apache/flink/pull/21569
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31288:
---
Labels: pull-request-available (was: )
> Disable overdraft buffer for batch shuffle
>
dmvk commented on code in PR #22066:
URL: https://github.com/apache/flink/pull/22066#discussion_r1122707632
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java:
##
@@ -128,10 +129,10 @@ private void
reswqa opened a new pull request, #22067:
URL: https://github.com/apache/flink/pull/22067
## What is the purpose of the change
*Only pipelined / pipelined-bounded partition needs overdraft buffer. More
specifically, there is no reason to request more buffers for non-pipelined
(i.e.
dmvk commented on code in PR #22066:
URL: https://github.com/apache/flink/pull/22066#discussion_r1122707632
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java:
##
@@ -128,10 +129,10 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695527#comment-17695527
]
Weihua Hu commented on FLINK-31234:
---
Hi, [~wangyang0918] [~chesnay] Looking forward to your opinion
[
https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695526#comment-17695526
]
Weihua Hu commented on FLINK-31233:
---
Hi, [~wangyang0918] [~chesnay] Looking forward to your opinion
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31288:
---
Description:
Only pipelined / pipelined-bounded partition needs overdraft buffer. More
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31288:
---
Description:
Only pipelined / pipelined-bounded partition needs overdraft buffer. More
[
https://issues.apache.org/jira/browse/FLINK-31133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695523#comment-17695523
]
Roman Khachatryan commented on FLINK-31133:
---
Thanks [~liyu] , you are right, it will likely
[
https://issues.apache.org/jira/browse/FLINK-31133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-31133:
--
Fix Version/s: 1.15.5
(was: 1.15.4)
>
ruanhang1993 commented on PR #22048:
URL: https://github.com/apache/flink/pull/22048#issuecomment-1451412221
@PatrickRen @zentol Would you like to help to review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
JingsongLi commented on code in PR #540:
URL: https://github.com/apache/flink-table-store/pull/540#discussion_r1122671042
##
docs/content/docs/how-to/writing-tables.md:
##
@@ -268,3 +268,146 @@ For more information of 'delete', see
{{< /tab >}}
{{< /tabs >}}
+
+## Merging
carp84 commented on code in PR #611:
URL: https://github.com/apache/flink-web/pull/611#discussion_r1122666900
##
docs/content/posts/2023-02-23-release-1.15.4.md:
##
@@ -0,0 +1,144 @@
+---
+authors:
+- danny: null
+ name: Danny Cranmer
+date: "2023-02-23T17:00:00Z"
+excerpt:
[
https://issues.apache.org/jira/browse/FLINK-31133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695501#comment-17695501
]
Yu Li commented on FLINK-31133:
---
The 1.15.4 version is about to release with [RC under
yuzelin commented on code in PR #563:
URL: https://github.com/apache/flink-table-store/pull/563#discussion_r1122663315
##
flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/source/StaticFileStoreSplitEnumerator.java:
##
[
https://issues.apache.org/jira/browse/FLINK-31252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31252:
---
Labels: pull-request-available (was: )
> Improve StaticFileStoreSplitEnumerator to assign
yuzelin commented on code in PR #563:
URL: https://github.com/apache/flink-table-store/pull/563#discussion_r1122663315
##
flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/source/StaticFileStoreSplitEnumerator.java:
##
flinkbot commented on PR #22066:
URL: https://github.com/apache/flink/pull/22066#issuecomment-1451378565
## CI report:
* 4c27324d51a07484182bbca3e54c4c0d20a6b9f1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29852:
---
Labels: pull-request-available (was: )
> The operator is repeatedly displayed on the Flink
huwh opened a new pull request, #22066:
URL: https://github.com/apache/flink/pull/22066
## What is the purpose of the change
adaptive scheduler will update the execution graph when parallelism changed.
It add all execution vertices to the json plan which should only add job
vertices.
[
https://issues.apache.org/jira/browse/FLINK-31286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-31286.
---
Fix Version/s: 1.17.0
1.15.4
1.16.2
Resolution: Fixed
Fixed
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Description:
In our TPC-DS test, we found that in the case of fierce competition in network
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Description:
In our TPC-DS test, we found that in the case of fierce competition in network
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Description:
In our TPC-DS test, we found that in the case of fierce competition in network
dianfu closed pull request #22065: [FLINK-31286][python] Make sure Python
processes are cleaned up when TaskManager crashes
URL: https://github.com/apache/flink/pull/22065
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-31296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695491#comment-17695491
]
Aitozi commented on FLINK-31296:
But this will affect the join key pair in the Join operator which may
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Description:
In our TPC-DS test, we found that in the case of fierce competition in network
snuyanzin commented on PR #22063:
URL: https://github.com/apache/flink/pull/22063#issuecomment-1451363517
@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
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695484#comment-17695484
]
Matheus Felisberto commented on FLINK-26088:
Hi there [~qinjunjerry], how are you? No
[
https://issues.apache.org/jira/browse/FLINK-31222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan closed FLINK-31222.
---
Fix Version/s: 1.18.0
Resolution: Fixed
> Remove usage of deprecated ConverterUtils.toApplicationId
[
https://issues.apache.org/jira/browse/FLINK-31222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-31222:
---
Assignee: Shilun Fan
> Remove usage of deprecated ConverterUtils.toApplicationId
>
[
https://issues.apache.org/jira/browse/FLINK-31222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695483#comment-17695483
]
Rui Fan commented on FLINK-31222:
-
Thanks for the fix:)
apache:master:
1996fanrui merged PR #22020:
URL: https://github.com/apache/flink/pull/22020
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-31178.
---
Resolution: Fixed
master: 9b8dc4e2f3cf8bc28a95d5381c8544868bd5b688
> Public Writer API
>
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695482#comment-17695482
]
JasonLee commented on FLINK-29852:
--
[~huwh] yeah,Thank you for your reply,I've already open it.
> The
[
https://issues.apache.org/jira/browse/FLINK-31248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-31248.
---
Resolution: Fixed
master: b8a700082a6032dfed7cee4273f3f76ce0483b5a
> Improve documentation for
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JasonLee reopened FLINK-29852:
--
> The operator is repeatedly displayed on the Flink Web UI
>
tsreaper merged PR #550:
URL: https://github.com/apache/flink-table-store/pull/550
--
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:
[
https://issues.apache.org/jira/browse/FLINK-30694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695477#comment-17695477
]
chenhaiyang commented on FLINK-30694:
-
Hi [~jark], I have pull the pr for this ticket.
>
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695476#comment-17695476
]
Weihua Hu commented on FLINK-29852:
---
Hi, [~JasonLee] I found this is a bug while adaptiveScheduler
Aitozi created FLINK-31296:
--
Summary: Add JoinConditionEqualityTransferRule to stream optimizer
Key: FLINK-31296
URL: https://issues.apache.org/jira/browse/FLINK-31296
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695473#comment-17695473
]
Yubin Li commented on FLINK-31292:
--
[~lzljs3620320] Good idea! Could you please assign this to me?
>
lindong28 commented on PR #21557:
URL: https://github.com/apache/flink/pull/21557#issuecomment-1451332786
@zentol @yunfengzhou-hub Do you have time to review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-31087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-31087:
Summary: Introduce MergeIntoAction. (was: Introduce InsertChangesAction.)
> Introduce MergeIntoAction.
>
[
https://issues.apache.org/jira/browse/FLINK-31087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-31087:
Description: This action simulates the 'MERGE INTO' syntax. (was: Applying
streaming changes to table
[
https://issues.apache.org/jira/browse/FLINK-30501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30501:
-
Description:
Flink 1.15 and later versions require at least Java 11 to build from sources
[1], whereas
[
https://issues.apache.org/jira/browse/FLINK-30501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30501:
-
Description:
Flink 1.15 and later versions require at least Java 11 to build from sources
[1], whereas
[
https://issues.apache.org/jira/browse/FLINK-31290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-31290:
Assignee: Guojun Li
> Remove features in documentation
>
[
https://issues.apache.org/jira/browse/FLINK-31291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-31291:
Assignee: Guojun Li
> Document table.exec.sink.upsert-materialize to none
>
[
https://issues.apache.org/jira/browse/FLINK-31289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31289.
Assignee: Shammon
Resolution: Fixed
master: 30f03264bf188df3ccf753cc53da421b3464318c
>
[
https://issues.apache.org/jira/browse/FLINK-31290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695468#comment-17695468
]
Guojun Li commented on FLINK-31290:
---
Hi Jingsong, I can take this task. Would you please assign it to
[
https://issues.apache.org/jira/browse/FLINK-31291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695466#comment-17695466
]
Guojun Li commented on FLINK-31291:
---
Hi jingsong, I can take this task, would you please assign it to
JingsongLi merged PR #568:
URL: https://github.com/apache/flink-table-store/pull/568
--
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:
HunterXHunter created FLINK-31295:
-
Summary: When kerbero authentication is enabled, hadoop_ Proxy
cannot take effect.
Key: FLINK-31295
URL: https://issues.apache.org/jira/browse/FLINK-31295
Project:
[
https://issues.apache.org/jira/browse/FLINK-31294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695457#comment-17695457
]
Ming Li commented on FLINK-31294:
-
[~lzljs3620320], hi, please help take a look at this issue if you
[
https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tamir Sagi updated FLINK-31140:
---
Description:
To date is is not possible to add additional jars to operator classpath.
In our
ming li created FLINK-31294:
---
Summary: CommitterOperator forgot to close Committer when closing.
Key: FLINK-31294
URL: https://issues.apache.org/jira/browse/FLINK-31294
Project: Flink
Issue Type:
Jackofmn12 commented on code in PR #562:
URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1122591066
##
docs/content/docs/features/append-only-table.md:
##
@@ -0,0 +1,98 @@
+---
+title: "Append Only Table"
+weight: 2
+type: docs
+aliases:
+-
[
https://issues.apache.org/jira/browse/FLINK-31289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31289:
---
Labels: pull-request-available (was: )
> Default aggregate-function for field can be
FangYongs opened a new pull request, #568:
URL: https://github.com/apache/flink-table-store/pull/568
If the field has no aggregate function for aggregation merge-engine, use
last_non_null_value aggregation as default.
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Attachment: image-2023-03-02-12-29-03-003.png
> Request memory segment from LocalBufferPool may
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Description:
In our TPC-DS test, we found that in the case of fierce competition in network
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Attachment: image-2023-03-02-12-28-48-437.png
> Request memory segment from LocalBufferPool may
[
https://issues.apache.org/jira/browse/FLINK-31208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-31208:
-
Assignee: Hongshun Wang
> KafkaSourceReader overrides meaninglessly a
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Description:
>From the thread dump information, we can see that the task is waiting for the
[
https://issues.apache.org/jira/browse/FLINK-31293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31293:
---
Attachment: image-2023-03-02-12-23-50-572.png
> Request memory segment from LocalBufferPool may
Weijie Guo created FLINK-31293:
--
Summary: Request memory segment from LocalBufferPool may hanging
forever.
Key: FLINK-31293
URL: https://issues.apache.org/jira/browse/FLINK-31293
Project: Flink
Jingsong Lee created FLINK-31292:
Summary: User HadoopUtils to get Configuration in CatalogContext
Key: FLINK-31292
URL: https://issues.apache.org/jira/browse/FLINK-31292
Project: Flink
Jingsong Lee created FLINK-31291:
Summary: Document table.exec.sink.upsert-materialize to none
Key: FLINK-31291
URL: https://issues.apache.org/jira/browse/FLINK-31291
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695442#comment-17695442
]
xzw0223 commented on FLINK-31287:
-
[~lzljs3620320] Can I have a ticket? I think I can do it.
> Default
Jingsong Lee created FLINK-31290:
Summary: Remove features in documentation
Key: FLINK-31290
URL: https://issues.apache.org/jira/browse/FLINK-31290
Project: Flink
Issue Type: Improvement
flinkbot commented on PR #22065:
URL: https://github.com/apache/flink/pull/22065#issuecomment-1451258837
## CI report:
* 849025d00ad19a620ea1930e4fdd0ffd56dbfb3d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jingsong Lee created FLINK-31289:
Summary: Default aggregate-function for field can be
last_non_null_value
Key: FLINK-31289
URL: https://issues.apache.org/jira/browse/FLINK-31289
Project: Flink
Weijie Guo created FLINK-31288:
--
Summary: Disable overdraft buffer for batch shuffle
Key: FLINK-31288
URL: https://issues.apache.org/jira/browse/FLINK-31288
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-31286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31286:
---
Labels: pull-request-available (was: )
> Python processes are still alive when shutting
dianfu opened a new pull request, #22065:
URL: https://github.com/apache/flink/pull/22065
## 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 on
Jingsong Lee created FLINK-31287:
Summary: Default value of 'changelog-producer.compaction-interval'
can be zero
Key: FLINK-31287
URL: https://issues.apache.org/jira/browse/FLINK-31287
Project: Flink
X-czh commented on code in PR #21673:
URL: https://github.com/apache/flink/pull/21673#discussion_r1122567761
##
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHaServicesTest.java:
##
@@ -44,18 +44,20 @@
import static
X-czh commented on code in PR #21673:
URL: https://github.com/apache/flink/pull/21673#discussion_r1122567580
##
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java:
##
@@ -225,6 +237,13 @@ public CompletableFuture
[
https://issues.apache.org/jira/browse/FLINK-31285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695425#comment-17695425
]
Yaroslav Tkachenko commented on FLINK-31285:
I think FileSplitAssigner is the only thing
Dian Fu created FLINK-31286:
---
Summary: Python processes are still alive when shutting down a
session cluster directly without stopping the jobs
Key: FLINK-31286
URL: https://issues.apache.org/jira/browse/FLINK-31286
flinkbot commented on PR #22064:
URL: https://github.com/apache/flink/pull/22064#issuecomment-1451176068
## CI report:
* 4cde341af47b24b20088c5379ff260bed0e9849c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuyongvs commented on PR #22064:
URL: https://github.com/apache/flink/pull/22064#issuecomment-1451174143
after this https://github.com/apache/flink/pull/22050 fixed, the unit test
will be passed.
so when it be merged, i wll rebase
--
This is an automated message from the Apache Git
liuyongvs opened a new pull request, #22064:
URL: https://github.com/apache/flink/pull/22064
## What is the purpose of the change
*add DATE_SUB function*
## Brief change log
- *SELECT DATE_SUB('2018-05-01',INTERVAL '1' YEAR/MONTH/DAY);*
## Does this pull request
JingsongLi commented on code in PR #550:
URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1122527375
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableWrite.java:
##
@@ -18,39 +18,42 @@
package
1 - 100 of 269 matches
Mail list logo
