[GitHub] flink pull request #2324: Bump version to 1.2-SNAPSHOT

2016-08-01 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/2324 Bump version to 1.2-SNAPSHOT It is about time to do this. You can merge this pull request into a Git repository by running: $ git pull https://github.com/mbalassi/flink 12-bump

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

2016-08-01 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402825#comment-15402825 ] Ivan Mushketyk commented on FLINK-3414: --- Hey Till. Thank you for you reply. I'll implement an

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

2016-08-01 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3414: - Assignee: Ivan Mushketyk > Add Scala API for CEP's pattern definition >

[jira] [Comment Edited] (FLINK-3873) Add a Kafka TableSink with Avro serialization

2016-08-01 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402814#comment-15402814 ] Ivan Mushketyk edited comment on FLINK-3873 at 8/1/16 9:03 PM: --- I've

[jira] [Commented] (FLINK-3873) Add a Kafka TableSink with Avro serialization

2016-08-01 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402814#comment-15402814 ] Ivan Mushketyk commented on FLINK-3873: --- I've implemented TableSink with Avro serialization here:

[jira] [Commented] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector

2016-08-01 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402806#comment-15402806 ] Ivan Mushketyk commented on FLINK-4043: --- If you are going to work on it, here is an implementation

[GitHub] flink issue #2323: [FLINK-2090] toString of CollectionInputFormat takes long...

2016-08-01 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2323 Set maximum limit for the toString result, as suggested by Stephan here: https://issues.apache.org/jira/browse/FLINK-2090 --- If your project is set up for it, you can reply to this email and

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

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402762#comment-15402762 ] ASF GitHub Bot commented on FLINK-2090: --- Github user mushketyk commented on the issue:

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

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402759#comment-15402759 ] ASF GitHub Bot commented on FLINK-2090: --- GitHub user mushketyk opened a pull request:

[GitHub] flink pull request #2323: [FLINK-2090] toString of CollectionInputFormat tak...

2016-08-01 Thread mushketyk
GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2323 [FLINK-2090] toString of CollectionInputFormat takes long time when t… Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402673#comment-15402673 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73037620 --- Diff: docs/internals/flink_security.md --- @@ -0,0 +1,87 @@ +--- +title: "Flink Security" +# Top navigation +top-nav-group: internals

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 @mxm - Thanks for your feedback and here is my response to some of your comments. - Do we need to run all the Yarn tests normally and secured? We already have problems with our test

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402626#comment-15402626 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the issue:

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402606#comment-15402606 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the issue:

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 @nielsbasjes - In most deployments, the KRB5 configuration file will be located in a well known (for e.g., /etc/krb5.conf) but in scenarios where custom location needs to be provided, we could

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402585#comment-15402585 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73028461 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java --- @@ -75,34 +84,47 @@ public static void runYarnTaskManager(String[]

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402572#comment-15402572 ] Stephan Ewen commented on FLINK-4094: - If we pool the off-heap byte buffers, we effectively make a

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402570#comment-15402570 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73027093 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/RunTypeSelectionRunner.java --- @@ -0,0 +1,54 @@ +/*

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402551#comment-15402551 ] ASF GitHub Bot commented on FLINK-2363: --- Github user StephanEwen closed the pull request at:

[GitHub] flink pull request #913: [FLINK-2363] [docs] First part of internals - compl...

