[
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 (wa
[
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 UI
[
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"
+excerp
[
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"
+excerp
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"
+excerp
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 1993ad0c968efa60ad5071e8472f630b247251
[
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 alloc
[
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 the
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 handleExecutionGraphCreation(
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: issues-unsubscr...@flink.apache
[
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 handleExecutionGraphCreation(
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. b
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 handleExecutionGraphCreation(
[
https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695527#comment-17695527
]
Weihua Hu commented on FLINK-31234:
---
Hi, [~wangyang0918] [~chesnay] Looking forward to
[
https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695526#comment-17695526
]
Weihua Hu commented on FLINK-31233:
---
Hi, [~wangyang0918] [~chesnay] Looking forward to
[
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
specifically
[
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
specifically
[
https://issues.apache.org/jira/browse/FLINK-31133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695523#comment-17695523
]
Roman Khachatryan commented on FLINK-31133:
---
Thanks [~liyu] , you are right, i
[
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)
> PartiallyFinishedSourcesI
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 th
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 in
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: The
[
https://issues.apache.org/jira/browse/FLINK-31133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695501#comment-17695501
]
Yu Li commented on FLINK-31133:
---
The 1.15.4 version is about to release with [RC under
vo
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 b
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 in:
[
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
memory,
[
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
memory,
[
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
memory,
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 t
[
https://issues.apache.org/jira/browse/FLINK-31296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695491#comment-17695491
]
Aitozi commented on FLINK-31296:
But this will affect the join key pair in the Join oper
[
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
memory,
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 comment.
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695484#comment-17695484
]
Matheus Felisberto commented on FLINK-26088:
Hi there [~qinjunjerry], how ar
[
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&focusedCommentId=17695483#comment-17695483
]
Rui Fan commented on FLINK-31222:
-
Thanks for the fix:)
apache:master: 95dd5423aad84
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: issues-unsubscr...@flink.ap
[
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&focusedCommentId=17695482#comment-17695482
]
JasonLee commented on FLINK-29852:
--
[~huwh] yeah,Thank you for your reply,I've already
[
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 appe
[
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: issues-unsubscr...@fl
[
https://issues.apache.org/jira/browse/FLINK-30694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695477#comment-17695477
]
chenhaiyang commented on FLINK-30694:
-
Hi [~jark], I have pull the pr for this ticke
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695476#comment-17695476
]
Weihua Hu commented on FLINK-29852:
---
Hi, [~JasonLee] I found this is a bug while adapt
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: Imp
[
https://issues.apache.org/jira/browse/FLINK-31292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695473#comment-17695473
]
Yubin Li commented on FLINK-31292:
--
[~lzljs3620320] Good idea! Could you please assign
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 the
[
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 nee
[
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
> Defa
[
https://issues.apache.org/jira/browse/FLINK-31290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695468#comment-17695468
]
Guojun Li commented on FLINK-31290:
---
Hi Jingsong, I can take this task. Would you plea
[
https://issues.apache.org/jira/browse/FLINK-31291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695466#comment-17695466
]
Guojun Li commented on FLINK-31291:
---
Hi jingsong, I can take this task, would you plea
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: issues-unsubscr...@
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&focusedCommentId=17695457#comment-17695457
]
Ming Li commented on FLINK-31294:
-
[~lzljs3620320], hi, please help take a look at this
[
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 case,
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: B
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:
+- /features/append
[
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 last_n
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 respond
[
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 hang
[
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
memory,
[
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 hang
[
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 method(pauseOrRes
[
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
>\{{Loc
[
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 hang
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
Issue
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 Typ
[
https://issues.apache.org/jira/browse/FLINK-31287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695442#comment-17695442
]
xzw0223 commented on FLINK-31287:
-
[~lzljs3620320] Can I have a ticket? I think I can d
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 dow
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 org.hamcrest.Matchers.contai
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 globalCleanupAsync(JobI
[
https://issues.apache.org/jira/browse/FLINK-31285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695425#comment-17695425
]
Yaroslav Tkachenko commented on FLINK-31285:
I think FileSplitAssigner is th
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 S
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 po
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 org.apache.flink.table.sto
1 - 100 of 269 matches
Mail list logo