[jira] [Updated] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test

[ https://issues.apache.org/jira/browse/FLINK-15183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15183: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Use SQL-CLI to TPC-DS E2E test >

[jira] [Updated] (FLINK-14361) Decorrelate subQuery fail when multi correlate in project

[ https://issues.apache.org/jira/browse/FLINK-14361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14361: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Decorrelate subQuery fail when multi

[jira] [Updated] (FLINK-14764) The final Explicit conversion matrix we should support in our planner

[ https://issues.apache.org/jira/browse/FLINK-14764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14764: --- Fix Version/s: (was: 1.12.0) 1.13.0 > The final Explicit conversion matrix

[jira] [Updated] (FLINK-14763) flink sql cep parallelism error

[ https://issues.apache.org/jira/browse/FLINK-14763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14763: --- Fix Version/s: (was: 1.12.0) 1.13.0 > flink sql cep parallelism error >

[jira] [Updated] (FLINK-17398) Filesystem support flexible path reading

[ https://issues.apache.org/jira/browse/FLINK-17398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17398: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Filesystem support flexible path

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

[ https://issues.apache.org/jira/browse/FLINK-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14875: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Blink planner should pass the right

[jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client

[ https://issues.apache.org/jira/browse/FLINK-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17405: --- Fix Version/s: (was: 1.11.3) (was: 1.10.3) (was:

[jira] [Updated] (FLINK-17371) Failed to cast decimal from string or double

[ https://issues.apache.org/jira/browse/FLINK-17371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17371: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Failed to cast decimal from string or

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

[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13437: --- Fix Version/s: (was: 1.12.0) > Add Hive SQL E2E test > - > >

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

[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13437: --- Fix Version/s: 1.13.0 > Add Hive SQL E2E test > - > > Key:

[jira] [Updated] (FLINK-13998) Fix ORC test failure with Hive 2.0.x

[ https://issues.apache.org/jira/browse/FLINK-13998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13998: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Fix ORC test failure with Hive 2.0.x >

[jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode

[ https://issues.apache.org/jira/browse/FLINK-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13735: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Support session window with blink

[jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive

[ https://issues.apache.org/jira/browse/FLINK-17785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17785: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Refactor orc shim to create a

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17784: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Better detection for parquet and orc

[jira] [Updated] (FLINK-17855) UDF with parameter Array(Row) can not work

[ https://issues.apache.org/jira/browse/FLINK-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17855: --- Fix Version/s: (was: 1.12.0) 1.13.0 > UDF with parameter Array(Row) can not

[jira] [Updated] (FLINK-17909) Add a TestCatalog to hold the serialized meta data to uncover more potential bugs

[ https://issues.apache.org/jira/browse/FLINK-17909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17909: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add a TestCatalog to hold the

[jira] [Updated] (FLINK-17957) Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser

[ https://issues.apache.org/jira/browse/FLINK-17957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17957: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Forbidden syntax "CREATE SYSTEM

[jira] [Commented] (FLINK-20119) Test Temporal Table DDL and Temporal Table Join

[ https://issues.apache.org/jira/browse/FLINK-20119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232788#comment-17232788 ] Leonard Xu commented on FLINK-20119: I'd like to take this one ^_^ > Test Temporal Table DDL and

[jira] [Commented] (FLINK-20151) Test SQL Hive integration

[ https://issues.apache.org/jira/browse/FLINK-20151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232787#comment-17232787 ] Leonard Xu commented on FLINK-20151: cc [~lirui] > Test SQL Hive integration >

[jira] [Commented] (FLINK-20122) Test Small file compaction

[ https://issues.apache.org/jira/browse/FLINK-20122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232786#comment-17232786 ] Leonard Xu commented on FLINK-20122: cc : [~lzljs3620320] > Test Small file compaction >

[jira] [Commented] (FLINK-20121) Test the upsert-kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-20121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232784#comment-17232784 ] Leonard Xu commented on FLINK-20121: cc [~fsk119] > Test the upsert-kafka Connector >

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229672#comment-17229672 ] Leonard Xu commented on FLINK-19863: [~dian.fu] could you help assign this to me? I'd like to fix it

[jira] [Comment Edited] (FLINK-18869) Batch SQL end-to-end test unstable due to terminated process

[ https://issues.apache.org/jira/browse/FLINK-18869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229616#comment-17229616 ] Leonard Xu edited comment on FLINK-18869 at 11/11/20, 1:02 AM: --- [~dian.fu] 

[jira] [Commented] (FLINK-18869) Batch SQL end-to-end test unstable due to terminated process

[ https://issues.apache.org/jira/browse/FLINK-18869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229616#comment-17229616 ] Leonard Xu commented on FLINK-18869: [~dian.fu] I agree [~rmetzger]'s opinion that this should have

[jira] [Commented] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

[ https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229226#comment-17229226 ] Leonard Xu commented on FLINK-19914: [~dian.fu] I'm working to fix this one >

[jira] [Closed] (FLINK-19342) stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23

[ https://issues.apache.org/jira/browse/FLINK-19342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19342. -- Fix Version/s: 1.12.0 Resolution: Fixed fixed in FLINK-16579 > stop overriding convertFrom()

[jira] [Commented] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228960#comment-17228960 ] Leonard Xu commented on FLINK-19436: And in these failed tests, all failed TM pid(e.g. *4267*) can

[jira] [Comment Edited] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228947#comment-17228947 ] Leonard Xu edited comment on FLINK-19436 at 11/10/20, 3:27 AM: --- Hi,

[jira] [Comment Edited] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228947#comment-17228947 ] Leonard Xu edited comment on FLINK-19436 at 11/10/20, 3:25 AM: --- Hi,

[jira] [Comment Edited] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228947#comment-17228947 ] Leonard Xu edited comment on FLINK-19436 at 11/10/20, 3:24 AM: --- Hi,

[jira] [Commented] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228947#comment-17228947 ] Leonard Xu commented on FLINK-19436: Hi, [~rmetzger] I doubt that, all failed log shows there more

[jira] [Updated] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19436: --- Attachment: image-2020-11-10-11-09-20-534.png > TPC-DS end-to-end test (Blink planner) failed

[jira] [Updated] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19436: --- Attachment: image-2020-11-10-11-08-53-199.png > TPC-DS end-to-end test (Blink planner) failed

[jira] [Comment Edited] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228915#comment-17228915 ] Leonard Xu edited comment on FLINK-18570 at 11/10/20, 2:06 AM: --- Hi

[jira] [Commented] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228915#comment-17228915 ] Leonard Xu commented on FLINK-18570: [https://github.com/apache/flink/pull/13616] >

[jira] [Commented] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228598#comment-17228598 ] Leonard Xu commented on FLINK-19436: I think the reason is the previous e2e tests didn't close flink

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228379#comment-17228379 ] Leonard Xu commented on FLINK-19635: I checked the failed tests in this ticket and   

[jira] [Closed] (FLINK-19081) Deprecate TemporalTableFunction and Table#createTemporalTableFunction()

[ https://issues.apache.org/jira/browse/FLINK-19081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19081. -- Fix Version/s: 1.12.0 Resolution: Not A Problem > Deprecate TemporalTableFunction and

[jira] [Resolved] (FLINK-19080) Materialize TimeIndicatorRelDataType in the right input of temporal join

[ https://issues.apache.org/jira/browse/FLINK-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-19080. Fix Version/s: 1.12.0 Release Note: resolved in FLINK-19076 Resolution: Resolved >

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225557#comment-17225557 ] Leonard Xu commented on FLINK-19644: After discussed with [~lzljs3620320] [~lirui] [~ykt836] We

[jira] [Commented] (FLINK-18759) Add readme.md for TPC-DS tools

[ https://issues.apache.org/jira/browse/FLINK-18759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223337#comment-17223337 ] Leonard Xu commented on FLINK-18759: Hi, [~waywanted]  this ticket has been fixed but forget to

[jira] [Commented] (FLINK-18759) Add readme.md for TPC-DS tools

[ https://issues.apache.org/jira/browse/FLINK-18759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223335#comment-17223335 ] Leonard Xu commented on FLINK-18759: fixed in master: 7e27659a0b79d8fa38bb042064c36a7e0538b97a >

[jira] [Closed] (FLINK-18759) Add readme.md for TPC-DS tools

[ https://issues.apache.org/jira/browse/FLINK-18759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-18759. -- Resolution: Fixed > Add readme.md for TPC-DS tools > -- > >

[jira] [Created] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

Leonard Xu created FLINK-19881: -- Summary: Optimize temporal join with upsert-Source(upsert-kafka) Key: FLINK-19881 URL: https://issues.apache.org/jira/browse/FLINK-19881 Project: Flink Issue

[jira] [Updated] (FLINK-19878) Improve watermark for upsertSource

[ https://issues.apache.org/jira/browse/FLINK-19878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19878: --- Description: Cutrrently, for a upsertSource like upsert-kafka, the WatermarkAssigner is followed

[jira] [Created] (FLINK-19878) Improve watermark ChangelogNormalize for upsertSource

Leonard Xu created FLINK-19878: -- Summary: Improve watermark ChangelogNormalize for upsertSource Key: FLINK-19878 URL: https://issues.apache.org/jira/browse/FLINK-19878 Project: Flink Issue

[jira] [Updated] (FLINK-19878) Improve watermark for upsertSource

[ https://issues.apache.org/jira/browse/FLINK-19878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19878: --- Summary: Improve watermark for upsertSource (was: Improve watermark ChangelogNormalize for

[jira] [Commented] (FLINK-19854) TableScanTest.testTemporalJoinOnUpsertSource fails

[ https://issues.apache.org/jira/browse/FLINK-19854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222193#comment-17222193 ] Leonard Xu commented on FLINK-19854: Sorry for the broken tests, I didn't rebase the latest master

[jira] [Created] (FLINK-19830) Properly implements processing-time temporal table join

Leonard Xu created FLINK-19830: -- Summary: Properly implements processing-time temporal table join Key: FLINK-19830 URL: https://issues.apache.org/jira/browse/FLINK-19830 Project: Flink Issue

[jira] [Commented] (FLINK-19771) NullPointerException when accessing null array from postgres in JDBC Connector

[ https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220454#comment-17220454 ] Leonard Xu commented on FLINK-19771: [~dforciea]  Your branch makes sense to me, I think you can

[jira] [Commented] (FLINK-19771) NullPointerException when accessing null array from postgres in JDBC Connector

[ https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220439#comment-17220439 ] Leonard Xu commented on FLINK-19771: Thanks [~dforciea] for reporting, I think we should override

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 4:39 AM: --- Thanks

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:49 AM: --- How about

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:48 AM: --- How about

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:48 AM: --- How about

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:32 AM: --- How about

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu commented on FLINK-19644: How about the Option?   "read.partition=latest-partition /

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219021#comment-17219021 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:13 AM: --- According

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219021#comment-17219021 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:11 AM: --- According

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219082#comment-17219082 ] Leonard Xu commented on FLINK-19644: [~jark]  Thanks for your clarification,

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219021#comment-17219021 ] Leonard Xu commented on FLINK-19644: According to my Investigation, a major user case is to load

[jira] [Commented] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218074#comment-17218074 ] Leonard Xu commented on FLINK-18570: The same reason with my previous investigation, unfortunately I

[jira] [Closed] (FLINK-19731) 使用了批量执行SQL的api，job执行的时候，DataStream 不触发

[ https://issues.apache.org/jira/browse/FLINK-19731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19731. -- Resolution: Duplicate > 使用了批量执行SQL的api，job执行的时候，DataStream 不触发 >

[jira] [Commented] (FLINK-19731) 使用了批量执行SQL的api，job执行的时候，DataStream 不触发

[ https://issues.apache.org/jira/browse/FLINK-19731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217585#comment-17217585 ] Leonard Xu commented on FLINK-19731: Hi, [~lprince] Thanks for opening the issue. We suggest using

[jira] [Created] (FLINK-19734) Add scan-only TableSoure tests

Leonard Xu created FLINK-19734: -- Summary: Add scan-only TableSoure tests Key: FLINK-19734 URL: https://issues.apache.org/jira/browse/FLINK-19734 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217368#comment-17217368 ] Leonard Xu commented on FLINK-19436: Sure, I'll have a look:) > TPC-DS end-to-end test (Blink

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217367#comment-17217367 ] Leonard Xu commented on FLINK-19635: Sure, I'll have a look >

[jira] [Updated] (FLINK-19655) NPE when using blink planner and TemporalTableFunction after setting IdleStateRetentionTime

[ https://issues.apache.org/jira/browse/FLINK-19655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19655: --- Affects Version/s: 1.11.0 > NPE when using blink planner and TemporalTableFunction after setting >

[jira] [Commented] (FLINK-19655) NPE when using blink planner and TemporalTableFunction after setting IdleStateRetentionTime

[ https://issues.apache.org/jira/browse/FLINK-19655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216395#comment-17216395 ] Leonard Xu commented on FLINK-19655: [~seunjjs] I reviewed the PR, you can have a look. ^_^ > NPE

[jira] [Closed] (FLINK-19076) Import rule to deal Temporal Join condition

[ https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19076. -- Resolution: Resolved master: cd65bbb7cc2ec2099d70375cc009215cf57afe13 > Import rule to deal Temporal

[jira] [Closed] (FLINK-19073) Improve streamExecTemporalJoinRule

[ https://issues.apache.org/jira/browse/FLINK-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19073. -- Resolution: Resolved > Improve streamExecTemporalJoinRule > -- > >

[jira] [Commented] (FLINK-19073) Improve streamExecTemporalJoinRule

[ https://issues.apache.org/jira/browse/FLINK-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215463#comment-17215463 ] Leonard Xu commented on FLINK-19073: master: cd65bbb7cc2ec2099d70375cc009215cf57afe13 > Improve

[jira] [Issue Comment Deleted] (FLINK-18948) Add end to end test for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18948: --- Comment: was deleted (was: [~dian.fu] I just saw PyFlink Table end-to-end test takes 23 mins, I

[jira] [Commented] (FLINK-18948) Add end to end test for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215405#comment-17215405 ] Leonard Xu commented on FLINK-18948: [~dian.fu] I just saw PyFlink Table end-to-end test takes 23

[jira] [Commented] (FLINK-18948) Add end to end test for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215403#comment-17215403 ] Leonard Xu commented on FLINK-18948: [~dian.fu] I just saw PyFlink Table end-to-end test takes 23

[jira] [Commented] (FLINK-18948) Add end to end test for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215314#comment-17215314 ] Leonard Xu commented on FLINK-18948: The e2e tests always failed by timeout [1], I found the new

[jira] [Commented] (FLINK-19664) Upload logs before end to end tests time out

[ https://issues.apache.org/jira/browse/FLINK-19664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215120#comment-17215120 ] Leonard Xu commented on FLINK-19664: +1 for this > Upload logs before end to end tests time out >

[jira] [Created] (FLINK-19644) Support read specific partition of Hive table in temporal join

Leonard Xu created FLINK-19644: -- Summary: Support read specific partition of Hive table in temporal join Key: FLINK-19644 URL: https://issues.apache.org/jira/browse/FLINK-19644 Project: Flink

[jira] [Commented] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213081#comment-17213081 ] Leonard Xu commented on FLINK-18570: The test failed when get region information of HBase table, in

[jira] [Commented] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208577#comment-17208577 ] Leonard Xu commented on FLINK-18570: [~rmetzger]  I'll take a look at this ticket, could you help

[jira] [Closed] (FLINK-16788) Support username and password options for Elasticsearch SQL connector

[ https://issues.apache.org/jira/browse/FLINK-16788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-16788. -- Release Note: Resolved in https://issues.apache.org/jira/browse/FLINK-18361 Resolution: Resolved

[jira] [Created] (FLINK-19342) stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23

Leonard Xu created FLINK-19342: -- Summary: stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23 Key: FLINK-19342 URL: https://issues.apache.org/jira/browse/FLINK-19342 Project:

[jira] [Commented] (FLINK-19271) wrong HOP_PROCTIME output when materialize proctime

[ https://issues.apache.org/jira/browse/FLINK-19271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199128#comment-17199128 ] Leonard Xu commented on FLINK-19271: Hi, [~nicholasjiang]  I think the call order is not the reason,

[jira] [Commented] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198145#comment-17198145 ] Leonard Xu commented on FLINK-18333: Thanks [~dian.fu] [~jark] :) > UnsignedTypeConversionITCase

[jira] [Created] (FLINK-19271) wrong HOP_PROCTIME output when materialize proctime

Leonard Xu created FLINK-19271: -- Summary: wrong HOP_PROCTIME output when materialize proctime Key: FLINK-19271 URL: https://issues.apache.org/jira/browse/FLINK-19271 Project: Flink Issue Type:

[jira] [Created] (FLINK-19148) Table crashed in Flink Table API & SQL Docs

Leonard Xu created FLINK-19148: -- Summary: Table crashed in Flink Table API & SQL Docs Key: FLINK-19148 URL: https://issues.apache.org/jira/browse/FLINK-19148 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-19078) Import rowtime join temporal operator

[ https://issues.apache.org/jira/browse/FLINK-19078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19078: --- Component/s: Table SQL / Runtime > Import rowtime join temporal operator >

[jira] [Updated] (FLINK-19079) Support row time deduplicate operator

[ https://issues.apache.org/jira/browse/FLINK-19079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19079: --- Component/s: Table SQL / Runtime > Support row time deduplicate operator >

[jira] [Updated] (FLINK-19076) Import rule to deal Temporal Join condition

[ https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19076: --- Component/s: Table SQL / Planner > Import rule to deal Temporal Join condition >

[jira] [Updated] (FLINK-19077) Import process time temporal join operator

[ https://issues.apache.org/jira/browse/FLINK-19077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19077: --- Component/s: Table SQL / Runtime > Import process time temporal join operator >

[jira] [Updated] (FLINK-19072) Import Temporal Table join rule

[ https://issues.apache.org/jira/browse/FLINK-19072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19072: --- Component/s: Table SQL / Planner > Import Temporal Table join rule >

[jira] [Updated] (FLINK-19073) Improve streamExecTemporalJoinRule

[ https://issues.apache.org/jira/browse/FLINK-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19073: --- Component/s: Table SQL / Planner > Improve streamExecTemporalJoinRule >

[jira] [Updated] (FLINK-19079) Support row time deduplicate operator

[ https://issues.apache.org/jira/browse/FLINK-19079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19079: --- Description: To convert a insert-only table to versioned table, the recommended way is use

[jira] [Updated] (FLINK-19080) Materialize timeindicator data type in the right input of temporal join

[ https://issues.apache.org/jira/browse/FLINK-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19080: --- Description: The output of temporal join should follow left stream's time attribute,  we should

[jira] [Updated] (FLINK-19080) Materialize TimeIndicatorRelDataType in the right input of temporal join

[ https://issues.apache.org/jira/browse/FLINK-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19080: --- Summary: Materialize TimeIndicatorRelDataType in the right input of temporal join (was:

[jira] [Updated] (FLINK-19078) Import rowtime join temporal operator

[ https://issues.apache.org/jira/browse/FLINK-19078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19078: --- Description: import *TemporalRowTimeJoinOperator* for EventTime-Time temporal join. > Import

[jira] [Updated] (FLINK-19077) Import process time temporal join operator

[ https://issues.apache.org/jira/browse/FLINK-19077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19077: --- Description: import *TemporalProcessTimeJoinOperator* for Processing-Time temporal join. > Import

[jira] [Updated] (FLINK-19077) Import process time temporal join operator

[ https://issues.apache.org/jira/browse/FLINK-19077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19077: --- Summary: Import process time temporal join operator (was: Improve process time temporal join

[jira] [Updated] (FLINK-19073) Improve streamExecTemporalJoinRule

[ https://issues.apache.org/jira/browse/FLINK-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19073: --- Description: Improve streamExecTemporalJoinRule that matches a temporal join node and converts it

[jira] [Updated] (FLINK-19073) Improve streamExecTemporalJoinRule

[ https://issues.apache.org/jira/browse/FLINK-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19073: --- Description: Rule that matches a temporal join node and converts it to [[StreamExecTemporalJoin]],

<    11   12   13   14   15   16   17   18   19   20   >