[jira] [Created] (FLINK-15432) JDBCOutputFormat add flushInterval just like JDBCUpsertOutputFormat

2019-12-27 Thread xiaodao (Jira)
xiaodao created FLINK-15432: --- Summary: JDBCOutputFormat add flushInterval just like JDBCUpsertOutputFormat Key: FLINK-15432 URL: https://issues.apache.org/jira/browse/FLINK-15432 Project: Flink I

[GitHub] [flink] flinkbot edited a comment on issue #10711: [hotfix][docs] Fix a typo in [flink-example] - CollectionExecutionExample.java

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10711: [hotfix][docs] Fix a typo in [flink-example] - CollectionExecutionExample.java URL: https://github.com/apache/flink/pull/10711#issuecomment-569393203 ## CI report: * 286126c476bc24bace36cc84ce7e284ab7b4e741 Travis: [PENDING](https://tra

[GitHub] [flink] flinkbot commented on issue #10712: [FLINK-15389][Connectors/flink-jdbc] JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1

2019-12-27 Thread GitBox
flinkbot commented on issue #10712: [FLINK-15389][Connectors/flink-jdbc] JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1 URL: https://github.com/apache/flink/pull/10712#issuecomment-569394891 Thanks a lot for your contribution to the Apache Flink project. I'm t

[jira] [Updated] (FLINK-15389) JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1

2019-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15389: --- Labels: pull-request-available (was: ) > JDBCUpsertOutputFormat no need to create schedule

[GitHub] [flink] zoudaokoulife opened a new pull request #10712: [FLINK-15389][Connectors/flink-jdbc] JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1

2019-12-27 Thread GitBox
zoudaokoulife opened a new pull request #10712: [FLINK-15389][Connectors/flink-jdbc] JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1 URL: https://github.com/apache/flink/pull/10712 ## What is the purpose of the change JDBCUpsertOutputFormat no need to c

[GitHub] [flink] flinkbot commented on issue #10711: [hotfix][docs] Fix a typo in [flink-example] - CollectionExecutionExample.java

2019-12-27 Thread GitBox
flinkbot commented on issue #10711: [hotfix][docs] Fix a typo in [flink-example] - CollectionExecutionExample.java URL: https://github.com/apache/flink/pull/10711#issuecomment-569393203 ## CI report: * 286126c476bc24bace36cc84ce7e284ab7b4e741 UNKNOWN Bot commands

[jira] [Updated] (FLINK-15430) Fix Java 64K method compiling limitation for blink planner.

2019-12-27 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-15430: --- Component/s: Table SQL / Planner > Fix Java 64K method compiling limitation for blink planner. > ---

[jira] [Created] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2019-12-27 Thread Benchao Li (Jira)
Benchao Li created FLINK-15431: -- Summary: Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator Key: FLINK-15431 URL: https://issues.apache.org/jira/browse/FLINK-15431 Project:

[jira] [Commented] (FLINK-15430) Fix Java 64K method compiling limitation for blink planner.

2019-12-27 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004409#comment-17004409 ] Benchao Li commented on FLINK-15430: I know that current fix is not perfect, just fi

[jira] [Updated] (FLINK-15430) Fix Java 64K method compiling limitation for blink planner.

2019-12-27 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-15430: --- Description: Our SQL is migrated from 1.5 to 1.9, and from legacy planner to blink planner. We find

[jira] [Created] (FLINK-15430) Fix Java 64K method compiling limitation for blink planner.

2019-12-27 Thread Benchao Li (Jira)
Benchao Li created FLINK-15430: -- Summary: Fix Java 64K method compiling limitation for blink planner. Key: FLINK-15430 URL: https://issues.apache.org/jira/browse/FLINK-15430 Project: Flink Issu

[GitHub] [flink] flinkbot commented on issue #10711: [hotfix][docs] Fix a typo in [flink-example] - CollectionExecutionExample.java

