[jira] [Commented] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776597#comment-16776597 ] Jark Wu commented on FLINK-11286: - Hi [~tzulitai], thanks for your feedback. I agree with you that the

[jira] [Created] (FLINK-11739) Markdown Syntax Errors in Flink-Web Chinese Documents

2019-02-24 Thread xulinjie (JIRA)
xulinjie created FLINK-11739: Summary: Markdown Syntax Errors in Flink-Web Chinese Documents Key: FLINK-11739 URL: https://issues.apache.org/jira/browse/FLINK-11739 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Se

2019-02-24 Thread Congxian Qiu(klion26) (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776596#comment-16776596 ] Congxian Qiu(klion26) commented on FLINK-11738: --- Hi, [~thinktothings] , I think 11690 has

[jira] [Comment Edited] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776540#comment-16776540 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11286 at 2/25/19 7:26 AM:

[jira] [Updated] (FLINK-11714) Add cost model for both batch and streaming

2019-02-24 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11714: --- Description: Calcite's default cost model only contains ROWS, IO and CPU, and does not take IO and

[jira] [Comment Edited] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776586#comment-16776586 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11286 at 2/25/19 7:35 AM:

[jira] [Commented] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776586#comment-16776586 ] Tzu-Li (Gordon) Tai commented on FLINK-11286: - Regarding limitation to source DOP if

[jira] [Commented] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776585#comment-16776585 ] Tzu-Li (Gordon) Tai commented on FLINK-11286: - [~yanghua] Ok. I think I was misguided by

[jira] [Comment Edited] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776585#comment-16776585 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11286 at 2/25/19 7:33 AM:

[jira] [Commented] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776563#comment-16776563 ] vinoyang commented on FLINK-11286: -- [~tzulitai]  When I looked at the history of this issue, I didn't

[GitHub] eaglewatcherwb removed a comment on issue #7537: [FLINK-11309][core] make SpillableSubpartition repeatably read to enable

2019-02-24 Thread GitBox
eaglewatcherwb removed a comment on issue #7537: [FLINK-11309][core] make SpillableSubpartition repeatably read to enable URL: https://github.com/apache/flink/pull/7537#issuecomment-458417919 Hi @aljoscha , would you mind to have a look at this PR? Or anyone else should I ask to review

[jira] [Commented] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776546#comment-16776546 ] Tzu-Li (Gordon) Tai commented on FLINK-11286: - Some thoughts regarding the discussion

[jira] [Comment Edited] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776540#comment-16776540 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11286 at 2/25/19 5:58 AM:

[jira] [Comment Edited] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776540#comment-16776540 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11286 at 2/25/19 5:57 AM:

[jira] [Commented] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776540#comment-16776540 ] Tzu-Li (Gordon) Tai commented on FLINK-11286: - Please allow me to re-elaborate what I do

[GitHub] flinkbot edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-24 Thread GitBox
flinkbot edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462574731 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-24 Thread GitBox
tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r259679680 ## File path:

[jira] [Updated] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

2019-02-24 Thread thinktothings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings updated FLINK-11738: -- Attachment: (was: image-2019-02-25-10-57-32-876.png) > Caused by:

[jira] [Updated] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

2019-02-24 Thread thinktothings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings updated FLINK-11738: -- Attachment: (was: image-2019-02-25-10-57-20-106.png) > Caused by:

[jira] [Updated] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

2019-02-24 Thread thinktothings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings updated FLINK-11738: -- Attachment: image-2019-02-25-13-11-13-723.png > Caused by: akka.pattern.AskTimeoutException:

[jira] [Updated] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

2019-02-24 Thread thinktothings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings updated FLINK-11738: -- Description: Akka.ask.timeout 10 seconds, this miniCluster environment is written dead, can

[jira] [Updated] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

2019-02-24 Thread thinktothings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings updated FLINK-11738: -- Attachment: (was: image-2019-02-25-10-57-39-753.png) > Caused by:

[jira] [Updated] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

2019-02-24 Thread thinktothings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings updated FLINK-11738: -- Description: Akka.ask.timeout 10 seconds, this miniCluster environment is written dead, can

[jira] [Commented] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

2019-02-24 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776504#comment-16776504 ] shengjk1 commented on FLINK-11725: -- 1.7.2已修复 > use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the

[GitHub] flinkbot edited a comment on issue #7798: [FLINK-11388] Add Aliyun OSS recoverable writer

2019-02-24 Thread GitBox
flinkbot edited a comment on issue #7798: [FLINK-11388] Add Aliyun OSS recoverable writer URL: https://github.com/apache/flink/pull/7798#issuecomment-466283546 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] wujinhu commented on issue #7798: [FLINK-11388] Add Aliyun OSS recoverable writer

2019-02-24 Thread GitBox
wujinhu commented on issue #7798: [FLINK-11388] Add Aliyun OSS recoverable writer URL: https://github.com/apache/flink/pull/7798#issuecomment-466859984 @StefanRRichter Please help to review this PR, thanks! This is an

[jira] [Closed] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

2019-02-24 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 closed FLINK-11725. Resolution: Fixed Fix Version/s: 1.7.2 > use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the

[GitHub] flinkbot commented on issue #7816: [FLINK-11701][table] Introduce an abstract set of data formats

2019-02-24 Thread GitBox
flinkbot commented on issue #7816: [FLINK-11701][table] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#issuecomment-466858802 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] JingsongLi commented on issue #7816: [FLINK-11701][table] Introduce an abstract set of data formats

2019-02-24 Thread GitBox
JingsongLi commented on issue #7816: [FLINK-11701][table] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#issuecomment-466858885 After https://github.com/apache/flink/pull/7790 merge

[jira] [Updated] (FLINK-11701) Introduce an abstract set of data formats

2019-02-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11701: --- Labels: pull-request-available (was: ) > Introduce an abstract set of data formats >

[GitHub] JingsongLi opened a new pull request #7816: [FLINK-11701][table] Introduce an abstract set of data formats

2019-02-24 Thread GitBox
JingsongLi opened a new pull request #7816: [FLINK-11701][table] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816 ## What is the purpose of the change Blink uses an abstract set of data formats to make internal calculations use the binary

[jira] [Updated] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

2019-02-24 Thread thinktothings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings updated FLINK-11738: -- Description: Akka.ask.timeout 10 seconds, this miniCluster environment is written dead, can

[jira] [Updated] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

2019-02-24 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11725: - Environment: flink1.7.2 linux java8 kafka1.1 scala 2.1 CDH  was: flink1.7.1 linux java8

[jira] [Created] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Send

2019-02-24 Thread thinktothings (JIRA)
thinktothings created FLINK-11738: - Summary: Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [1 ms]. Sender[null] sent

[jira] [Updated] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

2019-02-24 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11725: - Description: I provide a simple example and used resource's picture for this issue  this application

[jira] [Comment Edited] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

2019-02-24 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774999#comment-16774999 ] shengjk1 edited comment on FLINK-11725 at 2/25/19 2:54 AM: --- i think two ways 

[jira] [Updated] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

2019-02-24 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11725: - Attachment: MainConnect4.java > use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources

[jira] [Commented] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

2019-02-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776485#comment-16776485 ] vinoyang commented on FLINK-11286: -- [~jark] Thank you for your thoughts on this issue, it is valuable.

[jira] [Commented] (FLINK-10882) Misleading job/task state for scheduled jobs

2019-02-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776471#comment-16776471 ] vinoyang commented on FLINK-10882: -- Hi [~Zentol]  I think this is not just an issue of web frontend. It

[jira] [Closed] (FLINK-10043) Refactor object construction/inititlization/restore code

2019-02-24 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-10043. - Resolution: Implemented > Refactor object construction/inititlization/restore code >

[jira] [Reopened] (FLINK-10043) Refactor object construction/inititlization/restore code

2019-02-24 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reopened FLINK-10043: --- Assignee: Yu Li (was: Stefan Richter) Reopening to add fix versions. > Refactor object

[jira] [Updated] (FLINK-10043) Refactor object construction/inititlization/restore code

2019-02-24 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-10043: -- Fix Version/s: 1.8.0 Component/s: State Backends, Checkpointing > Refactor object

[GitHub] TisonKun commented on a change in pull request #7815: [FLINK-11710][tests] Remove Instance usages in valid Test

2019-02-24 Thread GitBox
TisonKun commented on a change in pull request #7815: [FLINK-11710][tests] Remove Instance usages in valid Test URL: https://github.com/apache/flink/pull/7815#discussion_r259609950 ## File path:

[GitHub] TisonKun commented on a change in pull request #7815: [FLINK-11710][tests] Remove Instance usages in valid Test

2019-02-24 Thread GitBox
TisonKun commented on a change in pull request #7815: [FLINK-11710][tests] Remove Instance usages in valid Test URL: https://github.com/apache/flink/pull/7815#discussion_r259609923 ## File path:

[GitHub] flinkbot commented on issue #7815: [FLINK-11710][tests] Remove Instance usages in valid Test

2019-02-24 Thread GitBox
flinkbot commented on issue #7815: [FLINK-11710][tests] Remove Instance usages in valid Test URL: https://github.com/apache/flink/pull/7815#issuecomment-466751520 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] TisonKun commented on a change in pull request #7815: [FLINK-11710][tests] Remove Instance usages in valid Test

2019-02-24 Thread GitBox
TisonKun commented on a change in pull request #7815: [FLINK-11710][tests] Remove Instance usages in valid Test URL: https://github.com/apache/flink/pull/7815#discussion_r259609923 ## File path:

[GitHub] TisonKun opened a new pull request #7815: [FLINK-11710][tests] Remove Instance usages in valid Test

2019-02-24 Thread GitBox
TisonKun opened a new pull request #7815: [FLINK-11710][tests] Remove Instance usages in valid Test URL: https://github.com/apache/flink/pull/7815 ## What is the purpose of the change **DOT MERGE** Based on #7809 . The last batch of FLINK-10569. 1. Replace SimpleSlot

[jira] [Created] (FLINK-11737) Support MultipleOutputs output

2019-02-24 Thread vinoyang (JIRA)
vinoyang created FLINK-11737: Summary: Support MultipleOutputs output Key: FLINK-11737 URL: https://issues.apache.org/jira/browse/FLINK-11737 Project: Flink Issue Type: Improvement