[
https://issues.apache.org/jira/browse/FLINK-36460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36460:
---
Labels: pull-request-available (was: )
> Refactor Kubernetes Operator Edge to Edge test set
SamBarker opened a new pull request, #893:
URL: https://github.com/apache/flink-kubernetes-operator/pull/893
## What is the purpose of the change
As observed in
[FLINK-36332](https://github.com/apache/flink-kubernetes-operator/pull/881#issuecomment-2378765602)
the CI workflow has bec
flinkbot commented on PR #25477:
URL: https://github.com/apache/flink/pull/25477#issuecomment-2404181439
## CI report:
* ea2e19fbae18568d95b7195492cbe3ef448f1892 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25476:
URL: https://github.com/apache/flink/pull/25476#issuecomment-2404177936
## CI report:
* 4cf5dec3610ec538a01e66210e753478fb6ff216 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Shawn-Hx opened a new pull request, #3631:
URL: https://github.com/apache/flink-cdc/pull/3631
FlinkCDC uses debezium for capturing and parsing incremental data, but
during the snapshot phase, FlinkCDC uses its own designed read implementation,
so for FlinkCDC, some debezium options do not t
[
https://issues.apache.org/jira/browse/FLINK-36463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36463:
---
Labels: pull-request-available (was: )
> Disable some debezium options which do not take ef
mateczagany opened a new pull request, #25477:
URL: https://github.com/apache/flink/pull/25477
Backport of #21885
--
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 unsubsc
flinkbot commented on PR #25475:
URL: https://github.com/apache/flink/pull/25475#issuecomment-2404151228
## CI report:
* 9caf8bd67c561f901965887f6276486a2dbd2518 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mateczagany opened a new pull request, #25476:
URL: https://github.com/apache/flink/pull/25476
Backport of #21885
--
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 unsubsc
flinkbot commented on PR #25474:
URL: https://github.com/apache/flink/pull/25474#issuecomment-2404137411
## CI report:
* c6840733ae17fbf7dc3d47e283dcba5b879716a3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Xiao Huang created FLINK-36463:
--
Summary: Disable some debezium options which do not take effect
Key: FLINK-36463
URL: https://issues.apache.org/jira/browse/FLINK-36463
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-36423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36423:
---
Labels: pull-request-available (was: )
> RichMapPartitionFunction does not invoke the open
reswqa commented on code in PR #25452:
URL: https://github.com/apache/flink/pull/25452#discussion_r1794735269
##
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/KeyedPartitionWindowedStreamITCase.java:
##
@@ -97,6 +101,42 @@ public void mapPartition(
reswqa commented on code in PR #25452:
URL: https://github.com/apache/flink/pull/25452#discussion_r1794735269
##
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/KeyedPartitionWindowedStreamITCase.java:
##
@@ -97,6 +101,42 @@ public void mapPartition(
snuyanzin commented on code in PR #21161:
URL: https://github.com/apache/flink/pull/21161#discussion_r1794733051
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java:
##
@@ -32,7 +32,7 @@
/** Integration tests of
[
https://issues.apache.org/jira/browse/FLINK-36414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888148#comment-17888148
]
LvYanquan commented on FLINK-36414:
---
I would like to fix the compatiblity with flink-1
reswqa opened a new pull request, #25475:
URL: https://github.com/apache/flink/pull/25475
## What is the purpose of the change
*Update rest documentation*
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
## Does
[
https://issues.apache.org/jira/browse/FLINK-36462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuhuang updated FLINK-36462:
Summary: Restore per-job mode (was: Revert "remove per-job")
> Restore per-job mode
> ---
[
https://issues.apache.org/jira/browse/FLINK-36462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuhuang updated FLINK-36462:
Description:
JIRA https://issues.apache.org/jira/browse/FLINK-36310 and pull request
https://github.com/a
xuhuang created FLINK-36462:
---
Summary: Revert "remove per-job"
Key: FLINK-36462
URL: https://issues.apache.org/jira/browse/FLINK-36462
Project: Flink
Issue Type: Bug
Reporter: xuhuang
[
https://issues.apache.org/jira/browse/FLINK-36447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36447:
---
Labels: pull-request-available (was: )
> Add .java-version(generated by jenv) to git ignore
reswqa opened a new pull request, #25474:
URL: https://github.com/apache/flink/pull/25474
## What is the purpose of the change
*Add .java-version to git ignore*
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
#
yux created FLINK-36461:
---
Summary: YAML job failed to schema evolve with unmatched transform
tables
Key: FLINK-36461
URL: https://issues.apache.org/jira/browse/FLINK-36461
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-36447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36447:
---
Summary: Add .java-version(generated by jenv) to git ignore (was: Add
.java-version(generated by je
r-sidd commented on PR #25463:
URL: https://github.com/apache/flink/pull/25463#issuecomment-2404069277
@ferenc-csaky I've pushed the changes now
--
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 th
r-sidd commented on PR #25463:
URL: https://github.com/apache/flink/pull/25463#issuecomment-2404062534
> Can you pls update the version in the notice file as well, like here:
#18228
>
> (The documentation do not contain it anymore.)
Sure thing, will do now
--
This is an auto
Juoelenis commented on PR #25463:
URL: https://github.com/apache/flink/pull/25463#issuecomment-2404028171
I aproovd
--
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 unsub
[
https://issues.apache.org/jira/browse/FLINK-36440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-36440:
Assignee: Siddharth R
> Bump log4j from 2.17.1 to 2.24.1
> --
reswqa merged PR #25466:
URL: https://github.com/apache/flink/pull/25466
--
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
ferenc-csaky commented on code in PR #25463:
URL: https://github.com/apache/flink/pull/25463#discussion_r1794652460
##
pom.xml:
##
@@ -127,7 +127,7 @@ under the License.
true
11
1.7.36
- 2.17.1
+ 2.23.1
[
https://issues.apache.org/jira/browse/FLINK-30899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888126#comment-17888126
]
Ferenc Csaky commented on FLINK-30899:
--
[{{08b1859}}|https://github.com/apache/flin
[
https://issues.apache.org/jira/browse/FLINK-30899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888125#comment-17888125
]
Ferenc Csaky commented on FLINK-30899:
--
Hi [~mateczagany], i think it would worth t
ferenc-csaky merged PR #21885:
URL: https://github.com/apache/flink/pull/21885
--
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-30899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-30899:
-
Fix Version/s: 2.0.0
1.19.2
1.20.1
> FileSystemTableSource
Sam Barker created FLINK-36460:
--
Summary: Refactor Kubernetes Operator Edge to Edge test setup
Key: FLINK-36460
URL: https://issues.apache.org/jira/browse/FLINK-36460
Project: Flink
Issue Type:
flinkbot commented on PR #25473:
URL: https://github.com/apache/flink/pull/25473#issuecomment-2403913805
## CI report:
* dd54c09afab52f3178da592cd9196ad3036e66b4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia opened a new pull request, #25473:
URL: https://github.com/apache/flink/pull/25473
## What is the purpose of the change
This PR removes string.format() in critical path in ForSt map state.
## Brief change log
- Remove string.format() in `ForStMapState#buildDBPu
whhe commented on PR #144:
URL:
https://github.com/apache/flink-connector-jdbc/pull/144#issuecomment-2403896256
This PR is a follow-up to
https://github.com/apache/flink-connector-jdbc/pull/109. Considering the CI
failure of https://github.com/apache/flink-connector-jdbc/pull/143, the star
LvYanquan created FLINK-36459:
-
Summary: Add document to guide user to configure debezium
properties
Key: FLINK-36459
URL: https://issues.apache.org/jira/browse/FLINK-36459
Project: Flink
Issue
zhuzhurk commented on code in PR #754:
URL: https://github.com/apache/flink-web/pull/754#discussion_r1794568585
##
docs/content/posts/2024-10-01-release-2.0-preview.md:
##
@@ -0,0 +1,1264 @@
+---
+authors:
+- xtsong:
+ name: "Xintong Song"
+date: "2024-10-01T08:00:00Z"
+subtitl
[
https://issues.apache.org/jira/browse/FLINK-36440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888120#comment-17888120
]
Siddharth R commented on FLINK-36440:
-
I was testing this about a month back, that t
r-sidd commented on code in PR #25463:
URL: https://github.com/apache/flink/pull/25463#discussion_r1794572630
##
pom.xml:
##
@@ -127,7 +127,7 @@ under the License.
true
11
1.7.36
- 2.17.1
+ 2.23.1
Revie
[
https://issues.apache.org/jira/browse/FLINK-36440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Siddharth R updated FLINK-36440:
Description:
Bumping *log4j* to the latest version (2.24.1) - this will remediate a lot of
vulner
[
https://issues.apache.org/jira/browse/FLINK-36440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Siddharth R updated FLINK-36440:
Description:
Bumping *log4j* to the latest version (2.24.1) - this will remediate a lot of
vulner
r-sidd commented on code in PR #25463:
URL: https://github.com/apache/flink/pull/25463#discussion_r1794564310
##
pom.xml:
##
@@ -127,7 +127,7 @@ under the License.
true
11
1.7.36
- 2.17.1
+ 2.23.1
Revie
Sxnan merged PR #25467:
URL: https://github.com/apache/flink/pull/25467
--
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.
xuyangzhong commented on PR #754:
URL: https://github.com/apache/flink-web/pull/754#issuecomment-2403854034
Furthermore, there’s another type of change regarding SQL Client startup
options, how about adding a category like：
List of SQL Client startup options changes
The followi
[
https://issues.apache.org/jira/browse/FLINK-36458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36458:
---
Labels: pull-request-available (was: )
> Use original 'OceanBaseCEContainer' of testcontain
He Wang created FLINK-36458:
---
Summary: Use original 'OceanBaseCEContainer' of testcontainers in
testing
Key: FLINK-36458
URL: https://issues.apache.org/jira/browse/FLINK-36458
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-36421.
-
Fix Version/s: 2.0-preview
Assignee: Marc Aurel Fritz
Resolution: Fixed
> Missin
[
https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888115#comment-17888115
]
Zakelly Lan edited comment on FLINK-36421 at 10/10/24 2:26 AM:
---
Zakelly merged PR #25468:
URL: https://github.com/apache/flink/pull/25468
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888115#comment-17888115
]
Zakelly Lan commented on FLINK-36421:
-
Merged
[fd427ff|https://github.com/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888114#comment-17888114
]
Zakelly Lan commented on FLINK-36421:
-
[~planet9] It is the java part of flink that
flinkbot commented on PR #25472:
URL: https://github.com/apache/flink/pull/25472#issuecomment-2403754374
## CI report:
* 9ab828a1b4d27f7de1c7568b8faf74dc67b2884f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36065:
---
Labels: pull-request-available (was: )
> Support for submitting StreamGraph
> -
JunRuiLee opened a new pull request, #25472:
URL: https://github.com/apache/flink/pull/25472
## What is the purpose of the change
[FLINK-36065][runtime] Support submit stream graph.
## Brief change log
[FLINK-36065][runtime] Support submit stream graph.
Jiabao-Sun commented on code in PR #21161:
URL: https://github.com/apache/flink/pull/21161#discussion_r1794452407
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java:
##
@@ -32,7 +32,7 @@
/** Integration tests o
flinkbot commented on PR #25471:
URL: https://github.com/apache/flink/pull/25471#issuecomment-2403710518
## CI report:
* 4bde8abfacf7f25ccbb6c8cc4ddd206ae7d57c51 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
nikunjagarwal321 opened a new pull request, #25471:
URL: https://github.com/apache/flink/pull/25471
## What is the purpose of the change
[NonDex](https://github.com/TestingResearchIllinois/NonDex) is a tool for
detecting and debugging wrong assumptions on under-determined Java APIs. W
aplyusnin commented on PR #891:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/891#issuecomment-2403691503
```kubernetesClient.resource(deployment).delete()``` has to be a blocking
call, but when I run the tests wtih some extra logging I saw, that 404 response
code doesn't a
github-actions[bot] commented on PR #3456:
URL: https://github.com/apache/flink-cdc/pull/3456#issuecomment-2403643960
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
[
https://issues.apache.org/jira/browse/FLINK-36457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Pilipenko updated FLINK-36457:
Description:
When using Python DataStream API with standard yaml configuration, ca
Aleksandr Pilipenko created FLINK-36457:
---
Summary: Python DataStream API: calling add_jars or add_classpaths
results in corrupted execution config
Key: FLINK-36457
URL: https://issues.apache.org/jira/browse/
SamBarker closed pull request #892: [FlINK-] Expand the matrix for the
smoke test.
URL: https://github.com/apache/flink-kubernetes-operator/pull/892
--
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
SamBarker opened a new pull request, #892:
URL: https://github.com/apache/flink-kubernetes-operator/pull/892
The goal is to remove namespace from the main CI run based on
https://github.com/apache/flink-kubernetes-operator/pull/881#discussion_r1790257507
## What is the purpose
[
https://issues.apache.org/jira/browse/FLINK-33926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33926:
---
Labels: pull-request-available (was: )
> Can't start a job with a jar in the system classpa
SamBarker commented on code in PR #25445:
URL: https://github.com/apache/flink/pull/25445#discussion_r1794173964
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java:
##
@@ -214,9 +215,12 @@ public ClusterClientProvider
deployApplicatio
snuyanzin commented on PR #21161:
URL: https://github.com/apache/flink/pull/21161#issuecomment-2403319420
@Jiabao-Sun since you are one of those who contributed a lot in JUnit5
migration may I ask you to have a look here?
--
This is an automated message from the Apache Git Service.
To res
Juoelenis commented on code in PR #25463:
URL: https://github.com/apache/flink/pull/25463#discussion_r1794127775
##
pom.xml:
##
@@ -127,7 +127,7 @@ under the License.
true
11
1.7.36
- 2.17.1
+ 2.23.1
Re
ferenc-csaky commented on code in PR #25463:
URL: https://github.com/apache/flink/pull/25463#discussion_r1794118721
##
pom.xml:
##
@@ -127,7 +127,7 @@ under the License.
true
11
1.7.36
- 2.17.1
+ 2.23.1
[
https://issues.apache.org/jira/browse/FLINK-36440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36440:
---
Labels: pull-request-available (was: )
> Bump log4j from 2.17.1 to 2.23.1
> ---
Juoelenis commented on PR #25463:
URL: https://github.com/apache/flink/pull/25463#issuecomment-2403221800
1+ aura
--
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
Juoelenis commented on PR #25469:
URL: https://github.com/apache/flink/pull/25469#issuecomment-2403214920
Big W
--
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
Juoelenis commented on PR #25470:
URL: https://github.com/apache/flink/pull/25470#issuecomment-2403211335
Very legit 👍👍👍
--
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
clmccart commented on PR #32:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/32#issuecomment-2402775724
looks like the sink rewrite was completed in
[FLINK-24298](https://issues.apache.org/jira/browse/FLINK-24298). will need to
take a look at that and probably remove the si
clmccart commented on code in PR #32:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/32#discussion_r1793809868
##
.gitignore:
##
@@ -35,4 +35,8 @@ out/
tools/flink
tools/flink-*
tools/releasing/release
-tools/japicmp-output
\ No newline at end of file
+tools/
clmccart commented on code in PR #32:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/32#discussion_r1793804145
##
ordering-keys-prober/README.md:
##
@@ -0,0 +1,75 @@
+### Introduction
+
+The prober is designed to demonstrate effective use of Cloud Pub/Sub's
+[or
clmccart commented on code in PR #32:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/32#discussion_r1793804145
##
ordering-keys-prober/README.md:
##
@@ -0,0 +1,75 @@
+### Introduction
+
+The prober is designed to demonstrate effective use of Cloud Pub/Sub's
+[or
flinkbot commented on PR #25470:
URL: https://github.com/apache/flink/pull/25470#issuecomment-2402739010
## CI report:
* 8e38de9c2f05656c51131a9d241ccab6fa8824c2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wcoqscwx commented on PR #25470:
URL: https://github.com/apache/flink/pull/25470#issuecomment-2402733236
Same change as this PR opened > 24 months ago:
https://github.com/apache/flink/pull/19684
--
This is an automated message from the Apache Git Service.
To respond to the message, please
rxp90 opened a new pull request, #25470:
URL: https://github.com/apache/flink/pull/25470
… DD_API_KEY if not present
## 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
[
https://issues.apache.org/jira/browse/FLINK-36456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36456:
---
Labels: pull-request-available (was: )
> Improve Security in DatadogHttpReporterFactory by
[
https://issues.apache.org/jira/browse/FLINK-36456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raul Garcia updated FLINK-36456:
Component/s: Runtime / Configuration
(was: Runtime / Metrics)
> Improve Secur
Raul Garcia created FLINK-36456:
---
Summary: Improve Security in DatadogHttpReporterFactory by
providing ENV alternative to retrieve API key
Key: FLINK-36456
URL: https://issues.apache.org/jira/browse/FLINK-36456
[
https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887988#comment-17887988
]
Galen Warren commented on FLINK-36455:
--
Thanks for checking, much appreciated. I ma
[
https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887987#comment-17887987
]
Arvid Heise commented on FLINK-36455:
-
I'm not an expert of the SFS but from cross c
aplyusnin opened a new pull request, #891:
URL: https://github.com/apache/flink-kubernetes-operator/pull/891
Tests that perform requests are usualy fail now on CI due to race
conditions.
To fix it, I addeв busywait for metrics with timeout as it is done in
RestApiMetricsCollectorTes
[
https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887949#comment-17887949
]
Galen Warren commented on FLINK-36455:
--
Gotcha, thanks. Presumably that wouldn't in
[
https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887948#comment-17887948
]
Arvid Heise commented on FLINK-36455:
-
Yes, all sinks following the FLIP-143 API are
[
https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-36455:
---
Assignee: Arvid Heise
> Sink should commit everything on notifyCheckpointCompleted
> --
[
https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887940#comment-17887940
]
Galen Warren commented on FLINK-36455:
--
[~arvid] I'm trying to understand the scope
dawidwys commented on PR #25298:
URL: https://github.com/apache/flink/pull/25298#issuecomment-2402337798
@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.
Arvid Heise created FLINK-36455:
---
Summary: Sink should commit everything on notifyCheckpointCompleted
Key: FLINK-36455
URL: https://issues.apache.org/jira/browse/FLINK-36455
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-36440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887927#comment-17887927
]
Ferenc Csaky commented on FLINK-36440:
--
Latest version is 2.24.1 [1], any specific
gaborgsomogyi commented on PR #25468:
URL: https://github.com/apache/flink/pull/25468#issuecomment-2402249199
Needs a green 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 com
[
https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887922#comment-17887922
]
Gabor Somogyi commented on FLINK-36421:
---
I would backport it to at least 1.20 line
gaborgsomogyi commented on PR #25468:
URL: https://github.com/apache/flink/pull/25468#issuecomment-2402241930
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-36452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36452:
--
Assignee: LvYanquan
> Avoid EOFException when reading binlog after a large table has just com
[
https://issues.apache.org/jira/browse/FLINK-36453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36453:
--
Assignee: yux
> Backport DBZ-6502 patch to fix Oracle 23.x JDBC driver compatbility
> ---
1 - 100 of 153 matches
Mail list logo
