[
https://issues.apache.org/jira/browse/FLINK-34545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34545:
---
Labels: pull-request-available (was: )
> Add OceanBase pipeline connector to Flink CDC
> --
zhuzhurk commented on code in PR #24771:
URL: https://github.com/apache/flink/pull/24771#discussion_r1612975806
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java:
##
@@ -0,0 +1,1217 @@
+/*
+ * Licensed to the Apache Softwar
zhuzhurk commented on code in PR #24771:
URL: https://github.com/apache/flink/pull/24771#discussion_r1612986632
##
flink-tests/src/test/java/org/apache/flink/test/scheduling/JMFailoverITCase.java:
##
@@ -98,7 +98,7 @@
import java.util.stream.IntStream;
import static org.apac
JunRuiLee commented on code in PR #24771:
URL: https://github.com/apache/flink/pull/24771#discussion_r1612997227
##
flink-tests/src/test/java/org/apache/flink/test/scheduling/JMFailoverITCase.java:
##
@@ -98,7 +98,7 @@
import java.util.stream.IntStream;
import static org.apa
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849209#comment-17849209
]
xuyang commented on FLINK-34380:
Hi, [~rovboyko] . +1 to fix the wrong order. I'll take
LvYanquan created FLINK-35444:
-
Summary: Paimon Pipeline Connector support changing column names
to lowercase for Hive metastore
Key: FLINK-35444
URL: https://issues.apache.org/jira/browse/FLINK-35444
Pro
davidradl commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1613069596
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to
davidradl commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1613069596
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to
dawidwys merged PR #24834:
URL: https://github.com/apache/flink/pull/24834
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-35437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-35437.
--
Resolution: Fixed
Fixed in 3d40bd7dd197b12b7b156bd758b4129148e885d1
> BlockStatementG
davidradl commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1613069596
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to
zoltar9264 commented on code in PR #24833:
URL: https://github.com/apache/flink/pull/24833#discussion_r1613094184
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStWriteBatchOperation.java:
##
@@ -75,7 +74,10 @@ public CompletableFu
davidradl commented on code in PR #24835:
URL: https://github.com/apache/flink/pull/24835#discussion_r1613096352
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DefaultLineageDataset.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software F
yuanoOo commented on PR #3360:
URL: https://github.com/apache/flink-cdc/pull/3360#issuecomment-2128951367
Please trigger the CI again，I have removed the snapshot dependency.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
leonardBang commented on code in PR #3300:
URL: https://github.com/apache/flink-cdc/pull/3300#discussion_r1613103947
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/connection/JdbcConnectionPoolFactory.java:
#
davidradl commented on code in PR #24835:
URL: https://github.com/apache/flink/pull/24835#discussion_r1613096352
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DefaultLineageDataset.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software F
davidradl commented on code in PR #24835:
URL: https://github.com/apache/flink/pull/24835#discussion_r1613106837
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DefaultLineageDataset.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software F
davidradl commented on code in PR #24835:
URL: https://github.com/apache/flink/pull/24835#discussion_r1613112277
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DefaultLineageDataset.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software F
davidradl commented on code in PR #24835:
URL: https://github.com/apache/flink/pull/24835#discussion_r1613118293
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DefaultLineageDataset.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software F
yuxiqian commented on PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#issuecomment-2128993381
@PatrickRen @leonardBang 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 specif
[
https://issues.apache.org/jira/browse/FLINK-35272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35272:
--
Assignee: yux
> Pipeline Transform job supports omitting / renaming calculation column
>
[
https://issues.apache.org/jira/browse/FLINK-35272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849224#comment-17849224
]
Leonard Xu commented on FLINK-35272:
Thanks [~xiqian_yu] for taking this ticket, ass
[
https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35301:
---
Affects Version/s: 3.1.0
> Fix deadlock when loading driver classes
> --
[
https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35301:
---
Description:
In JDK 8 and earlier version, if multiple threads invoking
Class.forName("com.xx.Drive
[
https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35301:
---
Description:
In JDK 8 and earlier version, if multiple threads invoking
Class.forName("com.xx.Drive
lvyanquan commented on PR #3039:
URL: https://github.com/apache/flink-cdc/pull/3039#issuecomment-2129028432
Hi @dufeng1010 can you help to rebase to master？
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
Shawn-Hx commented on code in PR #3300:
URL: https://github.com/apache/flink-cdc/pull/3300#discussion_r1613143714
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/connection/JdbcConnectionPoolFactory.java:
[
https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35301:
---
Description:
In JDK 8 and earlier version, if multiple threads invoke
Class.forName("com.xx.Driver"
[
https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849226#comment-17849226
]
Leonard Xu commented on FLINK-35301:
Thanks [~ShawnHx] for report this issue, I saw
[
https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35301:
--
Assignee: Xiao Huang
> Fix deadlock when loading driver classes
> ---
[
https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35301:
---
Fix Version/s: cdc-3.2.0
> Fix deadlock when loading driver classes
> --
[
https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35301:
---
Affects Version/s: cdc-3.1.0
(was: 3.1.0)
> Fix deadlock when loading dri
[
https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35294:
---
Affects Version/s: 3.1.0
> Use source config to check if the filter should be applied in timestamp
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611984504
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35294:
---
Description:
Since MySQL does not support the ability to quickly locate an binlog offset
through a
[
https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849229#comment-17849229
]
Muhammet Orazov commented on FLINK-34582:
-
Ohh no. Yes indeed you are right [~ma
[
https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35294:
---
Affects Version/s: cdc-3.1.0
> Use source config to check if the filter should be applied in timesta
[
https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35294:
---
Fix Version/s: cdc-3.2.0
> Use source config to check if the filter should be applied in timestamp
[
https://issues.apache.org/jira/browse/FLINK-35295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35295:
---
Description: As described in ticket title.
> Improve jdbc connection pool initialization failure mes
[
https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35298:
---
Description:
* In snapshot phase, set -1 as the value of currentFetchEventTimeLag metric.
* Support
loserwang1024 commented on code in PR #3349:
URL: https://github.com/apache/flink-cdc/pull/3349#discussion_r1613185257
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.
loserwang1024 commented on code in PR #3349:
URL: https://github.com/apache/flink-cdc/pull/3349#discussion_r1613185257
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.
[
https://issues.apache.org/jira/browse/FLINK-35297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35297:
---
Description: the value of option `connector.timeout` needs to be checked at
compile time.
> Add val
leonardBang commented on code in PR #3349:
URL: https://github.com/apache/flink-cdc/pull/3349#discussion_r1613201109
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.ja
[
https://issues.apache.org/jira/browse/FLINK-35300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35300:
---
Description: As described in title.
> Improve MySqlStreamingChangeEventSource to skip null events in
leonardBang merged PR #3298:
URL: https://github.com/apache/flink-cdc/pull/3298
--
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
[
https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35298:
---
Affects Version/s: cdc-3.1.0
> Improve metric reporter logic
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35298:
---
Fix Version/s: cdc-3.2.0
> Improve metric reporter logic
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35298:
--
Assignee: Xiao Huang
> Improve metric reporter logic
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35298.
Resolution: Implemented
via master: 8e8fd304afdd9668247a8869698e0949806cad7b
> Improve metric rep
hlteoh37 commented on PR #190:
URL: https://github.com/apache/flink-docker/pull/190#issuecomment-2129138391
@MartijnVisser can we merge this?
--
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 s
[
https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35408:
---
Description:
Now, MySQL CDC connector will retrieve the number of seconds the
database-configured t
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1613226372
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,51 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY
[
https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35408:
---
Description:
Now, MySQL CDC connector will retrieve the offset seconds between the
configured timez
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1613227700
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,51 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY
[
https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35409:
---
Description:
Suppose this scenario: A job is still in the snapshot phase, and the remaining
uncompl
[
https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35409:
---
Issue Type: Bug (was: Improvement)
> Request more splits if all splits are filtered from addSplits
[
https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35408:
---
Fix Version/s: cdc-3.2.0
> Add 30 min tolerance value when validating the time-zone setting
> --
[
https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35409:
---
Affects Version/s: cdc-3.1.0
> Request more splits if all splits are filtered from addSplits method
[
https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35409:
---
Fix Version/s: cdc-3.2.0
> Request more splits if all splits are filtered from addSplits method
> --
[
https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiao Huang updated FLINK-35408:
---
Affects Version/s: cdc-3.1.0
> Add 30 min tolerance value when validating the time-zone setting
> --
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1613261308
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,51 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY
davidradl commented on PR #24835:
URL: https://github.com/apache/flink/pull/24835#issuecomment-2129222164
Shouldn't this pr go in after
[https://github.com/apache/flink/pull/24618](https://github.com/apache/flink/pull/24618)
--
This is an automated message from the Apache Git Service.
T
MartijnVisser merged PR #190:
URL: https://github.com/apache/flink-docker/pull/190
--
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-34746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-34746.
--
Resolution: Fixed
Fixed in apache/flink-docker@master 883600747505c128d97e9d25c9326f0c6f1d31e4
twalthr commented on code in PR #24818:
URL: https://github.com/apache/flink/pull/24818#discussion_r1613283206
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionMiscITCase.java:
##
@@ -384,4 +410,15 @@ public static class Local
davidradl commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1613290123
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/LineageGraph.java:
##
@@ -20,13 +20,12 @@
package org.apache.flink.streaming.api.lineage
[
https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Hamdy updated FLINK-35435:
Attachment: Screenshot 2024-05-24 at 11.06.30.png
Screenshot 2024-05-24 at 12.06.20
zhuzhurk commented on code in PR #24771:
URL: https://github.com/apache/flink/pull/24771#discussion_r1612975806
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java:
##
@@ -0,0 +1,1217 @@
+/*
+ * Licensed to the Apache Softwar
yuxiqian commented on PR #3348:
URL: https://github.com/apache/flink-cdc/pull/3348#issuecomment-2129300597
Pushed another commit to resolve CI issue, could @leonardBang please
re-trigger the CI? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849270#comment-17849270
]
Ahmed Hamdy commented on FLINK-35435:
-
h1. Non-Functional Backward compatibility
To
Ahmed Hamdy created FLINK-35445:
---
Summary: Update Async Sink documentation for Timeout configuration
Key: FLINK-35445
URL: https://issues.apache.org/jira/browse/FLINK-35445
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-35445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Hamdy updated FLINK-35445:
Parent: FLINK-35435
Issue Type: Sub-task (was: Improvement)
> Update Async Sink documenta
Ryan Skraba created FLINK-35446:
---
Summary: FileMergingSnapshotManagerBase throws a
NullPointerException
Key: FLINK-35446
URL: https://issues.apache.org/jira/browse/FLINK-35446
Project: Flink
I
vahmed-hamdy opened a new pull request, #24839:
URL: https://github.com/apache/flink/pull/24839
## What is the purpose of the change
Implementation of
[FLIP-451](https://cwiki.apache.org/confluence/display/FLINK/FLIP-451%3A+Introduce+timeout+configuration+to+AsyncSink+API)
in
[
https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35435:
---
Labels: pull-request-available (was: )
> [FLIP-451] Introduce timeout configuration to Asyn
flinkbot commented on PR #24839:
URL: https://github.com/apache/flink/pull/24839#issuecomment-2129354320
## CI report:
* 2b91a9c92af7d97d492a9c83d43d7c544f85d355 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849272#comment-17849272
]
Ahmed Hamdy commented on FLINK-35435:
-
[~danny.cranmer] Could you please take a look
Zhongqiang Gong created FLINK-35447:
---
Summary: Flink CDC Document document file had removed but website
can access
Key: FLINK-35447
URL: https://issues.apache.org/jira/browse/FLINK-35447
Project: Fl
zoltar9264 commented on code in PR #24833:
URL: https://github.com/apache/flink/pull/24833#discussion_r1613094184
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStWriteBatchOperation.java:
##
@@ -75,7 +74,10 @@ public CompletableFu
GOODBOY008 opened a new pull request, #3362:
URL: https://github.com/apache/flink-cdc/pull/3362
Solution:
Deletes files from the destination directory that are not present in the
source directory.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
GOODBOY008 commented on PR #3362:
URL: https://github.com/apache/flink-cdc/pull/3362#issuecomment-2129373300
@leonardBang 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 comment
[
https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35447:
---
Labels: pull-request-available (was: )
> Flink CDC Document document file had removed but w
zhuzhurk commented on code in PR #24771:
URL: https://github.com/apache/flink/pull/24771#discussion_r1612989352
##
flink-tests/src/test/java/org/apache/flink/test/scheduling/JMFailoverITCase.java:
##
@@ -532,9 +508,9 @@ private JobGraph
createJobGraphWithUnsupportedBatchSnapsho
davidradl commented on code in PR #24741:
URL: https://github.com/apache/flink/pull/24741#discussion_r1613388125
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTestBase.java:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Found
morazow commented on code in PR #3349:
URL: https://github.com/apache/flink-cdc/pull/3349#discussion_r1613394340
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.java:
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849282#comment-17849282
]
Ryan Skraba commented on FLINK-28440:
-
* 1.19 Hadoop 3.1.3 / Test (module: tests)
h
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849283#comment-17849283
]
Ryan Skraba commented on FLINK-35342:
-
* 1.20 AdaptiveScheduler / Test (module: tabl
[
https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849284#comment-17849284
]
Ryan Skraba commented on FLINK-35446:
-
* 1.20 Java 11 / Test (module: tests)
https:
[
https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849285#comment-17849285
]
Ryan Skraba commented on FLINK-35446:
-
[~lijinzhong] or [~zakelly] Do you think this
morazow commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2129446733
Hey @XComp, @HuangXingBo ,
What do you think of the latest commit changes for migration?
This way both Linux & MacOS platform use similar build system, we also don't
depend o
MartijnVisser commented on PR #190:
URL: https://github.com/apache/flink-docker/pull/190#issuecomment-2129446485
@hlteoh37 Done, but I'm not sure if this actually needs to be backported to
the other branches. @lincoln-lil do you know?
--
This is an automated message from the Apache Git Se
ViktorCosenza commented on PR #24795:
URL: https://github.com/apache/flink/pull/24795#issuecomment-2129462557
@JingGe Are you able to trigger the CI manually? I think I't wasnt triggered
after the squash because no changes were detected.
--
This is an automated message from the Apache Git
morazow commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2129494739
Test run built wheel artifacts:
https://github.com/morazow/flink/actions/runs/9224143298
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
Caican Cai created FLINK-35448:
--
Summary: Translate pod templates documentation into Chinese
Key: FLINK-35448
URL: https://issues.apache.org/jira/browse/FLINK-35448
Project: Flink
Issue Type: Su
[
https://issues.apache.org/jira/browse/FLINK-35448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35448:
---
Labels: pull-request-available (was: )
> Translate pod templates documentation into Chinese
caicancai opened a new pull request, #830:
URL: https://github.com/apache/flink-kubernetes-operator/pull/830
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment` cu
afedulov opened a new pull request, #831:
URL: https://github.com/apache/flink-kubernetes-operator/pull/831
## What is the purpose of the change
The admission webhook currently does not verify if FlinkDeployment CR
utilizes Flink versions that are not supported by the Operator. This c
[
https://issues.apache.org/jira/browse/FLINK-35052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35052:
---
Labels: pull-request-available (was: )
> Webhook validator should reject unsupported Flink
reta commented on code in PR #104:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/104#discussion_r1613488632
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8TestUtils.java:
##
@@ -0,0 +1,69 @@
+packa
1 - 100 of 135 matches
Mail list logo
