[GitHub] [flink] flinkbot commented on pull request #15477: [FLINK-22099][table-planner-blink] Fix bug for semi/anti window join.

2021-04-01 Thread GitBox
flinkbot commented on pull request #15477: URL: https://github.com/apache/flink/pull/15477#issuecomment-812337208 ## CI report: * 68bacb55c3c718eddba8cf5596bf94c3e4931d40 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15479: [FLINK-19606][table-runtime-blink] Implement streaming window join operator

2021-04-01 Thread GitBox
flinkbot commented on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812337085 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15425: URL: https://github.com/apache/flink/pull/15425#issuecomment-809890369 ## CI report: * 1b248e49e4695b3ac7d21320a377fb74ff460687 Azure:

[jira] [Commented] (FLINK-22101) PyFlinkBatchUserDefinedTableFunctionTests fail

2021-04-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313596#comment-17313596 ] Dian Fu commented on FLINK-22101: - [~maguowei] Thanks for reporting this issue. It may be caused by the

[jira] [Assigned] (FLINK-20230) INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-20230: -- Assignee: Jingsong Lee > INSERT INTO EMPTY VALUES, THROW FileNotFoundException >

[jira] [Assigned] (FLINK-19066) InnerJoinITCase.testBigForSpill failed with "java.lang.ClassCastException: org.apache.flink.table.runtime.util.ResettableExternalBuffer$BufferIterator cannot be cast to

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-19066: -- Assignee: Caizhi Weng > InnerJoinITCase.testBigForSpill failed with

[GitHub] [flink] flinkbot edited a comment on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15280: URL: https://github.com/apache/flink/pull/15280#issuecomment-802654466 ## CI report: * 3b4b5fcd9d8108b51e0bf62a0bee888b4fdb5186 UNKNOWN * 4dbc85669c36e06a1e42378c592f09627874b0ce Azure:

[jira] [Closed] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type

2021-04-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-14036. -- Resolution: Won't Fix > function log(f0,f1) in Table API do not support decimal type >

[jira] [Updated] (FLINK-14875) Blink planner should pass the right ExecutionConfig to the creation of serializer

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14875: --- Fix Version/s: (was: 1.13.0) > Blink planner should pass the right ExecutionConfig to the

[GitHub] [flink] lirui-apache commented on pull request #15151: [FLINK-21727][hive] Support DDL in HiveParser

2021-04-01 Thread GitBox
lirui-apache commented on pull request #15151: URL: https://github.com/apache/flink/pull/15151#issuecomment-812336556 Hey @wangqinghuan , thanks for trying out this feature and reporting the issue. Hive dialect doesn't support hive's storage handler table. That's mainly because hive

[jira] [Closed] (FLINK-19074) Materialize timeindicator in the right input of temporal join

2021-04-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19074. -- Resolution: Implemented > Materialize timeindicator in the right input of temporal join >

[jira] [Assigned] (FLINK-17803) Should throw a readable exception when group by Map type

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17803: -- Assignee: Jingsong Lee > Should throw a readable exception when group by Map type >

[jira] [Assigned] (FLINK-20722) HiveTableSink should copy the record when converting RowData to Row

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20722: --- Assignee: godfrey he (was: Godfrey He) > HiveTableSink should copy the record when converting

[jira] [Commented] (FLINK-20722) HiveTableSink should copy the record when converting RowData to Row

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313592#comment-17313592 ] Jark Wu commented on FLINK-20722: - Yes. Assigned to you [~godfreyhe]. > HiveTableSink should copy the

[jira] [Assigned] (FLINK-20747) ClassCastException when using MAX aggregate function

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-20747: -- Assignee: Jingsong Lee > ClassCastException when using MAX aggregate function >

[jira] [Assigned] (FLINK-20722) HiveTableSink should copy the record when converting RowData to Row

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20722: --- Assignee: Godfrey He > HiveTableSink should copy the record when converting RowData to Row >

[jira] [Closed] (FLINK-19075) Infer changelog trait for temporal join node

2021-04-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19075. -- Resolution: Not A Problem > Infer changelog trait for temporal join node >

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

2021-04-01 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313589#comment-17313589 ] Guowei Ma commented on FLINK-22085: ---

[jira] [Assigned] (FLINK-22082) Nested projection push down doesn't work for data such as row(array(row))

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-22082: -- Assignee: Jark Wu > Nested projection push down doesn't work for data such as

[jira] [Assigned] (FLINK-22075) Incorrect null outputs in left join

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-22075: -- Assignee: Jingsong Lee > Incorrect null outputs in left join >

