[jira] [Created] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job

2016-11-22 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5140: --- Summary: NoResourceAvailableException is thrown while starting a new job Key: FLINK-5140 URL: https://issues.apache.org/jira/browse/FLINK-5140 Project: Flink Issue

[jira] [Created] (FLINK-5139) consum kafka can set offset

2016-11-22 Thread jing lining (JIRA)
jing lining created FLINK-5139: -- Summary: consum kafka can set offset Key: FLINK-5139 URL: https://issues.apache.org/jira/browse/FLINK-5139 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-5138) The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5138: - Description: Users may specify the state size in *setResource* API, then the different

[jira] [Updated] (FLINK-5138) The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5138: - Component/s: Core > The StateBackend provides the method to estimate memory usage based on hint

[jira] [Created] (FLINK-5138) The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec

2016-11-22 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5138: Summary: The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec Key: FLINK-5138 URL:

[jira] [Updated] (FLINK-5131) Fine-grained Resource Configuration

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5131: - Description: Normally the UDF just creates short-life small objects and these can be recycled

[jira] [Assigned] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating job graph

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-5134: Assignee: Zhijiang Wang > Aggregate ResourceSpe for chained operators when generating job

[jira] [Assigned] (FLINK-5133) Add new setResource API for DataStream and DataSet

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-5133: Assignee: Zhijiang Wang > Add new setResource API for DataStream and DataSet >

[jira] [Assigned] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory by ResourceManager

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-5136: Assignee: Zhijiang Wang > Aggregation of slot ResourceProfile and framework memory by

[jira] [Assigned] (FLINK-5135) ResourceProfile for slot request should be expanded to correspond with ResourceSpec

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-5135: Assignee: Zhijiang Wang > ResourceProfile for slot request should be expanded to

[jira] [Assigned] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-5132: Assignee: Zhijiang Wang > Introduce the ResourceSpec for grouping different resource

[jira] [Assigned] (FLINK-5137) Config JVM options and set onto the TaskManager container

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-5137: Assignee: Zhijiang Wang > Config JVM options and set onto the TaskManager container >

[jira] [Updated] (FLINK-5137) Config JVM options and set onto the TaskManager container

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5137: - Description: The users can config JVM options in job level. And the *ResourceManager* will set

[jira] [Created] (FLINK-5137) Config JVM options and set onto the TaskManager container

2016-11-22 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5137: Summary: Config JVM options and set onto the TaskManager container Key: FLINK-5137 URL: https://issues.apache.org/jira/browse/FLINK-5137 Project: Flink

[jira] [Updated] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory by ResourceManager

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5136: - Description: When *ResourceManager* requests container resource from cluster, the framework

