[jira] [Updated] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-15421: --- Description: `TimestmapType` has two types of physical representation: `Timestamp` and

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

2019-12-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003976#comment-17003976 ] Benchao Li commented on FLINK-15418: [~jark] I've fixed this bug, could you help to verify and

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

2019-12-26 Thread GitBox
flinkbot commented on issue #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed… URL: https://github.com/apache/flink/pull/10702#issuecomment-569214736 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

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

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

[jira] [Commented] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003974#comment-17003974 ] Benchao Li commented on FLINK-15421: [~lzljs3620320] Sorry about the format of the code. Could you

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

2019-12-26 Thread GitBox
lirui-apache commented on issue #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed… URL: https://github.com/apache/flink/pull/10702#issuecomment-569214511 I'm just back porting FLINK-15240. cc @KurtYoung @bowenli86

[jira] [Commented] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003973#comment-17003973 ] Jingsong Lee commented on FLINK-15421: -- Thanks [~libenchao] for reporting. Can you format the code

[GitHub] [flink] lirui-apache opened a new pull request #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed…

2019-12-26 Thread GitBox
lirui-apache opened a new pull request #10702: [FLINK-15412][hive] LocalExecutorITCase#testParameterizedTypes failed… URL: https://github.com/apache/flink/pull/10702 … in travis ## What is the purpose of the change Fix LocalExecutorITCase#testParameterizedTypes in

[jira] [Updated] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-15421: --- Description: `TimestmapType` has two types of physical representation: `Timestamp` and

[jira] [Updated] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15421: - Component/s: Table SQL / Planner > GroupAggsHandler throws java.time.LocalDateTime cannot be

[jira] [Updated] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-15421: --- Description: `TimestmapType` has two types of physical representation: `Timestamp` and

[jira] [Updated] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15421: - Fix Version/s: 1.10.0 1.9.2 > GroupAggsHandler throws

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

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003950#comment-17003950 ] Jingsong Lee commented on FLINK-15420: -- CC: [~docete] > Cast string to timestamp will loose

[jira] [Commented] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003951#comment-17003951 ] Jingsong Lee commented on FLINK-15421: -- CC: [~docete] > GroupAggsHandler throws

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

2019-12-26 Thread GitBox
wuchong commented on issue #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#issuecomment-569213420 Hi @danny0405 , thanks for the suggestion. I agree with you. Many users don't understand what is DML and

[jira] [Updated] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-15421: --- Description: `TimestmapType` has two types of physical representation: `Timestamp` and

[jira] [Updated] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-15421: --- Description: `TimestmapType` has two types of physical representation: `Timestamp` and

[jira] [Created] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Benchao Li (Jira)
Benchao Li created FLINK-15421: -- Summary: GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp Key: FLINK-15421 URL: https://issues.apache.org/jira/browse/FLINK-15421

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

2019-12-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15420: Summary: Cast string to timestamp will loose precision Key: FLINK-15420 URL: https://issues.apache.org/jira/browse/FLINK-15420 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #10695: [FLINK-15377] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10695: [FLINK-15377] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#issuecomment-569014612 ## CI report: * 97ac65498d207e34e891dcd59c87b6a44f04bead Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10681: [FLINK-14849][hive][doc] Fix documentation about Hive dependencies

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10681: [FLINK-14849][hive][doc] Fix documentation about Hive dependencies URL: https://github.com/apache/flink/pull/10681#issuecomment-568831538 ## CI report: * 4347bedaf5a20884347af39baf197932238c6d24 Travis:

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

2019-12-26 Thread Kaibo Zhou (Jira)
Kaibo Zhou created FLINK-15419: -- Summary: Validate SQL syntax not need to depend on connector jar Key: FLINK-15419 URL: https://issues.apache.org/jira/browse/FLINK-15419 Project: Flink Issue

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

2019-12-26 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003944#comment-17003944 ] Rui Li commented on FLINK-15412: The failure was introduced since FLINK-15240 was not properly ported to

[GitHub] [flink] zjuwangg commented on issue #9919: [FLINK-13303][hive]add hive e2e connector test

2019-12-26 Thread GitBox
zjuwangg commented on issue #9919: [FLINK-13303][hive]add hive e2e connector test URL: https://github.com/apache/flink/pull/9919#issuecomment-569210087 I'll close this PR and open a new PR FLINK-13437 to cover this based on new Java based test framework.

[GitHub] [flink] zjuwangg closed pull request #9919: [FLINK-13303][hive]add hive e2e connector test

