1996fanrui commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1403215622
> Ok, let's go with the `CanEmitBatchOfRecordsChecker`
Hi @pnowojski , thanks for your feedback, I will update the PR today.
> Just to double check, is this PR near
[
https://issues.apache.org/jira/browse/FLINK-24438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24438:
---
Labels: pull-request-available (was: )
> Port Kinesis Source to new Source API (FLIP-27)
>
hlteoh37 opened a new pull request, #49:
URL: https://github.com/apache/flink-connector-aws/pull/49
## What is the purpose of the change
- Implement FlinkKinesisSource using the new FLIP-27 Source interface
## Verifying this change
## Does this pull request potentially affect
flinkbot commented on PR #21754:
URL: https://github.com/apache/flink/pull/21754#issuecomment-1403087860
## CI report:
* b6af133b388b8a58a5eb21847bb3cc3157fa3fa0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Samrat002 opened a new pull request, #21754:
URL: https://github.com/apache/flink/pull/21754
## What is the purpose of the change
Fix typo in flink doc.
## Verifying this change
## Does this pull request potentially affect one of the following parts:
SinBex commented on PR #21695:
URL: https://github.com/apache/flink/pull/21695#issuecomment-1402996470
@zhuzhurk Thanks for reviewing, I have fixed the problems you commented.
PTAL~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-30301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-30301.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged into master as b4fe4a4288777c4
rkhachatryan merged PR #21467:
URL: https://github.com/apache/flink/pull/21467
--
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.
SinBex commented on code in PR #21695:
URL: https://github.com/apache/flink/pull/21695#discussion_r1086123499
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java:
##
@@ -219,7 +220,8 @@ private List
findExec
SinBex commented on code in PR #21695:
URL: https://github.com/apache/flink/pull/21695#discussion_r1086119088
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/slowtaskdetector/ExecutionTimeBasedSlowTaskDetector.java:
##
@@ -168,21 +168,34 @@ private double getFi
jbusche commented on PR #510:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/510#issuecomment-1402839750
I tested on an OpenShift 4.10.46 Cluster, both with the helm install method,
as well as building a bundle and installing in multiple namespaces. It looked
good in all ca
[
https://issues.apache.org/jira/browse/FLINK-30577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680389#comment-17680389
]
James Busche commented on FLINK-30577:
--
I've switched to your branch [~tagarr] and
rkhachatryan commented on PR #21467:
URL: https://github.com/apache/flink/pull/21467#issuecomment-1402765296
Since the previous feedback was addressed I'm going to merge the PR.
Thanks for reviewing!
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-30328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-30328.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged into master as f8105bb584f8e7b
rkhachatryan merged PR #21733:
URL: https://github.com/apache/flink/pull/21733
--
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.
rkhachatryan commented on PR #21733:
URL: https://github.com/apache/flink/pull/21733#issuecomment-1402758440
Thanks for the review @AlanConfluent,
merging
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
rkhachatryan commented on code in PR #21733:
URL: https://github.com/apache/flink/pull/21733#discussion_r1085994402
##
flink-tests/src/test/java/org/apache/flink/test/state/TaskManagerWideRocksDbMemorySharingITCase.java:
##
@@ -125,36 +129,45 @@ public void testBlockCache() thro
flinkbot commented on PR #21753:
URL: https://github.com/apache/flink/pull/21753#issuecomment-1402753784
## CI report:
* 02a83862bc6c3c9a4feeb90ccf8d44364552ee1f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30782:
---
Labels: pull-request-available (was: )
> Use https for schemaLocations
> --
snuyanzin opened a new pull request, #21753:
URL: https://github.com/apache/flink/pull/21753
## What is the purpose of the change
The PR makes use `https` rather than `http` for schemalocation in pom.xml
## Verifying this change
This change is a trivial rework / code clea
Sergey Nuyanzin created FLINK-30782:
---
Summary: Use https for schemaLocations
Key: FLINK-30782
URL: https://issues.apache.org/jira/browse/FLINK-30782
Project: Flink
Issue Type: Technical Deb
[
https://issues.apache.org/jira/browse/FLINK-30766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30766.
--
Fix Version/s: kubernetes-operator-1.4.0
Resolution: Fixed
merged to main cb30a70dc961e6f61ddd3
gyfora merged PR #511:
URL: https://github.com/apache/flink-kubernetes-operator/pull/511
--
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
[
https://issues.apache.org/jira/browse/FLINK-22137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-22137.
---
Resolution: Done
Thanks for reminding. This has been done eons ago ;)
> Execute unaligned checkpoin
dependabot[bot] opened a new pull request, #6:
URL: https://github.com/apache/flink-connector-opensearch/pull/6
Bumps [opensearch](https://github.com/opensearch-project/OpenSearch) from
1.3.0 to 2.5.0.
Release notes
Sourced from https://github.com/opensearch-project/OpenSearch/rele
snuyanzin commented on code in PR #21519:
URL: https://github.com/apache/flink/pull/21519#discussion_r1085686175
##
flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/RelDecorrelator.java:
##
@@ -1973,10 +1972,6 @@ public void onMatch(RelOptRuleCall call) {
snuyanzin commented on code in PR #21519:
URL: https://github.com/apache/flink/pull/21519#discussion_r1085679541
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -431,13 +431,16 @@ public void onMa
twalthr commented on code in PR #21519:
URL: https://github.com/apache/flink/pull/21519#discussion_r1085506331
##
flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/RelDecorrelator.java:
##
@@ -1973,10 +1972,6 @@ public void onMatch(RelOptRuleCall call) {
[
https://issues.apache.org/jira/browse/FLINK-30781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-30781:
-
Assignee: Gabor Somogyi
> Add completed checkpoint check to cluster health check
>
Gabor Somogyi created FLINK-30781:
-
Summary: Add completed checkpoint check to cluster health check
Key: FLINK-30781
URL: https://issues.apache.org/jira/browse/FLINK-30781
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680281#comment-17680281
]
Robert Sims commented on FLINK-18568:
-
Is this issue awaiting the sub-task 3 to comp
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085316765
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Lic
mxm commented on code in PR #509:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/509#discussion_r1085603239
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingExecutor.java:
##
@@ -99,14 +103,27 @@ public boolean sca
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085585517
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Lic
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085595610
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Lic
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085595610
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Lic
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085585517
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Lic
masteryhx commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1085579491
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java:
##
@@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVi
masteryhx commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1085568912
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerSnapshot.java:
##
@@ -290,26 +332,26 @@ protected void readOuterSnapshot(
[
https://issues.apache.org/jira/browse/FLINK-30278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-30278.
--
Fix Version/s: 1.17.0
Resolution: Fixed
Merged to master as f38c2370e85
> Unexpected c
[
https://issues.apache.org/jira/browse/FLINK-30278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-30278:
---
Affects Version/s: (was: 1.16.0)
> Unexpected config mutation in SinkTransformationTrans
SinBex commented on PR #21695:
URL: https://github.com/apache/flink/pull/21695#issuecomment-1402211968
@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.
T
pnowojski merged PR #21445:
URL: https://github.com/apache/flink/pull/21445
--
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.apa
masteryhx commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1085553601
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java:
##
@@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVi
kristoffSC commented on code in PR #21393:
URL: https://github.com/apache/flink/pull/21393#discussion_r1085531144
##
flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java:
##
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the Apa
z3d1k commented on code in PR #48:
URL:
https://github.com/apache/flink-connector-aws/pull/48#discussion_r1085539586
##
.github/workflows/nightly.yml:
##
@@ -0,0 +1,33 @@
+
+# Licensed to the Apach
masteryhx commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1085539860
##
flink-core/src/test/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerSnapshotTest.java:
##
@@ -232,14 +232,11 @@ public void testRestoreCompositeT
z3d1k commented on code in PR #48:
URL:
https://github.com/apache/flink-connector-aws/pull/48#discussion_r1085538878
##
.github/workflows/common.yml:
##
@@ -16,66 +16,87 @@
# limitations under the License.
#
kristoffSC commented on code in PR #21393:
URL: https://github.com/apache/flink/pull/21393#discussion_r1085531144
##
flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java:
##
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the Apa
kristoffSC commented on code in PR #21393:
URL: https://github.com/apache/flink/pull/21393#discussion_r1085531144
##
flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java:
##
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the Apa
snuyanzin commented on PR #20773:
URL: https://github.com/apache/flink/pull/20773#issuecomment-1402168038
Thanks for the feedback, rebased
--
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
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680267#comment-17680267
]
Matthias Pohl commented on FLINK-25343:
---
You have a point here. But the instabilit
[
https://issues.apache.org/jira/browse/FLINK-30778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680265#comment-17680265
]
Timo Walther commented on FLINK-30778:
--
Even though `Configuration` is not deprecat
[
https://issues.apache.org/jira/browse/FLINK-22137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680263#comment-17680263
]
Anton Kalashnikov commented on FLINK-22137:
---
I don't remember why we didn't cl
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680261#comment-17680261
]
Ferenc Csaky commented on FLINK-25343:
--
Hi! No, I was not able to spend time on thi
[
https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680259#comment-17680259
]
Matthias Pohl commented on FLINK-30727:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680258#comment-17680258
]
Matthias Pohl commented on FLINK-30727:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680256#comment-17680256
]
Matthias Pohl commented on FLINK-30733:
---
Two additional builds were missed (which
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679716#comment-17679716
]
Matthias Pohl edited comment on FLINK-25343 at 1/24/23 3:13 PM:
--
XComp commented on PR #21751:
URL: https://github.com/apache/flink/pull/21751#issuecomment-1402104138
What speaks against replacing the `Thread.sleep(10L)` with a waiting
condition in the test?
```
CommonTestUtils.waitUtil(
() -> upTimeGauge.getValue() > 0L,
flinkbot commented on PR #21752:
URL: https://github.com/apache/flink/pull/21752#issuecomment-1402057786
## CI report:
* 59acfe5e0467444b5c187967dde3cbd30dad1e5c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085417186
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-30691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30691:
---
Labels: pull-request-available (was: )
> SQL Client supports to specify endpoint address
>
fsk119 opened a new pull request, #21752:
URL: https://github.com/apache/flink/pull/21752
## What is the purpose of the change
*Supports the SQL Client gateway mode to allow the SQL Client connects to
the SQL Gateway.*
## Brief change log
- *Add command lin
MartijnVisser commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1402048507
Just to double check, is this PR nearing a stage where it can be merged
soon? Especially since this performance regression has been open for quite some
time and is a blocker for the
[
https://issues.apache.org/jira/browse/FLINK-30733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680233#comment-17680233
]
Martijn Visser commented on FLINK-30733:
Created #builds-debug to see if both ch
dawidwys commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1085396914
##
flink-core/src/test/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerSnapshotTest.java:
##
@@ -232,14 +232,11 @@ public void testRestoreCompositeTy
[
https://issues.apache.org/jira/browse/FLINK-30619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30619:
---
Labels: pull-request-available test-stability (was: test-stability)
> AdaptiveSchedulerTest
flinkbot commented on PR #21751:
URL: https://github.com/apache/flink/pull/21751#issuecomment-1402034380
## CI report:
* 3503146c403a36a3466538801ee71623954c1355 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680232#comment-17680232
]
Chesnay Schepler commented on FLINK-30619:
--
Can't reproduce it locally. Either
Grzegorz Kołakowski created FLINK-30780:
---
Summary: Develop ElasticCatalog to connect Flink with Elastic
tables and ecosystem
Key: FLINK-30780
URL: https://issues.apache.org/jira/browse/FLINK-30780
gyfora commented on PR #511:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/511#issuecomment-1402009883
cc @gaborgsomogyi
--
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 spec
dawidwys commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1085369657
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerSnapshot.java:
##
@@ -290,26 +332,26 @@ protected void readOuterSnapshot(
dawidwys commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1085369657
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerSnapshot.java:
##
@@ -290,26 +332,26 @@ protected void readOuterSnapshot(
[
https://issues.apache.org/jira/browse/FLINK-30766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30766:
---
Labels: pull-request-available (was: )
> Only parameterize tests with Flink 1.14 and 1.15
>
gyfora opened a new pull request, #511:
URL: https://github.com/apache/flink-kubernetes-operator/pull/511
## What is the purpose of the change
- Improve test speed by only parameterizing with FlinkVersions that have
different operator behaviour.
- Fix flaky rollback test and make
[
https://issues.apache.org/jira/browse/FLINK-30779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30779:
---
Summary: Bump josdk version to 4.3.2 (was: Bomp josdk version to 4.3.2)
> Bump josdk version to 4.3
Gyula Fora created FLINK-30779:
--
Summary: Bomp josdk version to 4.3.2
Key: FLINK-30779
URL: https://issues.apache.org/jira/browse/FLINK-30779
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-29540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680219#comment-17680219
]
Sergey Nuyanzin edited comment on FLINK-29540 at 1/24/23 1:28 PM:
[
https://issues.apache.org/jira/browse/FLINK-29540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680219#comment-17680219
]
Sergey Nuyanzin commented on FLINK-29540:
-
I workarounded it in Flink code
howev
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085316765
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Lic
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085311136
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-29215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-29215:
Assignee: Sergey Nuyanzin
> Use config based constructors for flink calcite Converter rul
[
https://issues.apache.org/jira/browse/FLINK-30733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680209#comment-17680209
]
Matthias Pohl commented on FLINK-30733:
---
Just for documentation purposes: One requ
[
https://issues.apache.org/jira/browse/FLINK-30763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-30763.
-
Resolution: Duplicate
> Make TestingLeaderElectionService comply to how the LeaderElectionServic
[
https://issues.apache.org/jira/browse/FLINK-30761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-30761.
---
Fix Version/s: 1.17.0
Resolution: Fixed
master: b26c695b5332dd44f9c744cf7d7c0db539892
XComp merged PR #21738:
URL: https://github.com/apache/flink/pull/21738
--
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.
[
https://issues.apache.org/jira/browse/FLINK-30760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680203#comment-17680203
]
Matthias Pohl commented on FLINK-30760:
---
I didn't backport this change despite it
[
https://issues.apache.org/jira/browse/FLINK-30760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-30760.
---
Fix Version/s: 1.17.0
Resolution: Fixed
master: bf1fc7ad206421509433346351dcd8f6f23ea
dawidwys commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1085267360
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java:
##
@@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVie
XComp merged PR #21737:
URL: https://github.com/apache/flink/pull/21737
--
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.
[
https://issues.apache.org/jira/browse/FLINK-30759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-30759.
---
Fix Version/s: 1.17.0
Resolution: Fixed
master: 2d1d61c68d81eba0f721b10eaf2a7246aa081
XComp merged PR #21740:
URL: https://github.com/apache/flink/pull/21740
--
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.
XComp commented on code in PR #20919:
URL: https://github.com/apache/flink/pull/20919#discussion_r1085241002
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/table/fullcache/inputformat/InputFormatCacheLoaderTest.java:
##
@@ -123,46 +127,
fsk119 commented on PR #21717:
URL: https://github.com/apache/flink/pull/21717#issuecomment-1401848129
I also run the TPC-h e2e test in my private pipeline. It all passes. I think
with the commit a94aff3, the sql client exits without the risk of the resource
leak if the connection is stable
gyfora commented on code in PR #509:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/509#discussion_r1085187769
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingExecutor.java:
##
@@ -99,14 +103,27 @@ public boolean
zentol merged PR #21749:
URL: https://github.com/apache/flink/pull/21749
--
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
mxm commented on code in PR #509:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/509#discussion_r1085133129
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingExecutor.java:
##
@@ -116,6 +133,20 @@ public boolean sca
MartijnVisser commented on PR #21295:
URL: https://github.com/apache/flink/pull/21295#issuecomment-1401715188
Closing this PR because the Pulsar connector has been externalized to
https://github.com/apache/flink-connector-pulsar/
--
This is an automated message from the Apache Git Service
MartijnVisser closed pull request #21295: [Typo] Fix the typo 'retriable',
which means 'retryable'.
URL: https://github.com/apache/flink/pull/21295
--
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
1 - 100 of 114 matches
Mail list logo