2016-08-01 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/913 --- 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 feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73023852 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/RunTypeHolder.java --- @@ -0,0 +1,36 @@ +/* + *

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402540#comment-15402540 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402541#comment-15402541 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73023816 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java --- @@

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73023705 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/RunTypeHolder.java --- @@ -0,0 +1,36 @@ +/* + *

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402535#comment-15402535 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[jira] [Commented] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402530#comment-15402530 ] ASF GitHub Bot commented on FLINK-4251: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2281: RMQ Sink: Possibility to customize queue config [F...

2016-08-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2281 --- 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 feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73020806 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetentionTestBase.java

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402485#comment-15402485 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402457#comment-15402457 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73017860 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkSecuredITCase.java ---

[jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402439#comment-15402439 ] ASF GitHub Bot commented on FLINK-4297: --- Github user uce commented on the issue:

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402438#comment-15402438 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink issue #2320: [FLINK-4297][yarn] decode URL encoded fat jar path

2016-08-01 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2320 It didn't fix it unfortunately. --- 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 feature enabled and

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73015565 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java --- @@ -0,0 +1,218 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402428#comment-15402428 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73014755 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java --- @@ -0,0 +1,218 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402414#comment-15402414 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[jira] [Commented] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402416#comment-15402416 ] ASF GitHub Bot commented on FLINK-4299: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2322: [FLINK-4299] show loss of job manager in Client

2016-08-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2322 --- 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 feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4299. -- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 4d988a9 (release-1.1), 7ea9c01 (master). > Show

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73013795 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java --- @@ -0,0 +1,158 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402412#comment-15402412 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[jira] [Closed] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4296. -- Resolution: Fixed Fixed in fa3a3fc (release-1.1), 10642f7 (master). > Scheduler accepts more tasks

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73013657 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java --- @@ -0,0 +1,158 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402408#comment-15402408 ] ASF GitHub Bot commented on FLINK-4296: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2321: [FLINK-4296] Fixes failure reporting of consumer t...

2016-08-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2321 --- 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 feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402402#comment-15402402 ] ASF GitHub Bot commented on FLINK-4297: --- Github user mxm commented on the issue:

[GitHub] flink issue #2320: [FLINK-4297][yarn] decode URL encoded fat jar path

2016-08-01 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2320 Thanks for trying it out @uce! There was an unrelated quoting issue in `yarn-session.sh`. I pushed another fix. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73012870 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java --- @@ -0,0 +1,158 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402398#comment-15402398 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402395#comment-15402395 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73012593 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java --- @@ -0,0 +1,158 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402387#comment-15402387 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on a diff in the pull

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-01 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73012055 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -1016,6 +1016,23 @@ /** The environment variable

[jira] [Commented] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402376#comment-15402376 ] ASF GitHub Bot commented on FLINK-4299: --- Github user uce commented on the issue:

[GitHub] flink issue #2322: [FLINK-4299] show loss of job manager in Client

2016-08-01 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2322 Yes, sir! :-) +1 to merge. --- 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 feature enabled and wishes

[jira] [Created] (FLINK-4303) Add CEP examples

2016-08-01 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4303: --- Summary: Add CEP examples Key: FLINK-4303 URL: https://issues.apache.org/jira/browse/FLINK-4303 Project: Flink Issue Type: Improvement Components:

[jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402373#comment-15402373 ] ASF GitHub Bot commented on FLINK-4297: --- Github user uce commented on the issue:

[GitHub] flink issue #2320: [FLINK-4297][yarn] decode URL encoded fat jar path

2016-08-01 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2320 Tested this with Hadoop 2.4.1 and it works as expected with `bin/flink run -m yarn-cluster`: ``` 2016-08-01 16:32:06,214 INFO org.apache.flink.yarn.Utils - Copying from 2016-08-01 16:32:06,214

[jira] [Commented] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402370#comment-15402370 ] ASF GitHub Bot commented on FLINK-4296: --- Github user mxm commented on the issue:

[GitHub] flink issue #2321: [FLINK-4296] Fixes failure reporting of consumer task sch...

2016-08-01 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2321 +1 LGTM --- 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 feature enabled and wishes so, or if the

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

2016-08-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402367#comment-15402367 ] Aljoscha Krettek commented on FLINK-4282: - Also, when you have day windows you need to offset

[jira] [Commented] (FLINK-4302) Add JavaDocs to MetricConfig

2016-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402363#comment-15402363 ] Chesnay Schepler commented on FLINK-4302: - that's a good idea. We could also think about renaming

[jira] [Commented] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402348#comment-15402348 ] ASF GitHub Bot commented on FLINK-4299: --- GitHub user mxm opened a pull request:

[GitHub] flink issue #2322: [FLINK-4299] show loss of job manager in Client

2016-08-01 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2322 @uce Is this has you had in mind? --- 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 feature enabled and

[GitHub] flink pull request #2322: [FLINK-4299] show loss of job manager in Client

2016-08-01 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2322 [FLINK-4299] show loss of job manager in Client This prints a message when the leading JobManager changes after first connecting to a JobManager. Further, it prints a message when a connection

[jira] [Commented] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402349#comment-15402349 ] ASF GitHub Bot commented on FLINK-4299: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-4289) Source files have executable flag set

2016-08-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402338#comment-15402338 ] Ufuk Celebi commented on FLINK-4289: Fixed in d13b825 (release-1.1). > Source files have executable

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

2016-08-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402339#comment-15402339 ] Aljoscha Krettek commented on FLINK-4282: - For most timezones this is valid but there are some

[jira] [Updated] (FLINK-4293) Malformatted Apache Headers

2016-08-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4293: Summary: Malformatted Apache Headers (was: Malformatted Apache Haders) > Malformatted

[jira] [Commented] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402334#comment-15402334 ] ASF GitHub Bot commented on FLINK-4296: --- Github user uce commented on the issue:

[GitHub] flink issue #2321: [FLINK-4296] Fixes failure reporting of consumer task sch...

2016-08-01 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2321 Good catch. The change and test look good to me! This was broken for a long time (since the initial refactoring of the network stack I think). It never surfaced, because most use cases and tests run

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

2016-08-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402332#comment-15402332 ] Till Rohrmann commented on FLINK-4283: -- I tried to reproduce this issue locally but I was not

[jira] [Commented] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402308#comment-15402308 ] ASF GitHub Bot commented on FLINK-4296: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #2321: [FLINK-4296] Fixes failure reporting of consumer t...

2016-08-01 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2321 [FLINK-4296] Fixes failure reporting of consumer task scheduling when producer has already finished This PR changes the failure behaviour such that the consumer task is failed instead of the

[jira] [Commented] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402305#comment-15402305 ] Maximilian Michels commented on FLINK-4299: --- Good idea! We should add some messages in the

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402291#comment-15402291 ] Stephan Ewen commented on FLINK-4280: - I like the latest suggestion for configuration, with a few

[jira] [Assigned] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4299: - Assignee: Maximilian Michels > Show loss of job manager in Client >

[jira] [Commented] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402303#comment-15402303 ] Till Rohrmann commented on FLINK-4296: -- I found the issue. The problem is that a scheduling failure

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

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402301#comment-15402301 ] Stephan Ewen commented on FLINK-4282: - Seems the offset can serve two purposes: 1. Compensate for

[jira] [Commented] (FLINK-4154) Correction of murmur hash breaks backwards compatibility

2016-08-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402300#comment-15402300 ] Ufuk Celebi commented on FLINK-4154: Reverted in 0274f9c (release-1.1) and 0f92a6b (master). >

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402281#comment-15402281 ] Stephan Ewen commented on FLINK-2237: - It it is just about the fact the it is currently called

[jira] [Created] (FLINK-4302) Add JavaDocs to MetricConfig

2016-08-01 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4302: -- Summary: Add JavaDocs to MetricConfig Key: FLINK-4302 URL: https://issues.apache.org/jira/browse/FLINK-4302 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-4301) Parameterize Flink version in Quickstart bash script

2016-08-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4301: Description: The Flink version is hard coded in the quickstart script (for Scala and Java). Thus,

[jira] [Updated] (FLINK-4301) Parameterize Flink version in Quickstart bash script

2016-08-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4301: Labels: starter (was: ) > Parameterize Flink version in Quickstart bash script >

[jira] [Created] (FLINK-4301) Parameterize Flink version in Quickstart bash script

2016-08-01 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4301: --- Summary: Parameterize Flink version in Quickstart bash script Key: FLINK-4301 URL: https://issues.apache.org/jira/browse/FLINK-4301 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402243#comment-15402243 ] Stephan Ewen commented on FLINK-4290: - Updating the test assumption to skip the Cassandra tests on all

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402231#comment-15402231 ] Maximilian Michels commented on FLINK-4094: --- Thanks for elaborating on your thoughts

[jira] [Created] (FLINK-4300) Improve error message for different Scala versions of JM and Client

2016-08-01 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4300: --- Summary: Improve error message for different Scala versions of JM and Client Key: FLINK-4300 URL: https://issues.apache.org/jira/browse/FLINK-4300 Project: Flink

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402204#comment-15402204 ] Stephan Ewen commented on FLINK-4290: - Seems Cassandra does not work with Java 7, actually. We should

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402201#comment-15402201 ] Stephan Ewen commented on FLINK-4290: - Sorry, correcting myself. The command line was Java 7, I

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402179#comment-15402179 ] Stephan Ewen commented on FLINK-4290: - My environment is Ubuntu 14.4, Maven 3.0.5, Java 8 >

[GitHub] flink issue #2294: [FLINK-4265] [dataset api] Add a NoOpOperator

2016-08-01 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2294 This would replace `Delegate` and is much simpler. I placed it in the Java API package but it would not be visible to users through the `DataSet` API. The ultimate goal is to implicitly

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402172#comment-15402172 ] Stephan Ewen commented on FLINK-4290: - Running it with maven (command line), I get

[jira] [Commented] (FLINK-4265) Add a NoOpOperator

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402174#comment-15402174 ] ASF GitHub Bot commented on FLINK-4265: --- Github user greghogan commented on the issue:

  1   2   >