zentol commented on a change in pull request #13464:
URL: https://github.com/apache/flink/pull/13464#discussion_r499377418
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceTrackerTest.java
##
@@ -0,0 +1,144 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-19469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207854#comment-17207854
]
Chesnay Schepler commented on FLINK-19469:
--
Is that an _actual_ SNAPSHOT depend
zentol commented on a change in pull request #13464:
URL: https://github.com/apache/flink/pull/13464#discussion_r499373537
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/JobScopedResourceTracker.java
##
@@ -0,0 +1,225 @@
+/*
+ *
zentol commented on a change in pull request #13464:
URL: https://github.com/apache/flink/pull/13464#discussion_r499373230
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/JobScopedResourceTracker.java
##
@@ -0,0 +1,225 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-19469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207853#comment-17207853
]
Robert Metzger commented on FLINK-19469:
Can we use a different mirror that host
zentol commented on a change in pull request #13464:
URL: https://github.com/apache/flink/pull/13464#discussion_r499371411
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/JobScopedResourceTracker.java
##
@@ -0,0 +1,225 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207849#comment-17207849
]
Robert Metzger commented on FLINK-18570:
[~Leonard Xu] Can you take a look at th
zentol commented on a change in pull request #13464:
URL: https://github.com/apache/flink/pull/13464#discussion_r499370304
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceTracker.java
##
@@ -0,0 +1,126 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207847#comment-17207847
]
Robert Metzger commented on FLINK-19154:
[~kkl0u] can I assign you to this ticke
[
https://issues.apache.org/jira/browse/FLINK-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207845#comment-17207845
]
Robert Metzger commented on FLINK-19332:
I agree that this should not be a block
[
https://issues.apache.org/jira/browse/FLINK-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19332:
---
Priority: Critical (was: Blocker)
> Special characters issue using Kinesis Data Analytics f
[
https://issues.apache.org/jira/browse/FLINK-18851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200915#comment-17200915
]
Matthias edited comment on FLINK-18851 at 10/5/20, 6:22 AM:
[
https://issues.apache.org/jira/browse/FLINK-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19332:
---
Fix Version/s: (was: 1.8.2)
> Special characters issue using Kinesis Data Analytics for
zentol commented on a change in pull request #13464:
URL: https://github.com/apache/flink/pull/13464#discussion_r499365760
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ResourceTracker.java
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed t
[
https://issues.apache.org/jira/browse/FLINK-19347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19347:
---
Component/s: Table SQL / API
> Generate InputGateDeploymentDescriptor from a JobVertex with
zentol commented on a change in pull request #13464:
URL: https://github.com/apache/flink/pull/13464#discussion_r499365732
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceTracker.java
##
@@ -0,0 +1,126 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-19348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19348:
---
Component/s: Table SQL / API
> Introduce CacheSource and CacheSink
> ---
[
https://issues.apache.org/jira/browse/FLINK-19159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19159:
---
Component/s: API / Scala
> Using Scalafmt to format scala source code
>
[
https://issues.apache.org/jira/browse/FLINK-19349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19349:
---
Component/s: Table SQL / API
> StreamGraphGenerator handle CacheSource and CacheSink
> -
[
https://issues.apache.org/jira/browse/FLINK-19353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19353:
---
Component/s: Table SQL / API
> BlinkPlanner translate and optimize CacheOperation
>
[
https://issues.apache.org/jira/browse/FLINK-19354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19354:
---
Component/s: Table SQL / API
> Add invalidateCache() method in CachedTable
> --
[
https://issues.apache.org/jira/browse/FLINK-19352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19352:
---
Component/s: Table SQL / API
> Add cache() method to Table
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-19350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19350:
---
Component/s: Table SQL / API
> StreamingJobGraphGenerator add the ClusterPartitionDescriptor
[
https://issues.apache.org/jira/browse/FLINK-19351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19351:
---
Component/s: Table SQL / API
> StreamingJobGraphGenerator set the caching node to BoundedBlo
[
https://issues.apache.org/jira/browse/FLINK-19346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19346:
---
Component/s: Table SQL / API
> Generate and put ClusterPartitionDescriptor of ClusterPartiti
[
https://issues.apache.org/jira/browse/FLINK-19355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19355:
---
Component/s: Table SQL / API
> Add close() method to TableEnvironment
>
[
https://issues.apache.org/jira/browse/FLINK-19463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19463:
---
Component/s: API / DataStream
> Disentangle StateBackends from Checkpointing
> -
[
https://issues.apache.org/jira/browse/FLINK-19460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19460:
---
Component/s: Connectors / Kinesis
> AWS Kinesis Producer EXACTLY_ONCE semantic
> --
[
https://issues.apache.org/jira/browse/FLINK-19476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19476:
---
Component/s: Table SQL / API
> Introduce CacheManager in CatalogManager to keep track of the
[
https://issues.apache.org/jira/browse/FLINK-19493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19493:
---
Component/s: Command Line Client
> In CliFrontend, make flow of Configuration more obvious
>
[
https://issues.apache.org/jira/browse/FLINK-19252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19252:
---
Component/s: Runtime / Coordination
> Jaas file created under io.tmp.dirs - folder not creat
[
https://issues.apache.org/jira/browse/FLINK-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19331:
---
Component/s: API / State Processor
> State processor api has native resouce leak when workin
[
https://issues.apache.org/jira/browse/FLINK-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207836#comment-17207836
]
Robert Metzger commented on FLINK-19331:
This has been merged to master in
http
[
https://issues.apache.org/jira/browse/FLINK-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-19331.
--
Resolution: Fixed
> State processor api has native resouce leak when working with RocksDB
> --
[
https://issues.apache.org/jira/browse/FLINK-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19331:
---
Fix Version/s: 1.12.0
> State processor api has native resouce leak when working with RocksD
[
https://issues.apache.org/jira/browse/FLINK-19382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19382:
---
Component/s: Runtime / State Backends
> Introducing ReplayableSourceStateBackend
> -
[
https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-19441:
--
Assignee: Stephan Ewen
> Performance regression on 24.09.2020
> -
[
https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207834#comment-17207834
]
Robert Metzger commented on FLINK-19441:
Since this ticket is a blocker, I'd lik
flinkbot edited a comment on pull request #13536:
URL: https://github.com/apache/flink/pull/13536#issuecomment-702954233
## CI report:
* c994eac2e1b064914f09ec4ea306ab7a714d40b3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13536:
URL: https://github.com/apache/flink/pull/13536#issuecomment-702954233
## CI report:
* Unknown: [CANCELED](TBD)
* c994eac2e1b064914f09ec4ea306ab7a714d40b3 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620
flinkbot edited a comment on pull request #13536:
URL: https://github.com/apache/flink/pull/13536#issuecomment-702954233
## CI report:
* Unknown: [CANCELED](TBD)
* c994eac2e1b064914f09ec4ea306ab7a714d40b3 UNKNOWN
Bot commands
The @flinkbot bot supports the fol
autodidacticon commented on pull request #13536:
URL: https://github.com/apache/flink/pull/13536#issuecomment-703386803
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 693a3c828e7c7b8782ad978ff7fb63288ef2f4d9 UNKNOWN
* 9e2afb6339296312216da63a5b751a5233bb7614 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-19295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207793#comment-17207793
]
Dian Fu commented on FLINK-19295:
-
Instance on 1.11:
https://dev.azure.com/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-19489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207792#comment-17207792
]
Dian Fu commented on FLINK-19489:
-
Another instance:
https://dev.azure.com/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-19295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207791#comment-17207791
]
Dian Fu commented on FLINK-19295:
-
Another instance on master:
https://dev.azure.com/ap
[
https://issues.apache.org/jira/browse/FLINK-19458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207789#comment-17207789
]
Dian Fu commented on FLINK-19458:
-
Another instance:
https://dev.azure.com/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-19422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207787#comment-17207787
]
Dian Fu commented on FLINK-19422:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
[
https://issues.apache.org/jira/browse/FLINK-19484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207786#comment-17207786
]
Dian Fu commented on FLINK-19484:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 693a3c828e7c7b8782ad978ff7fb63288ef2f4d9 UNKNOWN
* e7851e95b95667b7a12fc9495155416f2b9574d2 Azure:
[CANCELED](https://dev.azure.com/apache-f
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 693a3c828e7c7b8782ad978ff7fb63288ef2f4d9 UNKNOWN
* e7851e95b95667b7a12fc9495155416f2b9574d2 Azure:
[CANCELED](https://dev.azure.com/apache-f
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 524d380a3d1811870ffce75b4d149f3d8cf38392 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 524d380a3d1811870ffce75b4d149f3d8cf38392 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 524d380a3d1811870ffce75b4d149f3d8cf38392 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 524d380a3d1811870ffce75b4d149f3d8cf38392 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN
* b9c536699ab90573a07e283f815e77ee60e0
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 524d380a3d1811870ffce75b4d149f3d8cf38392 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN
* b9c536699ab90573a07e283f815e77ee60e0
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN
* 9cfca3cfa8cfec45ef0f97bb67e36e73208a
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN
* 4d2d57b8c2f6810c03d284fdd5807b81a2b5
senegalo commented on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-703233062
@dawidwys i took care of every single comment you mentioned hope that does
the deed.
This is an automated mess
senegalo commented on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-703232999
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please
senegalo commented on a change in pull request #12056:
URL: https://github.com/apache/flink/pull/12056#discussion_r499228712
##
File path:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java
##
@@ -219,7 +22
senegalo commented on a change in pull request #12056:
URL: https://github.com/apache/flink/pull/12056#discussion_r499228712
##
File path:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java
##
@@ -219,7 +22
flinkbot edited a comment on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 524d380a3d1811870ffce75b4d149f3d8cf38392 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN
* 4d2d57b8c2f6810c03d284fdd5807b81a2b5
caozhen1937 commented on a change in pull request #13296:
URL: https://github.com/apache/flink/pull/13296#discussion_r499217948
##
File path:
flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerializationSc
[
https://issues.apache.org/jira/browse/FLINK-19500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207301#comment-17207301
]
CaoZhen commented on FLINK-19500:
-
[~jark], sorry, you are right. I got it wrong.
> Usi
[
https://issues.apache.org/jira/browse/FLINK-19500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CaoZhen closed FLINK-19500.
---
Resolution: Not A Problem
> Using canal-json,debezium-json,maxwell-json serialization, the DELETE
> semanti
[
https://issues.apache.org/jira/browse/FLINK-19500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17207299#comment-17207299
]
Jark Wu commented on FLINK-19500:
-
Hi [~caozhen1937], AFAIK, for DELETE messages, Maxwel
flinkbot commented on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703227980
## CI report:
* 524d380a3d1811870ffce75b4d149f3d8cf38392 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-19500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CaoZhen updated FLINK-19500:
Description:
When Using {{canal-json}},{{debezium-json}},{{maxwell-json}} serialization, the
RowData of {
caozhen1937 commented on a change in pull request #13296:
URL: https://github.com/apache/flink/pull/13296#discussion_r499217948
##
File path:
flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerializationSc
[
https://issues.apache.org/jira/browse/FLINK-19500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CaoZhen updated FLINK-19500:
Description:
When Using {{canal-json}},{{debezium-json}},{{maxwell-json}} serialization, the
RowData of {
[
https://issues.apache.org/jira/browse/FLINK-19500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CaoZhen updated FLINK-19500:
Summary: Using canal-json,debezium-json,maxwell-json serialization, the
DELETE semantics should be interpr
CaoZhen created FLINK-19500:
---
Summary: Using canal-json,debezium-json,maxwell-json
serialization, The DELETE semantics should be interpreted.
Key: FLINK-19500
URL: https://issues.apache.org/jira/browse/FLINK-19500
flinkbot commented on pull request #13539:
URL: https://github.com/apache/flink/pull/13539#issuecomment-703225231
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 pro
AHeise opened a new pull request #13539:
URL: https://github.com/apache/flink/pull/13539
## What is the purpose of the change
If a local channel does not receive a buffer during recovery, a live lock
may occur where the local channel cannot recover because it is waiting for a
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN
* 4d2d57b8c2f6810c03d284fdd5807b81a2b5
caozhen1937 commented on a change in pull request #13296:
URL: https://github.com/apache/flink/pull/13296#discussion_r499217948
##
File path:
flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerializationSc
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN
* 4d2d57b8c2f6810c03d284fdd5807b81a2b5
senegalo commented on a change in pull request #12056:
URL: https://github.com/apache/flink/pull/12056#discussion_r499214594
##
File path:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java
##
@@ -318,6 +32
flinkbot edited a comment on pull request #13296:
URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193
## CI report:
* c266341c63cc4cdc28a6585a82294710fd8ebbc5 UNKNOWN
* c6301b9c4f43e851a0d47972bd52880b69b720c6 Azure:
[FAILURE](https://dev.azure.com/apache-fl
83 matches
Mail list logo
