flinkbot commented on PR #22991:
URL: https://github.com/apache/flink/pull/22991#issuecomment-1633436746
## CI report:
* 9070417fbb43a78750514b351793bc0244ca5816 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xuzhiwen1255 commented on code in PR #22010:
URL: https://github.com/apache/flink/pull/22010#discussion_r1261890872
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -22,29 +22,44 @@
import
WencongLiu commented on PR #22855:
URL: https://github.com/apache/flink/pull/22855#issuecomment-1633420229
@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
xuzhiwen1255 commented on code in PR #22010:
URL: https://github.com/apache/flink/pull/22010#discussion_r1261875654
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -189,8 +206,28 @@ public static
xuzhiwen1255 commented on code in PR #22010:
URL: https://github.com/apache/flink/pull/22010#discussion_r1261873363
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -22,29 +22,44 @@
import
tzulitai commented on PR #35:
URL:
https://github.com/apache/flink-connector-kafka/pull/35#issuecomment-1633401964
`Dependency convergence error for
org.apache.flink:flink-shaded-jackson:2.13.4-16.1 paths to dependency are`
Looks like conflict between the pinned versions in the
[
https://issues.apache.org/jira/browse/FLINK-30349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742482#comment-17742482
]
Ferenc Csaky commented on FLINK-30349:
--
Cherry-picked the commit for fixing the tests to 1.17 from
ferenc-csaky opened a new pull request, #14:
URL: https://github.com/apache/flink-connector-hbase/pull/14
…not enforced check
This closes #21507
--
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
flinkbot commented on PR #22990:
URL: https://github.com/apache/flink/pull/22990#issuecomment-1632800475
## CI report:
* 490c28863020016238ac9d98b24b865284b51738 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32280:
---
Labels: pull-request-available (was: )
> HashAgg support operator fusion codegen
>
lsyldliu opened a new pull request, #22990:
URL: https://github.com/apache/flink/pull/22990
## What is the purpose of the change
*HashAgg support operator fusion code generator, include without key and
with key case, also include one phase and two phase case. Please attention, we
rkhachatryan commented on code in PR #22744:
URL: https://github.com/apache/flink/pull/22744#discussion_r1261378225
##
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java:
##
@@ -375,6 +378,49 @@
rkhachatryan commented on code in PR #22772:
URL: https://github.com/apache/flink/pull/22772#discussion_r1261375807
##
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java:
##
@@ -67,10 +70,12 @@ public class TaskIOMetricGroup extends
[
https://issues.apache.org/jira/browse/FLINK-30349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742471#comment-17742471
]
Ferenc Csaky commented on FLINK-30349:
--
Correct I think. Although the E2E tests are failing ATM.
tisonkun commented on code in PR #22989:
URL: https://github.com/apache/flink/pull/22989#discussion_r1261363199
##
tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/licensecheck/JarFileChecker.java:
##
@@ -216,6 +216,10 @@ private static int
flinkbot commented on PR #22989:
URL: https://github.com/apache/flink/pull/22989#issuecomment-1632760597
## CI report:
* 8d12b0851cfaa07c1a30672ca6df316a4375f106 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ferenc-csaky commented on code in PR #22937:
URL: https://github.com/apache/flink/pull/22937#discussion_r1261353832
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemoryCatalogStoreTest.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the
zentol commented on code in PR #22989:
URL: https://github.com/apache/flink/pull/22989#discussion_r1261354494
##
tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/licensecheck/JarFileChecker.java:
##
@@ -216,6 +216,10 @@ private static int
ferenc-csaky commented on code in PR #22937:
URL: https://github.com/apache/flink/pull/22937#discussion_r1261353832
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemoryCatalogStoreTest.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-31035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-31035.
-
Fix Version/s: 1.18.0
Assignee: xy
Resolution: Fixed
Merged into master
rkhachatryan commented on PR #22980:
URL: https://github.com/apache/flink/pull/22980#issuecomment-1632748955
Thanks for the PR, merged into master.
--
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
rkhachatryan merged PR #22980:
URL: https://github.com/apache/flink/pull/22980
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
flinkbot commented on PR #22988:
URL: https://github.com/apache/flink/pull/22988#issuecomment-1632746708
## CI report:
* 930863b673435c3232b99314a903b22326e85561 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32585:
---
Labels: pull-request-available (was: )
> Filter javax.xml.bind:jaxb-api false positive for
tisonkun opened a new pull request, #22989:
URL: https://github.com/apache/flink/pull/22989
## What is the purpose of the change
Add one more filter to suppress false positive.
## Brief change log
Trivial.
## Verifying this change
Semantically. I don't find
Zili Chen created FLINK-32585:
-
Summary: Filter javax.xml.bind:jaxb-api false positive for Pulsar
connector
Key: FLINK-32585
URL: https://issues.apache.org/jira/browse/FLINK-32585
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32157:
---
Labels: pull-request-available starter (was: starter)
> Replaces LeaderConnectionInfo with
archzi opened a new pull request, #22988:
URL: https://github.com/apache/flink/pull/22988
## What is the purpose of the change
This pull request replaces `LeaderConnectionInfo` with `LeaderInformation`
## Brief change log
This change replaces all references to
[
https://issues.apache.org/jira/browse/FLINK-32277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-32277.
---
Fix Version/s: 1.18.0
Assignee: dalongliu
Resolution: Fixed
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-32278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742454#comment-17742454
]
Jark Wu edited comment on FLINK-32278 at 7/12/23 2:55 PM:
--
Fixed in master with
[
https://issues.apache.org/jira/browse/FLINK-32278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-32278.
---
Fix Version/s: 1.18.0
Assignee: dalongliu
Resolution: Fixed
Fixed in master with
wuchong closed pull request #22734: [FLINK-32277][table-runtime] Introduce the
basic operator fusion codegen framework
URL: https://github.com/apache/flink/pull/22734
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-32552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742453#comment-17742453
]
Fabio Wanner commented on FLINK-32552:
--
I dug a bit deeper and found the following:
Anytime when
[
https://issues.apache.org/jira/browse/FLINK-32584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742448#comment-17742448
]
Dawid Wysakowicz commented on FLINK-32584:
--
Hey [~jark] this is not a big change of behaviour.
[
https://issues.apache.org/jira/browse/FLINK-32563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742446#comment-17742446
]
Etienne Chauchot commented on FLINK-32563:
--
Also the other option (proposed privately by
[
https://issues.apache.org/jira/browse/FLINK-32583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742435#comment-17742435
]
Patrick Lucas commented on FLINK-32583:
---
Further investigation suggests that this can only happen
gyfora merged PR #629:
URL: https://github.com/apache/flink-kubernetes-operator/pull/629
--
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:
gyfora opened a new pull request, #630:
URL: https://github.com/apache/flink-kubernetes-operator/pull/630
## What is the purpose of the change
In place scaling through the rest api should only be used in cases where we
are not falling back to default configs (remove overrides). This
hackergin commented on code in PR #22937:
URL: https://github.com/apache/flink/pull/22937#discussion_r1261189996
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemoryCatalogStoreTest.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the
flinkbot commented on PR #22987:
URL: https://github.com/apache/flink/pull/22987#issuecomment-1632531200
## CI report:
* 4a78684a6d5d9655a92550ff8f5132f9047a7ddf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
tisonkun commented on PR #54:
URL:
https://github.com/apache/flink-connector-pulsar/pull/54#issuecomment-1632527498
@zentol can we disable false positive for LicenseChecker?
https://github.com/apache/flink-connector-pulsar/actions/runs/5531507804/jobs/10092293645
```
[
https://issues.apache.org/jira/browse/FLINK-32583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32583:
---
Labels: pull-request-available (was: )
> RestClient can deadlock if request made after
patricklucas opened a new pull request, #22987:
URL: https://github.com/apache/flink/pull/22987
## What is the purpose of the change
Fix the issue described in FLINK-32583 wherein a request made to a
RestClient that has already been shutdown can deadlock due to the returned
future
flinkbot commented on PR #22986:
URL: https://github.com/apache/flink/pull/22986#issuecomment-1632516807
## CI report:
* f7b78c2fa5fc06b6eac001f4b25278b753fa7d2d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32582:
---
Labels: pull-request-available (was: )
> Move TypeSerializerUpgradeTestBase from Kafka
dawidwys opened a new pull request, #22986:
URL: https://github.com/apache/flink/pull/22986
## What is the purpose of the change
Make it possible to unset the default catalog and/or database
## Brief change log
* accept `null` in `useCatalog` and `useDatabase`
*
tzulitai commented on PR #35:
URL:
https://github.com/apache/flink-connector-kafka/pull/35#issuecomment-1632476295
@MartijnVisser can you rebase on top of latest `main`? 1.18 builds should be
passing now.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-31408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-31408.
---
Resolution: Fixed
> Add EXACTLY_ONCE support to upsert-kafka
>
[
https://issues.apache.org/jira/browse/FLINK-31408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31408:
Fix Version/s: kafka-3.1.0
> Add EXACTLY_ONCE support to upsert-kafka
>
[
https://issues.apache.org/jira/browse/FLINK-31408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742414#comment-17742414
]
Tzu-Li (Gordon) Tai commented on FLINK-31408:
-
Merged to flink-connector-kafka via:
main -
[
https://issues.apache.org/jira/browse/FLINK-32453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-32453:
Affects Version/s: kafka-3.0.0
(was: 1.18.0)
>
[
https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-32455.
---
Resolution: Fixed
> Breaking change in TypeSerializerUpgradeTestBase prevents
>
[
https://issues.apache.org/jira/browse/FLINK-32453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-32453.
---
Resolution: Fixed
> flink-connector-kafka does not build against Flink
[
https://issues.apache.org/jira/browse/FLINK-32453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-32453:
Fix Version/s: kafka-3.0.1
kafka-3.1.0
[
https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-32455:
Fix Version/s: kafka-3.0.1
kafka-3.1.0
> Breaking change in
[
https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-32455:
Affects Version/s: kafka-3.0.0
(was: 1.18.0)
>
[
https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742413#comment-17742413
]
Tzu-Li (Gordon) Tai commented on FLINK-32455:
-
Merged to flink-connector-kafka via:
main -
[
https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-32455:
Fix Version/s: (was: 1.18.0)
> Breaking change in
tzulitai closed pull request #7: [FLINK-31408] Add support for EOS
delivery-guarantee in upsert-kafka
URL: https://github.com/apache/flink-connector-kafka/pull/7
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
tzulitai closed pull request #39: [FLINK-32453] Make main and v3.0 branch build
against Flink 1.18-SNAPSHOT
URL: https://github.com/apache/flink-connector-kafka/pull/39
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Dawid Wysakowicz created FLINK-32584:
Summary: Make it possible to unset default catalog and/or database
Key: FLINK-32584
URL: https://issues.apache.org/jira/browse/FLINK-32584
Project: Flink
flinkbot commented on PR #22985:
URL: https://github.com/apache/flink/pull/22985#issuecomment-1632441560
## CI report:
* 0e6d7c53e566034c4faf370641be576103601eb5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
tisonkun opened a new pull request, #54:
URL: https://github.com/apache/flink-connector-pulsar/pull/54
## Purpose of the change
*For example: Add dynamic sink topic support for Pulsar connector.*
## Brief change log
- *Change the internal design of `ProducerRegister`.*
[
https://issues.apache.org/jira/browse/FLINK-21883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21883:
---
Labels: auto-deprioritized-major auto-deprioritized-minor
pull-request-available reactive
echauchot opened a new pull request, #22985:
URL: https://github.com/apache/flink/pull/22985
## What is the purpose of the change
Introduce the cooldown period in the adaptive scheduler
XComp commented on PR #22984:
URL: https://github.com/apache/flink/pull/22984#issuecomment-1632417952
I assumed the [discussion mentioned in
FLINK-14068](https://lists.apache.org/thread/76yywnwf3lk8qn4dby0vz7yoqx7f7pkj)
and FLINK-14068 itself are good enough as a conclusion. But I can go
Patrick Lucas created FLINK-32583:
-
Summary: RestClient can deadlock if request made after Netty event
executor terminated
Key: FLINK-32583
URL: https://issues.apache.org/jira/browse/FLINK-32583
[
https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32335:
---
Labels: pull-request-available (was: )
> Fix the Flink ML unittest failure
>
jiangxin369 opened a new pull request, #247:
URL: https://github.com/apache/flink-ml/pull/247
## What is the purpose of the change
Fix the ConcurrentModificationException in the unittest.
## Brief change log
- Operate the `PipelinedSubpartition#buffers` with
ferenc-csaky commented on code in PR #22937:
URL: https://github.com/apache/flink/pull/22937#discussion_r1261056641
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemoryCatalogStoreTest.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742375#comment-17742375
]
Nuno Afonso commented on FLINK-30257:
-
Hello [~martijnvisser],
Is this issue resolved?
I can
[
https://issues.apache.org/jira/browse/FLINK-30821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742369#comment-17742369
]
Nuno Afonso commented on FLINK-30821:
-
Hello [~JunRuiLi],
I have a couple of questions about the
[
https://issues.apache.org/jira/browse/FLINK-32420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-32420.
-
Fix Version/s: 1.18.0
Resolution: Fixed
> Watermark aggregation performance is poor when
[
https://issues.apache.org/jira/browse/FLINK-32420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742366#comment-17742366
]
Rui Fan commented on FLINK-32420:
-
Merged via: 354a8852766b16873b5fad972e4440c1eaa4c40a (master: 1.18)
FangYongs commented on code in PR #22937:
URL: https://github.com/apache/flink/pull/22937#discussion_r1260950412
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemoryCatalogStoreTest.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the
xuzifu666 commented on PR #22980:
URL: https://github.com/apache/flink/pull/22980#issuecomment-163249
@rkhachatryan format had changed，have a review plz
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
afedulov commented on PR #629:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/629#issuecomment-1632203222
@gyfora I made the adjustment, PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
flinkbot commented on PR #22984:
URL: https://github.com/apache/flink/pull/22984#issuecomment-1632192252
## CI report:
* 8d847f40f471bb1c1abc3bd08f682d3228205f04 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ferenc-csaky commented on code in PR #22937:
URL: https://github.com/apache/flink/pull/22937#discussion_r1260909612
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemoryCatalogStoreTest.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32570:
---
Labels: pull-request-available (was: )
> Deprecate API that uses Flink's Time
XComp opened a new pull request, #22984:
URL: https://github.com/apache/flink/pull/22984
## What is the purpose of the change
A preparation for FLINK-14068 to finally remove
`org.apache.flink.api.common.time.Time` and
`org.apache.flink.streaming.api.windowing.time.Time`.
##
[
https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742338#comment-17742338
]
Liu commented on FLINK-19249:
-
[~ym] [~zjwang] [~pnowojski] [~xtsong] Any progress on this issue? In our
xintongsong commented on code in PR #22975:
URL: https://github.com/apache/flink/pull/22975#discussion_r1260841837
##
flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java:
##
@@ -322,7 +322,8 @@ public class NettyShuffleEnvironmentOptions
afedulov commented on PR #629:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/629#issuecomment-1632149268
>This new page more or less overlaps with
https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/development/guide/
in a non-obvious way.
It
[
https://issues.apache.org/jira/browse/FLINK-32348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-32348.
Fix Version/s: mongodb-1.1.0
Resolution: Fixed
Fixed by flink-connector-mongodb(main):
[
https://issues.apache.org/jira/browse/FLINK-32348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-32348:
--
Assignee: Jiabao Sun
> MongoDB tests are flaky and time out
>
xintongsong commented on code in PR #22855:
URL: https://github.com/apache/flink/pull/22855#discussion_r1260830009
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/TierConsumerAgent.java:
##
@@ -47,6 +48,13 @@ Optional
leonardBang merged PR #13:
URL: https://github.com/apache/flink-connector-mongodb/pull/13
--
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:
gyfora commented on PR #629:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/629#issuecomment-1632080592
This new page more or less overlaps with
https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/development/guide/
in a non-obvious way.
For
[
https://issues.apache.org/jira/browse/FLINK-32572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32572.
--
Fix Version/s: kubernetes-operator-1.6.0
Resolution: Fixed
merged to main
Jiabao-Sun commented on code in PR #13:
URL:
https://github.com/apache/flink-connector-mongodb/pull/13#discussion_r1260771972
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java:
##
@@ -119,7 +119,6 @@
reswqa commented on code in PR #22983:
URL: https://github.com/apache/flink/pull/22983#discussion_r1260755316
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java:
##
@@ -348,24 +360,29 @@ public void
1996fanrui commented on code in PR #22983:
URL: https://github.com/apache/flink/pull/22983#discussion_r1260742080
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java:
##
@@ -348,24 +360,29 @@ public void
1996fanrui commented on code in PR #22983:
URL: https://github.com/apache/flink/pull/22983#discussion_r1260737895
##
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorFactoryTest.java:
##
@@ -69,4 +72,60 @@ private void
reswqa commented on code in PR #22983:
URL: https://github.com/apache/flink/pull/22983#discussion_r1260692502
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java:
##
@@ -348,24 +360,29 @@ public void
leonardBang commented on code in PR #13:
URL:
https://github.com/apache/flink-connector-mongodb/pull/13#discussion_r1260715225
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java:
##
@@ -119,7 +119,6
Matthias Pohl created FLINK-32582:
-
Summary: Move TypeSerializerUpgradeTestBase from Kafka connector
into flink-connector-common
Key: FLINK-32582
URL: https://issues.apache.org/jira/browse/FLINK-32582
[
https://issues.apache.org/jira/browse/FLINK-32157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32157:
-
Assignee: Jiadong Lu
> Replaces LeaderConnectionInfo with LeaderInformation
>
[
https://issues.apache.org/jira/browse/FLINK-32157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742294#comment-17742294
]
Matthias Pohl commented on FLINK-32157:
---
Thanks for volunteering. I assigned the issue to you.
>
[
https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742285#comment-17742285
]
Rui Fan edited comment on FLINK-32049 at 7/12/23 6:42 AM:
--
Thanks report this
1 - 100 of 116 matches
Mail list logo