2019-12-27 Thread GitBox
flinkbot commented on issue #10711: [hotfix][docs] Fix a typo in [flink-example] - CollectionExecutionExample.java URL: https://github.com/apache/flink/pull/10711#issuecomment-569391263 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] wangxianghu opened a new pull request #10711: [hotfix][docs] Fix a typo in [flink-example] - CollectionExecutionExample.java

2019-12-27 Thread GitBox
wangxianghu opened a new pull request #10711: [hotfix][docs] Fix a typo in [flink-example] - CollectionExecutionExample.java URL: https://github.com/apache/flink/pull/10711 ## What is the purpose of the change *Fix a typo in [flink-example] - CollectionExecutionExample.java* #

[GitHub] [flink] flinkbot edited a comment on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section URL: https://github.com/apache/flink/pull/10710#issuecomment-569382162 ## CI report: * 2515369f9f288d23e53ff933b698a998aebd9a42 Travis: [SUCCESS](https:

[jira] [Resolved] (FLINK-15426) TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15426. - Resolution: Fixed Fixed in 1.11.0: 450795ecbfd40d1f39df0769440bbfcb5abbcc93 1.10.0: 3d88f711bfadb9e48d5a

[GitHub] [flink] flinkbot edited a comment on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section URL: https://github.com/apache/flink/pull/10710#issuecomment-569382162 ## CI report: * 2515369f9f288d23e53ff933b698a998aebd9a42 Travis: [SUCCESS](https:

[GitHub] [flink] flinkbot edited a comment on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section URL: https://github.com/apache/flink/pull/10710#issuecomment-569382162 ## CI report: * 2515369f9f288d23e53ff933b698a998aebd9a42 Travis: [PENDING](https:

[GitHub] [flink] wuchong merged pull request #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread GitBox
wuchong merged pull request #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis URL: https://github.com/apache/flink/pull/10707 This is an automated message from the Apache Git Service. To r

[GitHub] [flink] wuchong commented on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread GitBox
wuchong commented on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis URL: https://github.com/apache/flink/pull/10707#issuecomment-569382258 Verified TPC-DS are all passed in my local machine. Merging it for hotfix. --

[GitHub] [flink] flinkbot commented on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section

2019-12-27 Thread GitBox
flinkbot commented on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section URL: https://github.com/apache/flink/pull/10710#issuecomment-569382162 ## CI report: * 2515369f9f288d23e53ff933b698a998aebd9a42 UNKNOWN Bot commands

[jira] [Resolved] (FLINK-15413) ScalarOperatorsTest failed in travis

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15413. - Resolution: Fixed Fixed in 1.9.2: 025aca82a541d838101d14de5190111597c6db83 > ScalarOperatorsTest failed

[GitHub] [flink] wuchong merged pull request #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch

2019-12-27 Thread GitBox
wuchong merged pull request #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch URL: https://github.com/apache/flink/pull/10708 This is an automated message from the Apache Git S

[GitHub] [flink] wuchong commented on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch

2019-12-27 Thread GitBox
wuchong commented on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch URL: https://github.com/apache/flink/pull/10708#issuecomment-569382047 Tests are passed except `LocalExecutorITCase.testParameterizedTypes` which will be fixed by FL

[GitHub] [flink] flinkbot commented on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section

2019-12-27 Thread GitBox
flinkbot commented on issue #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section URL: https://github.com/apache/flink/pull/10710#issuecomment-569380059 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] libenchao opened a new pull request #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section

2019-12-27 Thread GitBox
libenchao opened a new pull request #10710: [hotfix][doc] Fix temporal_tables correlate with a changing dimension table section URL: https://github.com/apache/flink/pull/10710 ## What is the purpose of the change Fix doc temporal_tables, correlate with a changing dimension table sec

[jira] [Commented] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

2019-12-27 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004342#comment-17004342 ] Bowen Li commented on FLINK-15411: -- yes, date is probably the most popular partition ty

[jira] [Updated] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

2019-12-27 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15411: - Fix Version/s: 1.11.0 > Planner can't prune partition on DATE/TIMESTAMP columns > --

[GitHub] [flink] sjwiesman commented on issue #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability

