[jira] [Commented] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495808#comment-15495808 ] ASF GitHub Bot commented on FLINK-4590: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #2504: [FLINK-4590] [table] Some Table API tests are fail...

2016-09-16 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2504 [FLINK-4590] [table] Some Table API tests are failing when debug lvl is set to DEBUG Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check

[jira] [Assigned] (FLINK-4581) Table API throws "No suitable driver found for jdbc:calcite"

2016-09-16 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4581: --- Assignee: Timo Walther > Table API throws "No suitable driver found for jdbc:calcite" >

[GitHub] flink pull request #2489: [FLINK-4608] Use short-circuit AND in Max/Min Aggr...

2016-09-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2489 --- 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-4626) Missing break in MetricStore#add()

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4626. --- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in

[GitHub] flink pull request #2492: [FLINK-4612] Close FileWriter using try with resou...

2016-09-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2492 --- 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 #2488: [FLINK-4607] Close FileInputStream in ParameterToo...

2016-09-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2488 --- 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-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4608. --- Resolution: Fixed Fixed in ceb3aa05bae3d05b9f6c5a7a55e6e43fc91a9450 > Use short-circuit AND

[jira] [Commented] (FLINK-4612) Close FileWriter using try with resources

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

[jira] [Commented] (FLINK-4607) Close FileInputStream in ParameterTool and other

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

[jira] [Closed] (FLINK-4612) Close FileWriter using try with resources

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4612. --- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in

[jira] [Commented] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

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

[jira] [Reopened] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-4608: - > Use short-circuit AND in Max/Min AggregationFunction >

[jira] [Comment Edited] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495983#comment-15495983 ] Chesnay Schepler edited comment on FLINK-4608 at 9/16/16 10:38 AM: ---

[jira] [Closed] (FLINK-4607) Close FileInputStream in ParameterTool and other

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4607. --- Resolution: Fixed Fixed in db90580ffdb93a55a6318b18b5d50ec3666b001b > Close FileInputStream

[jira] [Closed] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4608. --- Resolution: Fixed > Use short-circuit AND in Max/Min AggregationFunction >

[GitHub] flink pull request #2506: [FLINK-4581] [table] Table API throws "No suitable...

2016-09-16 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2506 [FLINK-4581] [table] Table API throws "No suitable driver found for jdbc:calcite" Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list

[jira] [Commented] (FLINK-4581) Table API throws "No suitable driver found for jdbc:calcite"

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496007#comment-15496007 ] ASF GitHub Bot commented on FLINK-4581: --- GitHub user twalthr opened a pull request:

[jira] [Assigned] (FLINK-4252) Table program cannot be compiled

2016-09-16 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4252: --- Assignee: Timo Walther > Table program cannot be compiled >

[jira] [Commented] (FLINK-4620) Automatically creating savepoints

2016-09-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495665#comment-15495665 ] Aljoscha Krettek commented on FLINK-4620: - I think FLINK-4511 is the specific issue for that part

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

2016-09-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495761#comment-15495761 ] Aljoscha Krettek commented on FLINK-3869: - I have another proposal for solving this: I started to

[jira] [Commented] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet

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

[GitHub] flink pull request #2476: [FLINK-4589] Fix Merging of Covering Window in Mer...

2016-09-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2476 --- 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 issue #2499: [FLINK-4485] close and remove user class loader after job...

2016-09-16 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2499 @StephanEwen Yes, it is simple. I just pushed a commit. This now releases all temp files after job completion. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-4607) Close FileInputStream in ParameterTool and other

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495953#comment-15495953 ] ASF GitHub Bot commented on FLINK-4607: --- Github user zentol commented on the issue:

[GitHub] flink issue #2488: [FLINK-4607] Close FileInputStream in ParameterTool and o...

2016-09-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2488 merging --- 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

[GitHub] flink pull request #2505: [FLINK-4628] provide user class loader during inpu...

2016-09-16 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2505 [FLINK-4628] provide user class loader during input split assignment In analogy to the configure() method, this also sets a context class loader during input split assignment. You can merge this pull

[jira] [Commented] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495952#comment-15495952 ] ASF GitHub Bot commented on FLINK-4608: --- Github user zentol commented on the issue:

[jira] [Updated] (FLINK-4626) Missing break in MetricStore#add()

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4626: Affects Version/s: 1.2.0 > Missing break in MetricStore#add() >

[jira] [Commented] (FLINK-4628) User class loader unavailable during input split assignment

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

[jira] [Assigned] (FLINK-4626) Missing break in MetricStore#add()

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4626: --- Assignee: Chesnay Schepler > Missing break in MetricStore#add() >

[jira] [Updated] (FLINK-4626) Missing break in MetricStore#add()

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4626: Component/s: Metrics > Missing break in MetricStore#add() >

[GitHub] flink issue #2492: [FLINK-4612] Close FileWriter using try with resources

2016-09-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2492 merging --- 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-4612) Close FileWriter using try with resources

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495962#comment-15495962 ] ASF GitHub Bot commented on FLINK-4612: --- Github user zentol commented on the issue:

[GitHub] flink issue #2499: [FLINK-4485] close and remove user class loader after job...

2016-09-16 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2499 Thanks! Just a few words to @nielsbasjes who reported the issue. I've tested the fix using the test instructions you provided. Even before this fix, I could get rid of the temp files by forcing a manual

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

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

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495910#comment-15495910 ] ASF GitHub Bot commented on FLINK-4485: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2499: [FLINK-4485] close and remove user class loader after job...

2016-09-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2499 What would the fix for the TaskManager look like? Simply explicitly closing the UserCodeClassloader, or does it need more? --- If your project is set up for it, you can reply to this email and

[jira] [Created] (FLINK-4628) User class loader unavailable during input split assignment