2019-12-26 Thread GitBox
zjuwangg closed pull request #9919: [FLINK-13303][hive]add hive e2e connector test URL: https://github.com/apache/flink/pull/9919 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Comment Edited] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003934#comment-17003934 ] Xintong Song edited comment on FLINK-15388 at 12/27/19 7:13 AM: One

[jira] [Comment Edited] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003934#comment-17003934 ] Xintong Song edited comment on FLINK-15388 at 12/27/19 7:12 AM: One

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003934#comment-17003934 ] Xintong Song commented on FLINK-15388: -- One thing draw my attention, it seems there are quite some

[GitHub] [flink] flinkbot edited a comment on issue #10695: [FLINK-15377] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10695: [FLINK-15377] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#issuecomment-569014612 ## CI report: * 97ac65498d207e34e891dcd59c87b6a44f04bead Travis:

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

2019-12-26 Thread Benchao Li (Jira)
Benchao Li created FLINK-15418: -- Summary: StreamExecMatchRule not set FlinkRelDistribution Key: FLINK-15418 URL: https://issues.apache.org/jira/browse/FLINK-15418 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-15414) KafkaITCase#prepare failed in travis

2019-12-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15414: Fix Version/s: 1.9.2 > KafkaITCase#prepare failed in travis > > >

[GitHub] [flink] lirui-apache commented on issue #10681: [FLINK-14849][hive][doc] Fix documentation about Hive dependencies

2019-12-26 Thread GitBox
lirui-apache commented on issue #10681: [FLINK-14849][hive][doc] Fix documentation about Hive dependencies URL: https://github.com/apache/flink/pull/10681#issuecomment-569205043 @bowenli86 PR updated to add the explanations.

[GitHub] [flink] JingsongLi commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders

2019-12-26 Thread GitBox
JingsongLi commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders URL: https://github.com/apache/flink/pull/10620#discussion_r361594049 ## File path:

[jira] [Commented] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

2019-12-26 Thread hiliuxg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003926#comment-17003926 ] hiliuxg commented on FLINK-15415: - Hi [~yunta]: Sorry, I don’t know if you can create a new question

[jira] [Created] (FLINK-15417) Remove the docker volume or mount when starting Mesos e2e cluster

2019-12-26 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-15417: -- Summary: Remove the docker volume or mount when starting Mesos e2e cluster Key: FLINK-15417 URL: https://issues.apache.org/jira/browse/FLINK-15417 Project: Flink

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15411: -- Assignee: Jingsong Lee (was: Rui Li) > Planner can't prune partition on DATE/TIMESTAMP

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003924#comment-17003924 ] Kurt Young edited comment on FLINK-15411 at 12/27/19 6:32 AM: -- Yeah, that

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003924#comment-17003924 ] Kurt Young commented on FLINK-15411: Yeah, that might also be true. Even if the want to partition

[GitHub] [flink] flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 Travis:

[GitHub] [flink] wuchong commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders

2019-12-26 Thread GitBox
wuchong commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders URL: https://github.com/apache/flink/pull/10620#discussion_r361592411 ## File path:

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

2019-12-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-15416: - Summary: Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel Key: FLINK-15416 URL: https://issues.apache.org/jira/browse/FLINK-15416 Project:

[jira] [Commented] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

2019-12-26 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003922#comment-17003922 ] Yun Tang commented on FLINK-15415: -- [~hiliuxg], generally speaking, it's not recommend to directly open

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

2019-12-26 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003920#comment-17003920 ] Rui Li commented on FLINK-15411: I find a lot of users using string partition columns to represent the

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

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003919#comment-17003919 ] Jingsong Lee commented on FLINK-15411: -- We did a simple survey. Most users use string to represent

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

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15411: - Description: Hive should work after planner fixed due to: 

[jira] [Commented] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

2019-12-26 Thread hiliuxg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003916#comment-17003916 ] hiliuxg commented on FLINK-15415: - Hi [~Benchao Li]: Thank you for following my question . I used the

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

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003913#comment-17003913 ] Jingsong Lee commented on FLINK-15411: -- [~ykt836] Can you assign this to me?  > Planner can't

[jira] [Commented] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

2019-12-26 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003912#comment-17003912 ] Yang Wang commented on FLINK-15415: --- Maybe it is a same case with 

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread hiliuxg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Attachment: 236log.7z > The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. >

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread hiliuxg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Attachment: 236log.7z > The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. >

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread hiliuxg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003911#comment-17003911 ] hiliuxg commented on FLINK-15388: - Hi [~xintongsong]: I ping taskmanager on the machine where the

