[
https://issues.apache.org/jira/browse/FLINK-34481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau closed FLINK-34481.
-
Release Note: merged f523b9d6191ecb584e36aa2aeffcd0659ce231f7
Resolution: Fixed
> Migrate SetOpRew
[
https://issues.apache.org/jira/browse/FLINK-34481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822434#comment-17822434
]
Jacky Lau commented on FLINK-34481:
---
Merged f523b9d6191ecb584e36aa2aeffcd0659ce231f7
1996fanrui merged PR #24386:
URL: https://github.com/apache/flink/pull/24386
--
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
1996fanrui commented on PR #24386:
URL: https://github.com/apache/flink/pull/24386#issuecomment-1972683847
Thanks @yuchen-ecnu for the review, merging~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to g
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822433#comment-17822433
]
Shuai Xu commented on FLINK-34380:
--
Let me take a look.
> Strange RowKind and records
JingGe merged PR #24358:
URL: https://github.com/apache/flink/pull/24358
--
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
1996fanrui commented on PR #24387:
URL: https://github.com/apache/flink/pull/24387#issuecomment-1972677393
Many thanks @HuangXingBo for the debug.
I'm on vacation and don't take my Mac, so my colleague @RocMarshal helps fix
this for 1.19 first due to 1.19 will be released soon.
flinkbot commented on PR #24422:
URL: https://github.com/apache/flink/pull/24422#issuecomment-1972653582
## CI report:
* cb4615792281b375a45da41795e9f1a0cd70ae2d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822420#comment-17822420
]
Muhammet Orazov commented on FLINK-34487:
-
Hey [~mapohl], I'd like to work on th
reswqa opened a new pull request, #24422:
URL: https://github.com/apache/flink/pull/24422
## What is the purpose of the change
*This is the first PR for DataStream V2, and aim to implement FLIP-409:
DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction *
huyuanfeng2018 commented on PR #24411:
URL: https://github.com/apache/flink/pull/24411#issuecomment-1972635698
> Hi @huyuanfeng2018 thanks for the PR. I have a few comments:
>
> * Please add `JSON_JOB_PLAN ` to the `python` API (e.g., to the
`basic_operations.py`) and test it there
[
https://issues.apache.org/jira/browse/FLINK-34180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34180:
---
Description:
As discussed in Flink dev mailing list[1][2], we have accepted the Flink CDC
project
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822415#comment-17822415
]
yisha zhou commented on FLINK-34529:
hi [~lincoln.86xy] , thanks for your advice.
A
[
https://issues.apache.org/jira/browse/FLINK-34548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34548:
---
Labels: (was: Umbrella)
> FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and
>
[
https://issues.apache.org/jira/browse/FLINK-34548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34548:
---
Description: This is the ticket for FLIP-409: DataStream V2 Building
Blocks: DataStream, Partitionin
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822401#comment-17822401
]
xuyang commented on FLINK-34380:
Hi, [~xu_shuai_] . Can you help check it again?
> Str
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822399#comment-17822399
]
yuanfenghu commented on FLINK-34535:
[~lincoln.86xy]
Thank you for your comment,
>
LadyForest commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1508526295
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/utils/PathUtils.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822390#comment-17822390
]
lincoln lee edited comment on FLINK-34535 at 3/1/24 5:43 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822390#comment-17822390
]
lincoln lee commented on FLINK-34535:
-
[~heigebupahei] The current `explain` syntax
flinkbot commented on PR #24421:
URL: https://github.com/apache/flink/pull/24421#issuecomment-1972492174
## CI report:
* c060447bb29118c3127c63eb09290a8c02c43e85 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34556:
---
Labels: pull-request-available (was: )
> Migrate EnumerableToLogicalTableScan
> ---
liuyongvs opened a new pull request, #24421:
URL: https://github.com/apache/flink/pull/24421
## What is the purpose of the change
The PR migrates EnumerableToLogicalTableScan to java
it doesn't touch EnumerableToLogicalTableScanTest to be sure that java
version continues passing it
Jacky Lau created FLINK-34556:
-
Summary: Migrate EnumerableToLogicalTableScan
Key: FLINK-34556
URL: https://issues.apache.org/jira/browse/FLINK-34556
Project: Flink
Issue Type: Sub-task
fredia commented on code in PR #24401:
URL: https://github.com/apache/flink/pull/24401#discussion_r1508457644
##
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:
##
@@ -76,6 +76,39 @@ public class CheckpointingOptions {
* CheckpointStorage
HuangXingBo commented on code in PR #24417:
URL: https://github.com/apache/flink/pull/24417#discussion_r1508454782
##
flink-python/pyflink/datastream/state.py:
##
@@ -809,7 +809,7 @@ def cleanup_incrementally(self,
def cleanup_in_rocksdb_compact_filter(
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822363#comment-17822363
]
yisha zhou commented on FLINK-34529:
[~libenchao] Thanks for assigning the ticket t
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822362#comment-17822362
]
lincoln lee commented on FLINK-34529:
-
[~nilerzhou] Thanks for reporting this!
As yo
[
https://issues.apache.org/jira/browse/FLINK-34555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34555:
---
Labels: pull-request-available (was: )
> Migrate JoinConditionTypeCoerceRule
>
flinkbot commented on PR #24420:
URL: https://github.com/apache/flink/pull/24420#issuecomment-1972439916
## CI report:
* 0183b6bb862ceaf1ef3ff96896ac5d673ba59493 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuyongvs opened a new pull request, #24420:
URL: https://github.com/apache/flink/pull/24420
## What is the purpose of the change
The PR migrates JoinConditionTypeCoerceRule to java
it doesn't touch JoinConditionTypeCoerceRuleTest to be sure that java
version continues passing it
Jacky Lau created FLINK-34555:
-
Summary: Migrate JoinConditionTypeCoerceRule
Key: FLINK-34555
URL: https://issues.apache.org/jira/browse/FLINK-34555
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #24419:
URL: https://github.com/apache/flink/pull/24419#issuecomment-1972391441
## CI report:
* b514f6bb29bd04049073b0762eacbce63d85e5ba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JustinLeesin commented on PR #24397:
URL: https://github.com/apache/flink/pull/24397#issuecomment-1972389996
> @JustinLeesin Thanks for update. LGTM. I'll merge to master after 1.19
branch cut
@luoyuxia OK, Thank you for taking the time to review my code.
--
This is an automated me
[
https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822358#comment-17822358
]
Benchao Li commented on FLINK-16627:
[~nilerzhou] Thank you for the interest of cont
[
https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-16627:
--
Assignee: yisha zhou
> Support only generate non-null values when serializing into JSON
> ---
[
https://issues.apache.org/jira/browse/FLINK-34536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822357#comment-17822357
]
Benchao Li commented on FLINK-34536:
It sounds like a useful feature from the user p
JustinLeesin commented on PR #24397:
URL: https://github.com/apache/flink/pull/24397#issuecomment-1972385924
> @JustinLeesin Could you please cherry pick it to release-1.18. I'll merge
to 1.18 firstly.
@luoyuxia Done , [24414](https://github.com/apache/flink/pull/24419)
--
This is
JustinLeesin opened a new pull request, #24419:
URL: https://github.com/apache/flink/pull/24419
1.18 backport for parent PR
[24397](https://github.com/apache/flink/pull/24397)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-34521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan closed FLINK-34521.
---
Resolution: Duplicate
> Using the Duration instead of the deprecated Time classes
>
[
https://issues.apache.org/jira/browse/FLINK-34521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822350#comment-17822350
]
Rui Fan commented on FLINK-34521:
-
Thanks for the reminder, i close this jira.
> Using
flinkbot commented on PR #24418:
URL: https://github.com/apache/flink/pull/24418#issuecomment-1972349443
## CI report:
* 61e97462d4566a1ae8f17ceb32e42f68f92631a6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32076:
---
Labels: pull-request-available (was: )
> Add file pool for concurrent file reusing
> --
masteryhx opened a new pull request, #24418:
URL: https://github.com/apache/flink/pull/24418
## What is the purpose of the change
Add file pool for concurrent file reusing
## Brief change log
- Introduce PhysicalFilePool and use it in FileMergingSnapshotMana
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822337#comment-17822337
]
xuyang commented on FLINK-33989:
Agree with [~libenchao] . This is a behavior by design.
flinkbot commented on PR #24417:
URL: https://github.com/apache/flink/pull/24417#issuecomment-1972320798
## CI report:
* c116a9c297479ebddb59864bda83ec8dfd43bb4b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
RocMarshal opened a new pull request, #24417:
URL: https://github.com/apache/flink/pull/24417
- What is the purpose of the change
[FLINK-32570](https://issues.apache.org/jira/browse/FLINK-32570) deprecated
the Time class and refactor all Public or PublicEvolving apis to use the Ja
[
https://issues.apache.org/jira/browse/FLINK-34550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siwei.gao updated FLINK-34550:
--
Attachment: image-2024-03-01-09-51-08-909.png
> attempted task still report metric of currentEmitEvent
[
https://issues.apache.org/jira/browse/FLINK-34550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siwei.gao updated FLINK-34550:
--
Description:
Attempted task still report metric of currentEmitEventTimeLag when use
kafka-connector.A
[
https://issues.apache.org/jira/browse/FLINK-34550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siwei.gao updated FLINK-34550:
--
Description:
Attempted task still report metric of currentEmitEventTimeLag when use
kafka-connector.A
[
https://issues.apache.org/jira/browse/FLINK-34553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822332#comment-17822332
]
Feng Jin commented on FLINK-34553:
--
>From what I currently know，only Paimon supports Fl
luoyuxia commented on PR #24397:
URL: https://github.com/apache/flink/pull/24397#issuecomment-1972271813
@JustinLeesin Could you please cherry pick it to release-1.18. I'll merge to
1.18 firstly.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
flinkbot commented on PR #24416:
URL: https://github.com/apache/flink/pull/24416#issuecomment-1972195868
## CI report:
* 0d64603764567494fefd05b5847a60795af949fd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lennon Yu updated FLINK-34542:
--
Description:
This is a ticket of misc. improvements on the build.gradle script provided at
{{Applicat
[
https://issues.apache.org/jira/browse/FLINK-34542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lennon Yu updated FLINK-34542:
--
Description:
This is a ticket of misc. improvements on the build.gradle script provided at
{{Applicat
[
https://issues.apache.org/jira/browse/FLINK-34542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34542:
---
Labels: pull-request-available (was: )
> Improve Gradle Quick Start build.gradle with Bette
LemonU opened a new pull request, #24416:
URL: https://github.com/apache/flink/pull/24416
## What is the purpose of the change
To improve the `build.gradle` build script provided in the Flink
documentation under section `Application Development >> Project Configuration
>> Ove
jeyhunkarimov commented on code in PR #24411:
URL: https://github.com/apache/flink/pull/24411#discussion_r1508294826
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala:
##
@@ -1824,6 +1826,11 @@ object TableTestUtil {
[
https://issues.apache.org/jira/browse/FLINK-34491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dhruv Patel updated FLINK-34491:
Description:
This task is to move away from experimental support for Java 17 to production
suppor
[
https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822311#comment-17822311
]
Jeyhun Karimov commented on FLINK-29370:
Hi [~tanjialiang] you might need to con
[
https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hilmi Al Fatih updated FLINK-34554:
---
Description:
Flink version: 1.17.1
Kafka Broker version: 2.7.1 * 4 GB heap memory for each
[
https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hilmi Al Fatih updated FLINK-34554:
---
Description:
Flink version: 1.17.1
Kafka Broker version: 2.7.1 * 4 GB heap memory for each
[
https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hilmi Al Fatih updated FLINK-34554:
---
Priority: Blocker (was: Minor)
> Using EXACTLY_ONCE with KafkaSink cause broker's OOM due t
[
https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hilmi Al Fatih updated FLINK-34554:
---
Issue Type: Improvement (was: New Feature)
> Using EXACTLY_ONCE with KafkaSink cause broker
Hilmi Al Fatih created FLINK-34554:
--
Summary: Using EXACTLY_ONCE with KafkaSink cause broker's OOM due
to newly created transactionalId per checkpoint
Key: FLINK-34554
URL: https://issues.apache.org/jira/browse/F
Mehmet Aktas created FLINK-34553:
Summary: Time travel support by Flink catalogs
Key: FLINK-34553
URL: https://issues.apache.org/jira/browse/FLINK-34553
Project: Flink
Issue Type: Technical D
JustinLeesin commented on PR #24397:
URL: https://github.com/apache/flink/pull/24397#issuecomment-1971516132
@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 comme
JustinLeesin commented on PR #24397:
URL: https://github.com/apache/flink/pull/24397#issuecomment-1971488431
@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 comme
JustinLeesin commented on code in PR #24397:
URL: https://github.com/apache/flink/pull/24397#discussion_r1507837138
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/ProcedureITCase.java:
##
@@ -210,6 +214,31 @@ void testNamedArgu
[
https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822189#comment-17822189
]
Sergey Anokhovskiy commented on FLINK-34552:
Thank you for the comment [~mar
HuangXingBo commented on PR #24387:
URL: https://github.com/apache/flink/pull/24387#issuecomment-1971427877
@1996fanrui The test failed is actually related to the implementation of
`Duration`. Now, `Duration` is a wrapper for the java class in the JVM created
by `gateway`. If `Duration` is
[
https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822172#comment-17822172
]
Martijn Visser edited comment on FLINK-34552 at 2/29/24 3:13 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822172#comment-17822172
]
Martijn Visser commented on FLINK-34552:
A couple of points from my point of vie
morazow commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1507732247
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SN
[
https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822169#comment-17822169
]
tanjialiang commented on FLINK-29370:
-
[~jark] [~libenchao] [~maosuhan] I found that
[
https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822161#comment-17822161
]
Ashish Khatkar edited comment on FLINK-34552 at 2/29/24 2:50 PM:
-
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1507354167
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/AbstractSortPartitionOperator.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822161#comment-17822161
]
Ashish Khatkar edited comment on FLINK-34552 at 2/29/24 2:49 PM:
-
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1507354390
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java:
##
@@ -1071,6 +1077,110 @@ protected SingleOutputStreamOperator
ag
[
https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822161#comment-17822161
]
Ashish Khatkar commented on FLINK-34552:
Adding an example for this
consider tw
[
https://issues.apache.org/jira/browse/FLINK-34552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Anokhovskiy updated FLINK-34552:
---
Description:
My main proposal is to have duplicate message suppression logic as a pa
Matthias Pohl created FLINK-34551:
-
Summary: Align retry mechanisms of FutureUtils
Key: FLINK-34551
URL: https://issues.apache.org/jira/browse/FLINK-34551
Project: Flink
Issue Type: Technical
Sergey Anokhovskiy created FLINK-34552:
--
Summary: Support message deduplication for input data sources
Key: FLINK-34552
URL: https://issues.apache.org/jira/browse/FLINK-34552
Project: Flink
morazow commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1507649411
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SN
morazow commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1507649411
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SN
morazow commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1507649411
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SN
XComp commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1507624836
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SNAP
XComp commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1507624836
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SNAP
siwei.gao created FLINK-34550:
-
Summary: attempted task still report metric of
currentEmitEventTimeLag
Key: FLINK-34550
URL: https://issues.apache.org/jira/browse/FLINK-34550
Project: Flink
Issu
yuchen-ecnu commented on PR #24403:
URL: https://github.com/apache/flink/pull/24403#issuecomment-1971160199
Hi @rmetzger, thanks for the quick and detailed comments! While
async-profiler supports most platforms, not all. So that's a good suggestion to
add the "Requirements" section, and I'v
morazow commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1507558823
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SN
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822118#comment-17822118
]
Benchao Li edited comment on FLINK-34529 at 2/29/24 1:08 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822118#comment-17822118
]
Benchao Li commented on FLINK-34529:
[~xuyangzhong][~nilerzhou] Thank you for the ex
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822119#comment-17822119
]
Benchao Li commented on FLINK-34529:
[~nilerzhou] Assigned to you~
> Projection can
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-34529:
--
Assignee: yisha zhou
> Projection cannot be pushed down through rank operator.
>
pnowojski commented on code in PR #24414:
URL: https://github.com/apache/flink/pull/24414#discussion_r1507543874
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/ExecutionFailureHandler.java:
##
@@ -141,6 +155,51 @@ private CompletableFuture>
labe
StefanRRichter commented on code in PR #24414:
URL: https://github.com/apache/flink/pull/24414#discussion_r1507540785
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/ExecutionFailureHandler.java:
##
@@ -141,6 +155,51 @@ private CompletableFuture>
pnowojski commented on code in PR #24414:
URL: https://github.com/apache/flink/pull/24414#discussion_r1507538335
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/ExecutionFailureHandler.java:
##
@@ -141,6 +155,51 @@ private CompletableFuture>
labe
StefanRRichter commented on code in PR #24414:
URL: https://github.com/apache/flink/pull/24414#discussion_r1507536006
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/ExecutionFailureHandler.java:
##
@@ -141,6 +150,48 @@ private CompletableFuture>
pnowojski commented on code in PR #24414:
URL: https://github.com/apache/flink/pull/24414#discussion_r1507534949
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/ExecutionFailureHandler.java:
##
@@ -141,6 +150,48 @@ private CompletableFuture>
labe
1 - 100 of 197 matches
Mail list logo
