[GitHub] flink issue #3017: [FLINK-5350] don't overwrite an existing JAAS config

Github user theomega commented on the issue: https://github.com/apache/flink/pull/3017 Tested: Works and fixes the underlying issue that one cannot use its own JAAS configuration file. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request #2373: [FLINK-4394] RMQSource: QueueName accessible for s...

GitHub user theomega opened a pull request: https://github.com/apache/flink/pull/2373 [FLINK-4394] RMQSource: QueueName accessible for subclasses Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration

[GitHub] flink issue #2133: [FLINK-4091] Fix Guava shading in Cassandra connector

Github user theomega commented on the issue: https://github.com/apache/flink/pull/2133 Are you sure that this fixes the problem (I haven't tried): The change only changes the references in the connectors-code to the new package. But someone needs to provide this package, or

[GitHub] flink issue #1771: [FLINK-3311/FLINK-3332] Add Cassandra connector

Github user theomega commented on the issue: https://github.com/apache/flink/pull/1771 I tried out this branch and it works like it should in the scenario I set up: I wrote (so only using the Sink) to a quiet complex columnfamily in a 8 node cassandra cluster. I was using a

[GitHub] flink pull request #2073: [FLINK-4025] Add possiblity for the RMQ Streaming ...

GitHub user theomega opened a pull request: https://github.com/apache/flink/pull/2073 [FLINK-4025] Add possiblity for the RMQ Streaming Source to customize the queue This patch adds the possibilty for the user of the RabbitMQ Streaming Connector to customize the queue which is