2016-09-16 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4628: - Summary: User class loader unavailable during input split assignment Key: FLINK-4628 URL: https://issues.apache.org/jira/browse/FLINK-4628 Project: Flink

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

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

[jira] [Commented] (FLINK-4628) User class loader unavailable during input split assignment

2016-09-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495945#comment-15495945 ] Flavio Pompermaier commented on FLINK-4628: --- Could this be also the cause of

[GitHub] flink issue #2489: [FLINK-4608] Use short-circuit AND in Max/Min Aggregation...

2016-09-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2489 merging --- 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] [Created] (FLINK-4629) Kafka v 0.10 Support

2016-09-16 Thread Mariano Gonzalez (JIRA)
Mariano Gonzalez created FLINK-4629: --- Summary: Kafka v 0.10 Support Key: FLINK-4629 URL: https://issues.apache.org/jira/browse/FLINK-4629 Project: Flink Issue Type: Wish

[jira] [Assigned] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2016-09-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2662: Assignee: Fabian Hueske > CompilerException: "Bug: Plan generation for Unions picked a

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15497564#comment-15497564 ] ASF GitHub Bot commented on FLINK-2662: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request #2508: [FLINK-2662] [dataSet] Translate union with multip...

2016-09-16 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/2508 [FLINK-2662] [dataSet] Translate union with multiple output into separate unions with single output. Fixes FLINK-2662 by translating Union operators with two (or more) successors into two or more

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

2016-09-16 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 @vijikarthi Thanks for the update. Great to see the tests are passing now. I'm curious, why did this issue only appear on Travis and not locally? --- If your project is set up for it, you can reply to

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79151542 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -161,6 +161,8 @@ public CliFrontend(String configDir) throws Exception {

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79151877 --- Diff: flink-dist/src/main/flink-bin/conf/flink-jaas.conf --- @@ -0,0 +1,26 @@

[jira] [Closed] (FLINK-4622) CLI help message should include 'savepoint' action

2016-09-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4622. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in

[GitHub] flink pull request #2501: [FLINK-4622] CLI help message should include 'save...

2016-09-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2501 --- 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-3929) Support for Kerberos Authentication with Keytab Credential

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

[jira] [Commented] (FLINK-4622) CLI help message should include 'savepoint' action

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496164#comment-15496164 ] ASF GitHub Bot commented on FLINK-4622: --- Github user zentol commented on the issue:

[GitHub] flink issue #2501: [FLINK-4622] CLI help message should include 'savepoint' ...

2016-09-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2501 merging --- 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

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r79157293 --- Diff: docs/apis/cli.md --- @@ -187,6 +187,8 @@ Action "run" compiles and runs a program.

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496179#comment-15496179 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r79156877 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java --- @@ -241,8 +255,11 @@ private static Options

[jira] [Closed] (FLINK-4393) Failed to serialize accumulators for task

2016-09-16 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-4393. --- Resolution: Won't Fix This issue does not describe a bug. > Failed to serialize accumulators for

[jira] [Assigned] (FLINK-4288) Make it possible to unregister tables

2016-09-16 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4288: --- Assignee: Timo Walther > Make it possible to unregister tables >

[jira] [Commented] (FLINK-4622) CLI help message should include 'savepoint' action

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

[GitHub] flink pull request #2507: [FLINK-4252] [table] Validate input and output cla...

2016-09-16 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2507 [FLINK-4252] [table] Validate input and output classes of Table API Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79153795 --- Diff: flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java --- @@

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79152436 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java --- @@ -79,9 +82,8 @@ public static void

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79153661 --- Diff: flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java --- @@

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79155885 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java --- @@ -158,22 +157,37 @@ public static void

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79153742 --- Diff: flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java --- @@

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79154987 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1585,6 +1585,8 @@ object TaskManager { }

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79152195 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java --- @@ -155,6 +157,58 @@ public static void

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79154968 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java --- @@ -155,6 +157,58 @@ public static void

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

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79156099 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -1233,6 +1239,9 @@ /** ZooKeeper default leader port. */

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496185#comment-15496185 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink issue #2297: [FLINK-4081] [core] [table] FieldParsers should support e...

2016-09-16 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2297 If there are no objections, I would like to merge this PR next week. Other my other PRs depend on this. --- If your project is set up for it, you can reply to this email and have your reply appear

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496180#comment-15496180 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-09-16 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r79157764 --- Diff: docs/apis/cli.md --- @@ -187,6 +187,8 @@ Action "run" compiles and runs a program.

[jira] [Commented] (FLINK-4252) Table program cannot be compiled

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496227#comment-15496227 ] ASF GitHub Bot commented on FLINK-4252: --- GitHub user twalthr opened a pull request:

[jira] [Commented] (FLINK-4081) FieldParsers should support empty strings

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496347#comment-15496347 ] ASF GitHub Bot commented on FLINK-4081: --- Github user twalthr commented on the issue:

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

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496542#comment-15496542 ] 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-09-16 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 > @vijikarthi Thanks for the update. Great to see the tests are passing now. I'm curious, why did this issue only appear on Travis and not locally? Kafka/ZK connection is unusually

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

2016-09-16 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79190433 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -1233,6 +1239,9 @@ /** ZooKeeper default leader

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

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

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2016-09-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496768#comment-15496768 ] Fabian Hueske commented on FLINK-2662: -- I found the root cause of this problem. The plan contains a

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

2016-09-16 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79221107 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -161,6 +161,8 @@ public CliFrontend(String configDir) throws

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

2016-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496955#comment-15496955 ] 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-09-16 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r79221254 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java --- @@ -155,6 +157,58 @@ public static void

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

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

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

2016-09-16 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 @mxm I have addressed some of the review feedback and rebased to upstream master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

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

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