[GitHub] [flink] wangyang0918 commented on a change in pull request #10695: [hotfix] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
wangyang0918 commented on a change in pull request #10695: [hotfix] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#discussion_r361574394 ## File path: flink-end-to-end-tests/test-scripts/docker-mesos-cluster/docker-compose.yml

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003909#comment-17003909 ] Kurt Young commented on FLINK-15412: cc [~lirui] > LocalExecutorITCase#testParameterizedTypes

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15412: --- Fix Version/s: 1.10.0 > LocalExecutorITCase#testParameterizedTypes failed in travis >

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003907#comment-17003907 ] Kurt Young commented on FLINK-15409: cc [~jark] [~jinyu.zj] > Add semicolon to

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15409: --- Affects Version/s: (was: 1.10.0) 1.9.1 > Add semicolon to

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15409: --- Fix Version/s: (was: 1.11.0) 1.10.0 1.9.2 > Add semicolon

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

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

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

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

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003905#comment-17003905 ] Kurt Young commented on FLINK-15411: IMO partition with DATE field maybe the most widely used in

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

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15413: --- Fix Version/s: 1.9.2 > ScalarOperatorsTest failed in travis >

[GitHub] [flink] JingsongLi commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders

2019-12-26 Thread GitBox
JingsongLi commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders URL: https://github.com/apache/flink/pull/10620#discussion_r361588690 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders

2019-12-26 Thread GitBox
JingsongLi commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders URL: https://github.com/apache/flink/pull/10620#discussion_r361588690 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 Travis:

[jira] [Commented] (FLINK-15343) Add Watermarks options for TwoInputStreamOperator

2019-12-26 Thread jocean.shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003898#comment-17003898 ] jocean.shi commented on FLINK-15343: [~aljoscha] As you're the author of method "processWatermark1" 

[jira] [Commented] (FLINK-15404) How to insert hive table for different catalog

2019-12-26 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003899#comment-17003899 ] hehuiyuan commented on FLINK-15404: --- Hi [~lzljs3620320] , thanks , I ingore to invoke the

[GitHub] [flink] lirui-apache commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders

2019-12-26 Thread GitBox
lirui-apache commented on a change in pull request #10620: [FLINK-15239][table-planner-blink] CompileUtils::COMPILED_CACHE leaks class loaders URL: https://github.com/apache/flink/pull/10620#discussion_r361588220 ## File path:

[jira] [Updated] (FLINK-15343) Add Watermarks options for TwoInputStreamOperator

2019-12-26 Thread jocean.shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jocean.shi updated FLINK-15343: --- Description:   Currently, The "TwoInputStreamOperator" such as "CoBroadcastWithKeyedOperator"

[jira] [Updated] (FLINK-15343) Add Watermarks options for TwoInputStreamOperator

2019-12-26 Thread jocean.shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jocean.shi updated FLINK-15343: --- Description:   Currently, The "TwoInputStreamOperator" such as "CoBroadcastWithKeyedOperator"

[jira] [Comment Edited] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread hiliuxg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003869#comment-17003869 ] hiliuxg edited comment on FLINK-15388 at 12/27/19 5:42 AM: --- Hi [~xintongsong]:

[GitHub] [flink] flinkbot edited a comment on issue #10695: [hotfix] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10695: [hotfix] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#issuecomment-569014612 ## CI report: * 97ac65498d207e34e891dcd59c87b6a44f04bead Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 Travis:

[GitHub] [flink] shidayang removed a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
shidayang removed a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-569178934 @flinkbot run travis This is an

[GitHub] [flink] shidayang removed a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
shidayang removed a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-569186927 @flinkbot run travis This is an

[GitHub] [flink] flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 Travis:

[GitHub] [flink] shidayang commented on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
shidayang commented on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-569186927 @flinkbot run travis This is an

[jira] [Updated] (FLINK-15391) DATE and TIMESTAMP partition columns don't work

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15391: --- Fix Version/s: (was: 1.11.0) > DATE and TIMESTAMP partition columns don't work >

[GitHub] [flink] danny0405 commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability

2019-12-26 Thread GitBox
danny0405 commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#discussion_r361579192 ## File path: docs/dev/table/sql/ddl.md ## @@ -0,0 +1,297 @@ +---

[GitHub] [flink] wuchong commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability

2019-12-26 Thread GitBox
wuchong commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#discussion_r361579079 ## File path: docs/dev/table/sql/ddl.md ## @@ -0,0 +1,297 @@ +--- +title:

