[jira] [Commented] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

2016-07-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395169#comment-15395169 ] Tzu-Li (Gordon) Tai commented on FLINK-2510: Related: FLINK-4023 and FLINK-415

[jira] [Assigned] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

2016-07-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-2510: -- Assignee: Tzu-Li (Gordon) Tai > KafkaConnector should access partition metadata

[jira] [Updated] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

2016-07-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-2510: --- Component/s: Kafka Connector > KafkaConnector should access partition metadata from ma

[jira] [Updated] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

2016-07-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-2510: --- Fix Version/s: 1.2.0 > KafkaConnector should access partition metadata from master/clu

[jira] [Commented] (FLINK-3006) TypeExtractor fails on custom type

2016-07-27 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395198#comment-15395198 ] Gyula Fora commented on FLINK-3006: --- I agree, Stephan, closing it. > TypeExtractor fail

[jira] [Closed] (FLINK-3006) TypeExtractor fails on custom type

2016-07-27 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-3006. - Resolution: Not A Problem > TypeExtractor fails on custom type > -- > >

[GitHub] flink issue #2299: [FLINK-4259]: Unclosed FSDataOutputStream in FileCache#co...

2016-07-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2299 I think it would be fine to merge it without a test; we merged plenty of PR's like this without requiring a test. The PythonPlanBinderTest failing is odd, but i would guess that it is unrelat

[jira] [Commented] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy()

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395271#comment-15395271 ] ASF GitHub Bot commented on FLINK-4259: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4245) Metric naming improvements

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395317#comment-15395317 ] ASF GitHub Bot commented on FLINK-4245: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #2300: [FLINK-4245] Expose all possible variables

2016-07-27 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2300 [FLINK-4245] Expose all possible variables This PR allows users and reporters to access a `Map` of all defined variables and their associated values via `MetricGroup#getAllVariables()`. The

[GitHub] flink issue #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() expects ...

2016-07-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2298 +1. We could also use the `@Internal` annotations for this. Out of curiosity, could you explain we can't just restrict access to the methods? --- If your project is set up for it, you can re

[jira] [Commented] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395330#comment-15395330 ] ASF GitHub Bot commented on FLINK-4247: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

2016-07-27 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395370#comment-15395370 ] GaoLun commented on FLINK-4263: --- [~jark], [~twalthr] i debug this issue and found that when

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread ramkrish86
GitHub user ramkrish86 opened a pull request: https://github.com/apache/flink/pull/2301 FLINK-3674 Add an interface for EventTime aware User Function (Ram) Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considera

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395389#comment-15395389 ] ASF GitHub Bot commented on FLINK-3674: --- GitHub user ramkrish86 opened a pull reques

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2301#discussion_r72416703 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java --- @@ -55,13 +56,18 @@

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2301#discussion_r72416769 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableAllWindowFunction.java --- @@ -8

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395396#comment-15395396 ] ASF GitHub Bot commented on FLINK-3674: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2301#discussion_r72416839 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueWindowFunction.java --- @@ -8

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395398#comment-15395398 ] ASF GitHub Bot commented on FLINK-3674: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2301#discussion_r72416820 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueAllWindowFunction.java --- @@

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395399#comment-15395399 ] ASF GitHub Bot commented on FLINK-3674: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2301#discussion_r72416804 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableWindowFunction.java --- @@ -83,4

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395402#comment-15395402 ] ASF GitHub Bot commented on FLINK-3674: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2301#discussion_r72416957 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java --- @@ -2003,6 +2048,53 @@ public

[GitHub] flink issue #2301: FLINK-3674 Add an interface for EventTime aware User Func...

2016-07-27 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2301 Created two interfaces EventTimeFunction and a WindowTimer (interface). The WindowTimer interface allows users to implement their own watermark timers and the way they could be fired. The EventTim

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395400#comment-15395400 ] ASF GitHub Bot commented on FLINK-3674: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395403#comment-15395403 ] ASF GitHub Bot commented on FLINK-3674: --- Github user ramkrish86 commented on the iss

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395404#comment-15395404 ] ASF GitHub Bot commented on FLINK-3674: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395407#comment-15395407 ] ASF GitHub Bot commented on FLINK-3674: --- Github user ramkrish86 commented on a diff

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2301#discussion_r72417108 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java --- @@ -55,13 +56,18 @@

[GitHub] flink pull request #2301: FLINK-3674 Add an interface for EventTime aware Us...

2016-07-27 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2301#discussion_r72417872 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java --- @@ -55,13 +56,18 @@

[GitHub] flink issue #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() expects ...

