flinkbot commented on PR #20981:
URL: https://github.com/apache/flink/pull/20981#issuecomment-1271081867
## CI report:
* 68d7cb132665dfad3b28d67ca969edec33e7b1ee UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuzhuang2017 opened a new pull request, #20981:
URL: https://github.com/apache/flink/pull/20981
## What is the purpose of the change
- Fix typo in rocksdb.
## Brief change log
- Fix typo in rocksdb.
## Verifying this change
- No need to test.
MartijnVisser commented on PR #20170:
URL: https://github.com/apache/flink/pull/20170#issuecomment-1271021662
I've ran the failing test multiple times locally, passing every time. Looks
like [FLINK-24119](https://issues.apache.org/jira/browse/FLINK-24119) but that
has been resolved
MartijnVisser commented on PR #20170:
URL: https://github.com/apache/flink/pull/20170#issuecomment-1271020448
@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
MartijnVisser commented on PR #20170:
URL: https://github.com/apache/flink/pull/20170#issuecomment-1270926463
@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
MartijnVisser commented on PR #20977:
URL: https://github.com/apache/flink/pull/20977#issuecomment-1270762062
@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
MartijnVisser commented on PR #14737:
URL: https://github.com/apache/flink/pull/14737#issuecomment-1270731529
@dannycranmer Thanks!
--
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
flinkbot commented on PR #20980:
URL: https://github.com/apache/flink/pull/20980#issuecomment-1270719355
## CI report:
* 5ba06042c9d0105867f8f048b926bbb0ea9b5019 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29532:
---
Labels: pull-request-available (was: )
> Update Pulsar dependency to 2.10.1
>
MartijnVisser commented on PR #20980:
URL: https://github.com/apache/flink/pull/20980#issuecomment-1270716377
@syhily @imaffe Can one of you have a look at this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
MartijnVisser opened a new pull request, #20980:
URL: https://github.com/apache/flink/pull/20980
## What is the purpose of the change
* Update the Pulsar dependency to 2.10.1 to benefit of the fixes highlights
at https://github.com/apache/pulsar/releases/tag/v2.10.1
## Brief
Martijn Visser created FLINK-29532:
--
Summary: Update Pulsar dependency to 2.10.1
Key: FLINK-29532
URL: https://issues.apache.org/jira/browse/FLINK-29532
Project: Flink
Issue Type: Technical
dannycranmer commented on PR #14737:
URL: https://github.com/apache/flink/pull/14737#issuecomment-1270702053
@MartijnVisser I will reach out to the team, if they cannot help I will find
someone.
--
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on PR #20979:
URL: https://github.com/apache/flink/pull/20979#issuecomment-1270683307
## CI report:
* 31f8e73e9e386f66d32ac0e36bffecbac024784f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
kristoffSC opened a new pull request, #20979:
URL: https://github.com/apache/flink/pull/20979
[DRAFT] KC_FLINK-29509_master - Set subtaskId and numberOfSubtasks on
CheckpointCommittableManagerImpl during deserialization.
Signed-off-by: Krzysztof Chmielewski
## What is
MartijnVisser commented on PR #14737:
URL: https://github.com/apache/flink/pull/14737#issuecomment-1270636829
@mohitpali Do you think you could help with updating the dependencies of the
Glue Schema Registry integrations in Flink? These are already quite outdated
and it would be nice if we
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r989449285
##
flink-core/src/test/java/org/apache/flink/api/connector/source/lib/DataGeneratorSourceTest.java:
##
@@ -0,0 +1,250 @@
+/*
+ * Licensed to the Apache Software
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r989449285
##
flink-core/src/test/java/org/apache/flink/api/connector/source/lib/DataGeneratorSourceTest.java:
##
@@ -0,0 +1,250 @@
+/*
+ * Licensed to the Apache Software
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r989449285
##
flink-core/src/test/java/org/apache/flink/api/connector/source/lib/DataGeneratorSourceTest.java:
##
@@ -0,0 +1,250 @@
+/*
+ * Licensed to the Apache Software
flinkbot commented on PR #20978:
URL: https://github.com/apache/flink/pull/20978#issuecomment-1270629485
## CI report:
* ec99bae39386b43c99cbda15fe6128352d60b395 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29462:
---
Priority: Critical (was: Major)
> LookupJoinITCase failed on azure due to classloader
snuyanzin commented on PR #20925:
URL: https://github.com/apache/flink/pull/20925#issuecomment-1270623766
@flinkbot run azure
since the error seems relates to
https://issues.apache.org/jira/browse/FLINK-29462
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-29531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29531:
---
Labels: pull-request-available (was: )
> Bump protoc and protobuf-java dependencies to
MartijnVisser opened a new pull request, #20978:
URL: https://github.com/apache/flink/pull/20978
## What is the purpose of the change
* Bump protoc and protobuf-java dependencies to at least 3.21.7 to avoid
false positive scans on Protobuf vulnerabilities
## Brief change log
Martijn Visser created FLINK-29531:
--
Summary: Bump protoc and protobuf-java dependencies to 3.21.7
Key: FLINK-29531
URL: https://issues.apache.org/jira/browse/FLINK-29531
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28405:
---
Description:
We have updated the used Kafka Clients to v3.1.1 via FLINK-28060 and then to
[
https://issues.apache.org/jira/browse/FLINK-29513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reopened FLINK-29513:
Re-opened to patch also 1.16
> Update Kafka version to 3.2.3
> -
MartijnVisser commented on code in PR #20170:
URL: https://github.com/apache/flink/pull/20170#discussion_r989430410
##
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java:
##
@@ -84,7
MartijnVisser commented on code in PR #20170:
URL: https://github.com/apache/flink/pull/20170#discussion_r989430227
##
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml:
##
@@ -156,6 +156,11 @@ under the License.
${project.version}
MartijnVisser commented on code in PR #20170:
URL: https://github.com/apache/flink/pull/20170#discussion_r989429992
##
flink-connectors/flink-connector-kafka/pom.xml:
##
@@ -111,11 +111,12 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613764#comment-17613764
]
Chesnay Schepler edited comment on FLINK-29501 at 10/6/22 7:35 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613764#comment-17613764
]
Chesnay Schepler commented on FLINK-29501:
--
?? The upside may be shorter downtime.??
The
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r989384508
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r989384683
##
flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/util/RateLimitedSourceReaderITCase.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r989384508
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-29245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613755#comment-17613755
]
Nagaraj Tantri commented on FLINK-29245:
Thanks [~mapohl] . Since most of the open tickets had
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r989292326
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerNG.java:
##
@@ -125,7 +127,8 @@ void notifyKvStateUnregistered(
CompletableFuture
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27060:
---
Summary: [FLIP-256] Support Job Dynamic Parameter With Flink Rest Api
(was: Extending
[
https://issues.apache.org/jira/browse/FLINK-29511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29511.
Resolution: Fixed
master:
c8fb99beeccd81f7b2ebfdc7ce178fcc04d100a1
zentol merged PR #20971:
URL: https://github.com/apache/flink/pull/20971
--
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:
XComp commented on code in PR #18760:
URL: https://github.com/apache/flink/pull/18760#discussion_r989215635
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java:
##
@@ -33,8 +33,8 @@
import
[
https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613630#comment-17613630
]
Gyula Fora commented on FLINK-29501:
I think [~mxm] makes valid points here.
The problem with the
XComp commented on code in PR #20230:
URL: https://github.com/apache/flink/pull/20230#discussion_r989201719
##
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/protobuf/ParquetProtoStreamingFileSinkITCase.java:
##
@@ -49,13 +50,12 @@
* Simple
zentol commented on PR #20971:
URL: https://github.com/apache/flink/pull/20971#issuecomment-1270288283
> If we ordering the properties/schema, shouldn't we also sort the
operations?
The operations should have a well-defined order; in whichever order we
define the endpoints. We don't
[
https://issues.apache.org/jira/browse/FLINK-28449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-28449:
-
Assignee: Ryan Skraba
> [JUnit5 Migration] Module: flink-parquet
>
XComp commented on code in PR #20258:
URL: https://github.com/apache/flink/pull/20258#discussion_r989176628
##
flink-formats/flink-sequence-file/src/test/java/org/apache/flink/formats/sequencefile/SequenceStreamingFileSinkITCase.java:
##
@@ -50,18 +51,17 @@
* Integration test
[
https://issues.apache.org/jira/browse/FLINK-29500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-29500.
Fix Version/s: 1.17.0
1.15.3
1.16.1
[
https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613593#comment-17613593
]
Chesnay Schepler edited comment on FLINK-29530 at 10/6/22 3:06 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613593#comment-17613593
]
Chesnay Schepler commented on FLINK-29530:
--
Maybe the issue isn't that they load the serializer
[
https://issues.apache.org/jira/browse/FLINK-29500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29500:
---
Labels: pull-request-available (was: )
> InitializeOnMaster uses wrong parallelism with
dawidwys merged PR #20950:
URL: https://github.com/apache/flink/pull/20950
--
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-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613592#comment-17613592
]
Chesnay Schepler commented on FLINK-29530:
--
{{equals()}} and {{hashcode()}} also load the
[
https://issues.apache.org/jira/browse/FLINK-29529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-29529:
--
Description:
Currently, we hardcoded the version of both flink image and pyflink pip package
as
[
https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29530:
-
Description:
The {{toString}} implementation calls the committable serializer factory,
Chesnay Schepler created FLINK-29530:
Summary: CommittableMessageTypeInfo#toString may force client to
have S3 credentials
Key: FLINK-29530
URL: https://issues.apache.org/jira/browse/FLINK-29530
[
https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613586#comment-17613586
]
Maximilian Michels commented on FLINK-29501:
It's definitely an option to use the
Biao Geng created FLINK-29529:
-
Summary: Update flink version in flink-python-example of flink k8s
operator
Key: FLINK-29529
URL: https://issues.apache.org/jira/browse/FLINK-29529
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-28522:
-
Assignee: Ryan Skraba
> [JUnit5 Migration] Module: flink-sequence-file
>
XComp commented on code in PR #20267:
URL: https://github.com/apache/flink/pull/20267#discussion_r989152235
##
flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemBehaviorTest.java:
##
@@ -23,26 +23,25 @@
import org.apache.flink.core.fs.FileSystemKind;
[
https://issues.apache.org/jira/browse/FLINK-29511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29511:
---
Labels: pull-request-available (was: )
> Sort properties/schemas in OpenAPI spec
>
MartijnVisser commented on PR #20971:
URL: https://github.com/apache/flink/pull/20971#issuecomment-1270189574
> Apologies in advance to the reviewer
Thank you 藍
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot commented on PR #20977:
URL: https://github.com/apache/flink/pull/20977#issuecomment-1270185730
## CI report:
* b47ae9021570ff3f8b39a98a6971743cd9002efa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
MartijnVisser commented on PR #20972:
URL: https://github.com/apache/flink/pull/20972#issuecomment-1270178162
> Will this be backported to 1.16 too?
@zentol I don't see much harm since it's only updating a patch version, but
if we would do so, we would only release it with Flink
MartijnVisser opened a new pull request, #20977:
URL: https://github.com/apache/flink/pull/20977
Unchanged backport of https://github.com/apache/flink/pull/20972
--
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-29528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29528:
-
Description:
fs-hadoop-shaded contains a core-default-shaded.xml that was originally
Chesnay Schepler created FLINK-29528:
Summary: Check if core-default-shaded is still required
Key: FLINK-29528
URL: https://issues.apache.org/jira/browse/FLINK-29528
Project: Flink
Issue
ijuma commented on PR #20972:
URL: https://github.com/apache/flink/pull/20972#issuecomment-1270130533
Will this be backported to 1.16 too?
--
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
ijuma commented on PR #20764:
URL: https://github.com/apache/flink/pull/20764#issuecomment-1270125693
This workaround is no longer needed since #20972 has been merged. If we want
to keep it in case of a user explicitly using the bad kafka version, it's worth
adding a comment explaining
1996fanrui commented on code in PR #20233:
URL: https://github.com/apache/flink/pull/20233#discussion_r989067790
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java:
##
@@ -569,6 +571,58 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-29509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul reassigned FLINK-29509:
---
Assignee: Krzysztof Chmielewski
> Set correct subtaskId during recovery of committables
>
[
https://issues.apache.org/jira/browse/FLINK-29509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613527#comment-17613527
]
Krzysztof Chmielewski commented on FLINK-29509:
---
Hi,
I would like to work on this thicket.
XComp commented on PR #18440:
URL: https://github.com/apache/flink/pull/18440#issuecomment-1270037362
@snuyanzin The change looks good to me, too. May you rebase the PR. It seems
that there was a junit5 migration for those tests that are conflicting now?
--
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613509#comment-17613509
]
Chesnay Schepler edited comment on FLINK-29501 at 10/6/22 1:16 PM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613509#comment-17613509
]
Chesnay Schepler commented on FLINK-29501:
--
I don't really see why we should make this a
[
https://issues.apache.org/jira/browse/FLINK-15130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-15130:
--
Description:
As per [mailing list
pnowojski commented on code in PR #20233:
URL: https://github.com/apache/flink/pull/20233#discussion_r989031922
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java:
##
@@ -569,6 +571,58 @@ public void
pnowojski commented on code in PR #20233:
URL: https://github.com/apache/flink/pull/20233#discussion_r989031922
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java:
##
@@ -569,6 +571,58 @@ public void
zentol commented on code in PR #20953:
URL: https://github.com/apache/flink/pull/20953#discussion_r989020962
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java:
##
@@ -148,11 +150,30 @@ private CompletableFuture loadJobGraph(
[
https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29501:
---
Labels: pull-request-available (was: )
> Allow overriding JobVertex parallelisms during
zentol commented on code in PR #20953:
URL: https://github.com/apache/flink/pull/20953#discussion_r989016671
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java:
##
@@ -148,11 +150,30 @@ private CompletableFuture loadJobGraph(
[
https://issues.apache.org/jira/browse/FLINK-15130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-15130:
-
Assignee: Sergey Nuyanzin
> Drop "RequiredParameters" and "Options"
>
[
https://issues.apache.org/jira/browse/FLINK-29246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29246:
--
Component/s: (was: Connectors / DynamoDB)
> Setup DynamoDB Maven Modules
>
XComp commented on code in PR #20925:
URL: https://github.com/apache/flink/pull/20925#discussion_r988616500
##
pom.xml:
##
@@ -599,7 +599,7 @@ under the License.
jackson-bom
pom
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988989113
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988986838
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988984499
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988986838
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988984499
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation
MartijnVisser commented on code in PR #20973:
URL: https://github.com/apache/flink/pull/20973#discussion_r988983537
##
pom.xml:
##
@@ -165,7 +165,7 @@ under the License.
Starting Hadoop 3, org.apache.kerby will be used
instead of MiniKDC. We may have
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988979454
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988979454
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation
1996fanrui commented on PR #20233:
URL: https://github.com/apache/flink/pull/20233#issuecomment-1269936458
@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
[
https://issues.apache.org/jira/browse/FLINK-29513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29513.
--
Fix Version/s: 1.17.0
Resolution: Fixed
Fixed in master:
MartijnVisser merged PR #20972:
URL: https://github.com/apache/flink/pull/20972
--
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:
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988967326
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation
zentol commented on code in PR #20170:
URL: https://github.com/apache/flink/pull/20170#discussion_r988947010
##
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml:
##
@@ -156,6 +156,11 @@ under the License.
${project.version}
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988952963
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation
1996fanrui commented on code in PR #20233:
URL: https://github.com/apache/flink/pull/20233#discussion_r988935163
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java:
##
@@ -568,6 +572,53 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-24404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613463#comment-17613463
]
Eui Heo commented on FLINK-24404:
-
Any updates?
If not, could you assign this issue to me?
> Support
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r988932935
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software
1 - 100 of 159 matches
Mail list logo
