Etienne CARRIERE created FLINK-9560:
---
Summary: RateLimiting for FileSystem
Key: FLINK-9560
URL: https://issues.apache.org/jira/browse/FLINK-9560
Project: Flink
Issue Type: Improvement
Hequn Cheng created FLINK-9559:
--
Summary: The type of a union of CHAR columns of different lengths
should be VARCHAR
Key: FLINK-9559
URL: https://issues.apache.org/jira/browse/FLINK-9559
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9537:
---
Assignee: mingleizhang
> JobManager isolation in session mode
>
[
https://issues.apache.org/jira/browse/FLINK-9262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506432#comment-16506432
]
Chris Schneider commented on FLINK-9262:
I'm not pulling in mockito-all, just mockito-core (and a
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506323#comment-16506323
]
Razvan edited comment on FLINK-9540 at 6/8/18 5:51 PM:
---
Hi [~aljoscha],
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506323#comment-16506323
]
Razvan commented on FLINK-9540:
---
Hi [~aljoscha],
Thanks for the hint. I managed to get 1.4.2 working
[
https://issues.apache.org/jira/browse/FLINK-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506212#comment-16506212
]
ASF GitHub Bot commented on FLINK-9499:
---
GitHub user st96d045 opened a pull request:
GitHub user st96d045 opened a pull request:
https://github.com/apache/flink/pull/6142
[FLINK-9499] Allow POST parameters to be used for submitting run job â¦
Enable users of the REST API to submit requests for running a FLINK job
using a POST operation but instead of only using
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506206#comment-16506206
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506204#comment-16506204
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506205#comment-16506205
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r194109528
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -40,22 +42,63 @@
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r194109518
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -105,7 +153,18 @@ public
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r194109540
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -40,22 +42,63 @@
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506191#comment-16506191
]
Rong Rong edited comment on FLINK-9430 at 6/8/18 4:07 PM:
--
Hi here, I did some
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506191#comment-16506191
]
Rong Rong commented on FLINK-9430:
--
Hi here, I did some integration test. There are 2 glues that makes
[
https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506155#comment-16506155
]
ASF GitHub Bot commented on FLINK-8944:
---
Github user kailashhd commented on the issue:
Github user kailashhd commented on the issue:
https://github.com/apache/flink/pull/5992
Bumping this up in case it got lost in the queue. @tzulitai
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6141
-1
This is achievable by configuring scope formats as described in the
[documentation](https://ci.apache.org/projects/flink/flink-docs-master/monitoring/metrics.html#system-scope).
---
[
https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9558:
---
Assignee: vinoyang
> Memory leaks during usage of bucketing-sink with disabled checkpointing
>
[
https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-9558:
--
Description:
Hi mates, we have some Flink jobs, that are writing data from kafka into hdfs,
[
https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-9558:
--
Description:
Hi mates, we have some Flink jobs, that are writing data from kafka into hdfs,
GitHub user XiaoZYang reopened a pull request:
https://github.com/apache/flink/pull/5845
[FLINK-9168][flink-connectors]Pulsar Sink connector
## What is the purpose of the change
Provide a [pulsar](https://github.com/apache/incubator-pulsar) sink
connector for flink.
##
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506090#comment-16506090
]
ASF GitHub Bot commented on FLINK-9168:
---
GitHub user XiaoZYang reopened a pull request:
Github user XiaoZYang commented on the issue:
https://github.com/apache/flink/pull/5845
@tzulitai @surryr @pluppens @sijie
This PR is going to be closed and I will open another PR to brunch
pulsar-connector to this issue.
---
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506085#comment-16506085
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user XiaoZYang commented on the issue:
Github user XiaoZYang closed the pull request at:
https://github.com/apache/flink/pull/5845
---
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506086#comment-16506086
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user XiaoZYang closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506081#comment-16506081
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user XiaoZYang commented on a diff in the pull
Github user XiaoZYang commented on a diff in the pull request:
https://github.com/apache/flink/pull/5845#discussion_r194076473
--- Diff:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducer.java
---
@@ -0,0 +1,304
[
https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-9558:
--
Description:
Hi mates, we got some Flink jobs, that are writing data from kafka into hdfs,
[
https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-9558:
--
Summary: Memory leaks during usage of bucketing-sink with disabled
checkpointing (was: Memory
Rinat Sharipov created FLINK-9558:
-
Summary: Memory leaks during usage with disabled checkpointing
Key: FLINK-9558
URL: https://issues.apache.org/jira/browse/FLINK-9558
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506061#comment-16506061
]
ASF GitHub Bot commented on FLINK-8914:
---
Github user Aitozi commented on the issue:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/6124
Got it. Thanks for your response @dawidwys and waiting for you further
comment on this PR. I am glad to contribute to the cep library and really hope
to get more ideas or share from you guys
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6136
+1
@kisimple Thank you for update!
---
[
https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506014#comment-16506014
]
ASF GitHub Bot commented on FLINK-4303:
---
Github user medcv commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506008#comment-16506008
]
Aljoscha Krettek commented on FLINK-9540:
-
If you want to use the flink-bundled S3A FileSystem
[
https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506006#comment-16506006
]
ASF GitHub Bot commented on FLINK-4303:
---
Github user medcv commented on a diff in the pull request:
Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6136#discussion_r194052688
--- Diff:
flink-examples/flink-examples-cep/src/main/java/org/apache/flink/cep/examples/java/monitoring/TemperatureMonitoring.java
---
@@ -0,0 +1,147 @@
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6141
@DmitryBe Thank you! is there a Jira ticket associate to this? I suggest
add Jira ticket and update PR title according the Contribution guideline
---
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505991#comment-16505991
]
ASF GitHub Bot commented on FLINK-9538:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6134#discussion_r194047289
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -3747,6 +3747,67 @@ public void process(Integer key,
[
https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505986#comment-16505986
]
ASF GitHub Bot commented on FLINK-8914:
---
Github user dawidwys commented on the issue:
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/6124
Hi @Aitozi , thanks for your contribution.
FYI. We had some discussions offline with @kl0u about how to approach this
issue. We plan to adjust the behaviour of AfterMatchSkip clause a bit
[
https://issues.apache.org/jira/browse/FLINK-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505966#comment-16505966
]
ASF GitHub Bot commented on FLINK-9521:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6123
@twalthr can you have a look?
---
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505955#comment-16505955
]
Razvan commented on FLINK-9540:
---
Hi,
This is the first exception:
2018-05-18 17:37:20.986 [main]
[
https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505944#comment-16505944
]
ASF GitHub Bot commented on FLINK-7251:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/6120
@StephanEwen could you take a look?
---
[
https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9552:
Priority: Blocker (was: Major)
> NPE in SpanningRecordSerializer during checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9552:
Fix Version/s: 1.6.0
> NPE in SpanningRecordSerializer during checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505930#comment-16505930
]
Aljoscha Krettek commented on FLINK-9540:
-
[~razvan] Just moving {{flink-s3-fs-hadoop-1.4.2.jar}}
[
https://issues.apache.org/jira/browse/FLINK-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9557:
Description:
Currently,
{code:java}
FlinkTypeFactory.typeInfoToSqlTypeName(typeInfo:
[
https://issues.apache.org/jira/browse/FLINK-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9557:
Description:
Currently,
{code:java}
FlinkTypeFactory.typeInfoToSqlTypeName(typeInfo:
[
https://issues.apache.org/jira/browse/FLINK-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9557:
Description:
Currently,
{code:java}
FlinkTypeFactory.typeInfoToSqlTypeName() {code}
does
[
https://issues.apache.org/jira/browse/FLINK-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9557:
Description: Currently, _FlinkTypeFactory.typeInfoToSqlTypeName()_ does not
support
Dominik Wosiński created FLINK-9557:
---
Summary: FlinkTypeFactory should support BigInteger type
Key: FLINK-9557
URL: https://issues.apache.org/jira/browse/FLINK-9557
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505854#comment-16505854
]
ASF GitHub Bot commented on FLINK-9538:
---
Github user yanghua commented on a diff in the pull
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6134#discussion_r194001177
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateFunction.java
---
@@ -25,13 +25,13 @@
* This functionality is only
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505847#comment-16505847
]
Razvan commented on FLINK-9540:
---
If you know of a way to use S3A without adding those dependencies I'd be
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Razvan reopened FLINK-9540:
---
> Apache Flink 1.4.2 S3 Hadoop library for Hadoop 2.7 is built for Hadoop 2.8
> and fails
>
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505833#comment-16505833
]
ASF GitHub Bot commented on FLINK-9538:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6134#discussion_r193989354
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateFunction.java
---
@@ -25,13 +25,13 @@
* This functionality is only
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505827#comment-16505827
]
ASF GitHub Bot commented on FLINK-9538:
---
Github user yanghua commented on a diff in the pull
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6134#discussion_r193985722
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateFunction.java
---
@@ -25,13 +25,13 @@
* This functionality is only
[
https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505810#comment-16505810
]
Lucas Resch commented on FLINK-9547:
[~dawidwys]
We are using a Kafka topic as a source:
Timo Walther created FLINK-9556:
---
Summary: Scala TypeAnalyzer does not consider ResultTypeQueryable
Key: FLINK-9556
URL: https://issues.apache.org/jira/browse/FLINK-9556
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505806#comment-16505806
]
Dawid Wysakowicz commented on FLINK-9547:
-
What source do you use? Do you make sure that the
[
https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505799#comment-16505799
]
Lucas Resch commented on FLINK-9547:
[~dawidwys] I tried both suggestions you made:
h5. Run with
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505798#comment-16505798
]
ASF GitHub Bot commented on FLINK-9538:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6134#discussion_r193976994
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateFunction.java
---
@@ -25,13 +25,13 @@
* This functionality is only
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505797#comment-16505797
]
ASF GitHub Bot commented on FLINK-9538:
---
Github user yanghua commented on a diff in the pull
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6134#discussion_r193976690
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateFunction.java
---
@@ -25,13 +25,13 @@
* This functionality is only
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505791#comment-16505791
]
Jeff Zhang commented on FLINK-9555:
---
I mean to support it natively so that user don't need to specify
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505785#comment-16505785
]
Dawid Wysakowicz commented on FLINK-9555:
-
I think you can use table API already. Just add the
[
https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-9547.
---
Resolution: Not A Problem
> CEP pattern not called on windowed stream
>
[
https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505782#comment-16505782
]
Dawid Wysakowicz edited comment on FLINK-9547 at 6/8/18 7:14 AM:
-
Now
[
https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505782#comment-16505782
]
Dawid Wysakowicz commented on FLINK-9547:
-
Now that I have whole picture I can explain it a bit.
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505781#comment-16505781
]
Jeff Zhang commented on FLINK-9555:
---
I will work on it
> Support table api in scala shell
>
Jeff Zhang created FLINK-9555:
-
Summary: Support table api in scala shell
Key: FLINK-9555
URL: https://issues.apache.org/jira/browse/FLINK-9555
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505776#comment-16505776
]
ASF GitHub Bot commented on FLINK-9538:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6134#discussion_r193968855
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateFunction.java
---
@@ -25,13 +25,13 @@
* This functionality is only
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505765#comment-16505765
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193965626
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -105,7 +155,24 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505762#comment-16505762
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on the issue:
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5410
Thanks for updating @pduveau. There still some minor comments on
`RMQSinkPublishOptions` and `README` that are open for discussion.
---
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505757#comment-16505757
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505755#comment-16505755
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505758#comment-16505758
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505756#comment-16505756
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193964437
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkPublishOptions.java
---
@@ -0,0 +1,70
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193964455
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkPublishOptions.java
---
@@ -0,0 +1,70
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193964429
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkPublishOptions.java
---
@@ -0,0 +1,70
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193964402
--- Diff: flink-connectors/flink-connector-rabbitmq/README.md ---
@@ -9,3 +9,7 @@ nor packages binaries from the "RabbitMQ AMQP Java Client".
Users that
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505752#comment-16505752
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193963772
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkTest.java
---
@@ -83,7 +103,22 @@
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505750#comment-16505750
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193963587
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -105,7 +153,18 @@ public
99 matches
Mail list logo
