[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401533#comment-15401533 ] ASF GitHub Bot commented on FLINK-1984: --- Github user EronWright commented on the issue:

[GitHub] flink issue #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1)

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/2315 @mxm I think this is ready for your review. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401532#comment-15401532 ] ASF GitHub Bot commented on FLINK-1984: --- GitHub user EronWright opened a pull request:

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

GitHub user EronWright opened a pull request: https://github.com/apache/flink/pull/2315 [FLINK-1984] Integrate Flink with Apache Mesos (T1) Part one ("T1") of Flink on Mesos. Implemented Mesos AppMaster including: - runners for AppMaster and TaskManager -

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401366#comment-15401366 ] Ivan Mushketyk commented on FLINK-3414: --- Hi, I would like to work on this task if you don't mind.

[jira] [Commented] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge

[ https://issues.apache.org/jira/browse/FLINK-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401363#comment-15401363 ] Ivan Mushketyk commented on FLINK-2090: --- I will fix this. > toString of CollectionInputFormat

[jira] [Assigned] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge

[ https://issues.apache.org/jira/browse/FLINK-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-2090: - Assignee: Ivan Mushketyk > toString of CollectionInputFormat takes long time when the

[jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401347#comment-15401347 ] Fabian Hueske commented on FLINK-2032: -- Hi [~neelesh77], sorry for the late reply. All sub-issues

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401254#comment-15401254 ] ASF GitHub Bot commented on FLINK-3298: --- GitHub user mushketyk opened a pull request:

[GitHub] flink pull request #2314: [FLINK-3298] Implement ActiveMQ streaming connecto...

GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2314 [FLINK-3298] Implement ActiveMQ streaming connector Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If

[jira] [Commented] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section

[ https://issues.apache.org/jira/browse/FLINK-4284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401248#comment-15401248 ] ASF GitHub Bot commented on FLINK-4284: --- Github user uce commented on the issue:

[GitHub] flink issue #2311: [FLINK-4284] [docu] Fix broken links

Github user uce commented on the issue: https://github.com/apache/flink/pull/2311 +1 to merge. Anchor links have been broken while moving the batch docs pages around... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401232#comment-15401232 ] Aljoscha Krettek commented on FLINK-4282: - The offset should be an additional (optional) parameter

[GitHub] flink issue #2002: Support for bz2 compression in flink-core

Github user mtanski commented on the issue: https://github.com/apache/flink/pull/2002 Added support for XZ as well and update the documentation. Newer versions of commons compression (1.12) add support for snappy and lzma. But the version included as a (transitive) dependency