[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315779418 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315737043 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315729123 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315779589 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315779264 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315778858 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315779371 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315779453 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315777453 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315779867 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315729910 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315779769 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,923

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911537#comment-16911537 ] zhijiang commented on FLINK-13798: -- Thanks for this notification [~StephanEwen]. Wish i

[GitHub] [flink] flinkbot commented on issue #9495: [FLINK-13798][task] Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread GitBox
flinkbot commented on issue #9495: [FLINK-13798][task] Refactor the process of checking stream status while emitting watermark in source URL: https://github.com/apache/flink/pull/9495#issuecomment-523096604 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13798: --- Labels: pull-request-available (was: ) > Refactor the process of checking stream status whi

[GitHub] [flink] zhijiangW opened a new pull request #9495: [FLINK-13798][task] Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread GitBox
zhijiangW opened a new pull request #9495: [FLINK-13798][task] Refactor the process of checking stream status while emitting watermark in source URL: https://github.com/apache/flink/pull/9495 ## What is the purpose of the change As we know, the watermark could be emitted to downstre

[GitHub] [flink] flinkbot edited a comment on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code URL: https://github.com/apache/flink/pull/9494#issuecomment-523030190 ## CI report: * 394dfe73e75cf9db8dcbbb96ead65ba5130e3e0c : CANCELED [Bu

[GitHub] [flink] xintongsong commented on issue #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese

2019-08-20 Thread GitBox
xintongsong commented on issue #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese URL: https://github.com/apache/flink/pull/9454#issuecomment-523080139 @1996fanrui I don't see the PR is updated. To update the PR, you need to push commits of new changes to you

[jira] [Updated] (FLINK-13804) Collections initial capacity

2019-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13804: --- Labels: pull-request-available (was: ) > Collections initial capacity > ---

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Description: As we know, the watermark could be emitted to downstream only when the stream status is ac

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-ci.c

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Description: As we know, the watermark could be emitted to downstream only when the stream status is ac

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Description: As we know, the watermark could be emitted to downstream only when the stream status is ac

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Description: As we know, the watermark could be emitted to downstream only when the stream status is ac

[jira] [Issue Comment Deleted] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Comment: was deleted (was: Thanks for the replies. [~StephanEwen] Wish it would make logic easy underst

[jira] [Created] (FLINK-13804) Collections initial capacity

2019-08-20 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-13804: --- Summary: Collections initial capacity Key: FLINK-13804 URL: https://issues.apache.org/jira/browse/FLINK-13804 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911455#comment-16911455 ] zhijiang commented on FLINK-13798: -- Thanks for the replies. [~StephanEwen] Wish it wou

[jira] [Created] (FLINK-13803) Introduce SpillableHeapKeyedStateBackend and all necessities

2019-08-20 Thread Yu Li (Jira)
Yu Li created FLINK-13803: - Summary: Introduce SpillableHeapKeyedStateBackend and all necessities Key: FLINK-13803 URL: https://issues.apache.org/jira/browse/FLINK-13803 Project: Flink Issue Type: S

[jira] [Created] (FLINK-13802) Flink code style guide

2019-08-20 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-13802: --- Summary: Flink code style guide Key: FLINK-13802 URL: https://issues.apache.org/jira/browse/FLINK-13802 Project: Flink Issue Type: Task Compo

[jira] [Updated] (FLINK-13777) Introduce sql function wrappers and conversion to ExpressionConverter

2019-08-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13777: - Description: For remove the extended calcite sql functions, we introduce wrappers to wrap flink

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Description: As we know, the watermark could be emitted to downstream only when the stream status is ac

[jira] [Updated] (FLINK-13776) Introduce new interfaces to BuiltInFunctionDefinition

2019-08-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13776: - Description: Introduce new interfaces to BuiltInFunctionDefinition from  [https://cwiki.apache.o

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Description: As we know, the watermark could be emitted to downstream only when the stream status is ac

[jira] [Updated] (FLINK-13775) Refactor ExpressionConverter(RexNodeConverter) in blink

2019-08-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13775: - Description: For subsequent development, refactor ExpressionConverter in the form of Rules. Now

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Description: As we know, the watermark could be emitted to downstream only when the stream status is ac

[jira] [Created] (FLINK-13801) Introduce a HybridStateTable to combine everything together

2019-08-20 Thread Yu Li (Jira)
Yu Li created FLINK-13801: - Summary: Introduce a HybridStateTable to combine everything together Key: FLINK-13801 URL: https://issues.apache.org/jira/browse/FLINK-13801 Project: Flink Issue Type: Su

[GitHub] [flink] flinkbot edited a comment on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code URL: https://github.com/apache/flink/pull/9494#issuecomment-523030190 ## CI report: * 394dfe73e75cf9db8dcbbb96ead65ba5130e3e0c : CANCELED [Bu

[GitHub] [flink] flinkbot edited a comment on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-521825874 ## CI report: * 1242679f7bd5ec3f7c1115006e978267abafc84b : CANCELED [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9493: FLINK-13797: Add missing format argument

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9493: FLINK-13797: Add missing format argument URL: https://github.com/apache/flink/pull/9493#issuecomment-522980507 ## CI report: * 11aa6551bd50d0d57edf694dbf76b138e4b5de4a : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/123877226)

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911428#comment-16911428 ] Stephan Ewen commented on FLINK-13798: -- FYI: I believe one outcome of FLIP-27 will

[jira] [Created] (FLINK-13800) Create a module for spill-able heap backend

2019-08-20 Thread Yu Li (Jira)
Yu Li created FLINK-13800: - Summary: Create a module for spill-able heap backend Key: FLINK-13800 URL: https://issues.apache.org/jira/browse/FLINK-13800 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13799) Web Job Submit Page displays stream of error message when web submit is disables in the config

2019-08-20 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-13799: Summary: Web Job Submit Page displays stream of error message when web submit is disables in the config Key: FLINK-13799 URL: https://issues.apache.org/jira/browse/FLINK-13799

[jira] [Updated] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13798: - Description: As we know, the watermark could be emitted to downstream only when the stream status is ac

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-08-20 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911414#comment-16911414 ] TisonKun commented on FLINK-10333: -- [~StephanEwen] transactional store on ZooKeeper imp

[GitHub] [flink] NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-20 Thread GitBox
NicoK commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315724419 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,897

[jira] [Commented] (FLINK-13662) FlinkKinesisProducerTest.testBackpressure failed on Travis

2019-08-20 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911397#comment-16911397 ] Till Rohrmann commented on FLINK-13662: --- So far we observed the test case to fail

[GitHub] [flink] flinkbot edited a comment on issue #9492: FLINK-13796: Remove unused variable

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9492: FLINK-13796: Remove unused variable URL: https://github.com/apache/flink/pull/9492#issuecomment-522977645 ## CI report: * 6c0180311411f307b1128c3ef7869605c09ac622 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/123875933) -

[jira] [Commented] (FLINK-13750) Separate HA services between client-/ and server-side

2019-08-20 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911396#comment-16911396 ] Till Rohrmann commented on FLINK-13750: --- Yes, you are right. The {{MiniCluster}} o

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-08-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911394#comment-16911394 ] Stephan Ewen commented on FLINK-10333: -- Quick question: Do we have an idea if the t

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-ci.c

[GitHub] [flink] flinkbot commented on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code

2019-08-20 Thread GitBox
flinkbot commented on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code URL: https://github.com/apache/flink/pull/9494#issuecomment-523030190 ## CI report: * 394dfe73e75cf9db8dcbbb96ead65ba5130e3e0c : PENDING [Build](htt

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-08-20 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911377#comment-16911377 ] TisonKun commented on FLINK-10333: -- Thanks for your review [~till.rohrmann]. In the imp

[jira] [Comment Edited] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-08-20 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911377#comment-16911377 ] TisonKun edited comment on FLINK-10333 at 8/20/19 1:56 PM: --- Th

[GitHub] [flink] flinkbot commented on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code

2019-08-20 Thread GitBox
flinkbot commented on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code URL: https://github.com/apache/flink/pull/9494#issuecomment-523025067 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-12847) Update Kinesis Connectors to latest Apache licensed libraries

2019-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12847: --- Labels: pull-request-available (was: ) > Update Kinesis Connectors to latest Apache license

[GitHub] [flink] dyanarose opened a new pull request #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code

2019-08-20 Thread GitBox
dyanarose opened a new pull request #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code URL: https://github.com/apache/flink/pull/9494 ## What is the purpose of the change The Kinesis Connector will now be able to be built and in

[GitHub] [flink] flinkbot edited a comment on issue #9491: [FLINK-12749] Add Flink Operations Playground

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9491: [FLINK-12749] Add Flink Operations Playground URL: https://github.com/apache/flink/pull/9491#issuecomment-522965231 ## CI report: * e8d9855138cff89f1c728ad334d13b0beae5b159 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/123870

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-08-20 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911350#comment-16911350 ] Till Rohrmann commented on FLINK-10333: --- Thanks for the updated design document Ti

[GitHub] [flink] flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-518524777 ## CI report: * f99e66ffb4356f8132b48d352b27686a6ad958f5 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-521825874 ## CI report: * 1242679f7bd5ec3f7c1115006e978267abafc84b : CANCELED [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9490: [hotfix][python] add System.exit() at the end of PythonGatewayServer to ensure the JVM will exit if its parent process dies.

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9490: [hotfix][python] add System.exit() at the end of PythonGatewayServer to ensure the JVM will exit if its parent process dies. URL: https://github.com/apache/flink/pull/9490#issuecomment-522958012 ## CI report: * 058163e892c68cb753ebe21b4ab458

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-08-20 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911294#comment-16911294 ] Till Rohrmann commented on FLINK-10333: --- Thanks for pinging me [~Tison]. I try to

[jira] [Commented] (FLINK-13750) Separate HA services between client-/ and server-side

2019-08-20 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911290#comment-16911290 ] TisonKun commented on FLINK-13750: -- The original issue FLINK-13500 caused by this issue

[jira] [Commented] (FLINK-13662) FlinkKinesisProducerTest.testBackpressure failed on Travis

2019-08-20 Thread Franz Thoma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911288#comment-16911288 ] Franz Thoma commented on FLINK-13662: - I did a quick check, there don't seem to be a

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911275#comment-16911275 ] zhijiang commented on FLINK-13798: -- Thanks for the offline discussion and suggestion.  

[jira] [Created] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

2019-08-20 Thread zhijiang (Jira)
zhijiang created FLINK-13798: Summary: Refactor the process of checking stream status while emitting watermark in source Key: FLINK-13798 URL: https://issues.apache.org/jira/browse/FLINK-13798 Project: Fl

[GitHub] [flink] flinkbot edited a comment on issue #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes URL: https://github.com/apache/flink/pull/9470#issuecomment-522260447 ## CI report: * 3db70d3f656ed9739d1a8f0b913e33732df36150 : SUCCESS [Build](https://travis-c

[GitHub] [flink] JingsongLi commented on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-20 Thread GitBox
JingsongLi commented on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522988978 ping @dawidwys @wuchong to review~ This

[GitHub] [flink] flinkbot edited a comment on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-521825874 ## CI report: * 1242679f7bd5ec3f7c1115006e978267abafc84b : CANCELED [Build](https://travis-c

[jira] [Resolved] (FLINK-13380) Improve the usability of Flink session cluster on Kubernetes

2019-08-20 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13380. --- Fix Version/s: 1.9.1 Resolution: Done Done via 1.10.0: 1bb6b053184a3551ec25223fe9e9e

[GitHub] [flink] tillrohrmann closed pull request #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes

2019-08-20 Thread GitBox
tillrohrmann closed pull request #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes URL: https://github.com/apache/flink/pull/9470 This is an automated message from the Apache Git Service.

[GitHub] [flink] hequn8128 commented on a change in pull request #9490: [hotfix][python] add System.exit() at the end of PythonGatewayServer to ensure the JVM will exit if its parent process dies.

2019-08-20 Thread GitBox
hequn8128 commented on a change in pull request #9490: [hotfix][python] add System.exit() at the end of PythonGatewayServer to ensure the JVM will exit if its parent process dies. URL: https://github.com/apache/flink/pull/9490#discussion_r315650706 ## File path: flink-python/src/m

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE [Buil

[GitHub] [flink] 1996fanrui commented on a change in pull request #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese

2019-08-20 Thread GitBox
1996fanrui commented on a change in pull request #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese URL: https://github.com/apache/flink/pull/9454#discussion_r315648546 ## File path: docs/ops/state/state_backends.zh.md ## @@ -22,114 +22,111 @@ speci

[jira] [Comment Edited] (FLINK-13750) Separate HA services between client-/ and server-side

2019-08-20 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911247#comment-16911247 ] Till Rohrmann edited comment on FLINK-13750 at 8/20/19 11:56 AM: -

[GitHub] [flink] flinkbot commented on issue #9493: FLINK-13797: Add missing format argument

2019-08-20 Thread GitBox
flinkbot commented on issue #9493: FLINK-13797: Add missing format argument URL: https://github.com/apache/flink/pull/9493#issuecomment-522980507 ## CI report: * 11aa6551bd50d0d57edf694dbf76b138e4b5de4a : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/123877226) ---

[jira] [Commented] (FLINK-13750) Separate HA services between client-/ and server-side

2019-08-20 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911247#comment-16911247 ] Till Rohrmann commented on FLINK-13750: --- This sounds good to me. Maybe another th

[GitHub] [flink] flinkbot commented on issue #9492: FLINK-13796: Remove unused variable

2019-08-20 Thread GitBox
flinkbot commented on issue #9492: FLINK-13796: Remove unused variable URL: https://github.com/apache/flink/pull/9492#issuecomment-522977645 ## CI report: * 6c0180311411f307b1128c3ef7869605c09ac622 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/123875933)

[GitHub] [flink] flinkbot commented on issue #9493: FLINK-13797: Add missing format argument

2019-08-20 Thread GitBox
flinkbot commented on issue #9493: FLINK-13797: Add missing format argument URL: https://github.com/apache/flink/pull/9493#issuecomment-522976190 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will u

[jira] [Updated] (FLINK-13797) Add missing format argument

2019-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13797: --- Labels: pull-request-available (was: ) > Add missing format argument >

[GitHub] [flink] tillrohrmann commented on a change in pull request #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes

2019-08-20 Thread GitBox
tillrohrmann commented on a change in pull request #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes URL: https://github.com/apache/flink/pull/9470#discussion_r315642229 ## File path: docs/ops/deployment/kubernetes.md ## @@ -166,18 +249

[GitHub] [flink] Fokko opened a new pull request #9493: FLINK-13797: Add missing format argument

2019-08-20 Thread GitBox
Fokko opened a new pull request #9493: FLINK-13797: Add missing format argument URL: https://github.com/apache/flink/pull/9493 ## What is the purpose of the change Add missing format argument. We expect an argument, but it is missing. https://jira.apache.org/jira/browse/FLINK-1

[GitHub] [flink] flinkbot commented on issue #9492: FLINK-13796: Remove unused variable

2019-08-20 Thread GitBox
flinkbot commented on issue #9492: FLINK-13796: Remove unused variable URL: https://github.com/apache/flink/pull/9492#issuecomment-522974901 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use th

[jira] [Created] (FLINK-13797) Add missing format argument

2019-08-20 Thread Fokko Driesprong (Jira)
Fokko Driesprong created FLINK-13797: Summary: Add missing format argument Key: FLINK-13797 URL: https://issues.apache.org/jira/browse/FLINK-13797 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-13796) Remove unused variable

2019-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13796: --- Labels: pull-request-available (was: ) > Remove unused variable > -- >

[GitHub] [flink] Fokko opened a new pull request #9492: FLINK-13796: Remove unused variable

2019-08-20 Thread GitBox
Fokko opened a new pull request #9492: FLINK-13796: Remove unused variable URL: https://github.com/apache/flink/pull/9492 ## What is the purpose of the change Remove the variable since it isn't used: https://jira.apache.org/jira/browse/FLINK-13796 ## Brief changelog *(f

[jira] [Created] (FLINK-13796) Remove unused variable

2019-08-20 Thread Fokko Driesprong (Jira)
Fokko Driesprong created FLINK-13796: Summary: Remove unused variable Key: FLINK-13796 URL: https://issues.apache.org/jira/browse/FLINK-13796 Project: Flink Issue Type: Task Com

[GitHub] [flink] flinkbot edited a comment on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API URL: https://github.com/apache/flink/pull/9422#issuecomment-520477677 ## CI report: * 355a7706b108371f31efe68f181c3dbeceed06d5 : FAILURE [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-ci.c

[jira] [Created] (FLINK-13795) Web UI logs errors when selecting Checkpoint Tab for Batch Jobs

2019-08-20 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-13795: Summary: Web UI logs errors when selecting Checkpoint Tab for Batch Jobs Key: FLINK-13795 URL: https://issues.apache.org/jira/browse/FLINK-13795 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9491: [FLINK-12749] Add Flink Operations Playground

2019-08-20 Thread GitBox
flinkbot commented on issue #9491: [FLINK-12749] Add Flink Operations Playground URL: https://github.com/apache/flink/pull/9491#issuecomment-522965231 ## CI report: * e8d9855138cff89f1c728ad334d13b0beae5b159 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/123870739)

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes URL: https://github.com/apache/flink/pull/9470#issuecomment-522260447 ## CI report: * 3db70d3f656ed9739d1a8f0b913e33732df36150 : SUCCESS [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-518524777 ## CI report: * f99e66ffb4356f8132b48d352b27686a6ad958f5 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot commented on issue #9491: [FLINK-12749] Add Flink Operations Playground

2019-08-20 Thread GitBox
flinkbot commented on issue #9491: [FLINK-12749] Add Flink Operations Playground URL: https://github.com/apache/flink/pull/9491#issuecomment-522961861 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We w

[GitHub] [flink] fhueske opened a new pull request #9491: [FLINK-12749] Add Flink Operations Playground

2019-08-20 Thread GitBox
fhueske opened a new pull request #9491: [FLINK-12749] Add Flink Operations Playground URL: https://github.com/apache/flink/pull/9491 ## What is the purpose of the change This PR adds the Flink Operations Playground to the Flink 1.8 documentation. The playground setup has been pus

[GitHub] [flink] hehuiyuan commented on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE`

2019-08-20 Thread GitBox
hehuiyuan commented on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE` URL: https://github.com/apache/flink/pull/9469#issuecomment-522960088 Hi ? This is an automated message

[GitHub] [flink] Myasuka commented on a change in pull request #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes

2019-08-20 Thread GitBox
Myasuka commented on a change in pull request #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes URL: https://github.com/apache/flink/pull/9470#discussion_r315623485 ## File path: docs/ops/deployment/kubernetes.md ## @@ -166,18 +249,34 @

[GitHub] [flink] flinkbot edited a comment on issue #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

2019-08-20 Thread GitBox
flinkbot edited a comment on issue #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#issuecomment-521294079 ## CI report: * 4d379770e97ef5333d7816713b79c9b5e9ee936e : FAILURE [Build](https://travis-ci.com/flink-ci/flin

<    1   2   3   >