[GitHub] [flink] YngwieWang commented on a change in pull request #9047: [FLINK-13109][docs-zh]Translate "Restart Strategies" page into Chinese

2019-07-11 Thread GitBox
YngwieWang commented on a change in pull request #9047: [FLINK-13109][docs-zh]Translate "Restart Strategies" page into Chinese URL: https://github.com/apache/flink/pull/9047#discussion_r302537698 ## File path: docs/dev/restart_strategies.zh.md ## @@ -114,63 +108,63 @@

[GitHub] [flink] JingsongLi opened a new pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-07-11 Thread GitBox
JingsongLi opened a new pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089 ## What is the purpose of the change See detail in: https://github.com/apache/flink/pull/8920

[jira] [Comment Edited] (FLINK-12858) Potentially not properly working Flink job in case of stop-with-savepoint failure

2019-07-11 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882944#comment-16882944 ] Kostas Kloudas edited comment on FLINK-12858 at 7/11/19 1:21 PM: - I

[GitHub] [flink] flinkbot commented on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-07-11 Thread GitBox
flinkbot commented on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#issuecomment-510482668 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302540371 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302540193 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302537660 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302526844 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302536460 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302508924 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302526748 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302539057 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302540026 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302514775 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302519545 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302512165 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302518755 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302519724 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302513028 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302521528 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302519618 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302526588 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302521309 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302543242 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302521633 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-11 Thread GitBox
knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r302525850 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,423 @@ +---

[jira] [Updated] (FLINK-13044) Shading of AWS SDK in flink-s3-fs-hadoop results in ClassNotFoundExceptions

2019-07-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13044: - Fix Version/s: 1.9.0 > Shading of AWS SDK in flink-s3-fs-hadoop results in

[jira] [Updated] (FLINK-13044) Shading of AWS SDK in flink-s3-fs-hadoop results in ClassNotFoundExceptions

2019-07-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13044: - Priority: Blocker (was: Critical) > Shading of AWS SDK in flink-s3-fs-hadoop results in

[jira] [Commented] (FLINK-13044) Shading of AWS SDK in flink-s3-fs-hadoop results in ClassNotFoundExceptions

2019-07-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882974#comment-16882974 ] Stephan Ewen commented on FLINK-13044: -- This is clearly a bug and should be fixed in 1.9.0 >

[jira] [Created] (FLINK-13229) ExpressionReducer with udf bug in blink

2019-07-11 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-13229: Summary: ExpressionReducer with udf bug in blink Key: FLINK-13229 URL: https://issues.apache.org/jira/browse/FLINK-13229 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on issue #9091: [FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink

2019-07-11 Thread GitBox
flinkbot commented on issue #9091: [FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink URL: https://github.com/apache/flink/pull/9091#issuecomment-510495097 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Closed] (FLINK-13112) Support LocalZonedTimestampType in blink

2019-07-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13112. -- Resolution: Implemented Assignee: Jingsong Lee Fix Version/s: 1.9.0 merged in 1.9.0: 

[GitHub] [flink] flinkbot edited a comment on issue #9009: [FLINK-13133] [docs] Fix small error in PubSub documentation

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9009: [FLINK-13133] [docs] Fix small error in PubSub documentation URL: https://github.com/apache/flink/pull/9009#issuecomment-510405780 ## CI report: * b8beb837a68a1aec276872c79d300eadd4d0fb4a : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9074: [FLINK-13198] Introduce TimeUtils with parsing method

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9074: [FLINK-13198] Introduce TimeUtils with parsing method URL: https://github.com/apache/flink/pull/9074#issuecomment-510405793 ## CI report: * df6685a3394eeea7a6013f2a9f6c1b6bfeac87e5 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9092: [FLINK-13211] Add drop table support for flink planner

2019-07-11 Thread GitBox
flinkbot commented on issue #9092: [FLINK-13211] Add drop table support for flink planner URL: https://github.com/apache/flink/pull/9092#issuecomment-510498703 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Created] (FLINK-13224) TupleTypeInfoBase equals function can't distinguish different struct type

2019-07-11 Thread forideal (JIRA)
forideal created FLINK-13224: Summary: TupleTypeInfoBase equals function can't distinguish different struct type Key: FLINK-13224 URL: https://issues.apache.org/jira/browse/FLINK-13224 Project: Flink

[GitHub] [flink] JingsongLi commented on a change in pull request #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink

