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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15400473#comment-15400473 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 7/30/16 5:48 AM: ---

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15400473#comment-15400473 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 7/30/16 5:46 AM: ---

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15400475#comment-15400475 ] Tzu-Li (Gordon) Tai commented on FLINK-3398: I've gave this idea a second thou

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15400473#comment-15400473 ] Tzu-Li (Gordon) Tai commented on FLINK-4280: It seems like that this JIRA and

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15400472#comment-15400472 ] Tzu-Li (Gordon) Tai commented on FLINK-4280: [~StephanEwen] On second thought,

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

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

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

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

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

2016-07-29 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2301 Closing this as discussed. I will wait for more feedback on what is expected here and then proceed. --- If your project is set up for it, you can reply to this email and have your reply appear on

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

2016-07-29 Thread ramkrish86
Github user ramkrish86 closed the pull request at: https://github.com/apache/flink/pull/2301 --- 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-3674) Add an interface for EventTime aware User Function

2016-07-29 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15400422#comment-15400422 ] ramkrishna.s.vasudevan commented on FLINK-3674: --- Thanks for the comments/fee

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399691#comment-15399691 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 7/30/16 3:30 AM: ---

[jira] [Comment Edited] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399667#comment-15399667 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3398 at 7/30/16 3:25 AM: ---

[jira] [Comment Edited] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399699#comment-15399699 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3398 at 7/29/16 5:46 PM: ---

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399699#comment-15399699 ] Tzu-Li (Gordon) Tai commented on FLINK-3398: I've left some thoughts on the mi

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399691#comment-15399691 ] Tzu-Li (Gordon) Tai commented on FLINK-4280: Migration plan I have in mind: 1

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399667#comment-15399667 ] Tzu-Li (Gordon) Tai commented on FLINK-3398: Would this be better?: Have setti

[GitHub] flink pull request #2313: [FLINK-4273] Modify JobClient to attach to running...

2016-07-29 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2313 [FLINK-4273] Modify JobClient to attach to running jobs These changes are required for FLINK-4272 (introduce a JobClient class for job control). Essentially, we want to be able to re-attach to a

[jira] [Comment Edited] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399667#comment-15399667 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3398 at 7/29/16 4:54 PM: ---

[jira] [Comment Edited] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399667#comment-15399667 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3398 at 7/29/16 4:54 PM: ---

[jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

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

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399650#comment-15399650 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 7/29/16 4:45 PM: ---

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399650#comment-15399650 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 7/29/16 4:46 PM: ---

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399650#comment-15399650 ] Tzu-Li (Gordon) Tai commented on FLINK-4280: Or perhaps we can seed the config

[jira] [Updated] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4195: --- Fix Version/s: (was: 1.1.0) 1.2.0 > Dedicated Configuration cla

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399648#comment-15399648 ] Tzu-Li (Gordon) Tai commented on FLINK-4280: I like the idea of typed configur

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399636#comment-15399636 ] Stephan Ewen commented on FLINK-3398: - We could do that, need to think then about whet

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399633#comment-15399633 ] Stephan Ewen commented on FLINK-3398: - [~tzulitai] If we use a separate flink group-id

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[GitHub] flink issue #1690: FLINK-3398: Allow for opting-out from Kafka offset auto-c...

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/1690 I left a few thoughts in the corresponding JIRA issue: https://issues.apache.org/jira/browse/FLINK-3398 --- If your project is set up for it, you can reply to this email and have your reply appe

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399625#comment-15399625 ] Tzu-Li (Gordon) Tai commented on FLINK-3398: [~StephanEwen] That's actually a

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

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

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

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2051 Good from my side. --- 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

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399575#comment-15399575 ] Stephan Ewen commented on FLINK-3398: - Let's reboot the discussion and work on this is

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3398: Component/s: Kafka Connector > Flink Kafka consumer should support auto-commit opt-outs > --

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3398: Fix Version/s: 1.2.0 > Flink Kafka consumer should support auto-commit opt-outs > --

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3398: Priority: Blocker (was: Major) > Flink Kafka consumer should support auto-commit opt-outs > ---

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3398: Issue Type: Improvement (was: Bug) > Flink Kafka consumer should support auto-commit opt-outs > ---

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3398: Priority: Major (was: Blocker) > Flink Kafka consumer should support auto-commit opt-outs > ---

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

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399544#comment-15399544 ] Stephan Ewen commented on FLINK-4280: - A more general thought on the configuration of

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

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399487#comment-15399487 ] Stephan Ewen commented on FLINK-4282: - Big +1 for this feature > Add Offset Parameter

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

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399484#comment-15399484 ] Stephan Ewen commented on FLINK-4283: - To the attention of the distributed coordinatio

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

2016-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399481#comment-15399481 ] Stephan Ewen commented on FLINK-3674: - I would also like to take a step back here from

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

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

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

2016-07-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2311 If this `[transformations](#dataset-transformations)` is a pure anchor link then they aren't broken. --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

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

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

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

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2301 I would suggest to close this PR and start with a proper design discussion. The approach taken here has a bunch of decisions/implications that I am not sure about, like - Mixing UDF

[jira] [Commented] (FLINK-4279) [py] Set flink dependencies to provided

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

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

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2301 Can we go back to the JIRA issue for a step, and first decide how we actually want his feature to look like? For API additions, it is crucial to not do "something fast", but discuss and under

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

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

[GitHub] flink issue #2308: [FLINK-4279] [py] Set flink dependencies to provided

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2308 For all the connectors and other libraries (that were included into user fat jars), these changes were good. So, if the Python module is used in a similar way, it should make sense there as w

[jira] [Commented] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies

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

[GitHub] flink issue #2309: [FLINK-4161] Add Quickstart exclusion for flink-dist depe...

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2309 Probably good for master (1.2) and 1.1.x --- 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

[jira] [Commented] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies

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

[GitHub] flink issue #2309: [FLINK-4161] Add Quickstart exclusion for flink-dist depe...

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2309 I think this change makes sense. +1 from my side --- 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

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

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

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

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2311 Out of curiosity: Are pure anchor linkes in general broken in the docs? --- 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 pro

[jira] [Commented] (FLINK-4277) TaskManagerConfigurationTest fails

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

[GitHub] flink issue #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#testDefault...

2016-07-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2310 good catch, thanks! +1 to merge this --- 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 f

[jira] [Updated] (FLINK-4277) TaskManagerConfigurationTest fails

2016-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4277: Labels: test-stability (was: ) > TaskManagerConfigurationTest fails > -

[jira] [Updated] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS

2016-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4276: Labels: test-stability (was: ) > TextInputFormatTest.testNestedFileRead fails on Windows OS

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

2016-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4283: Labels: test-stability (was: ) > ExecutionGraphRestartTest fails >

[jira] [Commented] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape

2016-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399306#comment-15399306 ] Chesnay Schepler commented on FLINK-4255: - The same exception occurred here: http

[jira] [Commented] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS

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

[jira] [Assigned] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS

2016-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4276: --- Assignee: Chesnay Schepler > TextInputFormatTest.testNestedFileRead fails on Windows

[GitHub] flink pull request #2312: [FLINK-4276] Fix TextInputFormatTest#testNestedFil...

2016-07-29 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2312 [FLINK-4276] Fix TextInputFormatTest#testNestedFileRead The problem with test was a simple formatting mismatch between the paths returned by `"file:" + File.getAbsolutePath()` and `Path#toString()`.

[jira] [Commented] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

2016-07-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399253#comment-15399253 ] ASF GitHub Bot commented on FLINK-4269: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

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

[GitHub] flink pull request #2307: [FLINK-4269] Decrease log level in RuntimeMonitorH...

2016-07-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2307 --- 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 enab

[jira] [Commented] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

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

[GitHub] flink issue #2307: [FLINK-4269] Decrease log level in RuntimeMonitorHandler

2016-07-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2307 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 feat

[GitHub] flink issue #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#testDefault...

2016-07-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2310 @mxm addressed your comments --- 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 wish

[jira] [Commented] (FLINK-4277) TaskManagerConfigurationTest fails

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

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

2016-07-29 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2311 [FLINK-4284] [docu] Fix broken links Fixes several broken links in the documentation. There were all links to the Batch documentation that are now under "Basic API Concepts". You can merge this pull

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

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

[jira] [Commented] (FLINK-4277) TaskManagerConfigurationTest fails

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

[GitHub] flink issue #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#testDefault...

2016-07-29 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2310 Thanks for the PR @zentol. The test didn't fail because the exception is swallowed in a catch block: ```java } catch (Exception e) { e.printStackT

[jira] [Commented] (FLINK-4277) TaskManagerConfigurationTest fails

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

[GitHub] flink pull request #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#test...

2016-07-29 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2310#discussion_r72780980 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerConfigurationTest.java --- @@ -110,7 +110,7 @@ public void testActorSystemP

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

2016-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4284: --- Assignee: Chesnay Schepler > DataSet/CEP link to non-existant "Linking with Flink" se

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

2016-07-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4284: --- Summary: DataSet/CEP link to non-existant "Linking with Flink" section Key: FLINK-4284 URL: https://issues.apache.org/jira/browse/FLINK-4284 Project: Flink

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

2016-07-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4283: --- Summary: ExecutionGraphRestartTest fails Key: FLINK-4283 URL: https://issues.apache.org/jira/browse/FLINK-4283 Project: Flink Issue Type: Bug Affec

[jira] [Commented] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends

2016-07-29 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399143#comment-15399143 ] Gyula Fora commented on FLINK-4275: --- I would not remove them in any case. They provide a

[GitHub] flink issue #2307: [FLINK-4269] Decrease log level in RuntimeMonitorHandler

2016-07-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2307 Please don't spend your time to write an actual test for this; for this change it is not necessary. --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[jira] [Commented] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

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

[jira] [Commented] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

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

[GitHub] flink issue #2307: [FLINK-4269] Decrease log level in RuntimeMonitorHandler

2016-07-29 Thread aditivin
Github user aditivin commented on the issue: https://github.com/apache/flink/pull/2307 Thanks @nssalian , @zentol - I'll keep the points in mind for next time. I will try testing the logging and update this thread. Also, I've enabled travis in my repository :) --- If your pr

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

2016-07-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4282: --- Summary: Add Offset Parameter to WindowAssigners Key: FLINK-4282 URL: https://issues.apache.org/jira/browse/FLINK-4282 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-4277) TaskManagerConfigurationTest fails

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

[GitHub] flink pull request #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#test...

2016-07-29 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2310 [FLINK-4277] Fix TaskManagerConfigurationTest#testDefaultFsParameterLoading This PR fixes the `TaskManagerConfigurationTest#testDefaultFsParameterLoading` by creating a proper `flink-conf.yaml` file

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

2016-07-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399092#comment-15399092 ] Aljoscha Krettek commented on FLINK-3674: - Could you please go a bit into the idea

[jira] [Assigned] (FLINK-4277) TaskManagerConfigurationTest fails

2016-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4277: --- Assignee: Chesnay Schepler > TaskManagerConfigurationTest fails > ---

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

2016-07-29 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399085#comment-15399085 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- [~mxm] Thanks for the comme

[jira] [Updated] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions

2016-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4281: Affects Version/s: 1.2.0 > Wrap all Calcite Exceptions in Flink Exceptions > ---

[jira] [Updated] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions

2016-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4281: Issue Type: Improvement (was: Bug) > Wrap all Calcite Exceptions in Flink Exceptions >

[jira] [Created] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions

2016-07-29 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4281: --- Summary: Wrap all Calcite Exceptions in Flink Exceptions Key: FLINK-4281 URL: https://issues.apache.org/jira/browse/FLINK-4281 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends

2016-07-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399081#comment-15399081 ] Aljoscha Krettek commented on FLINK-4275: - We can either fix those or remove them

[jira] [Commented] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies

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

[GitHub] flink pull request #2309: [FLINK-4161] Add Quickstart exclusion for flink-di...

2016-07-29 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2309 [FLINK-4161] Add Quickstart exclusion for flink-dist dependencies Updated version of #2218 which got closed as I accidentally deleted the branch. In addition to the previous changes: * `

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4280: --- Description: Currently, to start reading from the "earliest" and "latest" position in

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

2016-07-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4280: --- Description: Currently, to start reading from the "earliest" and "latest" position in

  1   2   >