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

2019-07-11 Thread GitBox
flinkbot edited a comment 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 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#issuecomment-510421703 ## CI report: * 0031874f16da8b96d90c5b7c2392d792b372cfd

[GitHub] [flink] flinkbot commented on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-11 Thread GitBox
flinkbot commented on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#issuecomment-510770597 ## CI report: * 6afb0645f386b618ddc1e9d86add2

[jira] [Commented] (FLINK-13158) Remove WebMonitor interface from webmonitor package

2019-07-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883576#comment-16883576 ] vinoyang commented on FLINK-13158: -- [~Tison] OK > Remove WebMonitor interface from web

[jira] [Updated] (FLINK-13158) Remove WebMonitor interface from webmonitor package

2019-07-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13158: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-10392 > Remove WebMonitor interface from

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

2019-07-11 Thread GitBox
twalthr commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r302847794 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/F

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

2019-07-11 Thread GitBox
twalthr commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r302847171 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Cat

[jira] [Commented] (FLINK-13158) Remove WebMonitor interface from webmonitor package

2019-07-11 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883572#comment-16883572 ] TisonKun commented on FLINK-13158: -- [~yanghua] I think this could be a subtask of FLINK

[GitHub] [flink] flinkbot commented on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-11 Thread GitBox
flinkbot commented on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#issuecomment-510766159 Thanks a lot for your contribution to the Apache Fli

[jira] [Updated] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13221: --- Labels: pull-request-available (was: ) > Blink planner should set ScheduleMode to > LAZY_F

[GitHub] [flink] liyafan82 opened a new pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-11 Thread GitBox
liyafan82 opened a new pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101 ## What is the purpose of the change Make batch jobs

[GitHub] [flink] flinkbot commented on issue #9100: update findAndCreateTableSource annotation

2019-07-11 Thread GitBox
flinkbot commented on issue #9100: update findAndCreateTableSource annotation URL: https://github.com/apache/flink/pull/9100#issuecomment-510765209 ## CI report: * c9047e3a73d40a615166316b4335fee5013afcce : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/118885755) -

[GitHub] [flink] flinkbot commented on issue #9100: update findAndCreateTableSource annotation

2019-07-11 Thread GitBox
flinkbot commented on issue #9100: update findAndCreateTableSource annotation URL: https://github.com/apache/flink/pull/9100#issuecomment-510762953 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

[jira] [Created] (FLINK-13239) Add unary loss functions

2019-07-11 Thread Xu Yang (JIRA)
Xu Yang created FLINK-13239: --- Summary: Add unary loss functions Key: FLINK-13239 URL: https://issues.apache.org/jira/browse/FLINK-13239 Project: Flink Issue Type: Sub-task Components: Lib

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

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

[GitHub] [flink] flinkbot commented on issue #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink

2019-07-11 Thread GitBox
flinkbot commented on issue #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink URL: https://github.com/apache/flink/pull/9099#issuecomment-510762700 ## CI report: * fb347fe30a5e894e388837ed2de4f9b60513d7b1 : PENDING [Build](https://travis-ci.com/flink-c

[GitHub] [flink] flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#issuecomment-510415691 ## CI report: * 2b6f431f4f281936034418c8ce64e2e1ba10bd5f : PENDING [Build](https://travis-ci.com/fl

[GitHub] [flink] hehuiyuan opened a new pull request #9100: update findAndCreateTableSource annotation

2019-07-11 Thread GitBox
hehuiyuan opened a new pull request #9100: update findAndCreateTableSource annotation URL: https://github.com/apache/flink/pull/9100 ## What is the purpose of the change update the `TableFactoryUtil.findAndCreateTableSource` method's annotation. -

[jira] [Created] (FLINK-13238) Reduce blink planner's testing time

2019-07-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-13238: -- Summary: Reduce blink planner's testing time Key: FLINK-13238 URL: https://issues.apache.org/jira/browse/FLINK-13238 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on issue #9023: [FLINK-13154][docs] Fix broken links of web docs

2019-07-11 Thread GitBox
flinkbot commented on issue #9023: [FLINK-13154][docs] Fix broken links of web docs URL: https://github.com/apache/flink/pull/9023#issuecomment-510760232 ## CI report: * e46e8fe47051e393cb99fd5e08a821ab72d334bf : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/118884406)

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

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9067: [FLINK-13069][hive] HiveTableSink should implement OverwritableTableSink URL: https://github.com/apache/flink/pull/9067#issuecomment-510405753 ## CI report: * 0034a70157b871b401cb1f8cd5a223427cf6223a : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot commented on issue #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink

