PatrickRen commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1194559931
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/ShardAssignerFactory.java:
##
@@ -0,0 +1,
XComp commented on PR #22380:
URL: https://github.com/apache/flink/pull/22380#issuecomment-1549085766
The e2e test failed due to some (temporary) network connectivity issues
within the Docker image (see
[logs](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=49011&view
XComp commented on PR #22380:
URL: https://github.com/apache/flink/pull/22380#issuecomment-1549084955
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723006#comment-17723006
]
Matthias Pohl edited comment on FLINK-32069 at 5/16/23 6:48 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723006#comment-17723006
]
Matthias Pohl commented on FLINK-32069:
---
>From the 1.15 finding above the issue mi
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-31759.
Resolution: Fixed
> Update some external connectors to use sql_connector_download_table and
> con
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722998#comment-17722998
]
Matthias Pohl edited comment on FLINK-32069 at 5/16/23 6:18 AM:
--
reswqa merged PR #45:
URL: https://github.com/apache/flink-connector-jdbc/pull/45
--
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...@fli
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722998#comment-17722998
]
Matthias Pohl edited comment on FLINK-32069 at 5/16/23 5:57 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-32104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722993#comment-17722993
]
Weijie Guo edited comment on FLINK-32104 at 5/16/23 5:55 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722998#comment-17722998
]
Matthias Pohl commented on FLINK-32069:
---
Ok, I was too lazy to switch to the 1.15
[
https://issues.apache.org/jira/browse/FLINK-32104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722993#comment-17722993
]
Weijie Guo edited comment on FLINK-32104 at 5/16/23 5:49 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-32104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722993#comment-17722993
]
Weijie Guo commented on FLINK-32104:
Hi Kurt,
I have tested the uploaded job witho
lindong28 commented on code in PR #237:
URL: https://github.com/apache/flink-ml/pull/237#discussion_r1194570809
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/updater/ModelUpdater.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722985#comment-17722985
]
Matthias Pohl edited comment on FLINK-32069 at 5/16/23 5:43 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722985#comment-17722985
]
Matthias Pohl edited comment on FLINK-32069 at 5/16/23 5:03 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722985#comment-17722985
]
Matthias Pohl commented on FLINK-32069:
---
Can you provide debug logs of the case?
flinkbot commented on PR #22588:
URL: https://github.com/apache/flink/pull/22588#issuecomment-1548979423
## CI report:
* 965fc11fe20d8b962b2a4c2ca67342051b130201 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa merged PR #50:
URL: https://github.com/apache/flink-connector-pulsar/pull/50
--
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...@f
bvarghese1 opened a new pull request, #22588:
URL: https://github.com/apache/flink/pull/22588
## What is the purpose of the change
This is an implementation of ARRAY_EXCEPT
## Brief change log
ARRAY_EXCEPT for Table API and SQL
```
Flink SQL> SELECT array_except
[
https://issues.apache.org/jira/browse/FLINK-32104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Ostfeld updated FLINK-32104:
-
Description:
I've put together a simple demo app that reproduces the issue with instructions
on
Kurt Ostfeld created FLINK-32104:
Summary: stop-with-savepoint fails and times out with simple
reproducible example
Key: FLINK-32104
URL: https://issues.apache.org/jira/browse/FLINK-32104
Project: Fli
flinkbot commented on PR #22587:
URL: https://github.com/apache/flink/pull/22587#issuecomment-1548949084
## CI report:
* 99f41cfb94b20162cce28f7e9ec5662afe385689 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Myracle commented on code in PR #22560:
URL: https://github.com/apache/flink/pull/22560#discussion_r1194578196
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -92,6 +92,17 @@ public class ExecutionOptions {
.withDescri
reswqa commented on PR #50:
URL:
https://github.com/apache/flink-connector-pulsar/pull/50#issuecomment-1548938191
Reviewed in #49.
--
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 co
reswqa opened a new pull request, #50:
URL: https://github.com/apache/flink-connector-pulsar/pull/50
Backport to `v4.0` as flink track this branch to render documentation.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
flinkbot commented on PR #22586:
URL: https://github.com/apache/flink/pull/22586#issuecomment-1548929471
## CI report:
* 6e8d876beb9ff0f2c5eddf4833ec572068629616 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yangjf2019 opened a new pull request, #601:
URL: https://github.com/apache/flink-kubernetes-operator/pull/601
## What is the purpose of the change
* I have updated some typos in the
`docs/content/docs/custom-resource/autoscaler.md` file.
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-31880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722973#comment-17722973
]
Kurt Ostfeld commented on FLINK-31880:
--
Updated PR
https://github.com/apache/flink
kurtostfeld opened a new pull request, #22586:
URL: https://github.com/apache/flink/pull/22586
Fixes unit test so it will pass regardless of time zone it is run in. Also
use a better testing date.
I submitted this before, I'm resubmitting with issues fixed. This should
follow commit
[
https://issues.apache.org/jira/browse/FLINK-31893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-31893:
---
Summary: Placeholder (was: Introduce AdaptiveScheduler global failure
enric
1996fanrui commented on code in PR #22560:
URL: https://github.com/apache/flink/pull/22560#discussion_r1194556471
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -92,6 +92,17 @@ public class ExecutionOptions {
.withDes
[
https://issues.apache.org/jira/browse/FLINK-31892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-31892:
---
Summary: Introduce AdaptiveScheduler global failure enrichment/labeling
(wa
kurtostfeld closed pull request #22451: FLINK-31880: Fixed broken date test. It
was failing when run in CST time zone.
URL: https://github.com/apache/flink/pull/22451
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
JunRuiLee commented on code in PR #16593:
URL: https://github.com/apache/flink/pull/16593#discussion_r1194546629
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java:
##
@@ -1291,7 +1291,7 @@ public void
testSlotSharingR
reswqa commented on PR #22574:
URL: https://github.com/apache/flink/pull/22574#issuecomment-1548891764
Rebased on `origin/master`, will be merged after AZP green.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-32101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722966#comment-17722966
]
Yuxin Tan commented on FLINK-32101:
---
[~mapohl] Yes, exactly. Thanks for tracking it.
[
https://issues.apache.org/jira/browse/FLINK-32101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32101:
--
Labels: test-stability (was: test)
> FlinkKafkaInternalProducerITCase.testInitTransactionId test fail
godfreyhe commented on code in PR #22566:
URL: https://github.com/apache/flink/pull/22566#discussion_r1194510238
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperatorTestBase.java:
##
@@ -0,0 +1,124 @@
+/*
+ *
pgaref commented on PR #22506:
URL: https://github.com/apache/flink/pull/22506#issuecomment-1548830252
Thanks for the comments once again @zhuzhurk !
PTAL on latest PR:
* introducing async task failure labeling as part of
ExecutionFailureHandler#handleFailure (for local and global
[
https://issues.apache.org/jira/browse/FLINK-32103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722952#comment-17722952
]
James Busche edited comment on FLINK-32103 at 5/16/23 1:07 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-32103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722952#comment-17722952
]
James Busche commented on FLINK-32103:
--
Can fix this on an existing OpenShift insta
[
https://issues.apache.org/jira/browse/FLINK-32103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722951#comment-17722951
]
James Busche commented on FLINK-32103:
--
Created PR [https://github.com/apache/flink
jbusche commented on PR #600:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/600#issuecomment-1548743480
OpenShift 4.10.54 is looking good with the PR:
```
oc get pods,flinkdeployments -n default
RamanVerma commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-kafka/pull/29#discussion_r119366
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java:
##
@@ -38,6 +38,10
jbusche commented on PR #600:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/600#issuecomment-1548682654
OK - the KIND cluster looks good - still deploying the samples fine.
```
NAME READY STATUS
RESTARTS AGE
jbusche commented on PR #600:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/600#issuecomment-1548632061
Trying a new deployment on both a KIND cluster (non OpenShift) as well as
two OpenShift clusters to verify the change. Will post results here.
--
This is an automated
jbusche opened a new pull request, #600:
URL: https://github.com/apache/flink-kubernetes-operator/pull/600
## What is the purpose of the change
Noticing in the 1.5.0-rc1 and 1.5.0-rc2 that we're having a problem
deploying on OpenShift. The solution is to either manually updat
[
https://issues.apache.org/jira/browse/FLINK-31890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-31890:
---
Summary: Introduce DefaultScheduler failure enrichment/labeling (was:
Intro
James Busche created FLINK-32103:
Summary: RBAC flinkdeployments/finalizers missing for OpenShift
Deployment
Key: FLINK-32103
URL: https://issues.apache.org/jira/browse/FLINK-32103
Project: Flink
reswqa commented on PR #22574:
URL: https://github.com/apache/flink/pull/22574#issuecomment-1548347105
Thanks @snuyanzin very much for your patient review 👍 . Without you, I
didn't even realize that the number of tests wouldn't be right (my mistake) 🙇
--
This is an automated message from
snuyanzin commented on PR #22574:
URL: https://github.com/apache/flink/pull/22574#issuecomment-1548342955
I checked that now number of tests before the change is equal to number of
tests after per changed class
no more findings from my side
lgtm
--
This is an automated message from
snuyanzin commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194200879
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import or
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194197548
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import org.a
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194197548
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import org.a
snuyanzin commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194178109
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import or
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194170872
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import org.a
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194169663
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import org.a
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194168520
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import org.a
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194168520
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import org.a
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194167000
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import org.a
snuyanzin commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194163579
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala:
##
@@ -23,17 +23,20 @@ import or
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194160609
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/FileSystemTestCsvITCase.scala:
##
@@ -32,12 +35,11 @@ class FileSystem
snuyanzin commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194131282
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/FileSystemTestCsvITCase.scala:
##
@@ -32,12 +35,11 @@ class FileSys
snuyanzin commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194131282
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/FileSystemTestCsvITCase.scala:
##
@@ -32,12 +35,11 @@ class FileSys
snuyanzin commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194131282
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/FileSystemTestCsvITCase.scala:
##
@@ -32,12 +35,11 @@ class FileSys
reswqa commented on code in PR #22574:
URL: https://github.com/apache/flink/pull/22574#discussion_r1194117257
##
flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcFileSystemITCase.java:
##
@@ -69,22 +72,18 @@
import static org.assertj.core.api.Assertions.assertThat;
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722858#comment-17722858
]
Aleksandr Iushmanov edited comment on FLINK-32069 at 5/15/23 4:47 PM:
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722858#comment-17722858
]
Aleksandr Iushmanov commented on FLINK-32069:
-
Thanks a lot [~mapohl] for th
[
https://issues.apache.org/jira/browse/FLINK-31946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722855#comment-17722855
]
Hong Liang Teoh commented on FLINK-31946:
-
Hi [~cjensen] ! Thanks for creating t
[
https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722771#comment-17722771
]
David Artiga edited comment on FLINK-31810 at 5/15/23 4:22 PM:
---
mxm opened a new pull request, #598:
URL: https://github.com/apache/flink-kubernetes-operator/pull/598
Some source expose multiple `.pendingRecords` metrics. If that is the case,
we must sum up these records to yield the correct internal pending records
count.
--
This is an automated mes
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722820#comment-17722820
]
Matthias Pohl edited comment on FLINK-32069 at 5/15/23 3:25 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722820#comment-17722820
]
Matthias Pohl edited comment on FLINK-32069 at 5/15/23 3:24 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722820#comment-17722820
]
Matthias Pohl edited comment on FLINK-32069 at 5/15/23 3:23 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722820#comment-17722820
]
Matthias Pohl commented on FLINK-32069:
---
Thanks for sharing your train of thought
Maximilian Michels created FLINK-32102:
--
Summary: Aggregate multiple pendingRecords metric per source if
present
Key: FLINK-32102
URL: https://issues.apache.org/jira/browse/FLINK-32102
Project: F
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722820#comment-17722820
]
Matthias Pohl edited comment on FLINK-32069 at 5/15/23 3:15 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-31609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-31609.
-
> Fatal error in ResourceManager caused
> YARNSessionFIFOSecuredITCase.testDetachedMode to fail
> -
[
https://issues.apache.org/jira/browse/FLINK-31609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-31609.
---
Fix Version/s: 1.18.0
Resolution: Fixed
4415c5150eda071b219db5532c359ca29730a378 on m
gaborgsomogyi merged PR #22550:
URL: https://github.com/apache/flink/pull/22550
--
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
tweise commented on code in PR #22556:
URL: https://github.com/apache/flink/pull/22556#discussion_r1193954446
##
flink-core/src/main/java/org/apache/flink/util/NetUtils.java:
##
@@ -120,6 +120,18 @@ private static URL validateHostPortString(String hostPort)
{
}
}
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722691#comment-17722691
]
Matthias Pohl edited comment on FLINK-32069 at 5/15/23 2:42 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-24696:
--
Assignee: lijie
> Translate how to configure unaligned checkpoints into Chinese
> ---
[
https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722802#comment-17722802
]
Piotr Nowojski commented on FLINK-24696:
Sure! Thanks :)
> Translate how to con
pnowojski commented on code in PR #22584:
URL: https://github.com/apache/flink/pull/22584#discussion_r1193934653
##
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperationTest.java:
##
@@ -785,6 +789,130 @@ public void testOnlyUpstreamChannelStat
StefanRRichter commented on code in PR #22584:
URL: https://github.com/apache/flink/pull/22584#discussion_r1193925009
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java:
##
@@ -136,19 +136,24 @@ public void assignStates() {
[
https://issues.apache.org/jira/browse/FLINK-32047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722785#comment-17722785
]
Gil Shmaya edited comment on FLINK-32047 at 5/15/23 2:26 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-32047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722785#comment-17722785
]
Gil Shmaya edited comment on FLINK-32047 at 5/15/23 2:25 PM:
-
rkhachatryan commented on code in PR #22584:
URL: https://github.com/apache/flink/pull/22584#discussion_r1193902234
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java:
##
@@ -136,19 +136,24 @@ public void assignStates() {
rkhachatryan commented on code in PR #22584:
URL: https://github.com/apache/flink/pull/22584#discussion_r1193908276
##
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperationTest.java:
##
@@ -1029,6 +1192,15 @@ private JobVertex createJobVertex(
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722691#comment-17722691
]
Matthias Pohl edited comment on FLINK-32069 at 5/15/23 2:05 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-32101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722790#comment-17722790
]
Matthias Pohl commented on FLINK-32101:
---
[~tanyuxin] this looks like a Kafka-inter
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722788#comment-17722788
]
Aleksandr Iushmanov commented on FLINK-32069:
-
I can provide more details on
[
https://issues.apache.org/jira/browse/FLINK-32047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722785#comment-17722785
]
Gil Shmaya commented on FLINK-32047:
We run with 1.14.6, sorry for the confusion.
>
XComp commented on code in PR #22380:
URL: https://github.com/apache/flink/pull/22380#discussion_r1193867705
##
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/TestingLeaderBase.java:
##
@@ -80,6 +84,20 @@ public Throwable getError() {
return error =
XComp commented on code in PR #22380:
URL: https://github.com/apache/flink/pull/22380#discussion_r1193866384
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java:
##
@@ -270,65 +390,73 @@ public void onLeaderInformationChange(L
XComp commented on code in PR #22380:
URL: https://github.com/apache/flink/pull/22380#discussion_r1193863651
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java:
##
@@ -32,49 +31,73 @@
import javax.annotation.Nullable;
impor
StefanRRichter commented on code in PR #22584:
URL: https://github.com/apache/flink/pull/22584#discussion_r1193856106
##
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperationTest.java:
##
@@ -785,6 +789,130 @@ public void testOnlyUpstreamChanne
[
https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722782#comment-17722782
]
Weijie Guo commented on FLINK-32094:
master(1.18) via 1a3b539fa43b4e1c8f07accf2d4aa3
1 - 100 of 249 matches
Mail list logo