[jira] [Updated] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory by ResourceManager

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5136: - Summary: Aggregation of slot ResourceProfile and framework memory by ResourceManager (was:

[jira] [Updated] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory for requesting resource from cluster by ResourceManager

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5136: - Summary: Aggregation of slot ResourceProfile and framework memory for requesting resource from

[jira] [Created] (FLINK-5136) ResourceManager should consider both slot resource profile and framework memory for requesting resource from cluster

2016-11-22 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5136: Summary: ResourceManager should consider both slot resource profile and framework memory for requesting resource from cluster Key: FLINK-5136 URL:

[jira] [Updated] (FLINK-5135) ResourceProfile for slot request should be expanded to correspond with ResourceSpec

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5135: - Description: The *JobManager* requests slot by *ResourceProfile* from *ResourceManager* before

[jira] [Updated] (FLINK-5135) ResourceProfile for slot request should be expanded to correspond with ResourceSpec

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5135: - Summary: ResourceProfile for slot request should be expanded to correspond with ResourceSpec

[jira] [Updated] (FLINK-5131) Fine-grained Resource Configuration

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5131: - Description: Normally the UDF just creates short-life small objects and these can be recycled

[jira] [Created] (FLINK-5135) ResourceProfile should be expanded to correspond with ResourceSpec

2016-11-22 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5135: Summary: ResourceProfile should be expanded to correspond with ResourceSpec Key: FLINK-5135 URL: https://issues.apache.org/jira/browse/FLINK-5135 Project: Flink

[jira] [Updated] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating job graph

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5134: - Description: In *JobGraph* generation, each *JobVertex* corresponds to a series of chained

[jira] [Updated] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating job graph

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5134: - Description: In *JobGraph* generation, each *JobVertex* corresponds to a series of chained

[jira] [Updated] (FLINK-5131) Fine-grained Resource Configuration

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5131: - Description: Normally the UDF just creates short-life small objects and these can be recycled

[jira] [Updated] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating job graph

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5134: - Summary: Aggregate ResourceSpe for chained operators when generating job graph (was: Aggregate

[jira] [Updated] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating stream graph

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5134: - Description: In DataStream API, the *ResourceSpec* is setted onto the internal transformation

[jira] [Updated] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating stream graph

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5134: - Description: In datastream API, > Aggregate ResourceSpe for chained operators when generating

[jira] [Created] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating stream graph

2016-11-22 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5134: Summary: Aggregate ResourceSpe for chained operators when generating stream graph Key: FLINK-5134 URL: https://issues.apache.org/jira/browse/FLINK-5134 Project:

[GitHub] flink issue #2792: [FLINK-4937] [Table] Add incremental group window aggrega...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/2792 @fhueske thanks a lot for the review. I have refactored AggregateUtil and updated the PR . --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688860#comment-15688860 ] ASF GitHub Bot commented on FLINK-4937: --- Github user sunjincheng121 commented on the issue:

[jira] [Updated] (FLINK-5133) Add new setResource API for DataStream and DataSet

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5133: - Description: This is part of the fine-grained resource configuration. For *DataStream*, the

[jira] [Commented] (FLINK-5023) Add get() method in State interface

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688809#comment-15688809 ] ASF GitHub Bot commented on FLINK-5023: --- Github user shixiaogang commented on the issue:

[GitHub] flink issue #2768: [FLINK-5023][FLINK-5024] Add SimpleStateDescriptor to cla...

2016-11-22 Thread shixiaogang
Github user shixiaogang commented on the issue: https://github.com/apache/flink/pull/2768 @aljoscha Thanks for your review. I have updated the PR according to your suggestion. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Created] (FLINK-5133) Add new setResource API for DataStream and DataSet

2016-11-22 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5133: Summary: Add new setResource API for DataStream and DataSet Key: FLINK-5133 URL: https://issues.apache.org/jira/browse/FLINK-5133 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5131) Fine-grained Resource Configuration

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5131: - Description: Normally the UDF just creates short-life small objects and these can be recycled

[jira] [Updated] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5132: - Description: This is part of the fine-grained resource configuration. The current resource

[jira] [Updated] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5132: - Description: This is part of the fine-grained resource configuration. The current resource

[GitHub] flink pull request #2653: [FLINK-4469] [table] Add support for user defined ...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2653#discussion_r89252908 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -135,6 +138,32

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

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

[jira] [Created] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API

2016-11-22 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5132: Summary: Introduce the ResourceSpec for grouping different resource factors in API Key: FLINK-5132 URL: https://issues.apache.org/jira/browse/FLINK-5132 Project:

[jira] [Updated] (FLINK-5131) Fine-grained Resource Configuration

2016-11-22 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5131: - Description: Normally the UDF just creates short-life small objects and these can be recycled

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89249046 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-5061) Remove ContinuousEventTimeTrigger

2016-11-22 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688654#comment-15688654 ] Manu Zhang commented on FLINK-5061: --- Agreed. Just some of my thoughts and should not block the changes.

[jira] [Created] (FLINK-5131) Fine-grained Resource Configuration

2016-11-22 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5131: Summary: Fine-grained Resource Configuration Key: FLINK-5131 URL: https://issues.apache.org/jira/browse/FLINK-5131 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89247407 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89247416 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89247362 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -39,66 +45,69 @@ object

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89247312 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -39,66 +45,69 @@ object

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89244761 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89242998 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -61,25 +61,108 @@ object

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter

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

[GitHub] flink issue #2541: [FLINK-4669] scala api createLocalEnvironment() function ...

2016-11-22 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2541 @StephanEwen have any improvement needed? --- 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

[jira] [Commented] (FLINK-4910) Introduce safety net for closing file system streams

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

[jira] [Commented] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts

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

[jira] [Resolved] (FLINK-4910) Introduce safety net for closing file system streams

2016-11-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4910. -- Resolution: Fixed Fixed via ba8ed263695d16eacb4bdfdf195dd22c83bb53ed > Introduce safety net

[GitHub] flink pull request #2837: [FLINK-5107] Introduced limit for prior execution ...

2016-11-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2837 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2691: [FLINK-4910] Introduce safety net for closing file...

2016-11-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2691 --- 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] [Resolved] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts

2016-11-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5107. -- Resolution: Fixed Fixed via f5af7f1025aac9cac3f83de5f0e3aece5730ec0f > Job Manager goes out of

