Jinzhong Li created FLINK-34936:
---
Summary: Register shared state files to FileMergingSnapshotManager
Key: FLINK-34936
URL: https://issues.apache.org/jira/browse/FLINK-34936
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34936:
Parent: FLINK-32070
Issue Type: Sub-task (was: New Feature)
> Register shared state
[
https://issues.apache.org/jira/browse/FLINK-32529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830805#comment-17830805
]
Gyula Fora commented on FLINK-32529:
[~tbnguyen1407] please open a separate Jira ticket for this. If
[
https://issues.apache.org/jira/browse/FLINK-32529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830800#comment-17830800
]
Binh-Nguyen Tran commented on FLINK-32529:
--
[~gyfora] The added startupProbe seems to always
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830807#comment-17830807
]
Zakelly Lan commented on FLINK-34936:
-
Thanks for reporting this! Assigned to you
> Register shared
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-34936:
---
Assignee: Jinzhong Li
> Register shared state files to FileMergingSnapshotManager
>
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830807#comment-17830807
]
Zakelly Lan edited comment on FLINK-34936 at 3/26/24 6:57 AM:
--
Thanks for
fredia commented on PR #24513:
URL: https://github.com/apache/flink/pull/24513#issuecomment-2019523721
@Zakelly Thanks for the review and suggestions, I have addressed the
comments and squashed commits, please take a look if you're free, thanks.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830812#comment-17830812
]
Matthias Pohl commented on FLINK-34643:
---
Should we try to reproduce the test failure in a PR by
[
https://issues.apache.org/jira/browse/FLINK-34656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830816#comment-17830816
]
yisha zhou commented on FLINK-34656:
[~libenchao] Hi ,sorry for the late reply. To reproduce the
Zakelly commented on code in PR #24513:
URL: https://github.com/apache/flink/pull/24513#discussion_r1538661895
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/filemerging/FileMergingOperatorStreamStateHandle.java:
##
@@ -0,0 +1,154 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-34929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-34929:
--
Assignee: Martijn Visser
> Create "flink-connector-kudu" repository
>
snuyanzin opened a new pull request, #24571:
URL: https://github.com/apache/flink/pull/24571
## What is the purpose of the change
The PR introduces `CollectIteratorAssert#matchesRecordsFromSource` and
`SinkTestSuiteBase#checkResultWithSemantic` with former signature to make
[
https://issues.apache.org/jira/browse/FLINK-34941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34941:
---
Labels: pull-request-available (was: )
> Cannot convert
[
https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-26515:
-
Assignee: Roman Khachatryan
> RetryingExecutorTest. testDiscardOnTimeout
[
https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34513:
---
Labels: pull-request-available test-stability (was: test-stability)
>
flinkbot commented on PR #24569:
URL: https://github.com/apache/flink/pull/24569#issuecomment-2021147280
## CI report:
* bd0e8d4a7e104a802ce5cbe19113ac8b63565423 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24570:
URL: https://github.com/apache/flink/pull/24570#issuecomment-2021435634
## CI report:
* f91d4893b28331645d872d1452d3181f014af24f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rkhachatryan opened a new pull request, #24569:
URL: https://github.com/apache/flink/pull/24569
## 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
morazow commented on PR #182:
URL: https://github.com/apache/flink-docker/pull/182#issuecomment-2021392610
Thanks @XComp for looking into I have squashed it as you suggested, fixed.
I will update the other PRs similar to this one tomorrow. Thanks a lot!
--
This is an
jnh5y opened a new pull request, #24570:
URL: https://github.com/apache/flink/pull/24570
* This addresses FLINK-34513 by changing `testMaterializedData` to only
check the data after the restore.
## What is the purpose of the change
Fix intermittent test failures.
##
jnh5y commented on PR #24570:
URL: https://github.com/apache/flink/pull/24570#issuecomment-2021439410
@bvarghese1 This approach fails since it breaks the JoinRestoreTest.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Sergey Nuyanzin created FLINK-34941:
---
Summary: Cannot convert
org.apache.flink.streaming.api.CheckpointingMode to
org.apache.flink.core.execution.CheckpointingMode
Key: FLINK-34941
URL:
snuyanzin commented on PR #24571:
URL: https://github.com/apache/flink/pull/24571#issuecomment-2021520200
@Zakelly , @masteryhx could you please have a look since it is related to
the change where you were participated
[FLINK-34516](https://issues.apache.org/jira/browse/FLINK-34516)
--
flinkbot commented on PR #24571:
URL: https://github.com/apache/flink/pull/24571#issuecomment-2021523128
## CI report:
* 51baa4e6f3c83fc4050c50b54dd69c2e8f16f2f5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xleoken commented on PR #3110:
URL: https://github.com/apache/flink-cdc/pull/3110#issuecomment-2021795499
cc @leonardBang @PatrickRen @Jiabao-Sun
--
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
[
https://issues.apache.org/jira/browse/FLINK-34943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong updated FLINK-34943:
Summary: Support Flink 1.19, 1.20-SNAPSHOT for JDBC connector (was:
Support Flink 1.19,
[
https://issues.apache.org/jira/browse/FLINK-34943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34943:
---
Labels: pull-request-available (was: )
> Support Flink 1.19, 1.20-SNAPSHOT for JDBC
GOODBOY008 commented on PR #88:
URL:
https://github.com/apache/flink-connector-jdbc/pull/88#issuecomment-2021803094
@Jiabao-Sun 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
GOODBOY008 opened a new pull request, #111:
URL: https://github.com/apache/flink-connector-jdbc/pull/111
Changes:
- Support Flink 1.19, 1.20-SNAPSHOT
- Code polish
--
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-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831141#comment-17831141
]
Hangxiang Yu edited comment on FLINK-33707 at 3/27/24 2:46 AM:
---
Hi, Scala
[
https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831141#comment-17831141
]
Hangxiang Yu commented on FLINK-33707:
--
Hi, Scala API has been marked as deprecated.
Do we still
[
https://issues.apache.org/jira/browse/FLINK-34942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34942:
---
Labels: pull-request-available (was: )
> Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch
snuyanzin opened a new pull request, #42:
URL: https://github.com/apache/flink-connector-opensearch/pull/42
PR makes current code compilable with Flink 1.19, 1.20-SNAPSHOT
also it bumps dependencies
jackson to 1.15.3
junit5 to 5.10.2
assertj to 3.25.3
testcontainers to 1.19.7
Zhongqiang Gong created FLINK-34943:
---
Summary: Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector
Key: FLINK-34943
URL: https://issues.apache.org/jira/browse/FLINK-34943
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-29481:
Fix Version/s: 1.20.0
> Show JobType on WebUI
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-29481:
---
Assignee: Rui Fan (was: LI Mingkun)
> Show JobType on WebUI
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831175#comment-17831175
]
Hang Ruan commented on FLINK-34445:
---
Fine, I will take a look at this. Thanks ~
> Integrate new
[
https://issues.apache.org/jira/browse/FLINK-34668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831130#comment-17831130
]
Yanfei Lei commented on FLINK-34668:
Merged via 05b27be
> Report State handle of file merging
[
https://issues.apache.org/jira/browse/FLINK-34668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei closed FLINK-34668.
--
Resolution: Resolved
> Report State handle of file merging directory to JM
>
Junrui Li created FLINK-34945:
-
Summary: Support recover shuffle descriptor and partition metrics
from tiered storage
Key: FLINK-34945
URL: https://issues.apache.org/jira/browse/FLINK-34945
Project:
[
https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-34445:
---
Fix Version/s: 1.20.0
> Integrate new endpoint with Flink UI metrics section
>
[
https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-3:
---
Fix Version/s: 1.20.0
> Add new endpoint handler to flink
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831170#comment-17831170
]
Mason Chen commented on FLINK-34445:
Anytime after https://issues.apache.org/jira/browse/FLINK-3
[
https://issues.apache.org/jira/browse/FLINK-34639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
He Wang updated FLINK-34639:
Fix Version/s: cdc-3.1.0
> Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector
He Wang created FLINK-34944:
---
Summary: Use Incremental Source Framework in Flink CDC OceanBase
Source Connector
Key: FLINK-34944
URL: https://issues.apache.org/jira/browse/FLINK-34944
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-34064:
---
Fix Version/s: 1.20.0
> Expose JobManagerOperatorMetrics via REST API
>
Sergey Nuyanzin created FLINK-34942:
---
Summary: Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector
Key: FLINK-34942
URL: https://issues.apache.org/jira/browse/FLINK-34942
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831119#comment-17831119
]
Hang Ruan commented on FLINK-34445:
---
Sure, I would like to help in this part. When should I finish
[
https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831151#comment-17831151
]
Rui Fan commented on FLINK-34643:
-
[
https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831150#comment-17831150
]
Rui Fan commented on FLINK-29481:
-
Discuss with [~dangshazi] offlien, I will take over this JIRA.
Based
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-34936:
-
Component/s: Runtime / Checkpointing
> Register shared state files to
[
https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-29481:
Labels: features pull-request-available (was: features
pull-request-available stale-assigned)
> Show
[
https://issues.apache.org/jira/browse/FLINK-34644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830837#comment-17830837
]
Ryan Skraba commented on FLINK-34644:
-
[
https://issues.apache.org/jira/browse/FLINK-34929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-34929.
--
Resolution: Fixed
Repo created and initialized
> Create "flink-connector-kudu" repository
>
Matthias Pohl created FLINK-34937:
-
Summary: Apache Infra GHA policy update
Key: FLINK-34937
URL: https://issues.apache.org/jira/browse/FLINK-34937
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34937:
--
Parent: FLINK-33901
Issue Type: Sub-task (was: Bug)
> Apache Infra GHA policy update
ashangit commented on code in PR #24563:
URL: https://github.com/apache/flink/pull/24563#discussion_r1538911667
##
flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java:
##
@@ -220,6 +222,52 @@ public class HighAvailabilityOptions {
whhe opened a new pull request, #109:
URL: https://github.com/apache/flink-connector-jdbc/pull/109
(no comment)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To
[
https://issues.apache.org/jira/browse/FLINK-34930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34930:
---
Component/s: Connectors / Kudu
> Move existing Kudu connector code from Bahir repo to
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830843#comment-17830843
]
Simon-Shlomo Poil commented on FLINK-34696:
---
Hi Galen,
How do we proceed with this issue?
JTaky commented on PR #24563:
URL: https://github.com/apache/flink/pull/24563#issuecomment-2020071741
@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.
Dawid Wysakowicz created FLINK-34938:
Summary: Incorrect behaviour for comparison functions
Key: FLINK-34938
URL: https://issues.apache.org/jira/browse/FLINK-34938
Project: Flink
Issue
Matthias Pohl created FLINK-34939:
-
Summary: Harden TestingLeaderElection
Key: FLINK-34939
URL: https://issues.apache.org/jira/browse/FLINK-34939
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830874#comment-17830874
]
Muhammet Orazov commented on FLINK-34937:
-
Hey [~mapohl], the first link is unreachable or is it
[
https://issues.apache.org/jira/browse/FLINK-34751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830877#comment-17830877
]
Ferenc Csaky commented on FLINK-34751:
--
Hi! Would you be able to share how to reproduce the issue?.
[
https://issues.apache.org/jira/browse/FLINK-34572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34572:
---
Labels: pull-request-available (was: )
> JDBC: Support OceanBase catalog
>
JTaky commented on PR #24563:
URL: https://github.com/apache/flink/pull/24563#issuecomment-2019847546
@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.
[
https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830838#comment-17830838
]
Ryan Skraba commented on FLINK-34643:
-
[
https://issues.apache.org/jira/browse/FLINK-34938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34938:
---
Labels: pull-request-available (was: )
> Incorrect behaviour for comparison functions
>
[
https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34937:
--
Description:
There is a policy update [announced in the infra
dawidwys opened a new pull request, #24566:
URL: https://github.com/apache/flink/pull/24566
## What is the purpose of the change
Fixes how SQL comparison functions work for TIMESTAMP types.
## Verifying this change
Added tests in `ComparisonFunctionsITCase`.
##
[
https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830876#comment-17830876
]
Matthias Pohl commented on FLINK-34937:
---
I updated the link to refer to a publicly available
flinkbot commented on PR #24566:
URL: https://github.com/apache/flink/pull/24566#issuecomment-2020121492
## CI report:
* bdb81bd565f519aaee699bc954f6f1b45ac590f8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34929:
---
Component/s: Connectors / Kudu
> Create "flink-connector-kudu" repository
>
[
https://issues.apache.org/jira/browse/FLINK-34931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34931:
---
Component/s: Connectors / Kudu
> Update Kudu connector DataStream Source/Sink
ashangit commented on code in PR #24563:
URL: https://github.com/apache/flink/pull/24563#discussion_r1538900208
##
docs/layouts/shortcodes/generated/high_availability_configuration.html:
##
@@ -68,6 +80,12 @@
Integer
Defines the session timeout for the
fredia merged PR #24513:
URL: https://github.com/apache/flink/pull/24513
--
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:
RubyChou opened a new pull request, #24567:
URL: https://github.com/apache/flink/pull/24567
## What is the purpose of the change
*The PR aims to support pushing a Project past a Window in stream mode(It
has been supported in batch mode).*
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34529:
---
Labels: pull-request-available (was: )
> Projection cannot be pushed down through rank
flinkbot commented on PR #24567:
URL: https://github.com/apache/flink/pull/24567#issuecomment-2020210585
## CI report:
* 839b369305d886c7575fe9c179db9965a3534432 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830900#comment-17830900
]
yisha zhou commented on FLINK-34529:
Hi [~libenchao] [~lincoln.86xy] , as your suggestions, I tried
whhe commented on PR #109:
URL:
https://github.com/apache/flink-connector-jdbc/pull/109#issuecomment-2020383288
Would you please take a look on this? @leonardBang
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
snuyanzin commented on PR #94:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/94#issuecomment-2020396716
Thanks for taking a look
--
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
snuyanzin merged PR #93:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/93
--
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:
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-25421.
---
> Port JDBC Sink to new Unified Sink API (FLIP-143)
>
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-25421.
-
Fix Version/s: jdbc-3.2.0
Resolution: Fixed
> Port JDBC Sink to new Unified Sink
snuyanzin commented on PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-2020439861
Thanks for the hard work @eskabetxe
and thanks everyone for the review
@eskabetxe can you also please provide a PR to update `jdbc.md`?
--
This is an automated
snuyanzin commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-jdbc/pull/100#discussion_r1539277654
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java:
##
@@ -52,11 +52,13 @@
XComp commented on code in PR #24563:
URL: https://github.com/apache/flink/pull/24563#discussion_r1539254121
##
flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java:
##
@@ -220,6 +222,52 @@ public class HighAvailabilityOptions {
Matthias Pohl created FLINK-34940:
-
Summary: LeaderContender implementations handle invalid state
Key: FLINK-34940
URL: https://issues.apache.org/jira/browse/FLINK-34940
Project: Flink
Issue
snuyanzin merged PR #94:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/94
--
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:
flinkbot commented on PR #24568:
URL: https://github.com/apache/flink/pull/24568#issuecomment-2020444328
## CI report:
* f956c0997145ebd0ed07f234795161e7672d4d25 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830931#comment-17830931
]
Sergey Nuyanzin commented on FLINK-25421:
-
Merged as
zhuzhurk commented on code in PR #24415:
URL: https://github.com/apache/flink/pull/24415#discussion_r1538868578
##
flink-core/src/main/java/org/apache/flink/api/connector/source/SupportsBatchSnapshot.java:
##
@@ -0,0 +1,30 @@
+/*
+ * Licensed to the Apache Software Foundation
XComp opened a new pull request, #24568:
URL: https://github.com/apache/flink/pull/24568
## What is the purpose of the change
Hardens `TestingLeaderElection` to comply to the `LeaderContender` contract
## Brief change log
* Notifying the contender of the leadership
[
https://issues.apache.org/jira/browse/FLINK-34939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34939:
---
Labels: pull-request-available (was: )
> Harden TestingLeaderElection
>
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-25421:
---
Assignee: João Boto
> Port JDBC Sink to new Unified Sink API (FLIP-143)
>
snuyanzin merged PR #2:
URL: https://github.com/apache/flink-connector-jdbc/pull/2
--
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:
dependabot[bot] commented on PR #104:
URL:
https://github.com/apache/flink-connector-jdbc/pull/104#issuecomment-2020436094
Superseded by #110.
--
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
1 - 100 of 114 matches
Mail list logo
