[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516257535 ## CI report: * 59b1a6d50b025925afd14a09b2b95a507889800a : FAILURE [Build](http

[GitHub] [flink] eskabetxe commented on issue #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

2019-08-06 Thread GitBox
eskabetxe commented on issue #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#issuecomment-518960368 thanks @kl0u if you need that i change the PR to master tell me.. --

[jira] [Commented] (FLINK-13605) AsyncDataStreamITCase.testUnorderedWait failed on Travis

2019-08-06 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901773#comment-16901773 ] TisonKun commented on FLINK-13605: -- [~kkl0u] you can try out the patch attached if it i

[jira] [Updated] (FLINK-13605) AsyncDataStreamITCase.testUnorderedWait failed on Travis

2019-08-06 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13605: - Attachment: 0001-FLINK-13605.patch > AsyncDataStreamITCase.testUnorderedWait failed on Travis >

[jira] [Commented] (FLINK-9953) Active Kubernetes integration

2019-08-06 Thread Yang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901759#comment-16901759 ] Yang Wang commented on FLINK-9953: -- Hi [~frank wang], Thanks for you attention. Chunhui

[GitHub] [flink] wuchong commented on a change in pull request #9328: [FLINK-13521][sql-client] Allow setting configurations in SQL CLI

2019-08-06 Thread GitBox
wuchong commented on a change in pull request #9328: [FLINK-13521][sql-client] Allow setting configurations in SQL CLI URL: https://github.com/apache/flink/pull/9328#discussion_r311382377 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/

[jira] [Commented] (FLINK-13548) Support priority of the Flink YARN application

2019-08-06 Thread thy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901753#comment-16901753 ] thy commented on FLINK-13548: - ok, I currently have pushed a new commit according to the las

[jira] [Assigned] (FLINK-13605) AsyncDataStreamITCase.testUnorderedWait failed on Travis

2019-08-06 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-13605: -- Assignee: (was: Kostas Kloudas) > AsyncDataStreamITCase.testUnorderedWait failed

[jira] [Created] (FLINK-13605) AsyncDataStreamITCase. testUnorderedWait failed on Travis

2019-08-06 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-13605: -- Summary: AsyncDataStreamITCase. testUnorderedWait failed on Travis Key: FLINK-13605 URL: https://issues.apache.org/jira/browse/FLINK-13605 Project: Flink

[jira] [Updated] (FLINK-13605) AsyncDataStreamITCase.testUnorderedWait failed on Travis

2019-08-06 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-13605: --- Summary: AsyncDataStreamITCase.testUnorderedWait failed on Travis (was: AsyncDataStreamITCa

[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516257535 ## CI report: * 59b1a6d50b025925afd14a09b2b95a507889800a : FAILURE [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9376: [1.9][FLINK-13452][runtime] Ensure to fail global when exception happens during reseting tasks of regions

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9376: [1.9][FLINK-13452][runtime] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9376#issuecomment-518940672 ## CI report: * ea55fdb7f417fee67e4862a9b871748bfc2210eb : CANCELE

[GitHub] [flink] flinkbot edited a comment on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#issuecomment-517610510 ## CI report: * 4fe9e1ba5707fb4d208290116bc172142e6be08a : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot commented on issue #9376: [1.9][FLINK-13452][runtime] Ensure to fail global when exception happens during reseting tasks of regions

2019-08-06 Thread GitBox
flinkbot commented on issue #9376: [1.9][FLINK-13452][runtime] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9376#issuecomment-518940672 ## CI report: * ea55fdb7f417fee67e4862a9b871748bfc2210eb : PENDING [Buil

[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516257535 ## CI report: * 59b1a6d50b025925afd14a09b2b95a507889800a : FAILURE [Build](http

[GitHub] [flink] flinkbot commented on issue #9376: [1.9][FLINK-13452][runtime] Ensure to fail global when exception happens during reseting tasks of regions

2019-08-06 Thread GitBox
flinkbot commented on issue #9376: [1.9][FLINK-13452][runtime] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9376#issuecomment-518939588 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkb

[jira] [Updated] (FLINK-13336) Remove the legacy batch fault tolerance page and redirect it to the new task failure recovery page

2019-08-06 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-13336: - Issue Type: Improvement (was: Task) > Remove the legacy batch fault tolerance page and redirect it to t

[GitHub] [flink] GJL commented on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

2019-08-06 Thread GitBox
GJL commented on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-518939416 Merging as soon as build is green. ---

[GitHub] [flink] GJL opened a new pull request #9376: [1.9][FLINK-13452][runtime] Ensure to fail global when exception happens during reseting tasks of regions

2019-08-06 Thread GitBox
GJL opened a new pull request #9376: [1.9][FLINK-13452][runtime] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9376 Backport to 1.9 of #9268 This

[jira] [Updated] (FLINK-13548) Support priority of the Flink YARN application

2019-08-06 Thread thy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thy updated FLINK-13548: Description: Currently, Flink 1.9 does not support yarn priority submission. The default priority of yarn submiss

[jira] [Updated] (FLINK-13548) Support priority of the Flink YARN application

2019-08-06 Thread thy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thy updated FLINK-13548: Description: Currently, Flink 1.9 does not support yarn priority submission. The default priority of yarn submiss

[jira] [Updated] (FLINK-13548) Support priority of the Flink YARN application

2019-08-06 Thread thy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thy updated FLINK-13548: Description: Currently, Flink 1.9 does not support yarn priority submission. The default priority of yarn submiss

[GitHub] [flink] flinkbot edited a comment on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9331#issuecomment-517548502 ## CI report: * 5e757e180999aea0a3346ba841d9d48e456cdc0c : FAILURE [

[jira] [Resolved] (FLINK-13529) Verify and correct agg function's semantic for Blink planner

2019-08-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13529. - Resolution: Fixed [FLINK-13529][table-planner-blink] Remove APPROX_COUNT_DISTINCT and INCR_SUM in blink

[GitHub] [flink] flinkbot edited a comment on issue #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data …

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data … URL: https://github.com/apache/flink/pull/9354#issuecomment-518083679 ## CI report: * 754c52de984cb476ae0442c6704219b64c68441e : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] asfgit closed pull request #9316: [FLINK-13529][table-planner-blink] Verify and correct agg function's semantic for Blink planner

2019-08-06 Thread GitBox
asfgit closed pull request #9316: [FLINK-13529][table-planner-blink] Verify and correct agg function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9316 This is an automated message from the Apache Gi

[GitHub] [flink] flinkbot edited a comment on issue #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data …

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data … URL: https://github.com/apache/flink/pull/9354#issuecomment-518083679 ## CI report: * 754c52de984cb476ae0442c6704219b64c68441e : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] danny0405 commented on a change in pull request #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data …

2019-08-06 Thread GitBox
danny0405 commented on a change in pull request #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data … URL: https://github.com/apache/flink/pull/9354#discussion_r311354937 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/tabl

[jira] [Created] (FLINK-13604) All kinds of problem when conversion from Logical type to DataType

2019-08-06 Thread Danny Chan (JIRA)
Danny Chan created FLINK-13604: -- Summary: All kinds of problem when conversion from Logical type to DataType Key: FLINK-13604 URL: https://issues.apache.org/jira/browse/FLINK-13604 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9335: [FLINK-13503][API] Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null.

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9335: [FLINK-13503][API] Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null. URL: https://github.com/apache/flink/pull/9335#issuecomment-517610500 ## CI report: * 3d97f63bc5356148d0c36390c9c5960d4d4c8de6 :

[GitHub] [flink] flinkbot edited a comment on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9331#issuecomment-517548502 ## CI report: * 5e757e180999aea0a3346ba841d9d48e456cdc0c : FAILURE [

[GitHub] [flink] docete commented on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner

2019-08-06 Thread GitBox
docete commented on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9331#issuecomment-518921260 Hi @JingsongLi I verified tpch e2e test locally `[PASS] 'flink-end-to-end-tests/te

[GitHub] [flink] flinkbot edited a comment on issue #9335: [FLINK-13503][API] Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null.

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9335: [FLINK-13503][API] Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null. URL: https://github.com/apache/flink/pull/9335#issuecomment-517610500 ## CI report: * 3d97f63bc5356148d0c36390c9c5960d4d4c8de6 :

[GitHub] [flink] docete commented on a change in pull request #9328: [FLINK-13521][sql-client] Allow setting configurations in SQL CLI

2019-08-06 Thread GitBox
docete commented on a change in pull request #9328: [FLINK-13521][sql-client] Allow setting configurations in SQL CLI URL: https://github.com/apache/flink/pull/9328#discussion_r311349954 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/E

[GitHub] [flink] docete commented on a change in pull request #9328: [FLINK-13521][sql-client] Allow setting configurations in SQL CLI

2019-08-06 Thread GitBox
docete commented on a change in pull request #9328: [FLINK-13521][sql-client] Allow setting configurations in SQL CLI URL: https://github.com/apache/flink/pull/9328#discussion_r311349325 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/E

[GitHub] [flink] beyond1920 commented on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value.

2019-08-06 Thread GitBox
beyond1920 commented on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value. URL: https://github.com/apache/flink/pull/9285#issuecomment-518917167 @KurtYoung The hbase lookup function is

[jira] [Resolved] (FLINK-13433) Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value

2019-08-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13433. - Resolution: Fixed Fix Version/s: 1.9.0 [table-planner-blink] Do not fetch data from LookupableTab

[GitHub] [flink] mikiaichiyu commented on issue #9353: Add a new connector ' flink-connector-rocketmq'

2019-08-06 Thread GitBox
mikiaichiyu commented on issue #9353: Add a new connector ' flink-connector-rocketmq' URL: https://github.com/apache/flink/pull/9353#issuecomment-518915810 Hi @tillrohrmann When I try to add a new connector to flink I found I have a JIRA ticket first, and I go to https://flink.apach

[GitHub] [flink] KurtYoung commented on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value.

2019-08-06 Thread GitBox
KurtYoung commented on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value. URL: https://github.com/apache/flink/pull/9285#issuecomment-518915075 BTW, could you also open a jira for empt

[GitHub] [flink] docete commented on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner

2019-08-06 Thread GitBox
docete commented on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9331#issuecomment-518914073 > Maybe this PR will affect TPC-H result too, @docete can you verify it manually?

[GitHub] [flink] asfgit closed pull request #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value.

2019-08-06 Thread GitBox
asfgit closed pull request #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value. URL: https://github.com/apache/flink/pull/9285 ---

[GitHub] [flink] dianfu commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

2019-08-06 Thread GitBox
dianfu commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#discussion_r311344959 ## File path: flink-table/flink-table-planner/src/main/scal

[GitHub] [flink] hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

2019-08-06 Thread GitBox
hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#discussion_r34270 ## File path: flink-table/flink-table-planner/src/main/s

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311342839 ## File path: flink-table/flink-table-planner-blink/src/main/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311337971 ## File path: flink-connectors/flink-connector-hive/src/test/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311338752 ## File path: flink-table/flink-table-planner-blink/src/main/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311342122 ## File path: flink-table/flink-table-planner-blink/src/main/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311337851 ## File path: flink-connectors/flink-connector-hive/src/test/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311344743 ## File path: flink-table/flink-table-planner-blink/src/test/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311338457 ## File path: flink-connectors/flink-connector-hive/src/test/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311338375 ## File path: flink-connectors/flink-connector-hive/src/test/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311343106 ## File path: flink-table/flink-table-planner-blink/src/main/java/org

[GitHub] [flink] KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

2019-08-06 Thread GitBox
KurtYoung commented on a change in pull request #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#discussion_r311338414 ## File path: flink-connectors/flink-connector-hive/src/test/java/org

[GitHub] [flink] hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

2019-08-06 Thread GitBox
hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#discussion_r311340002 ## File path: flink-python/src/main/java/org/apache/flin

[GitHub] [flink] hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

2019-08-06 Thread GitBox
hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#discussion_r310956276 ## File path: flink-table/flink-table-planner/src/main/s

[GitHub] [flink] hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

2019-08-06 Thread GitBox
hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#discussion_r34270 ## File path: flink-table/flink-table-planner/src/main/s

[GitHub] [flink] hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

2019-08-06 Thread GitBox
hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#discussion_r310960019 ## File path: flink-table/flink-table-planner/src/main/s

[GitHub] [flink] wuchong commented on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value.

2019-08-06 Thread GitBox
wuchong commented on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value. URL: https://github.com/apache/flink/pull/9285#issuecomment-518910899 Thanks @beyond1920 , looks good to me now.

[GitHub] [flink] hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

2019-08-06 Thread GitBox
hequn8128 commented on a change in pull request #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#discussion_r311343507 ## File path: flink-table/flink-table-planner-blink/src/

[jira] [Commented] (FLINK-13598) frocksdb doesn't have arm release

2019-08-06 Thread wangxiyuan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901613#comment-16901613 ] wangxiyuan commented on FLINK-13598: [~carp84], yeah, I'd like to do a full test loc

[GitHub] [flink] danny0405 commented on a change in pull request #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data …

2019-08-06 Thread GitBox
danny0405 commented on a change in pull request #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data … URL: https://github.com/apache/flink/pull/9354#discussion_r311338501 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/tabl

[GitHub] [flink] wuchong commented on issue #9316: [FLINK-13529][table-planner-blink] Verify and correct agg function's semantic for Blink planner

2019-08-06 Thread GitBox
wuchong commented on issue #9316: [FLINK-13529][table-planner-blink] Verify and correct agg function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9316#issuecomment-518902863 Travis passed. Merging... ---

[jira] [Commented] (FLINK-13441) Add batch sql E2E test which runs with fewer slots than parallelism

2019-08-06 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901596#comment-16901596 ] Kurt Young commented on FLINK-13441: FYI, I also modified tpch end-to-end tests to c

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: schema_mapping_error_screenshot .png > Flink Table ApI not working with nested Json schema startin

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518519629 ## CI report: * db9e30b162a1f8f7958a3e1a5ff61214f205de1c : SUCCESS [Bu

[jira] [Commented] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code

2019-08-06 Thread Kamal Lanka (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901452#comment-16901452 ] Kamal Lanka commented on FLINK-7673: Both KPL and KCL are now Apache 2.0. This should

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518519629 ## CI report: * db9e30b162a1f8f7958a3e1a5ff61214f205de1c : SUCCESS [Bu

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518518670 Thanks a lot for your contribution to the Apache Flink project. I'm the @flin

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518518670 Thanks a lot for your contribution to the Apache Flink project. I'm the @flin

[GitHub] [flink] carp84 commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
carp84 commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#discussion_r311260993 ## File path: flink-runtime/src/main/java/org/apache/flink/

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: FlinkTableBugCode > Flink Table ApI not working with nested Json schema starting From 1.6.x >

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: (was: FlinkTableBugCode) > Flink Table ApI not working with nested Json schema starting From 1

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: FlinkTableBugCode > Flink Table ApI not working with nested Json schema starting From 1.6.x >

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: (was: FlinkTableBugCode) > Flink Table ApI not working with nested Json schema starting From 1

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: (was: FlinkBugReport.java) > Flink Table ApI not working with nested Json schema starting From

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: FlinkBugReport.java > Flink Table ApI not working with nested Json schema starting From 1.6.x > --

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: (was: FlinkTableBugCode) > Flink Table ApI not working with nested Json schema starting From 1

[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Du updated FLINK-13603: -- Attachment: FlinkTableBugCode > Flink Table ApI not working with nested Json schema starting From 1.6.x >

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518518670 Thanks a lot for your contribution to the Apache Flink project. I'm the @flin

[GitHub] [flink] carp84 commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
carp84 commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#discussion_r311253548 ## File path: flink-runtime/src/main/java/org/apache/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9375: [FLINK-13159] Prevent potential NPE of restored PojoSerializer when deserializing

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9375: [FLINK-13159] Prevent potential NPE of restored PojoSerializer when deserializing URL: https://github.com/apache/flink/pull/9375#issuecomment-518797945 ## CI report: * 477e1053ef4348ca60a79e20ec55ad553127a0df : FAILURE [Build](https://travis

[jira] [Created] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-06 Thread Yu Du (JIRA)
Yu Du created FLINK-13603: - Summary: Flink Table ApI not working with nested Json schema starting From 1.6.x Key: FLINK-13603 URL: https://issues.apache.org/jira/browse/FLINK-13603 Project: Flink Is

[GitHub] [flink] carp84 commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
carp84 commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#discussion_r311154653 ## File path: flink-runtime/src/main/java/org/apache/flink/

[jira] [Created] (FLINK-13602) Presto S3 filesystem effectively does not support credential providers

2019-08-06 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-13602: Summary: Presto S3 filesystem effectively does not support credential providers Key: FLINK-13602 URL: https://issues.apache.org/jira/browse/FLINK-13602 Projec

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

2019-08-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13044. Resolution: Fixed master: 5e5f5bec72d30397253fc1f11105ca385ca8681f 1.9: 16f519a1e7efae9210

[GitHub] [flink] flinkbot edited a comment on issue #9318: [FLINK-13044][s3][fs] Fix handling of relocated amazon classes

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9318: [FLINK-13044][s3][fs] Fix handling of relocated amazon classes URL: https://github.com/apache/flink/pull/9318#issuecomment-517231236 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revie

[GitHub] [flink] zentol merged pull request #9318: [FLINK-13044][s3][fs] Fix handling of relocated amazon classes

2019-08-06 Thread GitBox
zentol merged pull request #9318: [FLINK-13044][s3][fs] Fix handling of relocated amazon classes URL: https://github.com/apache/flink/pull/9318 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518518670 Thanks a lot for your contribution to the Apache Flink project. I'm the @flin

[GitHub] [flink] Myasuka commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
Myasuka commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#discussion_r311229922 ## File path: flink-runtime/src/test/java/org/apache/flink

[GitHub] [flink] Myasuka commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-06 Thread GitBox
Myasuka commented on a change in pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#discussion_r311229514 ## File path: flink-runtime/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot commented on issue #9375: [FLINK-13159] Prevent potential NPE of restored PojoSerializer when deserializing

2019-08-06 Thread GitBox
flinkbot commented on issue #9375: [FLINK-13159] Prevent potential NPE of restored PojoSerializer when deserializing URL: https://github.com/apache/flink/pull/9375#issuecomment-518797945 ## CI report: * 477e1053ef4348ca60a79e20ec55ad553127a0df : PENDING [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #8418: [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep…

2019-08-06 Thread GitBox
flinkbot edited a comment on issue #8418: [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep… URL: https://github.com/apache/flink/pull/8418#issuecomment-518729487 ## CI report: * df6d3f5acd084931c16fe8564cfd8532d3889111 : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot commented on issue #9375: [FLINK-13159] Prevent potential NPE of restored PojoSerializer when deserializing

2019-08-06 Thread GitBox
flinkbot commented on issue #9375: [FLINK-13159] Prevent potential NPE of restored PojoSerializer when deserializing URL: https://github.com/apache/flink/pull/9375#issuecomment-518794911 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-13159) java.lang.ClassNotFoundException when restore job

2019-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13159: --- Labels: pull-request-available (was: ) > java.lang.ClassNotFoundException when restore job

[GitHub] [flink] Myasuka opened a new pull request #9375: [FLINK-13159] Prevent potential NPE of restored PojoSerializer when deserializing

2019-08-06 Thread GitBox
Myasuka opened a new pull request #9375: [FLINK-13159] Prevent potential NPE of restored PojoSerializer when deserializing URL: https://github.com/apache/flink/pull/9375 ## What is the purpose of the change Prevent potential NPE when PojoSerializer restored. ## Brief change lo

[jira] [Resolved] (FLINK-12928) Remove old Flink ML docs

2019-08-06 Thread Seth Wiesman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-12928. -- Resolution: Fixed > Remove old Flink ML docs > > > Ke

[jira] [Updated] (FLINK-12928) Remove old Flink ML docs

2019-08-06 Thread Seth Wiesman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-12928: - Fix Version/s: 1.9.0 > Remove old Flink ML docs > > > K

[jira] [Comment Edited] (FLINK-13517) Restructure Hive Catalog documentation

2019-08-06 Thread Seth Wiesman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901353#comment-16901353 ] Seth Wiesman edited comment on FLINK-13517 at 8/6/19 6:36 PM:

[jira] [Commented] (FLINK-13601) RegionFailoverITCase is unstable

2019-08-06 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901363#comment-16901363 ] Yun Tang commented on FLINK-13601: -- [~aljoscha] After looking up the [detail log|https

[jira] [Comment Edited] (FLINK-13548) Support priority of the Flink YARN application

2019-08-06 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901356#comment-16901356 ] Rong Rong edited comment on FLINK-13548 at 8/6/19 6:30 PM: --- I

  1   2   3   4   5   6   7   8   >