flinkbot commented on PR #24488:
URL: https://github.com/apache/flink/pull/24488#issuecomment-1993657819
## CI report:
* 740730fcf87de7999e8f56b143bdc97103c2a77e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
masteryhx commented on PR #24418:
URL: https://github.com/apache/flink/pull/24418#issuecomment-1993656300
The failed case caused by
[FLINK-34660](https://issues.apache.org/jira/browse/FLINK-34660) which is not
related to this PR.
I also submitted a pr to resolved this.
--
This is an a
[
https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34660:
---
Labels: pull-request-available (was: )
> AutoRescalingITCase#testCheckpointRescalingInKeyed
masteryhx opened a new pull request, #24488:
URL: https://github.com/apache/flink/pull/24488
## What is the purpose of the change
AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError:
```
expected:<[(0,8000), (0,32000), (0,48000), (0,72000), (1,78000
Hangxiang Yu created FLINK-34660:
Summary: AutoRescalingITCase#testCheckpointRescalingInKeyedState
AssertionError
Key: FLINK-34660
URL: https://issues.apache.org/jira/browse/FLINK-34660
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825913#comment-17825913
]
Ming Li commented on FLINK-33798:
-
[~fanrui], good idea, I will back port to 1.17 , 1.18
reswqa commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1522571183
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -128,6 +128,24 @@ public class ExecutionOptions {
LadyForest commented on PR #24390:
URL: https://github.com/apache/flink/pull/24390#issuecomment-1993628470
Hi @XComp, I plan to merge PR since the CI passed unless you have any other
concerns.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
reswqa commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1522571183
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -128,6 +128,24 @@ public class ExecutionOptions {
reswqa commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1522567807
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MapPartitionOperator.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Fou
reswqa commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-opensearch/pull/39#discussion_r1522556968
##
flink-connector-opensearch/archunit-violations/4382f1f0-807a-45ff-97d8-42f72b6e9484:
##
@@ -14,23 +14,5 @@
org.apache.flink.connector.opensearch.tabl
reswqa commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-opensearch/pull/39#discussion_r152244
##
flink-connector-opensearch/archunit-violations/4382f1f0-807a-45ff-97d8-42f72b6e9484:
##
@@ -14,23 +14,5 @@
org.apache.flink.connector.opensearch.tabl
PatrickRen commented on code in PR #721:
URL: https://github.com/apache/flink-web/pull/721#discussion_r1522504285
##
docs/content/posts/2024-03-xx-release-1.19.0.md:
##
@@ -0,0 +1,501 @@
+---
+authors:
+- LincolnLee:
+ name: "Lincoln Lee"
+ twitter: lincoln_86xy
+
+date: "2024
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-32953:
Fix Version/s: (was: 1.20.0)
> [State TTL]resolve data correctness problem after ttl was chang
PatrickRen commented on code in PR #24394:
URL: https://github.com/apache/flink/pull/24394#discussion_r1522493325
##
docs/content.zh/_index.md:
##
@@ -85,7 +85,8 @@ under the License.
For some reason Hugo will only allow linking to the
release notes if there is a leading '/'
hajimeni commented on PR #39:
URL:
https://github.com/apache/flink-connector-opensearch/pull/39#issuecomment-1993462184
Hey, @schulzp.
I have created a PR for testing.
https://github.com/hajimeni/flink-connector-opensearch/pull/1
CI passes, so it still seems that the differe
[
https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33798:
Fix Version/s: 1.20.0
> Automatically clean up rocksdb logs when the task failover.
>
[
https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825899#comment-17825899
]
Rui Fan commented on FLINK-33798:
-
Hi [~liming], IIUC, this JIRA is a file leak related
[
https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825898#comment-17825898
]
Rui Fan commented on FLINK-33798:
-
Merged to master(1.20) via: 398bb5068703a6461e2e52a90
[
https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33798:
Issue Type: Bug (was: Improvement)
> Automatically clean up rocksdb logs when the task failover.
> --
1996fanrui merged PR #23922:
URL: https://github.com/apache/flink/pull/23922
--
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-34557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825895#comment-17825895
]
tanliang commented on FLINK-34557:
--
My current temporary solution is to add a shutdownh
[
https://issues.apache.org/jira/browse/FLINK-34659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825894#comment-17825894
]
Junyao Huang commented on FLINK-34659:
--
[https://github.com/apache/flink/blob/94b55
[
https://issues.apache.org/jira/browse/FLINK-34659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyao Huang updated FLINK-34659:
-
Attachment: image-2024-03-13-11-21-57-846.png
> How to implement global sort in latest flink dat
[
https://issues.apache.org/jira/browse/FLINK-34659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junyao Huang updated FLINK-34659:
-
Description:
[https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/datastream/datase
Junyao Huang created FLINK-34659:
Summary: How to implement global sort in latest flink datastream
API
Key: FLINK-34659
URL: https://issues.apache.org/jira/browse/FLINK-34659
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825893#comment-17825893
]
tanliang commented on FLINK-34557:
--
hi [~mapohl] ,thanks for your comment, I'm sorry fo
[
https://issues.apache.org/jira/browse/FLINK-34569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825887#comment-17825887
]
Rob Young edited comment on FLINK-34569 at 3/13/24 3:14 AM:
damumu0625 commented on PR #24485:
URL: https://github.com/apache/flink/pull/24485#issuecomment-1993272350
LGTM
--
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 unsubscri
masteryhx commented on PR #24418:
URL: https://github.com/apache/flink/pull/24418#issuecomment-1993258271
@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.
lincoln-lil commented on PR #721:
URL: https://github.com/apache/flink-web/pull/721#issuecomment-1993232847
@Myasuka Thanks! I've updated the pr.
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825669#comment-17825669
]
Rui Fan edited comment on FLINK-34655 at 3/13/24 2:46 AM:
--
{quo
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34655:
Fix Version/s: kubernetes-operator-1.8.0
(was: 1.8.0)
> Autoscaler doesn't work for
[
https://issues.apache.org/jira/browse/FLINK-34569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825887#comment-17825887
]
Rob Young commented on FLINK-34569:
---
Hi, I've had a look into it and I think the repea
liuyongvs commented on PR #24486:
URL: https://github.com/apache/flink/pull/24486#issuecomment-1993138852
LGTM, only left a minor comment
--
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
liuyongvs commented on code in PR #24486:
URL: https://github.com/apache/flink/pull/24486#discussion_r1522385972
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/SplitPythonConditionFromJoinRule.java:
##
@@ -0,0 +1,133 @@
+/*
+ *
masteryhx commented on PR #24418:
URL: https://github.com/apache/flink/pull/24418#issuecomment-1993089967
@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.
Myasuka commented on code in PR #721:
URL: https://github.com/apache/flink-web/pull/721#discussion_r1522360842
##
docs/content/posts/2024-03-xx-release-1.19.0.md:
##
@@ -0,0 +1,501 @@
+---
+authors:
+- LincolnLee:
+ name: "Lincoln Lee"
+ twitter: lincoln_86xy
+
+date: "2024-03
ukby1234 commented on PR #24029:
URL: https://github.com/apache/flink/pull/24029#issuecomment-1992944538
@MartijnVisser can you help review this PR? and possibly
https://github.com/apache/flink/pull/23881 as well?
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-34647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34647:
---
Labels: pull-request-available (was: )
> Path normalization is allocation intensive
> -
schlosna commented on PR #24473:
URL: https://github.com/apache/flink/pull/24473#issuecomment-1992844641
Thanks for taking a look at this PR.
> 1. What's your setup for the path ?
We have checkpoints writing to a variety of file systems depending on the
infrastructure, so it mi
[
https://issues.apache.org/jira/browse/FLINK-25352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-25352:
---
Assignee: Jing Ge
> Update stability annotations to include the since and missedGraduations fields
Matthew Ernst created FLINK-34658:
-
Summary: Scala API unusable on Flink 1.18.1/Java 17 Docker image
Key: FLINK-34658
URL: https://issues.apache.org/jira/browse/FLINK-34658
Project: Flink
Iss
Zhenqiu Huang created FLINK-34657:
-
Summary: Implement Lineage Graph for streaming API use cases
Key: FLINK-34657
URL: https://issues.apache.org/jira/browse/FLINK-34657
Project: Flink
Issue T
schulzp commented on PR #39:
URL:
https://github.com/apache/flink-connector-opensearch/pull/39#issuecomment-1992274982
Hey @hajimeni!
> The CI error seems to be caused by differences in files under the
archunit-violations path.
> It was resolved in the following PR.
https://githu
HCTommy commented on PR #24476:
URL: https://github.com/apache/flink/pull/24476#issuecomment-1992162943
@zhuzhurk Hi, I fixed a grammar error in the comments when testing the
barrier. Could you please review in your available time.
--
This is an automated message from the Apache Git Servi
rkhachatryan commented on code in PR #24487:
URL: https://github.com/apache/flink/pull/24487#discussion_r1521803705
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -1046,27 +1046,32 @@ private void onTriggerFailure(
rkhachatryan commented on code in PR #24487:
URL: https://github.com/apache/flink/pull/24487#discussion_r1521803705
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -1046,27 +1046,32 @@ private void onTriggerFailure(
flinkbot commented on PR #24487:
URL: https://github.com/apache/flink/pull/24487#issuecomment-1992068365
## CI report:
* d07a37b06fc847c1f2c6ce148a918c2490f2490c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pnowojski opened a new pull request, #24487:
URL: https://github.com/apache/flink/pull/24487
Unexpected error can be for example NPE
## Verifying this change
This
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825698#comment-17825698
]
Matthias Pohl edited comment on FLINK-34227 at 3/12/24 3:45 PM:
--
lincoln-lil commented on code in PR #24394:
URL: https://github.com/apache/flink/pull/24394#discussion_r1521683726
##
docs/content.zh/release-notes/flink-1.19.md:
##
@@ -0,0 +1,362 @@
+---
+title: "Release Notes - Flink 1.19"
+---
+
+
+# Release notes - Flink 1.19
+
+These relea
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825698#comment-17825698
]
Matthias Pohl edited comment on FLINK-34227 at 3/12/24 3:20 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-23542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825712#comment-17825712
]
Ryan Skraba commented on FLINK-23542:
-
This has become slightly more important : the
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825698#comment-17825698
]
Matthias Pohl edited comment on FLINK-34227 at 3/12/24 3:12 PM:
--
lincoln-lil commented on code in PR #721:
URL: https://github.com/apache/flink-web/pull/721#discussion_r1521623410
##
docs/content/posts/2024-03-xx-release-1.19.0.md:
##
@@ -0,0 +1,456 @@
+---
Review Comment:
@MartijnVisser As we discussed at the sync meeting, I've added the
lincoln-lil commented on PR #721:
URL: https://github.com/apache/flink-web/pull/721#issuecomment-1991840142
@xintongsong @rmoff As per the conclusion of our discussion, I've tweaked
these examples and tried to keep them to just describing what the functionality
looks like (and avoiding over
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825698#comment-17825698
]
Matthias Pohl commented on FLINK-34227:
---
[~chesnay] supported the investigation. H
yisha zhou created FLINK-34656:
--
Summary: Generated code for `ITEM` operator should return null
when getting element of a null map/array/row
Key: FLINK-34656
URL: https://issues.apache.org/jira/browse/FLINK-34656
hejufang commented on code in PR #24322:
URL: https://github.com/apache/flink/pull/24322#discussion_r1521505824
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBProperty.java:
##
@@ -31,55 +31,92 @@
*/
@Internal
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825654#comment-17825654
]
Matthias Pohl edited comment on FLINK-34227 at 3/12/24 1:09 PM:
--
1996fanrui commented on code in PR #795:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/795#discussion_r1521431571
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java:
##
@@ -92,24 +99,51 @@ public static ConfigChanges tuneTaskM
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825669#comment-17825669
]
Rui Fan commented on FLINK-34655:
-
{quote}But the vertex parallelism overrides feature w
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825654#comment-17825654
]
Matthias Pohl edited comment on FLINK-34227 at 3/12/24 1:00 PM:
--
gyfora commented on PR #797:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/797#issuecomment-1991544918
> Thanks @gyfora for the valuable feedback!
>
> > Instead of a new rest client you could also do what is done in the
Kubernetes-operator module, see:
https://github
1996fanrui commented on PR #797:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/797#issuecomment-1991537856
Thanks @gyfora for the valuable feedback!
> Instead of a new rest client you could also do what is done in the
Kubernetes-operator module, see:
https://github.
gyfora commented on PR #797:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/797#issuecomment-1991513679
But still it will not make it work fully for 1.15 as the aggregated metrics
need to be back ported on the Flink side (similar to other features required
for the autoscaler
gyfora commented on PR #797:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/797#issuecomment-1991512469
Instead of a new rest client you could also do what is done in the
Kubernetes-operator module, see:
https://github.com/apache/flink-kubernetes-operator/blob/main/flink-
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825657#comment-17825657
]
Gyula Fora edited comment on FLINK-34655 at 3/12/24 12:12 PM:
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825657#comment-17825657
]
Gyula Fora commented on FLINK-34655:
Also this issue is fixed in the Kubernetes-oper
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-34655:
---
Priority: Major (was: Blocker)
> Autoscaler doesn't work for flink 1.15
> -
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825656#comment-17825656
]
Gyula Fora commented on FLINK-34655:
But the vertex parallelism overrides feature wa
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825654#comment-17825654
]
Matthias Pohl commented on FLINK-34227:
---
The [findings of my initial
analysis|htt
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825655#comment-17825655
]
Gyula Fora commented on FLINK-34655:
The bigger issue is that aggregated busy time m
mxm commented on PR #787:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/787#issuecomment-1991480345
I think there are some really good ideas in this PR which we might consider
in the future, but for the sake of simplicity it might be better to leave
things as-is for now. Th
mxm commented on code in PR #795:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/795#discussion_r1521324931
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java:
##
@@ -92,24 +99,51 @@ public static ConfigChanges tuneTaskManagerM
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1521322872
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MapPartitionOperator.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
LadyForest commented on PR #24390:
URL: https://github.com/apache/flink/pull/24390#issuecomment-1991461563
Hi [XComp](https://github.com/XComp), thanks so much for the time and effort
you've put into the review and discussion :)
--
This is an automated message from the Apache Git Service.
hajimeni commented on PR #39:
URL:
https://github.com/apache/flink-connector-opensearch/pull/39#issuecomment-1991441614
Hey @schulzp.
Thank you for creating this PR. It would be very helpful if this PR gets
merged.
The CI error seems to be caused by differences in files under the
`a
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825639#comment-17825639
]
Matthias Pohl edited comment on FLINK-34227 at 3/12/24 11:24 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825639#comment-17825639
]
Matthias Pohl commented on FLINK-34227:
---
My suspicion is that there's a bug in the
wckdman commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-1991405676
Any news here? :)
I'm really looking forward to see this feature 🙏
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34655:
---
Labels: pull-request-available (was: )
> Autoscaler doesn't work for flink 1.15
> -
1996fanrui opened a new pull request, #797:
URL: https://github.com/apache/flink-kubernetes-operator/pull/797
flink-ubernetes-operator is committed to supporting the latest 4 flink minor
versions, and autoscaler is a part of flink-ubernetes-operator. Currently, the
latest 4 flink minor vers
Zakelly commented on code in PR #24461:
URL: https://github.com/apache/flink/pull/24461#discussion_r1521260155
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java:
##
@@ -520,12 +521,40 @@ public void setTolerableCheckpointFailu
Rui Fan created FLINK-34655:
---
Summary: Autoscaler doesn't work for flink 1.15
Key: FLINK-34655
URL: https://issues.apache.org/jira/browse/FLINK-34655
Project: Flink
Issue Type: Bug
Compon
XComp commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1521248255
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/table/FileSystemOutputFormatTest.java:
##
@@ -282,7 +278,7 @@ private FileSystemOu
masteryhx commented on PR #24418:
URL: https://github.com/apache/flink/pull/24418#issuecomment-1991306532
@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.
wuchong commented on PR #725:
URL: https://github.com/apache/flink-web/pull/725#issuecomment-1991281258
@dannycranmer @hlteoh37 could you help to review the AWS part?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
wuchong commented on code in PR #725:
URL: https://github.com/apache/flink-web/pull/725#discussion_r1521200340
##
docs/content/what-is-flink/special-thanks.md:
##
@@ -0,0 +1,48 @@
+---
+title: Special Thanks
+bookCollapseSection: false
+weight: 9
+---
+
+
+# Special Thanks
+
+##
LadyForest commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1521195360
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/table/FileSystemOutputFormatTest.java:
##
@@ -37,24 +39,44 @@
import java.io
Zakelly commented on code in PR #725:
URL: https://github.com/apache/flink-web/pull/725#discussion_r1521191193
##
docs/content/what-is-flink/special-thanks.md:
##
@@ -0,0 +1,48 @@
+---
+title: Special Thanks
+bookCollapseSection: false
+weight: 9
+---
+
+
+# Special Thanks
+
+##
rmetzger commented on code in PR #725:
URL: https://github.com/apache/flink-web/pull/725#discussion_r1521186823
##
docs/content/what-is-flink/special-thanks.md:
##
@@ -0,0 +1,48 @@
+---
+title: Special Thanks
+bookCollapseSection: false
+weight: 9
+---
+
+
+# Special Thanks
+
+#
flinkbot commented on PR #24486:
URL: https://github.com/apache/flink/pull/24486#issuecomment-1991230364
## CI report:
* 83e67a1d6988fe08173cdbcf161f6097dde2fecb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34618:
---
Labels: pull-request-available (was: )
> Migrate SplitPythonConditionFromJoinRule
> ---
damumu0625 opened a new pull request, #24486:
URL: https://github.com/apache/flink/pull/24486
## What is the purpose of the change
The PR migrates SplitPythonConditionFromJoinRule to java
it doesn't touch SplitPythonConditionFromJoinRuleTest to be sure that java
version con
LadyForest commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1521155291
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemOutputFormat.java:
##
@@ -96,6 +99,22 @@ private FileSystemOu
[
https://issues.apache.org/jira/browse/FLINK-34654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34654:
---
Labels: pull-request-available (was: )
> Add "Special Thanks" Page on the Flink Website
> -
LadyForest commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1521155291
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemOutputFormat.java:
##
@@ -96,6 +99,22 @@ private FileSystemOu
masteryhx commented on code in PR #24418:
URL: https://github.com/apache/flink/pull/24418#discussion_r1521151391
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/BlockingPhysicalFilePool.java:
##
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the Apache Softw
1 - 100 of 137 matches
Mail list logo