2019-07-11 Thread GitBox
flinkbot commented on issue #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink URL: https://github.com/apache/flink/pull/9099#issuecomment-510759793 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to r

[jira] [Resolved] (FLINK-13163) Support execution of batch jobs with fewer slots than requested

2019-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13163. --- Resolution: Done Issue has been completed with the specified scope. > Support execution of

[jira] [Updated] (FLINK-13237) Add expression table api test to blink

2019-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13237: --- Labels: pull-request-available (was: ) > Add expression table api test to blink > -

[jira] [Closed] (FLINK-13165) Complete requested slots in request order

2019-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13165. - Resolution: Done Done via d73010b110f5dffda4b657ba2ebc274669a33845 > Complete requested slots i

[jira] [Closed] (FLINK-13234) TemporalTypesTest randomly failed on travis

2019-07-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13234. -- Resolution: Fixed Fix Version/s: 1.9.0 fixed via: 53a044c987718d74db3a9b6102f1fa27324a7fab > T

[GitHub] [flink] JingsongLi opened a new pull request #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink

2019-07-11 Thread GitBox
JingsongLi opened a new pull request #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink URL: https://github.com/apache/flink/pull/9099 ## What is the purpose of the change Add expression table api test and fix bugs. ## Verifying this change

[jira] [Closed] (FLINK-13232) TemporalTypesTest>ExpressionTestBase.evaluateExprs in blink planner fails on PST Timezone

2019-07-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13232. -- Resolution: Fixed merged in 1.9.0: 53a044c987718d74db3a9b6102f1fa27324a7fab > TemporalTypesTest>Expre

[jira] [Commented] (FLINK-13165) Complete requested slots in request order

2019-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883556#comment-16883556 ] Till Rohrmann commented on FLINK-13165: --- Yes agreed. One needs to set the input de

[GitHub] [flink] KurtYoung merged pull request #9095: [FLINK-13232][table-planner-blink] Correct CURRENT_DATE test to avoid timezone error

2019-07-11 Thread GitBox
KurtYoung merged pull request #9095: [FLINK-13232][table-planner-blink] Correct CURRENT_DATE test to avoid timezone error URL: https://github.com/apache/flink/pull/9095 This is an automated message from the Apache Git Servic

[jira] [Closed] (FLINK-13166) Support batch slot requests

2019-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13166. - Resolution: Done Done via d30854be2f8b6389c2c6deb66240ba63bd5ecf0e > Support batch slot request

[jira] [Created] (FLINK-13237) Add expression table api test to blink

2019-07-11 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-13237: Summary: Add expression table api test to blink Key: FLINK-13237 URL: https://issues.apache.org/jira/browse/FLINK-13237 Project: Flink Issue Type: New Featur

[jira] [Closed] (FLINK-13187) Expose batch slot request via new scheduling mode

2019-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13187. - Resolution: Fixed Fixed via 6a72a6ad8f4f582dcea8305ee9d8715aa7a66286 > Expose batch slot reques

[jira] [Commented] (FLINK-13234) TemporalTypesTest randomly failed on travis

2019-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883552#comment-16883552 ] Till Rohrmann commented on FLINK-13234: --- Another instance: https://api.travis-ci.o

[GitHub] [flink] pnowojski merged pull request #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

2019-07-11 Thread GitBox
pnowojski merged pull request #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer URL: https://github.com/apache/flink/pull/9062 This is an automated message from the Apa

[jira] [Commented] (FLINK-12916) KeyedComplexChainTest.testMigrationAndRestore failed on Travis

2019-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883551#comment-16883551 ] Till Rohrmann commented on FLINK-12916: --- Another instance: https://api.travis-ci.o

[GitHub] [flink] flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#issuecomment-510415691 ## CI report: * 2b6f431f4f281936034418c8ce64e2e1ba10bd5f : SUCCESS [Build](https://travis-ci.com/fl

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

