[jira] [Created] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-02 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5703: Summary: ExecutionGraph recovery based on reconciliation with TaskManager reports Key: FLINK-5703 URL: https://issues.apache.org/jira/browse/FLINK-5703 Project:

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

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849733#comment-15849733 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3398 at 2/3/17 6:39 AM: I

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

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849733#comment-15849733 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3398 at 2/3/17 6:39 AM: I

[jira] [Updated] (FLINK-5701) FlinkKafkaProducer should check asyncException on checkpoints

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5701: --- Summary: FlinkKafkaProducer should check asyncException on checkpoints (was:

[jira] [Created] (FLINK-5702) Kafka Producer docs should warn if using setLogFailuresOnly, at-least-once is compromised

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-5702: -- Summary: Kafka Producer docs should warn if using setLogFailuresOnly, at-least-once is compromised Key: FLINK-5702 URL:

[jira] [Updated] (FLINK-5701) FlinkKafkaPrdocuer should check asyncException on checkpoints

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5701: --- Description: Reported in ML:

[jira] [Updated] (FLINK-5701) FlinkKafkaPrdocuer should check asyncException on checkpoints

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5701: --- Description: Reported in ML:

[jira] [Updated] (FLINK-5701) FlinkKafkaPrdocuer should check asyncException on checkpoints

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5701: --- Priority: Critical (was: Major) > FlinkKafkaPrdocuer should check asyncException on

[jira] [Updated] (FLINK-5701) FlinkKafkaPrdocuer should check asyncException on checkpoints

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5701: --- Summary: FlinkKafkaPrdocuer should check asyncException on checkpoints (was:

[jira] [Created] (FLINK-5701) FlinkKafkaPrdocuer violates at-least-once by not handling failed records

2017-02-02 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-5701: -- Summary: FlinkKafkaPrdocuer violates at-least-once by not handling failed records Key: FLINK-5701 URL: https://issues.apache.org/jira/browse/FLINK-5701

[jira] [Commented] (FLINK-5499) Try to reuse the resource location of prior execution attempt in allocating slot

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15851009#comment-15851009 ] ASF GitHub Bot commented on FLINK-5499: --- Github user wangzhijiang999 commented on the issue:

[GitHub] flink issue #3125: [FLINK-5499][JobManager]Reuse the resource location of pr...

2017-02-02 Thread wangzhijiang999
Github user wangzhijiang999 commented on the issue: https://github.com/apache/flink/pull/3125 @StephanEwen Yes, the current concern is only focusing on state restore performance. This PR does not consider all the scenarios and it may be only the first step for the slot location

[jira] [Closed] (FLINK-5166) TextInputFormatTest.testNestedFileRead

2017-02-02 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui closed FLINK-5166. Resolution: Won't Fix > TextInputFormatTest.testNestedFileRead > -- > >

[GitHub] flink issue #3113: [FLINK-4912] Introduce RECONCILIATING state in ExecutionG...

2017-02-02 Thread wangzhijiang999
Github user wangzhijiang999 commented on the issue: https://github.com/apache/flink/pull/3113 @StephanEwen , thank you for the concrete suggestions. Sorry for delay response because of Chinese Spring Festival Holiday. I have considered and added some tests to validate the

[jira] [Commented] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15851002#comment-15851002 ] ASF GitHub Bot commented on FLINK-4912: --- Github user wangzhijiang999 commented on the issue:

[jira] [Commented] (FLINK-5640) configure the explicit Unit Test file suffix

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850984#comment-15850984 ] ASF GitHub Bot commented on FLINK-5640: --- Github user shijinkui commented on the issue:

[GitHub] flink issue #3211: [FLINK-5640][test]onfigure the explicit Unit Test file su...

2017-02-02 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/3211 cc @rmetzger --- 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

[jira] [Comment Edited] (FLINK-5695) Optimize table type systems based on database semantics

2017-02-02 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850965#comment-15850965 ] sunjincheng edited comment on FLINK-5695 at 2/3/17 2:48 AM: Hi, [~fhueske] ,

[jira] [Commented] (FLINK-5166) TextInputFormatTest.testNestedFileRead

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850972#comment-15850972 ] ASF GitHub Bot commented on FLINK-5166: --- Github user shijinkui closed the pull request at:

[GitHub] flink pull request #2876: [FLINK-5166] TextInputFormatTest.testNestedFileRea...

2017-02-02 Thread shijinkui
Github user shijinkui closed the pull request at: https://github.com/apache/flink/pull/2876 --- 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] [Comment Edited] (FLINK-5695) Optimize table type systems based on database semantics

2017-02-02 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850965#comment-15850965 ] sunjincheng edited comment on FLINK-5695 at 2/3/17 2:47 AM: Hi, [~fhueske] ,

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

2017-02-02 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850965#comment-15850965 ] sunjincheng commented on FLINK-5695: Hi, [~fhueske] , Yes, I would like to explain my purpose:

[jira] [Commented] (FLINK-5624) Support tumbling window on streaming tables in the SQL API

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850641#comment-15850641 ] ASF GitHub Bot commented on FLINK-5624: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3252: [FLINK-5624] Support tumbling window on streaming tables ...

2017-02-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3252 Hi @haohui, thanks for your contribution! The referenced JIRA is about adding support for group windows to SQL, not OVER (or row) windows. It should enable queries such as: ```

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850613#comment-15850613 ] ASF GitHub Bot commented on FLINK-2168: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3149: FLINK-2168 Add HBaseTableSource

2017-02-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3149 Thanks for the update @ramkrish86 and your patience! I skimmed over the PR and it looks good. I'll do a final pass early next week before merging it. Thanks, Fabian --- If your

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

2017-02-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850584#comment-15850584 ] Fabian Hueske commented on FLINK-5654: -- I agree [~rtudoran], the second approach looks much easier to

[jira] [Closed] (FLINK-3016) Update Flink roadmap

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3016. - Resolution: Resolved This info is now available in

[jira] [Closed] (FLINK-5700) Document akka.client.timeout

2017-02-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5700. Resolution: Fixed Fixed via 56d3611f3138a5605f61b4d1e0f59238f04296c6 > Document

[jira] [Closed] (FLINK-5494) Improve Mesos documentation

2017-02-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5494. Resolution: Fixed Fix Version/s: 1.3.0 1.3.0: f8f9cae191a5504450cfc1b141b114641c2216b3

[GitHub] flink pull request #3236: [FLINK-5494] [docs] Add more details to the Mesos ...

2017-02-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3236 --- 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-5494) Improve Mesos documentation

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

[jira] [Commented] (FLINK-5494) Improve Mesos documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850536#comment-15850536 ] ASF GitHub Bot commented on FLINK-5494: --- Github user tillrohrmann commented on the issue:

[GitHub] flink pull request #3236: [FLINK-5494] [docs] Add more details to the Mesos ...

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3236#discussion_r99223588 --- Diff: docs/setup/mesos.md --- @@ -145,60 +174,75 @@ If set to 'docker', specify the image name: In the `/bin` directory of the Flink

[GitHub] flink issue #3236: [FLINK-5494] [docs] Add more details to the Mesos documen...

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3236 Thanks for your review @tzulitai. I've addressed your comments. Merging this PR now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-5494) Improve Mesos documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850535#comment-15850535 ] ASF GitHub Bot commented on FLINK-5494: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Closed] (FLINK-2896) Right-hand side menu items of website are missing in narrow browsers

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-2896. - Resolution: Fixed The new web design places menu items vertically on the left side of the page. >

[jira] [Commented] (FLINK-2883) Add documentation to forbid key-modifying ReduceFunction

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850521#comment-15850521 ] ASF GitHub Bot commented on FLINK-2883: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #3256: [FLINK-2883] [docs] Add documentation to forbid ke...

2017-02-02 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3256 [FLINK-2883] [docs] Add documentation to forbid key-modifying ReduceFunction You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink

[jira] [Assigned] (FLINK-2883) Add documentation to forbid key-modifying ReduceFunction

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-2883: - Assignee: Greg Hogan > Add documentation to forbid key-modifying ReduceFunction >

[jira] [Commented] (FLINK-5494) Improve Mesos documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850516#comment-15850516 ] ASF GitHub Bot commented on FLINK-5494: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #3236: [FLINK-5494] [docs] Add more details to the Mesos ...

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3236#discussion_r99221601 --- Diff: docs/setup/mesos.md --- @@ -145,60 +174,75 @@ If set to 'docker', specify the image name: In the `/bin` directory of the Flink

[jira] [Commented] (FLINK-5494) Improve Mesos documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850505#comment-15850505 ] ASF GitHub Bot commented on FLINK-5494: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-5494) Improve Mesos documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850498#comment-15850498 ] ASF GitHub Bot commented on FLINK-5494: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-5494) Improve Mesos documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850494#comment-15850494 ] ASF GitHub Bot commented on FLINK-5494: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #3236: [FLINK-5494] [docs] Add more details to the Mesos ...

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3236#discussion_r99220223 --- Diff: docs/setup/mesos.md --- @@ -107,29 +107,58 @@ Unvierse. Please use the following workaround in the meantime: ## Mesos without DC/OS

[GitHub] flink pull request #3236: [FLINK-5494] [docs] Add more details to the Mesos ...

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3236#discussion_r99220004 --- Diff: docs/setup/mesos.md --- @@ -107,29 +107,58 @@ Unvierse. Please use the following workaround in the meantime: ## Mesos without DC/OS

[GitHub] flink pull request #3236: [FLINK-5494] [docs] Add more details to the Mesos ...

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3236#discussion_r99219038 --- Diff: docs/setup/mesos.md --- @@ -107,29 +107,58 @@ Unvierse. Please use the following workaround in the meantime: ## Mesos without DC/OS

[jira] [Commented] (FLINK-5494) Improve Mesos documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850488#comment-15850488 ] ASF GitHub Bot commented on FLINK-5494: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-5474) Extend DC/OS documentation

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

[jira] [Closed] (FLINK-5474) Extend DC/OS documentation

2017-02-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5474. Resolution: Fixed 1.3.0: 817e3c257d7b58f9de46ddb657d3d2707757d1c9 1.2.0:

[GitHub] flink pull request #3237: [FLINK-5474] [docs] Extend DC/OS documentation

2017-02-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3237 --- 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-5474) Extend DC/OS documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850478#comment-15850478 ] ASF GitHub Bot commented on FLINK-5474: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-5474) Extend DC/OS documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850474#comment-15850474 ] ASF GitHub Bot commented on FLINK-5474: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-5474) Extend DC/OS documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850475#comment-15850475 ] ASF GitHub Bot commented on FLINK-5474: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink issue #3237: [FLINK-5474] [docs] Extend DC/OS documentation

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3237 Thanks for the review @tzulitai. I'll address your comments and will then merge this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request #3237: [FLINK-5474] [docs] Extend DC/OS documentation

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3237#discussion_r99217592 --- Diff: docs/setup/mesos.md --- @@ -92,18 +92,25 @@ Universe. In the search prompt, just search for Flink. **Note**: At the time of this writing,

[GitHub] flink pull request #3237: [FLINK-5474] [docs] Extend DC/OS documentation

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3237#discussion_r99217650 --- Diff: docs/setup/mesos.md --- @@ -92,18 +92,25 @@ Universe. In the search prompt, just search for Flink. **Note**: At the time of this writing,

[jira] [Commented] (FLINK-5474) Extend DC/OS documentation

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850473#comment-15850473 ] ASF GitHub Bot commented on FLINK-5474: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #3237: [FLINK-5474] [docs] Extend DC/OS documentation

2017-02-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3237#discussion_r99217632 --- Diff: docs/setup/mesos.md --- @@ -92,18 +92,25 @@ Universe. In the search prompt, just search for Flink. **Note**: At the time of this writing,

[jira] [Commented] (FLINK-2772) Introduce dedicated garbage collector config parameter and set default values for batch and streaming

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850469#comment-15850469 ] Greg Hogan commented on FLINK-2772: --- Is this still apropos? I'm not seeing a distinction between

[jira] [Commented] (FLINK-2171) Add instruction to build Flink with Scala 2.11

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850299#comment-15850299 ] Greg Hogan commented on FLINK-2171: --- Is this now covered?

[jira] [Commented] (FLINK-2042) Increase font size for stack figure on website home

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850293#comment-15850293 ] Greg Hogan commented on FLINK-2042: --- This looks to be resolved with the new website design. > Increase

[jira] [Commented] (FLINK-1759) Execution statistics for vertex-centric iterations

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850264#comment-15850264 ] Greg Hogan commented on FLINK-1759: --- Might look at FLINK-3030 for the UI changes. > Execution

[jira] [Closed] (FLINK-1703) option to balance load according to CPU available rather than slots available

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-1703. - Resolution: Duplicate > option to balance load according to CPU available rather than slots available >

[jira] [Commented] (FLINK-1337) Create an Amazon EMR Bootstrap Action

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850229#comment-15850229 ] Greg Hogan commented on FLINK-1337: --- Amazon EMR includes Flink as of December 2016 (version

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850207#comment-15850207 ] ASF GitHub Bot commented on FLINK-2168: --- Github user wuchong commented on the issue:

[GitHub] flink issue #3149: FLINK-2168 Add HBaseTableSource

2017-02-02 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3149 The `NestedFieldsProjectableTableSource` makes sense to me. +1 to implement it in a separate JIRA. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Closed] (FLINK-3164) Spread out scheduling strategy

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3164. - Resolution: Duplicate > Spread out scheduling strategy > -- > >

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

2017-02-02 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850152#comment-15850152 ] radu commented on FLINK-5654: - There is another decision point to be made. When we do the parsing of the SQL

[jira] [Commented] (FLINK-867) Webinterface JobHistory does not work offline

2017-02-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850127#comment-15850127 ] Greg Hogan commented on FLINK-867: -- [~StephanEwen] is this still an issue with the new web frontend? >

[jira] [Resolved] (FLINK-2944) Collect, expose and display operator-specific stats

2017-02-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2944. --- Resolution: Fixed > Collect, expose and display operator-specific stats >

[jira] [Resolved] (FLINK-3766) Add a new tab for monitoring metrics in the web interface

2017-02-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3766. --- Resolution: Fixed Fix Version/s: 1.2.0 This has been merged for Flink 1.2.0 > Add a

[jira] [Assigned] (FLINK-4830) Show latency statistics in web interface

2017-02-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4830: - Assignee: (was: Robert Metzger) > Show latency statistics in web interface >

[jira] [Commented] (FLINK-5552) Make the JMX port available through RESTful API

2017-02-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850107#comment-15850107 ] Robert Metzger commented on FLINK-5552: --- [~Zentol] any thoughts on this issue? I wonder if we can

[GitHub] flink issue #3250: Eratosthenes Sieve, a helpful and interesting example of ...

2017-02-02 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3250 The code would need to be cleaned up. I would look to the other examples, add comments, remove unused code, change anonymous inner classes to be static inner classes, etc. There is also the

[jira] [Closed] (FLINK-5502) Add documentation about migrating functions from 1.1 to 1.2

2017-02-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5502. --- Resolution: Fixed Implemented on release-1.2: da6ac7b5f7caf14bb2a8581db2e405e0585f7872 on

[jira] [Commented] (FLINK-5502) Add documentation about migrating functions from 1.1 to 1.2

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850053#comment-15850053 ] ASF GitHub Bot commented on FLINK-5502: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #3130: [FLINK-5502] Add the function migration guide in docs.

2017-02-02 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3130 Thanks! 😄 I merged your changes, could you please close this 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

[jira] [Created] (FLINK-5700) Document akka.client.timeout

2017-02-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5700: Summary: Document akka.client.timeout Key: FLINK-5700 URL: https://issues.apache.org/jira/browse/FLINK-5700 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5699) Cancel with savepoint fails with a NPE if savepoint target directory not set

2017-02-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5699: Summary: Cancel with savepoint fails with a NPE if savepoint target directory not set Key: FLINK-5699 URL: https://issues.apache.org/jira/browse/FLINK-5699 Project:

[GitHub] flink pull request #3255: [FLINK-5509] Replace QueryableStateClient keyHashC...

2017-02-02 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3255 [FLINK-5509] Replace QueryableStateClient keyHashCode argument Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849963#comment-15849963 ] ASF GitHub Bot commented on FLINK-5509: --- GitHub user dawidwys opened a pull request:

[GitHub] flink issue #2925: [FLINK-4574] [kinesis] Strengthen fetch interval implemen...

2017-02-02 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/2925 Hi, @tzulitai I think there is no better way if trying to use `Timer` to deal with `0` fetch interval. Even though I implement my own `Timer` scheduler, it just move the `runForever`

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849919#comment-15849919 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tony810430 commented on the issue:

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849898#comment-15849898 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tony810430 commented on a diff in the pull

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

2017-02-02 Thread tony810430
Github user tony810430 commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99117155 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@

[GitHub] flink issue #3254: Fix typo in code snippet

2017-02-02 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3254 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Assigned] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

2017-02-02 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5509: --- Assignee: Dawid Wysakowicz > Replace QueryableStateClient keyHashCode argument >

[GitHub] flink issue #3250: Eratosthenes Sieve, a helpful and interesting example of ...

2017-02-02 Thread dsnz
Github user dsnz commented on the issue: https://github.com/apache/flink/pull/3250 Hello, I can describe the algorithm but I cannot say anything about appropriateness as an example running on a distributed stream processor. I don't use Flink, I just tried to learn quickly its API

[jira] [Updated] (FLINK-5698) Add NestedFieldsProjectableTableSource interface

2017-02-02 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5698: - Issue Type: New Feature (was: Improvement) > Add NestedFieldsProjectableTableSource interface >

[jira] [Created] (FLINK-5698) Add NestedFieldsProjectableTableSource interface

2017-02-02 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5698: Summary: Add NestedFieldsProjectableTableSource interface Key: FLINK-5698 URL: https://issues.apache.org/jira/browse/FLINK-5698 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5481) Cannot create Collection of Row

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849803#comment-15849803 ] ASF GitHub Bot commented on FLINK-5481: --- Github user tonycox commented on the issue:

[GitHub] flink issue #3127: [FLINK-5481] Add type extraction from collection

2017-02-02 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/3127 ```scala import Types._ ROW(Array("person", "additional"), ROW(Array("name", "age"), STRING, STRING), ROW(Array("more_info", "and_so_on"), STRING, STRING))

[jira] [Updated] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

2017-02-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5635: -- Fix Version/s: (was: 1.2.0) > Improve Docker tooling to make it easier to build images and

[jira] [Updated] (FLINK-5634) Flink should not always redirect stdout to a file.

2017-02-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5634: -- Fix Version/s: (was: 1.2.0) > Flink should not always redirect stdout to a file. >

[GitHub] flink pull request #3254: Fix typo in code snippet

2017-02-02 Thread katsharp
GitHub user katsharp opened a pull request: https://github.com/apache/flink/pull/3254 Fix typo in code snippet * fix typo in code snippet CheckpoingConfig -> CheckpointConfig * no jira as this is a typo fix, as per http://flink.apache.org/contribute-documentation.html *

[jira] [Assigned] (FLINK-5606) Remove magic number in key and namespace serialization

2017-02-02 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5606: --- Assignee: Dawid Wysakowicz > Remove magic number in key and namespace serialization

[jira] [Commented] (FLINK-5606) Remove magic number in key and namespace serialization

2017-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849771#comment-15849771 ] ASF GitHub Bot commented on FLINK-5606: --- GitHub user dawidwys opened a pull request:

[GitHub] flink pull request #3253: [FLINK-5606] Remove magic number in key and namesp...

2017-02-02 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3253 [FLINK-5606] Remove magic number in key and namespace serialization Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

  1   2   >