[jira] [Assigned] (FLINK-21516) UpsertKafkaTableITCase.testTemporalJoin fails on AZP

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-21516: -- Assignee: Leonard Xu > UpsertKafkaTableITCase.testTemporalJoin fails on AZP >

[jira] [Assigned] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-20975: -- Assignee: Rui Li > HiveTableSourceITCase.testPartitionFilter fails on AZP >

[GitHub] [flink] beyond1920 opened a new pull request #15479: [FLINK-19606][table-runtime-blink] Implement streaming window join operator

2021-04-01 Thread GitBox
beyond1920 opened a new pull request #15479: URL: https://github.com/apache/flink/pull/15479 ## What is the purpose of the change The pull request aims to implement streaming window join operator ## Brief change log - Introduce `WindowJoinOperator` and

[GitHub] [flink] dianfu commented on a change in pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

2021-04-01 Thread GitBox
dianfu commented on a change in pull request #15441: URL: https://github.com/apache/flink/pull/15441#discussion_r606080031 ## File path: flink-python/pyflink/datastream/checkpoint_storage.py ## @@ -0,0 +1,356 @@

[jira] [Commented] (FLINK-22101) PyFlinkBatchUserDefinedTableFunctionTests fail

2021-04-01 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313584#comment-17313584 ] Guowei Ma commented on FLINK-22101: --- cc [~dianfu] > PyFlinkBatchUserDefinedTableFunctionTests fail >

[jira] [Created] (FLINK-22101) PyFlinkBatchUserDefinedTableFunctionTests fail

2021-04-01 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22101: - Summary: PyFlinkBatchUserDefinedTableFunctionTests fail Key: FLINK-22101 URL: https://issues.apache.org/jira/browse/FLINK-22101 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-21063) ElasticsearchSinkITCase fails while setting up ES cluster

2021-04-01 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313582#comment-17313582 ] Guowei Ma commented on FLINK-21063: --- just for report

[jira] [Commented] (FLINK-22100) BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds

2021-04-01 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313580#comment-17313580 ] Guowei Ma commented on FLINK-22100: --- cc [~lzljs3620320] >

[jira] [Assigned] (FLINK-22095) Creating python release binaries does not work

2021-04-01 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-22095: Assignee: Huang Xingbo > Creating python release binaries does not work >

[GitHub] [flink] dianfu edited a comment on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

2021-04-01 Thread GitBox
dianfu edited a comment on pull request #15441: URL: https://github.com/apache/flink/pull/15441#issuecomment-812328762 @sjwiesman Sure. I'll take a look asap! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Created] (FLINK-22100) BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds

2021-04-01 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22100: - Summary: BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds Key: FLINK-22100 URL: https://issues.apache.org/jira/browse/FLINK-22100

[GitHub] [flink] dianfu commented on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

2021-04-01 Thread GitBox
dianfu commented on pull request #15441: URL: https://github.com/apache/flink/pull/15441#issuecomment-812328762 @sjwiesman I'll take a look asap! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot commented on pull request #15478: [FLINK-22095][python] Remove bundled licenses in apache-flink distributed package

2021-04-01 Thread GitBox
flinkbot commented on pull request #15478: URL: https://github.com/apache/flink/pull/15478#issuecomment-812326255 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22095) Creating python release binaries does not work

2021-04-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22095: --- Labels: pull-request-available (was: ) > Creating python release binaries does not work >

[GitHub] [flink] HuangXingBo commented on pull request #15478: [FLINK-22095][python] Remove bundled licenses in apache-flink distributed package

2021-04-01 Thread GitBox
HuangXingBo commented on pull request #15478: URL: https://github.com/apache/flink/pull/15478#issuecomment-812325830 This change can only be tested in executing `create_binary_release.sh` and I have tested manually -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] HuangXingBo opened a new pull request #15478: [FLINK-22095][python] Remove bundled licenses in apache-flink distributed package

2021-04-01 Thread GitBox
HuangXingBo opened a new pull request #15478: URL: https://github.com/apache/flink/pull/15478 ## What is the purpose of the change *This pull request will remove bundled licenses in apache-flink distributed package since apache-flink has not bundled jars anymore* ## Brief

[GitHub] [flink] flinkbot commented on pull request #15477: [FLINK-22099][table-planner-blink] Fix bug for semi/anti window join.

2021-04-01 Thread GitBox
flinkbot commented on pull request #15477: URL: https://github.com/apache/flink/pull/15477#issuecomment-812323175 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22099) Fix bug for semi/anti window join.

2021-04-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22099: --- Labels: pull-request-available (was: ) > Fix bug for semi/anti window join. >