2019-07-11 Thread GitBox
JingsongLi commented on a change in pull request #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink URL: https://github.com/apache/flink/pull/9036#discussion_r302528898 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

2019-07-11 Thread GitBox
pnowojski commented on a change in pull request #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer URL: https://github.com/apache/flink/pull/9062#discussion_r302527969 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

2019-07-11 Thread GitBox
pnowojski commented on a change in pull request #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer URL: https://github.com/apache/flink/pull/9062#discussion_r302531510 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

2019-07-11 Thread GitBox
pnowojski commented on a change in pull request #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer URL: https://github.com/apache/flink/pull/9062#discussion_r302526862 ## File path:

[jira] [Updated] (FLINK-13012) Handle default partition name of Hive table

2019-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13012: --- Labels: pull-request-available (was: ) > Handle default partition name of Hive table >

[GitHub] [flink] lirui-apache opened a new pull request #9088: [FLINK-13012][hive] Handle default partition name of Hive table

2019-07-11 Thread GitBox
lirui-apache opened a new pull request #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088 ## What is the purpose of the change To handle default partition name when reading/writing Hive tables. ##

[jira] [Created] (FLINK-13225) Introduce type inference for hive functions in blink

2019-07-11 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-13225: Summary: Introduce type inference for hive functions in blink Key: FLINK-13225 URL: https://issues.apache.org/jira/browse/FLINK-13225 Project: Flink Issue

[jira] [Updated] (FLINK-13225) Introduce type inference for hive functions in blink

2019-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13225: --- Labels: pull-request-available (was: ) > Introduce type inference for hive functions in

[jira] [Comment Edited] (FLINK-12998) Document Plugins mechanism

2019-07-11 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882946#comment-16882946 ] Piotr Nowojski edited comment on FLINK-12998 at 7/11/19 1:23 PM: - It

[jira] [Commented] (FLINK-13044) Shading of AWS SDK in flink-s3-fs-hadoop results in ClassNotFoundExceptions