2016-07-27 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2298 Yes, good idea. We can not restrict it as it is defined in an interface. If we would make it `protected`, we could not call it from the outside. --- If your project is set up for it, you can reply t

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395417#comment-15395417 ] ASF GitHub Bot commented on FLINK-3674: --- Github user ramkrish86 commented on a diff

[jira] [Commented] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395416#comment-15395416 ] ASF GitHub Bot commented on FLINK-4247: --- Github user twalthr commented on the issue:

[GitHub] flink issue #2257: [FLINK-4152] Allow re-registration of TMs at resource man...

2016-07-27 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2257 Glad we figured it out :) Thanks for your PR! --- 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 en

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395444#comment-15395444 ] ASF GitHub Bot commented on FLINK-4152: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-4243) Change "Scope" to "Namespace" for Metrics

2016-07-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395470#comment-15395470 ] Chesnay Schepler commented on FLINK-4243: - I just realized that this would be a AP

[GitHub] flink issue #2290: [FLINK-4242] [table] Improve validation exception message...

2016-07-27 Thread gallenvara
Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/2290 Will update later to include the issue of [flink-4241](https://issues.apache.org/jira/browse/FLINK-4241) . --- If your project is set up for it, you can reply to this email and have your reply ap

[jira] [Commented] (FLINK-4242) Improve validation exception messages

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395477#comment-15395477 ] ASF GitHub Bot commented on FLINK-4242: --- Github user gallenvara commented on the iss

[GitHub] flink pull request #2302: [hotfix] [metrics] Refactor constructors and tests

2016-07-27 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2302 [hotfix] [metrics] Refactor constructors and tests Several `ComponentMetricGroup` classes had an additional constructor which took a `ScopeFormat` argument. This contructor was only used by tests. In

[GitHub] flink issue #2051: [FLINK-3779] Add support for queryable state

2016-07-27 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2051 Now that we have forked off the 1.1 release branch, I would like to merge this if there are no objections. There are not many changes to our current code base and the follow ups can be addressed until th

[jira] [Commented] (FLINK-3779) Add support for queryable state

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395486#comment-15395486 ] ASF GitHub Bot commented on FLINK-3779: --- Github user uce commented on the issue:

[GitHub] flink issue #2123: [FLINK-3904] GlobalConfiguration doesn't ensure config ha...

2016-07-27 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2123 Rebased to latest master. Merging this once Travis passes. --- 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 th

[jira] [Commented] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded

2016-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395503#comment-15395503 ] ASF GitHub Bot commented on FLINK-3904: --- Github user mxm commented on the issue:

[jira] [Updated] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance

2016-07-27 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3722: --- Component/s: (was: Distributed Coordination) Local Runtime > The divisions in the

[jira] [Assigned] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance

2016-07-27 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-3722: -- Assignee: Gabor Gevay > The divisions in the InMemorySorters' swap/compare methods hurt perform

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

2016-07-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r72429676 --- Diff: docs/internals/flink_security.md --- @@ -0,0 +1,87 @@ +--- +title: "Flink Security" --- End diff -- Thank you for this nice documen

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

2016-07-27 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 Thanks for this PR! I'm checking out your changes now. You probably have to rebase the PR to the latest master at some point because there are some merge conflict that will have to be resolved. --- If

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

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

[jira] [Comment Edited] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-07-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395607#comment-15395607 ] Timo Walther edited comment on FLINK-4248 at 7/27/16 12:47 PM: -

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-07-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395607#comment-15395607 ] Timo Walther commented on FLINK-4248: - [~smarthi] have you already started working on

[jira] [Updated] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-07-27 Thread Suneel Marthi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi updated FLINK-4248: - Assignee: Timo Walther (was: Suneel Marthi) > CsvTableSource does not support reading SqlTimeType

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-07-27 Thread Suneel Marthi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395613#comment-15395613 ] Suneel Marthi commented on FLINK-4248: -- Go ahead and assign it to urself @timo, haven

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-07-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395616#comment-15395616 ] Timo Walther commented on FLINK-4248: - Thanks Suneel! Sorry for the confusion. > CsvT

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

2016-07-27 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2303 [FLINK-4248] [core] [table] CsvTableSource does not support reading SqlTimeTypeInfo types Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Created] (FLINK-4268) Add a parsers for BigDecimals/BigInteger

2016-07-27 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4268: --- Summary: Add a parsers for BigDecimals/BigInteger Key: FLINK-4268 URL: https://issues.apache.org/jira/browse/FLINK-4268 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

2016-07-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4268: Affects Version/s: 1.2.0 > Add a parsers for BigDecimal/BigInteger > ---

[jira] [Updated] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

2016-07-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4268: Summary: Add a parsers for BigDecimal/BigInteger (was: Add a parsers for BigDecimals/BigInteger) >

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

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

  1   2   3   >