[GitHub] [flink] flinkbot edited a comment on issue #10695: [hotfix] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10695: [hotfix] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#issuecomment-569014612 ## CI report: * 97ac65498d207e34e891dcd59c87b6a44f04bead Travis:

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

2019-12-26 Thread GitBox
danny0405 commented on issue #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#issuecomment-569184987 Thanks for refactoring this, the page looks much better now, i would suggest to split the page by specific

[GitHub] [flink] wuchong commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability

2019-12-26 Thread GitBox
wuchong commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#discussion_r361578824 ## File path: docs/dev/table/sql/ddl.md ## @@ -0,0 +1,297 @@ +--- +title:

[GitHub] [flink] danny0405 commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability

2019-12-26 Thread GitBox
danny0405 commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#discussion_r361578634 ## File path: docs/dev/table/sql/ddl.md ## @@ -0,0 +1,297 @@ +---

[GitHub] [flink] flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 Travis:

[GitHub] [flink] danny0405 commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability

2019-12-26 Thread GitBox
danny0405 commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#discussion_r361578477 ## File path: docs/dev/table/sql/ddl.md ## @@ -0,0 +1,297 @@ +---

[GitHub] [flink] danny0405 commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability

2019-12-26 Thread GitBox
danny0405 commented on a change in pull request #10669: [FLINK-15192][docs][table] Restructure "SQL" pages for better readability URL: https://github.com/apache/flink/pull/10669#discussion_r361578392 ## File path: docs/dev/table/sql/ddl.md ## @@ -0,0 +1,297 @@ +---

[jira] [Commented] (FLINK-15404) How to insert hive table for different catalog

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003879#comment-17003879 ] Jingsong Lee commented on FLINK-15404: -- [~hehuiyuan] You need invoke "tableEnv.execute" > How to

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003877#comment-17003877 ] Xintong Song commented on FLINK-15388: -- If you look at the log file, there are quite some

[jira] [Commented] (FLINK-15404) How to insert hive table for different catalog

2019-12-26 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003873#comment-17003873 ] hehuiyuan commented on FLINK-15404: --- Hi  [~lzljs3620320]  ,   that is not ok. My usage may be wrong.

[GitHub] [flink] wangyang0918 commented on a change in pull request #10695: [hotfix] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
wangyang0918 commented on a change in pull request #10695: [hotfix] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#discussion_r361574795 ## File path: flink-end-to-end-tests/test-scripts/docker-mesos-cluster/docker-compose.yml

[jira] [Commented] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

2019-12-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003870#comment-17003870 ] Benchao Li commented on FLINK-15415: what's your `-XX:MaxDirectMemory`'s value? and you can check

[GitHub] [flink] flinkbot edited a comment on issue #10695: [hotfix] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10695: [hotfix] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#issuecomment-569014612 ## CI report: * 97ac65498d207e34e891dcd59c87b6a44f04bead Travis:

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread hiliuxg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003869#comment-17003869 ] hiliuxg commented on FLINK-15388: - Hi [~xintongsong]: The problem reappears, the network is ok, the CPU

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

2019-12-26 Thread hiliuxg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Attachment: metrics.png > The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. >

[GitHub] [flink] flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 Travis:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10695: [hotfix] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
wangyang0918 commented on a change in pull request #10695: [hotfix] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#discussion_r361574795 ## File path: flink-end-to-end-tests/test-scripts/docker-mesos-cluster/docker-compose.yml

[GitHub] [flink] wangyang0918 commented on a change in pull request #10695: [hotfix] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
wangyang0918 commented on a change in pull request #10695: [hotfix] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#discussion_r361574394 ## File path: flink-end-to-end-tests/test-scripts/docker-mesos-cluster/docker-compose.yml

[GitHub] [flink] shidayang commented on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe…

2019-12-26 Thread GitBox
shidayang commented on issue #10651: [FLINK-15343][API/DataStream] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-569178934 @flinkbot run travis This is an

[jira] [Commented] (FLINK-15407) Add document to explain how to write a table with PK

2019-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003858#comment-17003858 ] Jingsong Lee commented on FLINK-15407: -- cc: [~jark] [~ykt836] > Add document to explain how to

[GitHub] [flink] flinkbot edited a comment on issue #10695: [hotfix] Remove the useless stage in Mesos dockerfile

2019-12-26 Thread GitBox
flinkbot edited a comment on issue #10695: [hotfix] Remove the useless stage in Mesos dockerfile URL: https://github.com/apache/flink/pull/10695#issuecomment-569014612 ## CI report: * 97ac65498d207e34e891dcd59c87b6a44f04bead Travis:

  1   2   3   4   >