2019-07-11 Thread Sebastian J. (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882955#comment-16882955 ] Sebastian J. commented on FLINK-13044: -- Glad to hear the plan for 1.10 [~StephanEwen]! May I ask

[jira] [Created] (FLINK-13226) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails on Travis

2019-07-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-13226: - Summary: KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails on Travis Key: FLINK-13226 URL: https://issues.apache.org/jira/browse/FLINK-13226 Project:

[GitHub] [flink] KurtYoung commented on issue #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink

2019-07-11 Thread GitBox
KurtYoung commented on issue #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink URL: https://github.com/apache/flink/pull/9036#issuecomment-510493598 travis passed: https://travis-ci.org/JingsongLi/flink/builds/557282177

[GitHub] [flink] flinkbot commented on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

2019-07-11 Thread GitBox
flinkbot commented on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090#issuecomment-510493315 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] KurtYoung commented on issue #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink

2019-07-11 Thread GitBox
KurtYoung commented on issue #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink URL: https://github.com/apache/flink/pull/9036#issuecomment-510493641 Merging this.. This is an automated

[jira] [Commented] (FLINK-13224) TupleTypeInfoBase equals function can't distinguish different struct type

2019-07-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882980#comment-16882980 ] Timo Walther commented on FLINK-13224: -- This is not a problem of the TupleTypeInfo but of the

[GitHub] [flink] JingsongLi opened a new pull request #9091: [FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink

2019-07-11 Thread GitBox
JingsongLi opened a new pull request #9091: [FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink URL: https://github.com/apache/flink/pull/9091 ## What is the purpose of the change When a udf is reduced by ExpressionReducer, there will be a code gen

[jira] [Updated] (FLINK-13211) Add drop table support for flink planner

2019-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13211: --- Labels: pull-request-available (was: ) > Add drop table support for flink planner >

[GitHub] [flink] flinkbot commented on issue #9092: [FLINK-13211] Add drop table support for flink planner

2019-07-11 Thread GitBox
flinkbot commented on issue #9092: [FLINK-13211] Add drop table support for flink planner URL: https://github.com/apache/flink/pull/9092#issuecomment-510504895 ## CI report: * 98a91c6075fa8ef6bf5cfe0da16249b411b2590d : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9043: [FLINK-13165] Complete slot requests in request order

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9043: [FLINK-13165] Complete slot requests in request order URL: https://github.com/apache/flink/pull/9043#issuecomment-510405816 ## CI report: * a75fa20222c0e9d4bdfbb6eafdfd1831e0ff48e8 : SUCCESS

[GitHub] [flink] zhijiangW commented on issue #9059: [FLINK-13141][network] Remove getBufferSize method from BufferPoolFactory

2019-07-11 Thread GitBox
zhijiangW commented on issue #9059: [FLINK-13141][network] Remove getBufferSize method from BufferPoolFactory URL: https://github.com/apache/flink/pull/9059#issuecomment-510508274 Actually that checkstyle issue was not brought by this PR. I ever checked the travis result for this

[GitHub] [flink] bowenli86 commented on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

2019-07-11 Thread GitBox
bowenli86 commented on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#issuecomment-510350722 Hi @JingsongLi , thanks for the explanation! I think solution II works better for now compared to solution I.

[GitHub] [flink] chancelq commented on issue #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

2019-07-11 Thread GitBox
chancelq commented on issue #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#issuecomment-510350794 LGTM This is an automated message from the Apache Git

[GitHub] [flink] wuchong commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

2019-07-11 Thread GitBox
wuchong commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#discussion_r302388287 ## File path:

[jira] [Assigned] (FLINK-12858) Potentially not properly working Flink job in case of stop-with-savepoint failure

2019-07-11 Thread yelun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yelun reassigned FLINK-12858: - Assignee: (was: yelun) > Potentially not properly working Flink job in case of stop-with-savepoint

[GitHub] [flink] wuchong commented on issue #9074: [FLINK-13198] Introduce TimeLength in configuration package

2019-07-11 Thread GitBox
wuchong commented on issue #9074: [FLINK-13198] Introduce TimeLength in configuration package URL: https://github.com/apache/flink/pull/9074#issuecomment-510358202 Thanks @TsReaper . LGTM. This is an automated

[GitHub] [flink] twalthr commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-07-11 Thread GitBox
twalthr commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r302395152 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-07-11 Thread GitBox
twalthr commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r302393576 ## File path:

[GitHub] [flink] flinkbot commented on issue #9049: [FLINK-13176][SQL CLI] remember current catalog and database in SQL CLI SessionContext

2019-07-11 Thread GitBox
flinkbot commented on issue #9049: [FLINK-13176][SQL CLI] remember current catalog and database in SQL CLI SessionContext URL: https://github.com/apache/flink/pull/9049#issuecomment-510365136 CI report for commit aa354f24b53407035750303e78e1fb9d95b37673: SUCCESS

[jira] [Closed] (FLINK-12852) [hotfix timeout] Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

2019-07-11 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-12852. -- Resolution: Fixed Release Note: To avoid a potential deadlock, this adds a timeout

[GitHub] [flink] JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

2019-07-11 Thread GitBox
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r302397256 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

2019-07-11 Thread GitBox
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r302391899 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

2019-07-11 Thread GitBox
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r302391575 ## File path:

[GitHub] [flink] pnowojski merged pull request #9059: [FLINK-13141][network] Remove getBufferSize method from BufferPoolFactory

2019-07-11 Thread GitBox
pnowojski merged pull request #9059: [FLINK-13141][network] Remove getBufferSize method from BufferPoolFactory URL: https://github.com/apache/flink/pull/9059 This is an automated message from the Apache Git Service. To

[GitHub] [flink] JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

2019-07-11 Thread GitBox
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r302397775 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

2019-07-11 Thread GitBox
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r302397113 ## File path:

[jira] [Created] (FLINK-13204) The subscribedPartitionStates should be thread safe.

2019-07-11 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created FLINK-13204: Summary: The subscribedPartitionStates should be thread safe. Key: FLINK-13204 URL: https://issues.apache.org/jira/browse/FLINK-13204 Project: Flink Issue

[GitHub] [flink] carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

2019-07-11 Thread GitBox
carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#discussion_r302379783 ## File path:

[jira] [Commented] (FLINK-12998) Document Plugins mechanism

2019-07-11 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882711#comment-16882711 ] Piotr Nowojski commented on FLINK-12998: Just for the record, the documentation should contain

[GitHub] [flink] JingsongLi commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

2019-07-11 Thread GitBox
JingsongLi commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#discussion_r302405476 ## File path:

[GitHub] [flink] KurtYoung commented on issue #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner

2019-07-11 Thread GitBox
KurtYoung commented on issue #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner URL: https://github.com/apache/flink/pull/9056#issuecomment-510379752 Seem we have some irrelevant fails:

[GitHub] [flink] TsReaper commented on issue #9074: [FLINK-13198] Introduce TimeInterval in configuration package

2019-07-11 Thread GitBox
TsReaper commented on issue #9074: [FLINK-13198] Introduce TimeInterval in configuration package URL: https://github.com/apache/flink/pull/9074#issuecomment-510380097 Thanks @twalthr for the comment. I think `org.apache.flink.api.common.time.Time` has a different functionality compared

[jira] [Updated] (FLINK-13202) Unstable StandaloneResourceManagerTest

2019-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13202: -- Priority: Critical (was: Major) > Unstable StandaloneResourceManagerTest >

[jira] [Created] (FLINK-13208) Add Notice file for upgrading calcite to 1.20

2019-07-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-13208: -- Summary: Add Notice file for upgrading calcite to 1.20 Key: FLINK-13208 URL: https://issues.apache.org/jira/browse/FLINK-13208 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-13207) Add the algorithm of Fast Fourier Transformation(FFT)

2019-07-11 Thread Xu Yang (JIRA)
Xu Yang created FLINK-13207: --- Summary: Add the algorithm of Fast Fourier Transformation(FFT) Key: FLINK-13207 URL: https://issues.apache.org/jira/browse/FLINK-13207 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on issue #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

2019-07-11 Thread GitBox
flinkbot commented on issue #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#issuecomment-510405743 ## CI report: * 4106cd9017d5a20ae427c74b627d6c574c02cc40 : PENDING

[GitHub] [flink] flinkbot commented on issue #9078: [FLINK-13186] Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient

2019-07-11 Thread GitBox
flinkbot commented on issue #9078: [FLINK-13186] Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient URL: https://github.com/apache/flink/pull/9078#issuecomment-510405833 ## CI report: * b73e7985607cee8e9a8abc5b8031e4ee149db514 : PENDING

[GitHub] [flink] flinkbot commented on issue #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink

2019-07-11 Thread GitBox
flinkbot commented on issue #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink URL: https://github.com/apache/flink/pull/9036#issuecomment-510405764 ## CI report: * 1abd1e5a9d7dc7698432234638fdbe80eb191e8d : PENDING

[GitHub] [flink] flinkbot commented on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

2019-07-11 Thread GitBox
flinkbot commented on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#issuecomment-510405859 ## CI report: * 4afedee15460ac0f1f2945ca657581c538ddfc06 : PENDING

[GitHub] [flink] flinkbot commented on issue #8925: [FLINK-12852][network] Fix the deadlock occured when requesting exclusive buffers

2019-07-11 Thread GitBox
flinkbot commented on issue #8925: [FLINK-12852][network] Fix the deadlock occured when requesting exclusive buffers URL: https://github.com/apache/flink/pull/8925#issuecomment-510405884 ## CI report: * 31a51cbe260a78381dc44973e6724c20532b5deb : PENDING

[GitHub] [flink] flinkbot commented on issue #9043: [FLINK-13165] Complete slot requests in request order

2019-07-11 Thread GitBox
flinkbot commented on issue #9043: [FLINK-13165] Complete slot requests in request order URL: https://github.com/apache/flink/pull/9043#issuecomment-510405816 ## CI report: * a75fa20222c0e9d4bdfbb6eafdfd1831e0ff48e8 : PENDING

[GitHub] [flink] flinkbot commented on issue #9021: [FLINK-13205][runtime] Make checkpoints injection ordered with stop-with-savepoint

2019-07-11 Thread GitBox
flinkbot commented on issue #9021: [FLINK-13205][runtime] Make checkpoints injection ordered with stop-with-savepoint URL: https://github.com/apache/flink/pull/9021#issuecomment-510405873 ## CI report: * abed4b5678a2f09b3bb729bd62b5264e56b55b9f : PENDING

[GitHub] [flink] zentol commented on issue #9074: [FLINK-13198] Introduce TimeInterval in configuration package

2019-07-11 Thread GitBox
zentol commented on issue #9074: [FLINK-13198] Introduce TimeInterval in configuration package URL: https://github.com/apache/flink/pull/9074#issuecomment-510405236 I'D like to get to the drawing board for this one; it seems this could be trivially solved using Java 8 durations.

[GitHub] [flink] flinkbot commented on issue #9079: [FLINK-13208][table-planner][table-planner-blink] Update Notice files after adding commons-codec to table package.

2019-07-11 Thread GitBox
flinkbot commented on issue #9079: [FLINK-13208][table-planner][table-planner-blink] Update Notice files after adding commons-codec to table package. URL: https://github.com/apache/flink/pull/9079#issuecomment-510405844 ## CI report: * b657d1382e635763a803582ea115956db794869a :

[GitHub] [flink] flinkbot commented on issue #9067: [FLINK-13069][hive] HiveTableSink should implement OverwritableTableSink

2019-07-11 Thread GitBox
flinkbot commented on issue #9067: [FLINK-13069][hive] HiveTableSink should implement OverwritableTableSink URL: https://github.com/apache/flink/pull/9067#issuecomment-510405753 ## CI report: * 0034a70157b871b401cb1f8cd5a223427cf6223a : PENDING

[GitHub] [flink] flinkbot commented on issue #9073: [FLINK-13187] Introduce ScheduleMode#LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST

2019-07-11 Thread GitBox
flinkbot commented on issue #9073: [FLINK-13187] Introduce ScheduleMode#LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST URL: https://github.com/apache/flink/pull/9073#issuecomment-510405770 ## CI report: * f588483906ba4c4459bf18671f84924a3286 : PENDING

[GitHub] [flink] flinkbot commented on issue #9057: [FLINK-13121] [table-planner-blink] Set batch properties to runtime in blink batch executor

2019-07-11 Thread GitBox
flinkbot commented on issue #9057: [FLINK-13121] [table-planner-blink] Set batch properties to runtime in blink batch executor URL: https://github.com/apache/flink/pull/9057#issuecomment-510405733 ## CI report: * b616282cb875778a7a5af22a2783eaaf48104908 : PENDING

[GitHub] [flink] flinkbot commented on issue #9077: [FLINK-13196][table] Fix Ambiguous column name exception bug for Table API

2019-07-11 Thread GitBox
flinkbot commented on issue #9077: [FLINK-13196][table] Fix Ambiguous column name exception bug for Table API URL: https://github.com/apache/flink/pull/9077#issuecomment-510405822 ## CI report: * 11d60ab9683d4ba90a801af3996a7ab62644dba8 : PENDING

[GitHub] [flink] flinkbot commented on issue #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

2019-07-11 Thread GitBox
flinkbot commented on issue #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#issuecomment-510405806 ## CI report: * 4536c6466c74447b306212df544d04e543315997 : PENDING

[GitHub] [flink] flinkbot commented on issue #9093: [FLINK-13220][blink-planner] Add DDL support for blink planner

2019-07-11 Thread GitBox
flinkbot commented on issue #9093: [FLINK-13220][blink-planner] Add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#issuecomment-510509119 ## CI report: * 58769c5dfd7f793c36095f001483ebf165610c73 : PENDING

[GitHub] [flink] TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source

2019-07-11 Thread GitBox
TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source URL: https://github.com/apache/flink/pull/9029#discussion_r302573571 ## File path:

[GitHub] [flink] mrzhangboss commented on a change in pull request #9064: [FLINK-13188][Runtime / State Backends][Test] Fix annotation type error in MockTtlStateTest

2019-07-11 Thread GitBox
mrzhangboss commented on a change in pull request #9064: [FLINK-13188][Runtime / State Backends][Test] Fix annotation type error in MockTtlStateTest URL: https://github.com/apache/flink/pull/9064#discussion_r302446584 ## File path:

[jira] [Closed] (FLINK-12464) Kinesis e2e test fails on Java 9

2019-07-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12464. Resolution: Won't Fix > Kinesis e2e test fails on Java 9 >

[GitHub] [flink] flinkbot edited a comment on issue #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#issuecomment-510405806 ## CI report: * 4536c6466c74447b306212df544d04e543315997 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9073: [FLINK-13187] Introduce ScheduleMode#LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9073: [FLINK-13187] Introduce ScheduleMode#LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST URL: https://github.com/apache/flink/pull/9073#issuecomment-510405770 ## CI report: * f588483906ba4c4459bf18671f84924a3286 : PENDING

<    1   2   3   4   5   6   7   >