2019-07-11 Thread GitBox
flinkbot edited a comment 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 : SUCCESS [Build](https://travi

[GitHub] [flink] Myasuka commented on a change in pull request #9023: [FLINK-13154][docs] Fix broken links of web docs

2019-07-11 Thread GitBox
Myasuka commented on a change in pull request #9023: [FLINK-13154][docs] Fix broken links of web docs URL: https://github.com/apache/flink/pull/9023#discussion_r302837692 ## File path: docs/dev/table/sqlClient.md ## @@ -456,8 +456,6 @@ catalogs: Currently Flink supports

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

2019-07-11 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883549#comment-16883549 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] Thanks for the quick reply. Just a

[GitHub] [flink] danny0405 closed pull request #9092: [FLINK-13211] Add drop table support for flink planner

2019-07-11 Thread GitBox
danny0405 closed pull request #9092: [FLINK-13211] Add drop table support for flink planner URL: https://github.com/apache/flink/pull/9092 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer

2019-07-11 Thread GitBox
flinkbot commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer URL: https://github.com/apache/flink/pull/9098#issuecomment-510755324 ## CI report: * 19d462121bdf06eb9982a9890dd5ce53cc9499b4 : PENDING [Build](https://travis-ci.com/

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

2019-07-11 Thread forideal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883545#comment-16883545 ] forideal commented on FLINK-13224: -- if user type equals device type,the following code

[GitHub] [flink] TsReaper commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer

2019-07-11 Thread GitBox
TsReaper commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer URL: https://github.com/apache/flink/pull/9098#issuecomment-510752945 @beyond1920 @wuchong @JingsongLi please take a look if you have time. --

[GitHub] [flink] flinkbot commented on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID

2019-07-11 Thread GitBox
flinkbot commented on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID URL: https://github.com/apache/flink/pull/7262#issuecomment-510752916 ## CI report: * 15f05f4c5791d9d42610099324e59057d26bd3ff : PENDING [Build](https://travis-ci.com/flink-ci/flink/

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

2019-07-11 Thread GitBox
flinkbot edited a comment 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 : SUCCESS [Build](https://travi

[GitHub] [flink] flinkbot commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer

2019-07-11 Thread GitBox
flinkbot commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer URL: https://github.com/apache/flink/pull/9098#issuecomment-510753038 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-13236) Fix bug and improve performance in TopNBuffer

2019-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13236: --- Labels: pull-request-available (was: ) > Fix bug and improve performance in TopNBuffer > --

[GitHub] [flink] TsReaper opened a new pull request #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer

2019-07-11 Thread GitBox
TsReaper opened a new pull request #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer URL: https://github.com/apache/flink/pull/9098 ## What is the purpose of the change The value of `currentTopNum` will be incorrectly calculated in the `putAll`

[jira] [Updated] (FLINK-13220) Add create/drop table support for blink planner

2019-07-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13220: --- Summary: Add create/drop table support for blink planner (was: Add DDL support for blink planner)

[jira] [Closed] (FLINK-13220) Add create/drop table support for blink planner

2019-07-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13220. -- Resolution: Fixed merged in 1.9.0: db488c0d19dbb96466b9b765cecc06784b844926 > Add create/drop table s

[jira] [Updated] (FLINK-13220) Add DDL support for blink planner

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

[GitHub] [flink] becketqin commented on a change in pull request #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID

2019-07-11 Thread GitBox
becketqin commented on a change in pull request #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID URL: https://github.com/apache/flink/pull/7262#discussion_r302832450 ## File path: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/str

[GitHub] [flink] KurtYoung closed pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

2019-07-11 Thread GitBox
KurtYoung closed pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093 This is an automated

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

2019-07-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13211. -- Resolution: Fixed merged in 1.9.0: 58280f44f5ff62d129580bb091671a52537536e3 > Add drop table support

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

2019-07-11 Thread GitBox
flinkbot edited a comment 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 : FAILURE [Build](http

[jira] [Commented] (FLINK-10636) ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed

2019-07-11 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883533#comment-16883533 ] Jiangjie Qin commented on FLINK-10636: -- [~lsy] Is this issue on Kafka 0.8? Starting

[GitHub] [flink] tzulitai commented on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API

2019-07-11 Thread GitBox
tzulitai commented on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API URL: https://github.com/apache/flink/pull/9094#issuecomment-510745686 @flinkbot approve all The changes look good to me, thanks for the quick prepara

[GitHub] [flink] flinkbot edited a comment on issue #9064: [FLINK-13188][Runtime / State Backends][Test] Fix MockStateBackend#resolveCheckpointStorageLocation return null cause intellij assertion dete

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9064: [FLINK-13188][Runtime / State Backends][Test] Fix MockStateBackend#resolveCheckpointStorageLocation return null cause intellij assertion detect test failed URL: https://github.com/apache/flink/pull/9064#issuecomment-510409332 ## CI report: *

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

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090#issuecomment-510496617 ## CI report: * 6c229740b17ae4e0df7c8ba9678ada086ae8bf47 : PENDING [Build](https://travis-ci.com/fli

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

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#issuecomment-510405859 ## CI report: * 4afedee15460ac0f1f2945ca657581c538ddfc06 : FAILURE [Build](https://travis-ci.com/flink-c

[jira] [Closed] (FLINK-13115) Introduce planner rule to support partition pruning for PartitionableTableSource

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

[GitHub] [flink] KurtYoung closed pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

2019-07-11 Thread GitBox
KurtYoung closed pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080 This is an automated me

[GitHub] [flink] KurtYoung commented on issue #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

2019-07-11 Thread GitBox
KurtYoung commented on issue #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#issuecomment-510742027 passed here: https://travis-ci.org/KurtYoung/flink/builds/557654396

[jira] [Created] (FLINK-13236) Fix bug and improve performance in TopNBuffer

2019-07-11 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13236: --- Summary: Fix bug and improve performance in TopNBuffer Key: FLINK-13236 URL: https://issues.apache.org/jira/browse/FLINK-13236 Project: Flink Issue Type: Impro

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

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#issuecomment-510405859 ## CI report: * 4afedee15460ac0f1f2945ca657581c538ddfc06 : FAILURE [Build](https://travis-ci.com/flink-c

[GitHub] [flink] flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

2019-07-11 Thread GitBox
flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-510741229 ## CI report: * e0f3d5b774c08e2154b31fdde4b2c193276723a3 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/11887951

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

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090#issuecomment-510496617 ## CI report: * 6c229740b17ae4e0df7c8ba9678ada086ae8bf47 : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9064: [FLINK-13188][Runtime / State Backends][Test] Fix MockStateBackend#resolveCheckpointStorageLocation return null cause intellij assertion dete

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9064: [FLINK-13188][Runtime / State Backends][Test] Fix MockStateBackend#resolveCheckpointStorageLocation return null cause intellij assertion detect test failed URL: https://github.com/apache/flink/pull/9064#issuecomment-510409332 ## CI report: *

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2019-07-11 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883520#comment-16883520 ] Jiangjie Qin commented on FLINK-10806: -- Would setting \{{auto.offset.reset}} for th

[jira] [Comment Edited] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2019-07-11 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883520#comment-16883520 ] Jiangjie Qin edited comment on FLINK-10806 at 7/12/19 4:31 AM: ---

[GitHub] [flink] flinkbot commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic

2019-07-11 Thread GitBox
flinkbot commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic URL: https://github.com/apache/flink/pull/7487#issuecomment-510739413 ## CI report: * c746405bfc3264fec2e9a5a6551360e37aa5688f : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/118

[GitHub] [flink] lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

2019-07-11 Thread GitBox
lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-510738891 Thanks for @zentol 's suggestions. PR updated accordingly. This i

[jira] [Commented] (FLINK-10876) Deadlock if closing firstly pending transactions in FlinkKafkaProducer(011).close()

2019-07-11 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883518#comment-16883518 ] Jiangjie Qin commented on FLINK-10876: -- Is this still an issue given FLINK-10455 is

[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 : FAILURE [Build](https://travis-ci

[GitHub] [flink] flinkbot edited a comment on issue #9083: [FLINK-13116] [table-planner-blink] Supports catalog statistics in blink planner

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9083: [FLINK-13116] [table-planner-blink] Supports catalog statistics in blink planner URL: https://github.com/apache/flink/pull/9083#issuecomment-510435070 ## CI report: * 402974d0ffb69d9244c108234c9837f2eacc8d37 : PENDING [Build](https://travis-

[GitHub] [flink] becketqin commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic

2019-07-11 Thread GitBox
becketqin commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic URL: https://github.com/apache/flink/pull/7487#issuecomment-510736925 @Fokko Any update on this? We should also fix the `KafkaPartitionDiscoverer` in the universal Kafka connector as well.

[jira] [Updated] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql

2019-07-11 Thread zjuwangg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-13206: - Affects Version/s: 1.9.0 > modify 'use database' syntax in SQL CLI to be consistant with standard sql >

[jira] [Updated] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql

2019-07-11 Thread zjuwangg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-13206: - Fix Version/s: 1.9.0 > modify 'use database' syntax in SQL CLI to be consistant with standard sql >

[GitHub] [flink] beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

2019-07-11 Thread GitBox
beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302807906 ## File path: flink-table/flink-table-p

[GitHub] [flink] beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

2019-07-11 Thread GitBox
beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302806301 ## File path: flink-table/flink-table-p

[GitHub] [flink] beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

2019-07-11 Thread GitBox
beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302807941 ## File path: flink-table/flink-table-p

[GitHub] [flink] JingsongLi commented on issue #9095: [FLINK-13232][table-planner-blink] Remove CURRENT_DATE test to avoid timezone error

2019-07-11 Thread GitBox
JingsongLi commented on issue #9095: [FLINK-13232][table-planner-blink] Remove CURRENT_DATE test to avoid timezone error URL: https://github.com/apache/flink/pull/9095#issuecomment-510736379 travis in: https://travis-ci.org/JingsongLi/flink/builds/557625626

[GitHub] [flink] flinkbot edited a comment on issue #9083: [FLINK-13116] [table-planner-blink] Supports catalog statistics in blink planner

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9083: [FLINK-13116] [table-planner-blink] Supports catalog statistics in blink planner URL: https://github.com/apache/flink/pull/9083#issuecomment-510435070 ## CI report: * 402974d0ffb69d9244c108234c9837f2eacc8d37 : FAILURE [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API URL: https://github.com/apache/flink/pull/9094#issuecomment-510560219 ## CI report: * 68c63247fc6c3b60b0cf7afb483cc04ee8f558d0 : PENDING [Bui

[GitHub] [flink] flinkbot edited a comment on issue #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer URL: https://github.com/apache/flink/pull/9062#issuecomment-510405737 ## CI report: * 106228aa31ad7065acf116029879a00fd998662b : FAILURE [Buil

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

2019-07-11 Thread GitBox
JingsongLi commented on issue #9091: [FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink URL: https://github.com/apache/flink/pull/9091#issuecomment-510735657 Test pass in: https://travis-ci.org/JingsongLi/flink/builds/557348029 --

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

2019-07-11 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883503#comment-16883503 ] Jiangjie Qin commented on FLINK-11654: -- [~pnowojski] [~aljoscha] [~dawidwys] [~vicT

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

2019-07-11 Thread GitBox
flinkbot edited a comment 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 [Bu

[GitHub] [flink] flinkbot edited a comment on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API URL: https://github.com/apache/flink/pull/9094#issuecomment-510560219 ## CI report: * 68c63247fc6c3b60b0cf7afb483cc04ee8f558d0 : SUCCESS [Bui

[GitHub] [flink] flinkbot edited a comment on issue #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

2019-07-11 Thread GitBox
flinkbot edited a comment on issue #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer URL: https://github.com/apache/flink/pull/9062#issuecomment-510405737 ## CI report: * 106228aa31ad7065acf116029879a00fd998662b : FAILURE [Buil

[jira] [Commented] (FLINK-11736) flink kafka producer failed with NOT_LEADER_FOR_PARTITION

2019-07-11 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883502#comment-16883502 ] Jiangjie Qin commented on FLINK-11736: -- [~debugman] NOT_LEADER_FOR_PARTITION indica

[jira] [Comment Edited] (FLINK-11736) flink kafka producer failed with NOT_LEADER_FOR_PARTITION

2019-07-11 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883502#comment-16883502 ] Jiangjie Qin edited comment on FLINK-11736 at 7/12/19 3:50 AM: ---

[jira] [Created] (FLINK-13235) Change the Netty default transport mode to auto

2019-07-11 Thread zhijiang (JIRA)
zhijiang created FLINK-13235: Summary: Change the Netty default transport mode to auto Key: FLINK-13235 URL: https://issues.apache.org/jira/browse/FLINK-13235 Project: Flink Issue Type: Improveme

[GitHub] [flink] godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

2019-07-11 Thread GitBox
godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner URL: https://github.com/apache/flink/pull/9035#discussion_r302818070 ## File path: flink-table/flink-table-planner-blink/src/ma

[GitHub] [flink] godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

2019-07-11 Thread GitBox
godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner URL: https://github.com/apache/flink/pull/9035#discussion_r302817944 ## File path: flink-table/flink-table-planner-blink/src/ma

[GitHub] [flink] godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

2019-07-11 Thread GitBox
godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner URL: https://github.com/apache/flink/pull/9035#discussion_r302816538 ## File path: flink-table/flink-table-planner-blink/src/te

[jira] [Commented] (FLINK-13153) SplitAggregateITCase.testMinMaxWithRetraction failed on Travis

2019-07-11 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883500#comment-16883500 ] Jark Wu commented on FLINK-13153: - I will look into this soon. > SplitAggregateITCase.t

[jira] [Assigned] (FLINK-13153) SplitAggregateITCase.testMinMaxWithRetraction failed on Travis

2019-07-11 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13153: --- Assignee: Jark Wu > SplitAggregateITCase.testMinMaxWithRetraction failed on Travis > --

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

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

  1   2   3   4   5   6   7   >