2019-12-27 Thread GitBox
sjwiesman commented on issue #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#issuecomment-569356922 Please add a redirect from the old sql page to the new overview page. --

[GitHub] [flink] qinjunjerry commented on a change in pull request #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

2019-12-27 Thread GitBox
qinjunjerry commented on a change in pull request #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#discussion_r361751039 ## File path: docs/dev/libs/state_processor_api.md ## @@ -413,

[GitHub] [flink] qinjunjerry commented on a change in pull request #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

2019-12-27 Thread GitBox
qinjunjerry commented on a change in pull request #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#discussion_r361525469 ## File path: docs/dev/libs/state_processor_api.md ## @@ -239,

[GitHub] [flink] flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 Travis: [FAILURE](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 Travis: [FAILURE](https:/

[jira] [Closed] (FLINK-14849) Fix documentation about Hive dependencies

2019-12-27 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14849. Fix Version/s: 1.11.0 Resolution: Fixed master: 28b6221aaaeb535afa728bb887e733b6576982a7 1.10: 7ada

[GitHub] [flink] bowenli86 closed pull request #10681: [FLINK-14849][hive][doc] Fix documentation about Hive dependencies

2019-12-27 Thread GitBox
bowenli86 closed pull request #10681: [FLINK-14849][hive][doc] Fix documentation about Hive dependencies URL: https://github.com/apache/flink/pull/10681 This is an automated message from the Apache Git Service. To respond to

[jira] [Closed] (FLINK-15412) LocalExecutorITCase#testParameterizedTypes failed in travis

2019-12-27 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15412. Resolution: Fixed release-1.9: baeb9b38bfef4b39f12bc7fe3934e140b3926698 > LocalExecutorITCase#testParamet

[GitHub] [flink] bowenli86 closed pull request #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed…

2019-12-27 Thread GitBox
bowenli86 closed pull request #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed… URL: https://github.com/apache/flink/pull/10702 This is an automated message from the Apache Git Service. To respon

[GitHub] [flink] bowenli86 commented on issue #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed…

2019-12-27 Thread GitBox
bowenli86 commented on issue #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed… URL: https://github.com/apache/flink/pull/10702#issuecomment-569318004 release-1.9: baeb9b38bfef4b39f12bc7fe3934e140b3926698 -

[GitHub] [flink] bowenli86 commented on issue #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed…

2019-12-27 Thread GitBox
bowenli86 commented on issue #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed… URL: https://github.com/apache/flink/pull/10702#issuecomment-569317916 @lirui-apache thanks for the fix! This is an a

[jira] [Closed] (FLINK-15189) Add documentation for hive view

2019-12-27 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15189. Fix Version/s: 1.11.0 Resolution: Fixed master: 2e0ba5d92750ab21273f8dc15ae7051c431f4eb7 1.10: a87b

[GitHub] [flink] bowenli86 closed pull request #10701: [FLINK-15189][hive][doc] Add documentation for hive view

2019-12-27 Thread GitBox
bowenli86 closed pull request #10701: [FLINK-15189][hive][doc] Add documentation for hive view URL: https://github.com/apache/flink/pull/10701 This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 Travis: [FAILURE](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-569310266 ## CI report: * 31cc4b771858ddf31a5cc19f2d3257b38f944825 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/1424

[GitHub] [flink] flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 Travis: [FAILURE](https:/

[GitHub] [flink] flinkbot commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

2019-12-27 Thread GitBox
flinkbot commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-569310266 ## CI report: * 31cc4b771858ddf31a5cc19f2d3257b38f944825 UNKNOWN Bot commands The @flinkbot bot supports the followi

[jira] [Commented] (FLINK-15416) Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel

2019-12-27 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004273#comment-17004273 ] Zhenqiu Huang commented on FLINK-15416: --- [~pnowojski] Would you please review this

[GitHub] [flink] flinkbot edited a comment on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis URL: https://github.com/apache/flink/pull/10707#issuecomment-569288086 ## CI report: * 67c35de0fffa00011edb3c8c54b3fe0bae50155f Travis: [SUCCESS](https://trav

[GitHub] [flink] flinkbot edited a comment on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch URL: https://github.com/apache/flink/pull/10708#issuecomment-569293648 ## CI report: * aadfc4f8b17404c0d22d12c1c95d4591ffe86617 Travis: [FAILURE](

[GitHub] [flink] zjuwangg commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

2019-12-27 Thread GitBox
zjuwangg commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-569303511 It's a base work, and we can add more ITCase based on this PR. This is an aut

[GitHub] [flink] flinkbot commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

2019-12-27 Thread GitBox
flinkbot commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-569303649 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 wil

[GitHub] [flink] zjuwangg commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

2019-12-27 Thread GitBox
zjuwangg commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-569303439 cc @bowenli86 @xuefuz @JingsongLi @KurtYoung @lirui-apache to have a review T

[jira] [Updated] (FLINK-13437) Add Hive SQL E2E test

2019-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13437: --- Labels: pull-request-available (was: ) > Add Hive SQL E2E test > - > >

[GitHub] [flink] zjuwangg opened a new pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

2019-12-27 Thread GitBox
zjuwangg opened a new pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709 ## What is the purpose of the change Set up a docker-based yarn-cluster and hive service using the new java based test runtime framework, add HiveConnecto

[GitHub] [flink] walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-12-27 Thread GitBox
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r361699910 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetCon

[GitHub] [flink] walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-12-27 Thread GitBox
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r361699849 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetCon

[GitHub] [flink] walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-12-27 Thread GitBox
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r361699961 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetCon

[GitHub] [flink] walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-12-27 Thread GitBox
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r361700199 ## File path: flink-ml-parent/flink-ml-lib/src/test/java/org/apache/flink/ml/common/utils/DataStream

[jira] [Assigned] (FLINK-15427) State TTL RocksDb backend end-to-end test stalls on travis

2019-12-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-15427: --- Assignee: Congxian Qiu(klion26) > State TTL RocksDb backend end-to-end test stalls on travis >

[GitHub] [flink] flinkbot edited a comment on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch URL: https://github.com/apache/flink/pull/10708#issuecomment-569293648 ## CI report: * aadfc4f8b17404c0d22d12c1c95d4591ffe86617 Travis: [PENDING](

[GitHub] [flink] flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 Travis: [FAILURE](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis URL: https://github.com/apache/flink/pull/10707#issuecomment-569288086 ## CI report: * 67c35de0fffa00011edb3c8c54b3fe0bae50155f Travis: [PENDING](https://trav

[GitHub] [flink] flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 Travis: [FAILURE](https:/

[GitHub] [flink] flinkbot commented on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch

2019-12-27 Thread GitBox
flinkbot commented on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch URL: https://github.com/apache/flink/pull/10708#issuecomment-569293648 ## CI report: * aadfc4f8b17404c0d22d12c1c95d4591ffe86617 UNKNOWN Bot com

[GitHub] [flink] flinkbot commented on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread GitBox
flinkbot commented on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis URL: https://github.com/apache/flink/pull/10707#issuecomment-569288086 ## CI report: * 67c35de0fffa00011edb3c8c54b3fe0bae50155f UNKNOWN Bot commands T

[GitHub] [flink] flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 Travis: [FAILURE](https:/

[jira] [Reopened] (FLINK-15408) Interval join support no equi-condition

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reopened FLINK-15408: - Assignee: hailong wang > Interval join support no equi-condition > ---

[GitHub] [flink] flinkbot commented on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch

2019-12-27 Thread GitBox
flinkbot commented on issue #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch URL: https://github.com/apache/flink/pull/10708#issuecomment-569287214 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink…

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink… URL: https://github.com/apache/flink/pull/10625#issuecomment-567374884 ## CI report: * b200938f6abf4bac5e929db791c52289d110054e Travis: [FAILURE](https://travis-ci.c

[jira] [Updated] (FLINK-15413) ScalarOperatorsTest failed in travis

2019-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15413: --- Labels: pull-request-available (was: ) > ScalarOperatorsTest failed in travis > ---

[GitHub] [flink] wuchong opened a new pull request #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch

2019-12-27 Thread GitBox
wuchong opened a new pull request #10708: [FLINK-15413][table-planner-blink] Fix ScalarOperatorsTest failed in travis in 1.9 branch URL: https://github.com/apache/flink/pull/10708 ## What is the purpose of the change `ScalarOperatorsTest` is failed because we use `CASE WH

[jira] [Commented] (FLINK-15426) TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004233#comment-17004233 ] Jark Wu commented on FLINK-15426: - The root cause is: {code} Caused by: org.apache.fli

[GitHub] [flink] flinkbot commented on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread GitBox
flinkbot commented on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis URL: https://github.com/apache/flink/pull/10707#issuecomment-569283995 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] wuchong opened a new pull request #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread GitBox
wuchong opened a new pull request #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis URL: https://github.com/apache/flink/pull/10707 ## What is the purpose of the change FLINK-15313 forbids to use TypeInformation defined in blink planner

[jira] [Updated] (FLINK-15426) TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15426: --- Labels: pull-request-available test-stability (was: test-stability) > TPC-DS end-to-end tes

[GitHub] [flink] wuchong commented on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis

2019-12-27 Thread GitBox
wuchong commented on issue #10707: [FLINK-15426][e2e] Fix TPC-DS end-to-end test (Blink planner) fails on travis URL: https://github.com/apache/flink/pull/10707#issuecomment-569283633 cc @JingsongLi @leonardBang This is an a

[GitHub] [flink] flinkbot edited a comment on issue #10705: [FLINK-15346][connectors / filesystem] Support treat empty column as null option in CsvTableSourceFactory

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10705: [FLINK-15346][connectors / filesystem] Support treat empty column as null option in CsvTableSourceFactory URL: https://github.com/apache/flink/pull/10705#issuecomment-569245359 ## CI report: * 825a2c9773fca40aeb85d056aec0e177a2ba9319 Tra

[jira] [Updated] (FLINK-15429) read hive table null value of timestamp type will throw an npe

2019-12-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15429: - Priority: Blocker (was: Major) > read hive table null value of timestamp type will throw an npe

[GitHub] [flink] flinkbot edited a comment on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink…

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink… URL: https://github.com/apache/flink/pull/10625#issuecomment-567374884 ## CI report: * b200938f6abf4bac5e929db791c52289d110054e Travis: [FAILURE](https://travis-ci.c

[jira] [Assigned] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15409: --- Assignee: hailong wang > Add semicolon to WindowJoinUtil#generateJoinFunction > '$collectorTerm.co

[jira] [Commented] (FLINK-15408) Interval join support no equi-condition

2019-12-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004201#comment-17004201 ] hailong wang commented on FLINK-15408: -- Oh [~jark], I got it wrong :D. Thank you fo

[GitHub] [flink] flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 Travis: [FAILURE](https:/

[jira] [Commented] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004200#comment-17004200 ] hailong wang commented on FLINK-15409: -- Hi [~jark], It is my pleasure to take it. T

[GitHub] [flink] wangxianghu closed pull request #10691: [hotfix] [javadocs] Fix typo in DistCp and CollectionExecutionExample

2019-12-27 Thread GitBox
wangxianghu closed pull request #10691: [hotfix] [javadocs] Fix typo in DistCp and CollectionExecutionExample URL: https://github.com/apache/flink/pull/10691 This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] flinkbot edited a comment on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink…

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink… URL: https://github.com/apache/flink/pull/10625#issuecomment-567374884 ## CI report: * b200938f6abf4bac5e929db791c52289d110054e Travis: [FAILURE](https://travis-ci.c

[jira] [Commented] (FLINK-15399) Join with a LookupableTableSource:java.lang.RuntimeException: while converting XXXX Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004194#comment-17004194 ] Jark Wu commented on FLINK-15399: - Thanks for reporting this [~Rockey Cui], I reproduced

[jira] [Updated] (FLINK-15399) Join with a LookupableTableSource:java.lang.RuntimeException: while converting XXXX Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15399: Fix Version/s: 1.10.0 > Join with a LookupableTableSource:java.lang.RuntimeException: while > converting

[GitHub] [flink] flinkbot edited a comment on issue #10705: [FLINK-15346][connectors / filesystem] Support treat empty column as null option in CsvTableSourceFactory

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10705: [FLINK-15346][connectors / filesystem] Support treat empty column as null option in CsvTableSourceFactory URL: https://github.com/apache/flink/pull/10705#issuecomment-569245359 ## CI report: * 825a2c9773fca40aeb85d056aec0e177a2ba9319 Tra

[GitHub] [flink] flinkbot commented on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule

2019-12-27 Thread GitBox
flinkbot commented on issue #10706: [FLINK-15418][table-planner-blink] Set FlinkRelDistribution in StreamExecMatchRule URL: https://github.com/apache/flink/pull/10706#issuecomment-569270452 ## CI report: * daaa89195ca2ff2cc09823f6f8505b99b9010997 UNKNOWN Bot commands

[jira] [Commented] (FLINK-15419) Validate SQL syntax not need to depend on connector jar

2019-12-27 Thread baijingjing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004189#comment-17004189 ] baijingjing commented on FLINK-15419: - * There is currently no exposed method for sq

[GitHub] [flink] flinkbot edited a comment on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink…

2019-12-27 Thread GitBox
flinkbot edited a comment on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink… URL: https://github.com/apache/flink/pull/10625#issuecomment-567374884 ## CI report: * b200938f6abf4bac5e929db791c52289d110054e Travis: [FAILURE](https://travis-ci.c

[jira] [Commented] (FLINK-15230) flink1.9.1 table API JSON schema array type exception

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004188#comment-17004188 ] Jark Wu commented on FLINK-15230: - Could you try {{new Json().deriveSchema()}} + {{new

[jira] [Assigned] (FLINK-15425) update outdated document of Filesystem connector and csv format in Connect to External Systems

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15425: --- Assignee: Leonard Xu > update outdated document of Filesystem connector and csv format in Connect t

[jira] [Updated] (FLINK-15412) LocalExecutorITCase#testParameterizedTypes failed in travis

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15412: Fix Version/s: (was: 1.10.0) 1.9.2 > LocalExecutorITCase#testParameterizedTypes fai

[jira] [Updated] (FLINK-15425) update outdated document of Filesystem connector and csv format in Connect to External Systems

2019-12-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15425: --- Description: Document of Connect to External Systems is outdated and is easy to mislead users. fro

[jira] [Assigned] (FLINK-15412) LocalExecutorITCase#testParameterizedTypes failed in travis

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15412: --- Assignee: Rui Li > LocalExecutorITCase#testParameterizedTypes failed in travis > --

[jira] [Assigned] (FLINK-15413) ScalarOperatorsTest failed in travis

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15413: --- Assignee: Jark Wu > ScalarOperatorsTest failed in travis > > >

[GitHub] [flink] lirui-apache commented on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink…

2019-12-27 Thread GitBox
lirui-apache commented on issue #10625: [FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink… URL: https://github.com/apache/flink/pull/10625#issuecomment-569266869 @JingsongLi @bowenli86 I have updated to use writable OIs for constant arguments, so that we don't need to o

[jira] [Updated] (FLINK-15425) update outdated document of Filesystem connector and csv format in Connect to External Systems

2019-12-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15425: --- Summary: update outdated document of Filesystem connector and csv format in Connect to External Syst

[jira] [Commented] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004180#comment-17004180 ] Jark Wu commented on FLINK-15409: - [~hailong wang] Good catch! Are you willing to contri

[jira] [Assigned] (FLINK-15420) Cast string to timestamp will loose precision

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15420: --- Assignee: Zhenghua Gao > Cast string to timestamp will loose precision > --

[jira] [Assigned] (FLINK-15418) StreamExecMatchRule not set FlinkRelDistribution

2019-12-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15418: --- Assignee: Benchao Li > StreamExecMatchRule not set FlinkRelDistribution > -

  1   2   3   >