[GitHub] [flink] beyond1920 opened a new pull request #15477: [FLINK-22099][table-planner-blink] Fix bug for semi/anti window join.

2021-04-01 Thread GitBox
beyond1920 opened a new pull request #15477: URL: https://github.com/apache/flink/pull/15477 ## What is the purpose of the change Currently, when run a semi/anti window join query, an exception would be thrown out in the optimization phase. The pull request aims to fix the bug.

[jira] [Created] (FLINK-22099) Fix bug for semi/anti window join.

2021-04-01 Thread Andy (Jira)
Andy created FLINK-22099: Summary: Fix bug for semi/anti window join. Key: FLINK-22099 URL: https://issues.apache.org/jira/browse/FLINK-22099 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-22098) Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-22098: - Priority: Minor (was: Critical) > Fix bug for window join: plan is wrong if join condition contain 'IS NOT >

[GitHub] [flink] gaoyunhaii removed a comment on pull request #15466: [FLINK-22003][checkpointing] Prevent checkpoint from starting if any Source isn't running

2021-04-01 Thread GitBox
gaoyunhaii removed a comment on pull request #15466: URL: https://github.com/apache/flink/pull/15466#issuecomment-812311659 Very thanks @rkhachatryan for the fix! The PR looks good to me~ -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-812307606 ## CI report: * 3023dfa33790b3140a132fd2f76f56a2caad4a78 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15280: URL: https://github.com/apache/flink/pull/15280#issuecomment-802654466 ## CI report: * 3b4b5fcd9d8108b51e0bf62a0bee888b4fdb5186 UNKNOWN * 4dbc85669c36e06a1e42378c592f09627874b0ce Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #15466: [FLINK-22003][checkpointing] Prevent checkpoint from starting if any Source isn't running

2021-04-01 Thread GitBox
gaoyunhaii commented on pull request #15466: URL: https://github.com/apache/flink/pull/15466#issuecomment-812311659 Very thanks @rkhachatryan for the fix! The PR looks good to me~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] leonardBang commented on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

2021-04-01 Thread GitBox
leonardBang commented on pull request #15280: URL: https://github.com/apache/flink/pull/15280#issuecomment-812310037 @twalthr Thanks very much for your comments and advice that I should have opened another PR for some subtasks, I'll keep in mind later in next work. @twalthr @wuchong I

[GitHub] [flink] wangqinghuan edited a comment on pull request #15151: [FLINK-21727][hive] Support DDL in HiveParser

2021-04-01 Thread GitBox
wangqinghuan edited a comment on pull request #15151: URL: https://github.com/apache/flink/pull/15151#issuecomment-812307978 I want to use Flink to connect Hive external table Elasticsearch. Following code doesn't create hive external table correctly after merging this pr into my fork.

[GitHub] [flink] wangqinghuan commented on pull request #15151: [FLINK-21727][hive] Support DDL in HiveParser

2021-04-01 Thread GitBox
wangqinghuan commented on pull request #15151: URL: https://github.com/apache/flink/pull/15151#issuecomment-812307978 I want to use Flink to connect Hive external table Elasticsearch. Following code doesn't create hive external table correctly after merging this pr into my fork.

[GitHub] [flink] flinkbot commented on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread GitBox
flinkbot commented on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-812307606 ## CI report: * 3023dfa33790b3140a132fd2f76f56a2caad4a78 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-22097) testChangelogResultViewClearEmptyResult fail.

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-22097: -- Assignee: Shengkai Fang > testChangelogResultViewClearEmptyResult fail. >

[jira] [Commented] (FLINK-22097) testChangelogResultViewClearEmptyResult fail.

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313549#comment-17313549 ] Kurt Young commented on FLINK-22097: cc [~fsk119] > testChangelogResultViewClearEmptyResult fail. >

[jira] [Updated] (FLINK-22097) testChangelogResultViewClearEmptyResult fail.

2021-04-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22097: --- Fix Version/s: 1.13.0 > testChangelogResultViewClearEmptyResult fail. >

[GitHub] [flink] flinkbot edited a comment on pull request #15474: [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15474: URL: https://github.com/apache/flink/pull/15474#issuecomment-812157288 ## CI report: * 01f8f29d7f8551319390c7bacc00e5fa31156f29 Azure:

[GitHub] [flink] flinkbot commented on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread GitBox
flinkbot commented on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-812303438 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowDa

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15247: URL: https://github.com/apache/flink/pull/15247#issuecomment-800773807 ## CI report: * edea56a09944bb33e1e944de4daa5bbec751df21 Azure:

[GitHub] [flink] beyond1920 commented on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread GitBox
beyond1920 commented on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-812301751 cc @wuchong -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Commented] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