[GitHub] flink issue #2837: [FLINK-5107] Introduced limit for prior execution attempt...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2837 Thanks for the contribution @StefanRRichter. Failing tests are unrelated. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4910) Introduce safety net for closing file system streams

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

[jira] [Commented] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts

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

[GitHub] flink issue #2691: [FLINK-4910] Introduce safety net for closing file system...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2691 Thanks for the great contribution @StefanRRichter. Merging 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

[jira] [Closed] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager

2016-11-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5082. Resolution: Fixed Fixed in 1.2 via ae4b274a9919d01a236df4e819a0a07c5d8543ac Fixed in 1.1.4 via

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688077#comment-15688077 ] ASF GitHub Bot commented on FLINK-3257: --- Github user senorcarbone commented on the issue:

[GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I...

2016-11-22 Thread senorcarbone
Github user senorcarbone commented on the issue: https://github.com/apache/flink/pull/1668 Ok, so I am progressing this a bit independently from the termination stuff and then we rebase to the first PR that is merged. I just changed everything and rebased to the current master.

[GitHub] flink pull request #2820: [FLINK-5082] Pull ExecutorService lifecycle manage...

2016-11-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2820 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2815: [FLINK-5073] Use Executor to run ZooKeeper callbac...

2016-11-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2815 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously

2016-11-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5085. Resolution: Fixed Fixed in 1.2 via c590912c93a4059b40452dfa6cffbdd4d58cac13 Fixed in 1.1.4 via

[GitHub] flink pull request #2825: [FLINK-5085] Execute CheckpointCoordinator's state...

2016-11-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2825 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread

2016-11-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5073. Resolution: Fixed Fixed in 1.2 via 3fb92d8687f03c1fac8b87396b2b5a7ff29f6dd6 Fixed in 1.1.4 via

[jira] [Commented] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager

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

[jira] [Commented] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread

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

[jira] [Commented] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously

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

[GitHub] flink issue #2825: [FLINK-5085] Execute CheckpointCoordinator's state discar...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2825 Build passed locally https://travis-ci.org/tillrohrmann/flink/builds/178011045. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2016-11-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582930#comment-15582930 ] Ted Yu edited comment on FLINK-4848 at 11/22/16 9:32 PM: - There is similar issue

[jira] [Resolved] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers

2016-11-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-4999. --- Resolution: Won't Fix > Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers >

[jira] [Commented] (FLINK-5050) JSON.org license is CatX

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15687938#comment-15687938 ] ASF GitHub Bot commented on FLINK-5050: --- Github user tedyu commented on the issue:

[GitHub] flink issue #2824: [FLINK-5050] JSON.org license is CatX

2016-11-22 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/2824 lgtm --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods

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

[GitHub] flink issue #2842: [FLINK-5097][gelly] Add missing input type information to...

2016-11-22 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2842 @vasia should `Graph` be using the function specific `TypeExtractor.getMapReturnTypes` (not sure why this is plural) and similar where core Functions are used? For `Gelly` functions, I

[GitHub] flink pull request #2851: [FLINK-5124] [table] Support more temporal arithme...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2851#discussion_r89192379 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala --- @@ -656,38 +656,56 @@ object

[jira] [Commented] (FLINK-5124) Support more temporal arithmetic

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

[jira] [Commented] (FLINK-5124) Support more temporal arithmetic

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

[GitHub] flink pull request #2851: [FLINK-5124] [table] Support more temporal arithme...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2851#discussion_r89192110 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala --- @@ -656,38 +656,56 @@ object

[jira] [Commented] (FLINK-5124) Support more temporal arithmetic

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

[jira] [Commented] (FLINK-4895) Drop support for Hadoop 1

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15687642#comment-15687642 ] ASF GitHub Bot commented on FLINK-4895: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2850: [FLINK-4895] Drop Hadoop1 support

2016-11-22 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2850 I haven't tried it yet. --- 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

[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

2016-11-22 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2664 Thank you for fixing the issue so quickly. I'm wondering whether the current approach is a good idea, because it requires manual checking of all transitive dependencies. We have something

[jira] [Commented] (FLINK-4861) Package optional project artifacts

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15687629#comment-15687629 ] ASF GitHub Bot commented on FLINK-4861: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2852: Fix misprint in condition

2016-11-22 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2852 Thanks for the fix @BorisOsipov! +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

[jira] [Commented] (FLINK-4861) Package optional project artifacts

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

[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

2016-11-22 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2664 @rmetzger it appears that project artifacts are not included as transitive dependencies and I had overlooked 0.9 as a dependency for the 0.10 connector. After correcting this the provided

  1   2   3   4   >