[
https://issues.apache.org/jira/browse/FLINK-35353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35353:
---
Labels: pull-request-available (was: )
> Translate "Profiler" page into Chinese
>
fhtrancoso commented on PR #83:
URL: https://github.com/apache/flink-training/pull/83#issuecomment-2112812806
Wrong base branch.
--
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
fhtrancoso closed pull request #83: [Module 1] Lab1 and Lab2 done
URL: https://github.com/apache/flink-training/pull/83
--
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
flinkbot commented on PR #24792:
URL: https://github.com/apache/flink/pull/24792#issuecomment-2112771239
## CI report:
* 2350fd3bacf5615be7997ad8fdc427f0048e79dd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846647#comment-17846647
]
Ferenc Csaky edited comment on FLINK-35358 at 5/15/24 2:51 PM:
---
This
flinkbot commented on PR #24791:
URL: https://github.com/apache/flink/pull/24791#issuecomment-2112758785
## CI report:
* 4cd4046d28fecc8e65408c87fd17ac4929b42138 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ferenc-csaky opened a new pull request, #24792:
URL: https://github.com/apache/flink/pull/24792
1.19 backport of https://github.com/apache/flink/pull/24791.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35358:
---
Labels: pull-request-available (was: )
> Breaking change when loading artifacts
>
ferenc-csaky opened a new pull request, #24791:
URL: https://github.com/apache/flink/pull/24791
## What is the purpose of the change
With
https://github.com/apache/flink/commit/e63aa12252843d0098a56f3091b28d48aff5b5af
in Flink 1.19 an unintentional change were introduced, that now
fhtrancoso opened a new pull request, #83:
URL: https://github.com/apache/flink-training/pull/83
- Implementing ride-cleaning filtering only rides that started and finished
within NYC range;
- rides-and-fares, TaxiRide and TaxiFare records may come in different
order, so we need to have
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846647#comment-17846647
]
Ferenc Csaky commented on FLINK-35358:
--
This change was unintentional. Restricting JARs to only be
flinkbot commented on PR #24790:
URL: https://github.com/apache/flink/pull/24790#issuecomment-2112623650
## CI report:
* f805504f4d19cd1b3b14824aa17abfebd8084c3b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35361:
---
Labels: pull-request-available (was: )
> Delete Flinkhistory files that failed to write to
d20162416 opened a new pull request, #24790:
URL: https://github.com/apache/flink/pull/24790
## What is the purpose of the change
*This pull request adds a code: when Flink History writes a file failed or
writes a file incompleted in local , it will delete the local file to avoid the
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846631#comment-17846631
]
Jeyhun Karimov commented on FLINK-35289:
Hi [~ekanthi] could you please provide a concrete
[
https://issues.apache.org/jira/browse/FLINK-35361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengxaing updated FLINK-35361:
--
Affects Version/s: 1.19.0
1.18.0
1.17.0
dengxaing created FLINK-35361:
-
Summary: Delete Flinkhistory files that failed to write to the
local directory
Key: FLINK-35361
URL: https://issues.apache.org/jira/browse/FLINK-35361
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846626#comment-17846626
]
Shuai Xu commented on FLINK-34380:
--
Hi [~rovboyko] , sorry for late reply.
For the incorrect order of
911432 closed pull request #3321: Update postgres-cdc.md
URL: https://github.com/apache/flink-cdc/pull/3321
--
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,
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846609#comment-17846609
]
Muhammet Orazov edited comment on FLINK-20392 at 5/15/24 12:25 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846609#comment-17846609
]
Muhammet Orazov commented on FLINK-20392:
-
Thanks [~lorenzo.affetti] ,
Zakelly commented on code in PR #24766:
URL: https://github.com/apache/flink/pull/24766#discussion_r1601510494
##
docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -292,4 +292,25 @@ The final checkpoint would be triggered immediately after
all operators
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846597#comment-17846597
]
Piotr Nowojski commented on FLINK-33109:
Hi!
{quote}
I guess this bug has been fixed in 1.17.2
gaborgsomogyi commented on code in PR #825:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/825#discussion_r1601464660
##
docker-entrypoint.sh:
##
@@ -22,6 +22,27 @@ args=("$@")
cd /flink-kubernetes-operator || exit
+maybe_enable_jemalloc() {
+if [
gaborgsomogyi commented on code in PR #825:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/825#discussion_r1601440347
##
docker-entrypoint.sh:
##
@@ -22,6 +22,27 @@ args=("$@")
cd /flink-kubernetes-operator || exit
+maybe_enable_jemalloc() {
+if [
vahmed-hamdy commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601406910
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java:
##
@@ -62,6 +62,7 @@
*
* @param
vahmed-hamdy commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601405551
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubSinkV2Builder.java:
##
@@ -0,0 +1,93 @@
+package
JingGe commented on code in PR #24788:
URL: https://github.com/apache/flink/pull/24788#discussion_r1601394755
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java:
##
@@ -234,20 +234,16 @@ private static boolean
whhe commented on PR #109:
URL:
https://github.com/apache/flink-connector-jdbc/pull/109#issuecomment-2112157138
@eskabetxe PTAL
--
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
morazow commented on PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#issuecomment-2112125712
Thanks @vahmed-hamdy, great work!
Added some minor suggestions. And a point for number of retries on failure
--
This is an automated message from the Apache Git
morazow commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601341788
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubSinkV2Builder.java:
##
@@ -0,0 +1,93 @@
+package
[
https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
王俊博 updated FLINK-35360:
Summary: [Feature] Submit Flink CDC pipeline job yarn Application mode
(was: [Feature] Submit Flink CDC pipeline
王俊博 created FLINK-35360:
---
Summary: [Feature] Submit Flink CDC pipeline job to yarn
Application mode
Key: FLINK-35360
URL: https://issues.apache.org/jira/browse/FLINK-35360
Project: Flink
Issue Type:
[ https://issues.apache.org/jira/browse/FLINK-34904 ]
王俊博 deleted comment on FLINK-34904:
-
was (Author: kwafor):
For now flink-cdc pipeline support cli yarn session mode submit.I'm willing to
support yarn application mode submit, could assign it to
Xuannan Su created FLINK-35359:
--
Summary: General Improvement to Configuration for Flink 2.0
Key: FLINK-35359
URL: https://issues.apache.org/jira/browse/FLINK-35359
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846571#comment-17846571
]
王俊博 edited comment on FLINK-34904 at 5/15/24 9:50 AM:
--
For now flink-cdc pipeline
[
https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846571#comment-17846571
]
王俊博 edited comment on FLINK-34904 at 5/15/24 9:49 AM:
--
For now flink-cdc pipeline
[
https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846571#comment-17846571
]
王俊博 commented on FLINK-34904:
-
For now flink-cdc pipeline support cli yarn session mode submit.I'm willing
[
https://issues.apache.org/jira/browse/FLINK-35357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846569#comment-17846569
]
Rui Fan commented on FLINK-35357:
-
IIUC, kubernetes.operator.plugins.listeners..class is similar to
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846567#comment-17846567
]
Alexey Novakov commented on FLINK-25920:
It also appears in Flink 1.17
> Allow receiving
[
https://issues.apache.org/jira/browse/FLINK-35357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846566#comment-17846566
]
Rui Fan commented on FLINK-35357:
-
Thanks [~xinzhuxianshenger] for reporting this JIRA. I checked the
[
https://issues.apache.org/jira/browse/FLINK-35357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-35357:
---
Assignee: Yang Zhou
> Add "kubernetes.operator.plugins.listeners" parameter description to the
>
[
https://issues.apache.org/jira/browse/FLINK-35153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-35153.
-
Resolution: Fixed
> Internal Async State Implementation and StateDescriptor for Map/List State
[
https://issues.apache.org/jira/browse/FLINK-35153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846563#comment-17846563
]
Zakelly Lan commented on FLINK-35153:
-
Merged into master via 73a7e1cc
> Internal Async State
Zakelly closed pull request #24781: [FLINK-35153][State] Internal async
list/map state and corresponding state descriptor
URL: https://github.com/apache/flink/pull/24781
--
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-26821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846558#comment-17846558
]
Lorenzo Affetti commented on FLINK-26821:
-
[~mzuehlke] are you working on this?
Otherwise I
Zakelly commented on code in PR #24748:
URL: https://github.com/apache/flink/pull/24748#discussion_r1601239723
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java:
##
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-20625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846554#comment-17846554
]
Lorenzo Affetti commented on FLINK-20625:
-
[~clmccart] still actively working on this?
>
[
https://issues.apache.org/jira/browse/FLINK-24299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846551#comment-17846551
]
Lorenzo Affetti commented on FLINK-24299:
-
I see there is no pull request for this issue, I
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846549#comment-17846549
]
Rasmus Thygesen commented on FLINK-35358:
-
I would like to add that we have a project where
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846540#comment-17846540
]
Matthias Pohl commented on FLINK-20392:
---
Thanks for the write-up. I'm just wondering whether we
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35358:
Description:
We have been using the following code snippet in our Dockerfiles for running
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1600156895
##
README.md:
##
@@ -8,6 +8,14 @@ Apache Flink is an open source stream processing framework
with powerful stream-
Learn more about Flink at
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846536#comment-17846536
]
Martijn Visser commented on FLINK-35358:
[~ferenc-csaky] [~mbalassi] Any thoughts on this one?
flinkbot commented on PR #24789:
URL: https://github.com/apache/flink/pull/24789#issuecomment-2111840165
## CI report:
* c93a842f7d8ef102428d784f68771414066cd451 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
PatrickRen commented on PR #3308:
URL: https://github.com/apache/flink-cdc/pull/3308#issuecomment-2111834224
@aiwenmo Could you backport the commit to release-3.1? Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
PatrickRen merged PR #3308:
URL: https://github.com/apache/flink-cdc/pull/3308
--
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:
fredia opened a new pull request, #24789:
URL: https://github.com/apache/flink/pull/24789
## What is the purpose of the change
This pr integrates snapshot file-merging with existing ITCases by enabling
file-merging in TestStreamEnvironment randomly.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32092:
---
Labels: pull-request-available (was: )
> Integrate snapshot file-merging with existing IT
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35358:
Description:
We have been using the following code snippet in our Dockerfiles for running
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35358:
Description:
We have been using the following code snippet in our Dockerfiles for running
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846535#comment-17846535
]
Lorenzo Affetti commented on FLINK-20392:
-
[~m.orazow] and I found ourselves working on two
Rasmus Thygesen created FLINK-35358:
---
Summary: Breaking change when loading artifacts
Key: FLINK-35358
URL: https://issues.apache.org/jira/browse/FLINK-35358
Project: Flink
Issue Type: New
flinkbot commented on PR #24788:
URL: https://github.com/apache/flink/pull/24788#issuecomment-2111798960
## CI report:
* 5ceaf0e8216ebcdcb09ce4a0c9574962789ee9c3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jeyhunkarimov commented on code in PR #24600:
URL: https://github.com/apache/flink/pull/24600#discussion_r1601116454
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java:
##
@@ -236,6 +238,9 @@ private void
jeyhunkarimov commented on code in PR #24600:
URL: https://github.com/apache/flink/pull/24600#discussion_r1601116454
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java:
##
@@ -236,6 +238,9 @@ private void
jeyhunkarimov commented on code in PR #24600:
URL: https://github.com/apache/flink/pull/24600#discussion_r1601116454
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java:
##
@@ -236,6 +238,9 @@ private void
ldadima commented on PR #24784:
URL: https://github.com/apache/flink/pull/24784#issuecomment-2111794984
> ## CI report:
> *
[309cf5b](https://github.com/apache/flink/commit/309cf5b7c295a56527b71ac0a1869ce06cd3a244)
Azure:
[
https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reopened FLINK-34379:
Reopening because of patch needed, as a result of the comment:
jeyhunkarimov opened a new pull request, #24788:
URL: https://github.com/apache/flink/pull/24788
## 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
MartijnVisser commented on code in PR #102:
URL:
https://github.com/apache/flink-connector-kafka/pull/102#discussion_r1601097465
##
.github/workflows/push_pr.yml:
##
@@ -28,21 +28,16 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.17.2 ]
-
XComp commented on code in PR #24471:
URL: https://github.com/apache/flink/pull/24471#discussion_r1600075906
##
flink-end-to-end-tests/flink-batch-sql-test/src/test/java/org/apache/flink/sql/tests/GeneratedRow.java:
##
@@ -0,0 +1,169 @@
+/*
+ * Licensed to the Apache Software
spoon-lz commented on PR #24461:
URL: https://github.com/apache/flink/pull/24461#issuecomment-2111766768
@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.
fredia commented on code in PR #24748:
URL: https://github.com/apache/flink/pull/24748#discussion_r1601082456
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperatorV2.java:
##
@@ -188,6 +190,35 @@
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846520#comment-17846520
]
Roman Boyko edited comment on FLINK-34380 at 5/15/24 7:14 AM:
--
Hi
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846520#comment-17846520
]
Roman Boyko commented on FLINK-34380:
-
Hi [~xuyangzhong] ! Thank you for your reply.
Yes, you're
[ https://issues.apache.org/jira/browse/FLINK-34380 ]
Roman Boyko deleted comment on FLINK-34380:
-
was (Author: rovboyko):
Hi [~xuyangzhong] ! Thank you for your reply.
> Strange RowKind and records about intermediate output when using
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846516#comment-17846516
]
Roman Boyko commented on FLINK-34380:
-
Hi [~xuyangzhong] ! Thank you for your reply.
> Strange
[
https://issues.apache.org/jira/browse/FLINK-33925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33925:
Fix Version/s: opensearch-2.0.0
> Extended failure handling for bulk requests
dongwoo6kim commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#discussion_r1601015487
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java:
##
@@ -122,27 +122,21 @@ public
[
https://issues.apache.org/jira/browse/FLINK-30537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-30537.
---
Resolution: Fixed
Closed in favor of FLINK-33859
> Add support for OpenSearch 2.3
>
[
https://issues.apache.org/jira/browse/FLINK-34942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-34942.
-
Fix Version/s: opensearch-1.2.0
opensearch-2.0.0
Resolution:
[
https://issues.apache.org/jira/browse/FLINK-34942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846511#comment-17846511
]
Sergey Nuyanzin commented on FLINK-34942:
-
Merged as
dongwoo6kim commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#discussion_r1601015487
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java:
##
@@ -122,27 +122,21 @@ public
snuyanzin commented on code in PR #102:
URL:
https://github.com/apache/flink-connector-kafka/pull/102#discussion_r1601012883
##
.github/workflows/push_pr.yml:
##
@@ -28,21 +28,16 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.17.2 ]
-
snuyanzin commented on code in PR #102:
URL:
https://github.com/apache/flink-connector-kafka/pull/102#discussion_r1601012883
##
.github/workflows/push_pr.yml:
##
@@ -28,21 +28,16 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.17.2 ]
-
101 - 186 of 186 matches
Mail list logo