2021-04-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313546#comment-17313546 ] Yang Wang commented on FLINK-22006: --- [~trohrmann] I will attach a PR for this ticket today. > Could

[jira] [Updated] (FLINK-22098) Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22098: --- Labels: pull-request-available (was: ) > Fix bug for window join: plan is wrong if join

[jira] [Assigned] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

2021-04-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-22006: - Assignee: Yang Wang > Could not run more than 20 jobs in a native K8s session when K8s HA

[GitHub] [flink] beyond1920 opened a new pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread GitBox
beyond1920 opened a new pull request #15476: URL: https://github.com/apache/flink/pull/15476 ## What is the purpose of the change Now plan is wrong if window join contain 'IS NOT DISTINCT FROM'. This pull request aims to fix the bug. ## Brief change log - Fix bug

[jira] [Updated] (FLINK-22098) Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-22098: - Summary: Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM' (was: Fix bug

[jira] [Created] (FLINK-22098) Fix bug for window join: plan test is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-01 Thread Andy (Jira)
Andy created FLINK-22098: Summary: Fix bug for window join: plan test is wrong if join condition contain 'IS NOT DISTINCT FROM' Key: FLINK-22098 URL: https://issues.apache.org/jira/browse/FLINK-22098

[jira] [Commented] (FLINK-21742) Support REMOVE JAR statement in SQL Client

2021-04-01 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313541#comment-17313541 ] zoucao commented on FLINK-21742: hi [~jark], could you assign to me, if 'support add jar command in sql

[jira] [Commented] (FLINK-21986) taskmanager native memory not release timely after restart

2021-04-01 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313537#comment-17313537 ] Feifan Wang commented on FLINK-21986: - Hi [~yunta], I simplify test code and put it to 

[GitHub] [flink] flinkbot edited a comment on pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowDa

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15247: URL: https://github.com/apache/flink/pull/15247#issuecomment-800773807 ## CI report: * 39fe4b018466afba1557e9f4fa123a7ae6ea0fc2 Azure:

[jira] [Commented] (FLINK-21464) Support ADD JAR command in sql client

2021-04-01 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313535#comment-17313535 ] Shengkai Fang commented on FLINK-21464: --- Any progress? [~xiangtao] > Support ADD JAR command in

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * c25dc3f83e07adf4f0788d09201b03bfc8e92801 Azure:

[jira] [Updated] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name

2021-04-01 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-20887: Fix Version/s: (was: 1.13.0) > Non-deterministic functions return different values even if it

[jira] [Updated] (FLINK-21477) Lookup joins should deal with intermediate table scans containing just the table source correctly

2021-04-01 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-21477: Fix Version/s: (was: 1.12.3) (was: 1.13.0) > Lookup joins should deal

[jira] [Updated] (FLINK-21444) Lookup joins should deal with intermediate table scans correctly

2021-04-01 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-21444: Fix Version/s: (was: 1.13.0) > Lookup joins should deal with intermediate table scans

[jira] [Updated] (FLINK-22097) testChangelogResultViewClearEmptyResult fail.

2021-04-01 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22097: -- Description:

[jira] [Created] (FLINK-22097) testChangelogResultViewClearEmptyResult fail.

2021-04-01 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22097: - Summary: testChangelogResultViewClearEmptyResult fail. Key: FLINK-22097 URL: https://issues.apache.org/jira/browse/FLINK-22097 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20386: Fix Version/s: (was: 1.13.0) > ClassCastException when lookup join a JDBC table on INT UNSIGNED

[jira] [Closed] (FLINK-20463) flink-1.11.2 -sql cannot ignore exception record

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20463. --- Resolution: Not A Problem > flink-1.11.2 -sql cannot ignore exception record >

[jira] [Commented] (FLINK-20722) HiveTableSink should copy the record when converting RowData to Row

2021-04-01 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313531#comment-17313531 ] godfrey he commented on FLINK-20722: [~lirui] [~jark], we should use CopyingBroadcastingOutput if

[GitHub] [flink] flinkbot edited a comment on pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowDa

2021-04-01 Thread GitBox
flinkbot edited a comment on pull request #15247: URL: https://github.com/apache/flink/pull/15247#issuecomment-800773807 ## CI report: * 39fe4b018466afba1557e9f4fa123a7ae6ea0fc2 Azure:

[jira] [Commented] (FLINK-20538) sink.rolling-policy.file-size does not work in filesystem connector

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313530#comment-17313530 ] Jark Wu commented on FLINK-20538: - cc [~lzljs3620320] > sink.rolling-policy.file-size does not work in

[GitHub] [flink] zzfukai commented on pull request #15054: [FLINK-13550][rest][ui] Vertex Flame Graph

