godfreyhe commented on PR #21490:
URL: https://github.com/apache/flink/pull/21490#issuecomment-1362522963
@swuferhong Currently, we had copied `RelMdUtil#numDistinctVals` to
`FlinkRelMdUtil.numDistinctVals` and do some changes. does it not meet your
requirements ？
--
This is an automated
XComp closed pull request #21478: [FLINK-28352][tests] Disable
PulsarSourceUnorderedE2ECase, PulsarUnorderedPartitionSplitReaderTest and
PulsarUnorderedSourceITCase
URL: https://github.com/apache/flink/pull/21478
--
This is an automated message from the Apache Git Service.
To respond to the
XComp commented on PR #21478:
URL: https://github.com/apache/flink/pull/21478#issuecomment-1362512313
Closing this one in favor of PR #21501 where we remove the pulsar-related
code.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
Myasuka commented on PR #21516:
URL: https://github.com/apache/flink/pull/21516#issuecomment-1362509538
@ljz2051 do you have a local green CI?
--
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
mas-chen commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-kafka/pull/1#discussion_r1055166044
##
flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java:
##
@@ -82,15
1996fanrui commented on PR #21540:
URL: https://github.com/apache/flink/pull/21540#issuecomment-1362490165
> I think even before this PR, the sort order is also the desc by default.
@yuchen-ecnu could you also take a look at this PR?
Thanks for your feedback, the `sortByBusyRatio` is
[
https://issues.apache.org/jira/browse/FLINK-30475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651102#comment-17651102
]
Hangxiang Yu commented on FLINK-30475:
--
Hi, Have you compared the whole performance
Myasuka commented on PR #21540:
URL: https://github.com/apache/flink/pull/21540#issuecomment-1362471115
I think even before this PR, the sort order is also the desc by default.
@yuchen-ecnu could you also take a look at this PR?
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-30188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30188.
Fix Version/s: 1.17.0
Resolution: Fixed
master (1.17): 4ea67f63eb1c43d7adf07c37946b20b525fb
xintongsong closed pull request #21388: [FLINK-30188][coordination] Set
partition finished state in ConsumedPartitionGroup for dynamic graph correctly.
URL: https://github.com/apache/flink/pull/21388
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
xintongsong commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1362444049
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651084#comment-17651084
]
Yuan Mei edited comment on FLINK-24932 at 12/22/22 5:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651084#comment-17651084
]
Yuan Mei edited comment on FLINK-24932 at 12/22/22 5:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651084#comment-17651084
]
Yuan Mei commented on FLINK-24932:
--
Thanks [~Yanfei Lei] continue pushing forwards the
[
https://issues.apache.org/jira/browse/FLINK-30443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651078#comment-17651078
]
Jiabao Sun commented on FLINK-30443:
I think it makes sense to expend sensitive conf
[
https://issues.apache.org/jira/browse/FLINK-26372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651077#comment-17651077
]
Yanfei Lei commented on FLINK-26372:
[~roman] [~Feifan Wang] I‘d like to continue t
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1055087635
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/converter/MongoConvertersTest.java:
##
@@ -146,28 +146,31 @@ public void
liuml07 commented on PR #21549:
URL: https://github.com/apache/flink/pull/21549#issuecomment-1362394086
CC: @twalthr @fapaul
--
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.
Samrat Deb created FLINK-30482:
--
Summary: Update catalog documentation
Key: FLINK-30482
URL: https://issues.apache.org/jira/browse/FLINK-30482
Project: Flink
Issue Type: Sub-task
Comp
Samrat Deb created FLINK-30481:
--
Summary: create base aws-glue catalog implementation in
flink-connector-aws
Key: FLINK-30481
URL: https://issues.apache.org/jira/browse/FLINK-30481
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-29549:
---
Component/s: Connectors / AWS
(was: Connectors / Hive)
> Add Aws Glue Catalog s
[
https://issues.apache.org/jira/browse/FLINK-29549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-29549:
---
Issue Type: New Feature (was: Improvement)
> Add Aws Glue Catalog support in Flink
> --
[
https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651066#comment-17651066
]
Zhu Zhu commented on FLINK-30480:
-
Thanks for volunteering. [~xiasun]
I have assigned yo
[
https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-30480:
---
Assignee: xingbe
> Add benchmarks for adaptive batch scheduler
> --
[
https://issues.apache.org/jira/browse/FLINK-30480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651065#comment-17651065
]
xingbe commented on FLINK-30480:
Hi, I would like to work on this issue, could you assig
Zhu Zhu created FLINK-30480:
---
Summary: Add benchmarks for adaptive batch scheduler
Key: FLINK-30480
URL: https://issues.apache.org/jira/browse/FLINK-30480
Project: Flink
Issue Type: Improvement
Fanoid commented on PR #191:
URL: https://github.com/apache/flink-ml/pull/191#issuecomment-1362362456
@zhipeng93 Thanks for your valuable comments. I've made some updates, please
check them.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
ljz2051 commented on PR #21516:
URL: https://github.com/apache/flink/pull/21516#issuecomment-1362349616
@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.
ljz2051 commented on PR #21516:
URL: https://github.com/apache/flink/pull/21516#issuecomment-1362328413
@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-30458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-30458.
---
Resolution: Fixed
master: 4c607a7356a5fd43364f93d70264d1ede98113ab
> Refactor Table Store Documenta
tsreaper merged PR #443:
URL: https://github.com/apache/flink-table-store/pull/443
--
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...@fl
ljz2051 commented on PR #21516:
URL: https://github.com/apache/flink/pull/21516#issuecomment-1362323900
@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.
masteryhx commented on PR #21468:
URL: https://github.com/apache/flink/pull/21468#issuecomment-1362320855
@Myasuka Do you have other suggestions?
--
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 t
tsreaper commented on code in PR #410:
URL: https://github.com/apache/flink-table-store/pull/410#discussion_r1055030061
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/source/snapshot/ContinuousFromSnapshotStartingScanner.java:
##
@@ -0,0 +1,49 @@
+/*
tsreaper commented on code in PR #410:
URL: https://github.com/apache/flink-table-store/pull/410#discussion_r1053120573
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/CoreOptions.java:
##
@@ -543,6 +550,8 @@ public static StartupMode startupMode(ReadableCon
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651050#comment-17651050
]
RocMarshal commented on FLINK-25421:
Hi [~eskabetxe] Is here any new progress about
[
https://issues.apache.org/jira/browse/FLINK-27731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651039#comment-17651039
]
Xintong Song commented on FLINK-27731:
--
Thanks for the pointer and explanation. Sou
[
https://issues.apache.org/jira/browse/FLINK-30479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30479:
--
Description:
The file system SQL connector itself is included in Flink and does not require
a
liuml07 commented on code in PR #21549:
URL: https://github.com/apache/flink/pull/21549#discussion_r1054985251
##
docs/content/docs/connectors/table/filesystem.md:
##
@@ -33,6 +33,18 @@ The file system connector itself is included in Flink and
does not require an ad
The corres
lincoln-lil commented on PR #21546:
URL: https://github.com/apache/flink/pull/21546#issuecomment-1362266272
@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 commen
flinkbot commented on PR #21549:
URL: https://github.com/apache/flink/pull/21549#issuecomment-1362266024
## CI report:
* 3d0a250bc8391007493b1031b98a5acd4b87eae4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30479:
---
Labels: pull-request-available (was: )
> Document flink-connector-files for local execution
liuml07 commented on PR #21549:
URL: https://github.com/apache/flink/pull/21549#issuecomment-1362264819
![Uploading Screenshot 2022-12-21 at 4.52.34 PM.png…]()
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
liuml07 opened a new pull request, #21549:
URL: https://github.com/apache/flink/pull/21549
## What is the purpose of the change
The file system SQL connector itself is included in Flink and does not
require an additional dependency. However, if a user uses the filesystem
connector fo
Mingliang Liu created FLINK-30479:
-
Summary: Document flink-connector-files for local execution
Key: FLINK-30479
URL: https://issues.apache.org/jira/browse/FLINK-30479
Project: Flink
Issue Ty
rkhachatryan commented on code in PR #21467:
URL: https://github.com/apache/flink/pull/21467#discussion_r1054964645
##
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerSenderImpl.java:
##
@@ -37,7 +37,7 @@
private final long heartbeatPeriod;
rkhachatryan commented on code in PR #21467:
URL: https://github.com/apache/flink/pull/21467#discussion_r1054957881
##
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/NoOpHeartbeatServices.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundatio
rkhachatryan commented on code in PR #21467:
URL: https://github.com/apache/flink/pull/21467#discussion_r1054946222
##
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatServices.java:
##
@@ -100,37 +62,31 @@ public HeartbeatManager
createHeartbeatManager(
snuyanzin opened a new pull request, #14:
URL: https://github.com/apache/flink-connector-jdbc/pull/14
This is a cherry pick from flink master to update junit5
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
boring-cyborg[bot] commented on PR #13:
URL:
https://github.com/apache/flink-connector-jdbc/pull/13#issuecomment-1362209144
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
snuyanzin opened a new pull request, #13:
URL: https://github.com/apache/flink-connector-jdbc/pull/13
This is almost a cherry pick from flink master + exclusion of `byte-buddy`
to avoid dependency convergence
--
This is an automated message from the Apache Git Service.
To respond to the m
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054892467
##
flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyAsyncV2Test.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licens
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054892121
##
flink-connector-kinesis/pom.xml:
##
@@ -256,6 +256,11 @@ under the License.
netty-nio-client
+
+software.amazo
[
https://issues.apache.org/jira/browse/FLINK-30113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30113:
--
Assignee: Etienne Chauchot
> Compression for operator state
> ---
MartijnVisser commented on PR #21548:
URL: https://github.com/apache/flink/pull/21548#issuecomment-1361943096
@gunnarmorling Since this library would be bundled, it's required to update
the NOTICE file in `flink-dist/src/main/resources/META-INF/NOTICE`
--
This is an automated message fro
MartijnVisser merged PR #594:
URL: https://github.com/apache/flink-web/pull/594
--
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
mxm merged PR #492:
URL: https://github.com/apache/flink-kubernetes-operator/pull/492
--
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...
mxm commented on PR #492:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/492#issuecomment-1361921179
Thanks for the review!
--
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 spe
MartijnVisser merged PR #590:
URL: https://github.com/apache/flink-web/pull/590
--
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
MartijnVisser merged PR #589:
URL: https://github.com/apache/flink-web/pull/589
--
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
reta commented on PR #21518:
URL: https://github.com/apache/flink/pull/21518#issuecomment-1361905787
Thank you very much, @dannycranmer and @MartijnVisser
--
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
[
https://issues.apache.org/jira/browse/FLINK-27731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650977#comment-17650977
]
Martijn Visser commented on FLINK-27731:
[~xtsong] See https://github.com/apache
[
https://issues.apache.org/jira/browse/FLINK-27731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650977#comment-17650977
]
Martijn Visser edited comment on FLINK-27731 at 12/21/22 6:56 PM:
MartijnVisser commented on PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1361896306
> The Opensearch documentations available here [2] but I am not sure how it
is going to be integrated into Flink documentation, @zentol may be you could
spot some ligh
reta commented on PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1361784372
> The artifacts you mentioned that will be available in the coming days is
referring to registering this library to maven repo?
@ypark2103 Correct
--
This is an autom
RyanSkraba commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1054648476
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed
ypark2103 commented on PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1361761149
@reta Is there a way we can install this library with pom.xml?
I don't see opensearch in maven depository yet like elasticsearch connector.
https://mvnrepository.com/
reta commented on PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1361745642
> hi @zentol @reta I see that
[flink-opensearch-connector](https://issues.apache.org/jira/browse/FLINK-opensearch-connector)
was merged to master recently but I don't see it wa
ypark2103 commented on PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1361723729
hi @zentol @reta
I see that flink-opensearch-connector was merged to master recently but I
don't see it was registered in maven repository.
When will this be added t
ramkrish86 commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1361723105
The current failure seems to be unrelated.
--
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
gunnarmorling commented on PR #21532:
URL: https://github.com/apache/flink/pull/21532#issuecomment-1361706613
Thanks a lot for reviewing @rmetzger; I have
* Reworked the commit message
* Added a test which would fail on JDK 17 without the fix; with the fix, it
passes on 11 and 17
flinkbot commented on PR #21548:
URL: https://github.com/apache/flink/pull/21548#issuecomment-1361676706
## CI report:
* 611c92cf2be5bf99de666458482644df08732cb9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30478:
---
Labels: pull-request-available (was: )
> Don't depend on IPAddressUtil
> --
gunnarmorling commented on PR #21548:
URL: https://github.com/apache/flink/pull/21548#issuecomment-1361672500
// CC @rmetzger
--
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
gunnarmorling opened a new pull request, #21548:
URL: https://github.com/apache/flink/pull/21548
## What is the purpose of the change
Increasing the usability of Flink with JDK 17: `sun.net.util.IPAddressUtil`
is not exported by the JDK, i.e. `--add-opens` configuration is needed for
[
https://issues.apache.org/jira/browse/FLINK-30478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-30478:
--
Assignee: Gunnar Morling
> Don't depend on IPAddressUtil
> --
Gunnar Morling created FLINK-30478:
--
Summary: Don't depend on IPAddressUtil
Key: FLINK-30478
URL: https://issues.apache.org/jira/browse/FLINK-30478
Project: Flink
Issue Type: Sub-task
XComp commented on code in PR #21467:
URL: https://github.com/apache/flink/pull/21467#discussion_r1054558267
##
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatServices.java:
##
@@ -100,37 +62,31 @@ public HeartbeatManager
createHeartbeatManager(
XComp commented on code in PR #21467:
URL: https://github.com/apache/flink/pull/21467#discussion_r1054523544
##
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerSenderImpl.java:
##
@@ -56,7 +56,7 @@
new HeartbeatMonitorImpl.Factory<
[
https://issues.apache.org/jira/browse/FLINK-27731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650930#comment-17650930
]
Xintong Song commented on FLINK-27731:
--
bq. We've recently decided to integrate doc
rmetzger commented on code in PR #21531:
URL: https://github.com/apache/flink/pull/21531#discussion_r1054551815
##
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java:
##
@@ -207,7 +207,7 @@ public Set getDirtyResultsInternal() thr
[
https://issues.apache.org/jira/browse/FLINK-22922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-22922:
--
Assignee: Martijn Visser (was: Daisy Tsang)
> Migrate flink project website to Hugo
ljz2051 commented on PR #21516:
URL: https://github.com/apache/flink/pull/21516#issuecomment-1361446598
@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.
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054485689
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSAsyncSinkUtil.java:
##
@@ -161,4 +163,47 @@ S createAwsAsyncClient(
ljz2051 commented on PR #21516:
URL: https://github.com/apache/flink/pull/21516#issuecomment-1361437935
@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.
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054467238
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSAsyncSinkUtil.java:
##
@@ -161,4 +163,47 @@ S createAwsAsyncClient(
ljz2051 commented on PR #21516:
URL: https://github.com/apache/flink/pull/21516#issuecomment-1361409276
@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.
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054459944
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/StreamConsumerRegistrar.java:
##
@@ -77,8 +7
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054458256
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/StreamConsumerRegistrar.java:
##
@@ -243,28
[
https://issues.apache.org/jira/browse/FLINK-30342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-30342:
-
Assignee: Matthias Pohl
> Migrate ZooKeeperLeaderElectionTest
> ---
lincoln-lil commented on PR #21177:
URL: https://github.com/apache/flink/pull/21177#issuecomment-1361378180
close the temporary backporting patch
--
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 t
lincoln-lil commented on PR #21222:
URL: https://github.com/apache/flink/pull/21222#issuecomment-1361378770
close the temporary backporting patch
--
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 t
lincoln-lil closed pull request #21222: [BP-1.15][FLINK-29849 &
FLINK-29781][table-planner] Fix event time temporal join on an upsert source
may produce incorrect execution plan
URL: https://github.com/apache/flink/pull/21222
--
This is an automated message from the Apache Git Service.
To re
lincoln-lil closed pull request #21177: [FLINK-29781][table-planner] Fix
ChangelogNormalize uses wrong keys after transformation by
WatermarkAssignerChangelogNormalizeTransposeRule
URL: https://github.com/apache/flink/pull/21177
--
This is an automated message from the Apache Git Service.
To
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054443739
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxySyncV2.java:
##
@@ -114,6 +104,7 @@ public DescribeSt
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054442840
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxySyncV2.java:
##
@@ -148,11 +139,10 @@ public Register
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1054441165
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/StreamConsumerRegistrar.java:
##
@@ -77,8 +7
flinkbot commented on PR #21547:
URL: https://github.com/apache/flink/pull/21547#issuecomment-1361366338
## CI report:
* 36cbe3cc7b8acbbce02401f20ee0fa3b39251d4d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30461:
---
Labels: pull-request-available (was: )
> Some rocksdb sst files will remain forever
> -
1996fanrui opened a new pull request, #21547:
URL: https://github.com/apache/flink/pull/21547
## What is the purpose of the change
In rocksdb incremental checkpoint mode, during file upload, if some files
have been uploaded and some files have not been uploaded, the checkpoint is
can
1 - 100 of 215 matches
Mail list logo
