curcur edited a comment on pull request #15420:
URL: https://github.com/apache/flink/pull/15420#issuecomment-864750211
Mark:
For recovery: Sync offline: did not see non-materialized part applied to the
delegated state backend. Double confirm
--
This is an automated message from
curcur edited a comment on pull request #15420:
URL: https://github.com/apache/flink/pull/15420#issuecomment-864750211
Mark:
For recovery: Sync offline: did not see non-materialized part be applied to
the delegated state backend. Double confirm
--
This is an automated message
curcur commented on pull request #15420:
URL: https://github.com/apache/flink/pull/15420#issuecomment-864750211
Mark:
Sync offline: did not see non-materialized part be applied to the delegated
state backend. Double confirm
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-16095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangzhl updated FLINK-16095:
-
Comment: was deleted
(was: hi [~jark]
I'm willing to translate this page. Could you assign it to me
[
https://issues.apache.org/jira/browse/FLINK-16152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangzhl updated FLINK-16152:
-
Comment: was deleted
(was: hi,[~jark],
I'm willing to translate this page. Could you assign it to me
[
https://issues.apache.org/jira/browse/FLINK-17647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ingo Bürk closed FLINK-17647.
-
Resolution: Won't Do
I'll take the liberty to close this issue since the legacy planner has been
[
https://issues.apache.org/jira/browse/FLINK-17647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ingo Bürk updated FLINK-17647:
--
Comment: was deleted
(was: I'll take the liberty to close this issue since the legacy planner has
[
https://issues.apache.org/jira/browse/FLINK-17647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366387#comment-17366387
]
Ingo Bürk commented on FLINK-17647:
---
I'll take the liberty to close this issue since the legacy
flinkbot edited a comment on pull request #16141:
URL: https://github.com/apache/flink/pull/16141#issuecomment-859291183
## CI report:
* 07736d279cca52434c2f4ee87f508231eaa33e6c Azure:
flinkbot commented on pull request #16213:
URL: https://github.com/apache/flink/pull/16213#issuecomment-864743785
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-22788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22788:
---
Labels: pull-request-available (was: )
> Code of equals method grows beyond 64 KB
>
Airblader opened a new pull request #16213:
URL: https://github.com/apache/flink/pull/16213
## What is the purpose of the change
When working with hundreds of fields, equalisers can fail to compile
because the method body grows beyond 64kb. With this change, instead of
[
https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-23042.
Resolution: Fixed
Subsumed by #16162
> Flink Chinese docs Fraud Detection with the DataStream
xintongsong closed pull request #16212:
URL: https://github.com/apache/flink/pull/16212
--
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.
For queries about this service,
xintongsong commented on pull request #16212:
URL: https://github.com/apache/flink/pull/16212#issuecomment-864740564
Hi @RollsBean, thanks for preparing the PR.
It seems another contributor has also noticed the problem and fixed it a
couple hours ago. So this PR is no longer
flinkbot edited a comment on pull request #16163:
URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972
## CI report:
* 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN
* da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN
*
flinkbot edited a comment on pull request #16212:
URL: https://github.com/apache/flink/pull/16212#issuecomment-864708536
## CI report:
* 3177431ef14291ae912b37f27983049d48158a02 Azure:
flinkbot edited a comment on pull request #16210:
URL: https://github.com/apache/flink/pull/16210#issuecomment-864682204
## CI report:
* ac28fa57c35305feb56c9825f360bc32d0547db9 Azure:
flinkbot edited a comment on pull request #16163:
URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972
## CI report:
* 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN
* da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN
*
flinkbot edited a comment on pull request #16161:
URL: https://github.com/apache/flink/pull/16161#issuecomment-861259205
## CI report:
* 742e4e8c3622802e1dcf7cf5fb020a5bd656a40d Azure:
flinkbot edited a comment on pull request #16148:
URL: https://github.com/apache/flink/pull/16148#issuecomment-859467607
## CI report:
* 86e49e125d78c43cdc415f15ee7056ffd770da54 Azure:
Myasuka commented on pull request #15410:
URL: https://github.com/apache/flink/pull/15410#issuecomment-864713425
@zhougit86 Shall we close this PR now and have more discussion in
https://issues.apache.org/jira/browse/FLINK-17808
?
--
This is an automated message from the Apache Git
Myasuka commented on pull request #16210:
URL: https://github.com/apache/flink/pull/16210#issuecomment-864710557
> > Thanks for the contribution, I wonder only three lines in the
documentation have typos?
>
> No, there are tons of typos. I don't have enough time to fix all of them.
flinkbot commented on pull request #16212:
URL: https://github.com/apache/flink/pull/16212#issuecomment-864708536
## CI report:
* 3177431ef14291ae912b37f27983049d48158a02 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #16161:
URL: https://github.com/apache/flink/pull/16161#issuecomment-861259205
## CI report:
* 742e4e8c3622802e1dcf7cf5fb020a5bd656a40d Azure:
flinkbot edited a comment on pull request #16153:
URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068
## CI report:
* 50b2100f9a62e662d6cb4a7ec111d3e73b9cd843 Azure:
flinkbot edited a comment on pull request #16148:
URL: https://github.com/apache/flink/pull/16148#issuecomment-859467607
## CI report:
* 86e49e125d78c43cdc415f15ee7056ffd770da54 Azure:
Myasuka commented on pull request #16162:
URL: https://github.com/apache/flink/pull/16162#issuecomment-864707829
I have closed FLINK-23012 and also pick your PR to release-1.13 branch with
removal of adding previous docs link in 3964761b80d2dce532d04704d1a3f4b097a8c5eb
--
This is an
raywill commented on pull request #16210:
URL: https://github.com/apache/flink/pull/16210#issuecomment-864705138
> Thanks for the contribution, I wonder only three lines in the
documentation have typos?
No, there are tons of typos. I don't have enough time to fix all of them.
you
[
https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-23012.
--
Resolution: Fixed
> Add v1.13 docs link in "Pick Docs Version" for master branch
>
[
https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-23012:
-
Fix Version/s: 1.14.0
> Add v1.13 docs link in "Pick Docs Version" for master branch
>
[
https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366363#comment-17366363
]
Yun Tang commented on FLINK-23012:
--
Fixed by a hotfix: 73b3d10613d95a399f60c982f94a740b4e777b3d
> Add
[
https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366362#comment-17366362
]
kevin edited comment on FLINK-23042 at 6/21/21, 3:50 AM:
-
Thanks a lot
tony810430 commented on pull request #16162:
URL: https://github.com/apache/flink/pull/16162#issuecomment-864703592
Hi @Myasuka
Thanks for the reviewing. I will remember to create a JIRA ticket next time.
besides, I think
Myasuka merged pull request #16162:
URL: https://github.com/apache/flink/pull/16162
--
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.
For queries about this service,
[
https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366362#comment-17366362
]
kevin commented on FLINK-23042:
---
Thanks a lot [~xintongsong]
> Flink Chinese docs Fraud Detection with
flinkbot commented on pull request #16212:
URL: https://github.com/apache/flink/pull/16212#issuecomment-864702375
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-15024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-15024:
Labels: (was: stale-major)
> System classloader memory leak after loading too many codegen
[
https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-23042:
---
Labels: docs documentation-update pull-request-available zh_CN (was: docs
[
https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-21788:
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Throw
RollsBean opened a new pull request #16212:
URL: https://github.com/apache/flink/pull/16212
… src
## What is the purpose of the change
*(This pull request fix Flink Chinese doc
flinkbot edited a comment on pull request #16211:
URL: https://github.com/apache/flink/pull/16211#issuecomment-864689257
## CI report:
* 33aec918ba974f8c0a0ccfd4ed3ceb9a91a6fdb5 Azure:
flinkbot edited a comment on pull request #16153:
URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068
## CI report:
* 50b2100f9a62e662d6cb4a7ec111d3e73b9cd843 Azure:
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366357#comment-17366357
]
Yun Gao edited comment on FLINK-22085 at 6/21/21, 3:38 AM:
---
I checked the last
curcur commented on a change in pull request #15420:
URL: https://github.com/apache/flink/pull/15420#discussion_r654946468
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
##
@@
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366359#comment-17366359
]
Dong Lin commented on FLINK-22085:
--
[~gaoyunhaii] Thanks for the investigation. Previously I have
luoyuxia commented on pull request #16161:
URL: https://github.com/apache/flink/pull/16161#issuecomment-864698057
@JingsongLi Now, I have added test to check emiting EndCheckpoint with
Long.MAX_VALUE when end of input in CompactFileWriterTest.
--
This is an automated message from the
hehuiyuan edited a comment on pull request #16148:
URL: https://github.com/apache/flink/pull/16148#issuecomment-864694544
> Thanks @hehuiyuan for working on this. Since a reader is created for every
split, will it be more useful if we also print the split in the logs? Besides,
maybe it's
hehuiyuan commented on pull request #16148:
URL: https://github.com/apache/flink/pull/16148#issuecomment-864694544
> Thanks @hehuiyuan for working on this. Since a reader is created for every
split, will it be more useful if we also print the split in the logs? Besides,
maybe it's better
Xintong Song created FLINK-23052:
Summary: cron_snapshot_deployment_maven unstable on maven
Key: FLINK-23052
URL: https://issues.apache.org/jira/browse/FLINK-23052
Project: Flink
Issue Type:
Carl created FLINK-23051:
Summary: Savepoint an application for source of cdc-kafka, then
restart the application from the savepoint, offset not be recovered.
Key: FLINK-23051
URL:
Zakelly commented on a change in pull request #16153:
URL: https://github.com/apache/flink/pull/16153#discussion_r655046921
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
##
@@ -607,6 +612,53 @@
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366357#comment-17366357
]
Yun Gao commented on FLINK-22085:
-
I checked the last several cases, it seems they are all failed at
[
https://issues.apache.org/jira/browse/FLINK-23050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-23050:
Assignee: Han Yin
> Add Chinese version of documentation of unaligned checkpoint
>
flinkbot commented on pull request #16211:
URL: https://github.com/apache/flink/pull/16211#issuecomment-864689257
## CI report:
* 33aec918ba974f8c0a0ccfd4ed3ceb9a91a6fdb5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #16210:
URL: https://github.com/apache/flink/pull/16210#issuecomment-864682204
## CI report:
* ac28fa57c35305feb56c9825f360bc32d0547db9 Azure:
flinkbot edited a comment on pull request #16179:
URL: https://github.com/apache/flink/pull/16179#issuecomment-863055916
## CI report:
* 1fddc9fa74da8400c9869aeea87038bcec3257fe Azure:
[
https://issues.apache.org/jira/browse/FLINK-23044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Yu updated FLINK-23044:
-
Description:
using [codetypo|[https://www.github.com/raywill/codetypo]] I found tons of
typos in
Yun Tang created FLINK-23050:
Summary: Add Chinese version of documentation of unaligned
checkpoint
Key: FLINK-23050
URL: https://issues.apache.org/jira/browse/FLINK-23050
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366353#comment-17366353
]
Xintong Song commented on FLINK-23042:
--
Usually, you only need to open PRs on the master branch.
[
https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-23018:
-
Fix Version/s: 1.13.2
> State factories should handle extended state descriptors
>
[
https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-23018.
--
Resolution: Fixed
> State factories should handle extended state descriptors
>
[
https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366351#comment-17366351
]
Yun Tang commented on FLINK-23018:
--
Merged
master: 73c103b6b117fe3996eedfb9d04e926f00c70996
[
https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366350#comment-17366350
]
Xintong Song commented on FLINK-22480:
--
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366349#comment-17366349
]
Xintong Song commented on FLINK-18634:
--
Xintong Song created FLINK-23049:
Summary: UnalignedCheckpointCompatibilityITCase hangs on azure
Key: FLINK-23049
URL: https://issues.apache.org/jira/browse/FLINK-23049
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366347#comment-17366347
]
kevin commented on FLINK-23042:
---
Hi [~xintongsong],
Both branch *release-1.13* and *master* have
Myasuka merged pull request #16178:
URL: https://github.com/apache/flink/pull/16178
--
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.
For queries about this service,
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366346#comment-17366346
]
Xintong Song commented on FLINK-22085:
--
flinkbot commented on pull request #16211:
URL: https://github.com/apache/flink/pull/16211#issuecomment-864684011
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366345#comment-17366345
]
luoyuxia commented on FLINK-16952:
--
[~lzljs3620320] Look forward your review.
> Parquet file system
Xintong Song created FLINK-23048:
Summary:
GroupWindowITCase.testEventTimeSlidingGroupWindowOverTimeNonOverlappingSplitPane
fails due to akka timeout
Key: FLINK-23048
URL:
[
https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16952:
---
Labels: auto-unassigned pull-request-available stale-assigned (was:
auto-unassigned
luoyuxia opened a new pull request #16211:
URL: https://github.com/apache/flink/pull/16211
## What is the purpose of the change
*Support filter push down for parquet format*
## Brief change log
**
- *Add ParquetFilters to convert expression to
flinkbot commented on pull request #16210:
URL: https://github.com/apache/flink/pull/16210#issuecomment-864682204
## CI report:
* ac28fa57c35305feb56c9825f360bc32d0547db9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #16179:
URL: https://github.com/apache/flink/pull/16179#issuecomment-863055916
## CI report:
* 1fddc9fa74da8400c9869aeea87038bcec3257fe Azure:
Xintong Song created FLINK-23047:
Summary: CassandraConnectorITCase.testCassandraBatchTupleFormat
fails on azure
Key: FLINK-23047
URL: https://issues.apache.org/jira/browse/FLINK-23047
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366343#comment-17366343
]
Xintong Song commented on FLINK-22890:
--
Failed again on master, with the fixing commit included.
cc
flinkbot commented on pull request #16210:
URL: https://github.com/apache/flink/pull/16210#issuecomment-864679930
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366342#comment-17366342
]
Xintong Song commented on FLINK-22702:
--
[~renqs], any insights on this instability?
>
[
https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366341#comment-17366341
]
Xintong Song commented on FLINK-22702:
--
[
https://issues.apache.org/jira/browse/FLINK-23044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-23044:
---
Labels: pull-request-available typo (was: typo)
> fix typos in docs
> -
>
raywill opened a new pull request #16210:
URL: https://github.com/apache/flink/pull/16210
## What is the purpose of the change
Fix typo.
Found some typos using the tool provided by
[https://github.com/raywill/codetypo](https://github.com/raywill/codetypo)
Xintong Song created FLINK-23046:
Summary:
OperatorEventSendingCheckpointITCase.testOperatorEventLostNoReaderFailure fails
on azure
Key: FLINK-23046
URL: https://issues.apache.org/jira/browse/FLINK-23046
[
https://issues.apache.org/jira/browse/FLINK-23013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366339#comment-17366339
]
Jingsong Lee commented on FLINK-23013:
--
+1
> Introduce faker source connector
>
[
https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-22781:
-
Labels: (was: stale-assigned)
> Incorrect result for group window aggregate when mini-batch
[
https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366337#comment-17366337
]
Jingsong Lee commented on FLINK-22719:
--
[~qingru zhang] is right, they are different problems. In
Huang Yu created FLINK-23044:
Summary: fix typos in docs
Key: FLINK-23044
URL: https://issues.apache.org/jira/browse/FLINK-23044
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366336#comment-17366336
]
Xintong Song commented on FLINK-22198:
--
[
https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366333#comment-17366333
]
Xintong Song commented on FLINK-22198:
--
[
https://issues.apache.org/jira/browse/FLINK-23030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jin Xing updated FLINK-23030:
-
Priority: Major (was: Blocker)
> PartitionRequestClientFactory#createPartitionRequestClient should
[
https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366332#comment-17366332
]
Xintong Song commented on FLINK-22545:
--
[
https://issues.apache.org/jira/browse/FLINK-23044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Yu updated FLINK-23044:
-
Description:
using [codetypo|[https://www.github.com/raywill/codetypo]] I found tons of
typos in
[
https://issues.apache.org/jira/browse/FLINK-23044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Yu updated FLINK-23044:
-
Description:
using [codetypo|[https://www.github.com/raywill/codetypo]] I found tons of
typos in
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366331#comment-17366331
]
Xintong Song commented on FLINK-22085:
--
Xintong Song created FLINK-23045:
Summary:
RunnablesTest.testExecutorService_uncaughtExceptionHandler fails on azure
Key: FLINK-23045
URL: https://issues.apache.org/jira/browse/FLINK-23045
Project:
chaplinthink commented on pull request #16198:
URL: https://github.com/apache/flink/pull/16198#issuecomment-864673718
@lirui-apache Could you give this pull request a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366330#comment-17366330
]
Xintong Song commented on FLINK-22085:
--
[
https://issues.apache.org/jira/browse/FLINK-21440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366329#comment-17366329
]
Xintong Song commented on FLINK-21440:
--
There is already a PR opened months ago, which seems have
becketqin commented on a change in pull request #15531:
URL: https://github.com/apache/flink/pull/15531#discussion_r655026006
##
File path:
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaEnumeratorTest.java
##
@@
1 - 100 of 220 matches
Mail list logo