2021-04-01 Thread GitBox
zzfukai commented on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-812290062 Hi, I'm trying to navigate the flamegraph with the fresh commit, the "flamegraph" tab can show up, while the sever side responses `Unable to load requested file

[jira] [Commented] (FLINK-20549) New ExecutionContext doesn't inherit classloader from previous context

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313529#comment-17313529 ] Jark Wu commented on FLINK-20549: - cc [~fsk119] [~lirui] > New ExecutionContext doesn't inherit

[jira] [Updated] (FLINK-20549) New ExecutionContext doesn't inherit classloader from previous context

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20549: Fix Version/s: 1.13.0 > New ExecutionContext doesn't inherit classloader from previous context >

[jira] [Updated] (FLINK-20644) Check return type of ScalarFunction eval method shouldn't be void

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Fix Version/s: (was: 1.13.0) > Check return type of ScalarFunction eval method shouldn't be void >

[jira] [Commented] (FLINK-20722) HiveTableSink should copy the record when converting RowData to Row

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313528#comment-17313528 ] Jark Wu commented on FLINK-20722: - ping [~godfreyhe] > HiveTableSink should copy the record when

[jira] [Updated] (FLINK-20747) ClassCastException when using MAX aggregate function

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20747: Fix Version/s: 1.13.0 > ClassCastException when using MAX aggregate function >

[jira] [Updated] (FLINK-20747) ClassCastException when using MAX aggregate function

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20747: Fix Version/s: (was: 1.12.3) (was: 1.13.0) > ClassCastException when using MAX

[jira] [Commented] (FLINK-21963) ReactiveModelITCase.testScaleDownOnTaskManagerLoss failed / hangs

2021-04-01 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313527#comment-17313527 ] Guowei Ma commented on FLINK-21963: ---

[jira] [Assigned] (FLINK-20761) Cannot read hive table/partition whose location path contains comma

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20761: --- Assignee: Rui Li > Cannot read hive table/partition whose location path contains comma >

[jira] [Updated] (FLINK-20855) Calculating numBuckets exceeds the maximum value of int and got a negative number

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20855: Fix Version/s: (was: 1.14.0) 1.13.0 > Calculating numBuckets exceeds the maximum

[jira] [Commented] (FLINK-20855) Calculating numBuckets exceeds the maximum value of int and got a negative number

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313526#comment-17313526 ] Jark Wu commented on FLINK-20855: - cc [~lzljs3620320] > Calculating numBuckets exceeds the maximum

[jira] [Updated] (FLINK-20851) flink datagen produce NULL value

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20851: Fix Version/s: (was: 1.13.0) > flink datagen produce NULL value > >

[jira] [Assigned] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20887: --- Assignee: Caizhi Weng > Non-deterministic functions return different values even if it is referred

[jira] [Updated] (FLINK-20899) encounter ClassCastException when calculating cost in HepPlanner

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20899: Fix Version/s: (was: 1.13.0) > encounter ClassCastException when calculating cost in HepPlanner >

[jira] [Assigned] (FLINK-20934) CsvFileCompactionITCase.testSingleParallelism test failure

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20934: --- Assignee: Jingsong Lee > CsvFileCompactionITCase.testSingleParallelism test failure >

[jira] [Updated] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20951: Fix Version/s: 1.13.0 > IllegalArgumentException when reading Hive parquet table if condition not >

[jira] [Updated] (FLINK-20934) CsvFileCompactionITCase.testSingleParallelism test failure

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20934: Fix Version/s: 1.13.0 > CsvFileCompactionITCase.testSingleParallelism test failure >

[jira] [Assigned] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20951: --- Assignee: Jingsong Lee > IllegalArgumentException when reading Hive parquet table if condition not

[jira] [Updated] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20995: Fix Version/s: (was: 1.13.0) > Calling execute() on org.apache.flink.table.api.Table Throws Exception

[jira] [Updated] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20995: Priority: Minor (was: Critical) > Calling execute() on org.apache.flink.table.api.Table Throws Exception

[jira] [Updated] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21060: Component/s: Runtime / Task > Could not create the DispatcherResourceManagerComponent >

[jira] [Updated] (FLINK-21200) User defined functions refuse to accept multi-set arguments without type hints

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21200: Fix Version/s: 1.13.0 > User defined functions refuse to accept multi-set arguments without type hints >

[jira] [Assigned] (FLINK-21444) Lookup joins should deal with intermediate table scans correctly

2021-04-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21444: --- Assignee: Caizhi Weng > Lookup joins should deal with intermediate table scans correctly >

  1   2   3   4   5   6   >