[jira] [Updated] (FLINK-29090) Fix the code gen for ColumnarMapData and ColumnarArrayData

2022-08-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-29090: --- Description: !image-2022-08-24-10-15-11-824.png|width=589,height=284! Currently, the code

[jira] [Created] (FLINK-29090) Fix the code gen for ColumnarMapData and ColumnarArrayData

2022-08-23 Thread Danny Chen (Jira)
Danny Chen created FLINK-29090: -- Summary: Fix the code gen for ColumnarMapData and ColumnarArrayData Key: FLINK-29090 URL: https://issues.apache.org/jira/browse/FLINK-29090 Project: Flink Issue

[jira] [Created] (FLINK-22370) ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true

2021-04-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-22370: -- Summary: ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true Key: FLINK-22370 URL: https://issues.apache.org/jira/browse/FLINK-22370 Project:

[jira] [Commented] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

2021-03-15 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301550#comment-17301550 ] Danny Chen commented on FLINK-21520: Thanks, i guess in your query, CPU filtering is not the

[jira] [Commented] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

2021-03-14 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301357#comment-17301357 ] Danny Chen commented on FLINK-21520: That's also a good news, how did you get this conclusion

[jira] [Commented] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

2021-03-11 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300105#comment-17300105 ] Danny Chen commented on FLINK-21520: I'm working on Flink on Apache HUDI now, and we use the Flink

[jira] [Commented] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

2021-01-28 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17274208#comment-17274208 ] Danny Chen commented on FLINK-20942: Thanks [~twalthr], i have fired a fix via

[jira] [Comment Edited] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

2021-01-27 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272647#comment-17272647 ] Danny Chen edited comment on FLINK-20942 at 1/27/21, 8:05 AM: -- I have fired

[jira] [Commented] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

2021-01-27 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272647#comment-17272647 ] Danny Chen commented on FLINK-20942: I have fired a fix in CALCITE-4479 but i have no idea how to

[jira] [Commented] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

2021-01-22 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270032#comment-17270032 ] Danny Chen commented on FLINK-20942: Hmm, the root cause is that the new introduced `Sarg` tries to

[jira] [Commented] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

2021-01-22 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270006#comment-17270006 ] Danny Chen commented on FLINK-20942: Thanks [~twalthr] for reporting this issue, i would take a look

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

2021-01-06 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260156#comment-17260156 ] Danny Chen commented on FLINK-18027: Fixed in https://issues.apache.org/jira/browse/CALCITE-4456,

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

2020-12-30 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256799#comment-17256799 ] Danny Chen commented on FLINK-18027: Thanks for the check [~twalthr], let me have a check for the

[jira] [Created] (FLINK-20785) MapRelDataType for legacy planner has wrong digest

2020-12-28 Thread Danny Chen (Jira)
Danny Chen created FLINK-20785: -- Summary: MapRelDataType for legacy planner has wrong digest Key: FLINK-20785 URL: https://issues.apache.org/jira/browse/FLINK-20785 Project: Flink Issue Type:

[jira] [Created] (FLINK-20704) Some rel data type does not implement the digest correctly

2020-12-21 Thread Danny Chen (Jira)
Danny Chen created FLINK-20704: -- Summary: Some rel data type does not implement the digest correctly Key: FLINK-20704 URL: https://issues.apache.org/jira/browse/FLINK-20704 Project: Flink Issue

[jira] [Comment Edited] (FLINK-20368) Supports custom operator name for Flink SQL

2020-11-26 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239503#comment-17239503 ] Danny Chen edited comment on FLINK-20368 at 11/27/20, 4:22 AM: --- Hi

[jira] [Commented] (FLINK-20368) Supports custom operator name for Flink SQL

2020-11-26 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239503#comment-17239503 ] Danny Chen commented on FLINK-20368: Hi [~ksp0422] ~ The DDL does not use DataStream API, for Blink

[jira] [Created] (FLINK-20368) Supports custom operator name for Flink SQL

2020-11-26 Thread Danny Chen (Jira)
Danny Chen created FLINK-20368: -- Summary: Supports custom operator name for Flink SQL Key: FLINK-20368 URL: https://issues.apache.org/jira/browse/FLINK-20368 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20307) Strength the document about temporal table join syntax

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237921#comment-17237921 ] Danny Chen commented on FLINK-20307: Yes, i have added more documents there so there is less

[jira] [Updated] (FLINK-20307) Strength the document about temporal table join syntax

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-20307: --- Priority: Minor (was: Critical) > Strength the document about temporal table join syntax >

[jira] [Updated] (FLINK-20307) Strength the document about temporal table join syntax

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-20307: --- Component/s: Documentation > Strength the document about temporal table join syntax >

[jira] [Updated] (FLINK-20307) Strength the document about temporal table join syntax

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-20307: --- Summary: Strength the document about temporal table join syntax (was: Cannot alias versioned table

[jira] [Comment Edited] (FLINK-20307) Cannot alias versioned table in a join

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237854#comment-17237854 ] Danny Chen edited comment on FLINK-20307 at 11/24/20, 4:25 AM: --- Based on

[jira] [Commented] (FLINK-20307) Cannot alias versioned table in a join

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237854#comment-17237854 ] Danny Chen commented on FLINK-20307: Based on the SQL standard 2011 7.6 table reference, the table

[jira] [Commented] (FLINK-20307) Cannot alias versioned table in a join

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237794#comment-17237794 ] Danny Chen commented on FLINK-20307: Hi, [~dwysakowicz] ~ I would like to take this issue ~ >

[jira] [Updated] (FLINK-19175) Tests in JoinITCase do not test BroadcastHashJoin

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-19175: --- Fix Version/s: 1.12.0 > Tests in JoinITCase do not test BroadcastHashJoin >

[jira] [Closed] (FLINK-20017) Improve the error message for join two windowed stream with time attributes

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-20017. -- Resolution: Fixed > Improve the error message for join two windowed stream with time attributes >

[jira] [Commented] (FLINK-20017) Improve the error message for join two windowed stream with time attributes

2020-11-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237223#comment-17237223 ] Danny Chen commented on FLINK-20017: The test case below works ok in master code now, so it is

[jira] [Updated] (FLINK-20234) Json format supports SE/DE null elements of ARRAY type field

2020-11-22 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-20234: --- Fix Version/s: (was: 1.12.0) > Json format supports SE/DE null elements of ARRAY type field >

[jira] [Created] (FLINK-20234) Json format supports SE/DE null elements of ARRAY type field

2020-11-19 Thread Danny Chen (Jira)
Danny Chen created FLINK-20234: -- Summary: Json format supports SE/DE null elements of ARRAY type field Key: FLINK-20234 URL: https://issues.apache.org/jira/browse/FLINK-20234 Project: Flink

[jira] [Commented] (FLINK-20200) SQL Hints are not supported in "Create View" syntax

2020-11-17 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17234193#comment-17234193 ] Danny Chen commented on FLINK-20200: Thanks for reporting [~tinny], this should be a bug, i'm fixing

[jira] [Commented] (FLINK-18988) Continuous query with LATERAL and LIMIT produces wrong result

2020-11-17 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233552#comment-17233552 ] Danny Chen commented on FLINK-18988: Sorry for the delay reply, i will fix both master and 1.11. >

[jira] [Comment Edited] (FLINK-18500) Make the legacy planner exception more clear when resolving computed columns types for schema

2020-11-17 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233419#comment-17233419 ] Danny Chen edited comment on FLINK-18500 at 11/17/20, 8:14 AM: --- Thanks,

[jira] [Commented] (FLINK-18500) Make the legacy planner exception more clear when resolving computed columns types for schema

2020-11-17 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233419#comment-17233419 ] Danny Chen commented on FLINK-18500: Thanks, i'm rebasing the code and fixing. > Make the legacy

[jira] [Updated] (FLINK-20017) Improve the error message for join two windowed stream with time attributes

2020-11-16 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-20017: --- Summary: Improve the error message for join two windowed stream with time attributes (was: Promote

[jira] [Updated] (FLINK-20142) Update the document for CREATE TABLE LIKE that source table from different catalog is supported

2020-11-16 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-20142: --- Fix Version/s: 1.12.0 > Update the document for CREATE TABLE LIKE that source table from different

[jira] [Created] (FLINK-20142) Update the document for CREATE TABLE LIKE that source table from different catalog is supported

2020-11-13 Thread Danny Chen (Jira)
Danny Chen created FLINK-20142: -- Summary: Update the document for CREATE TABLE LIKE that source table from different catalog is supported Key: FLINK-20142 URL: https://issues.apache.org/jira/browse/FLINK-20142

[jira] [Created] (FLINK-20017) Promote the error message for join two windowed stream with time attributes

2020-11-06 Thread Danny Chen (Jira)
Danny Chen created FLINK-20017: -- Summary: Promote the error message for join two windowed stream with time attributes Key: FLINK-20017 URL: https://issues.apache.org/jira/browse/FLINK-20017 Project:

[jira] [Updated] (FLINK-20017) Promote the error message for join two windowed stream with time attributes

2020-11-06 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-20017: --- Description: Reported from USER mailing list by Satyam ~ Current for table: {code:sql} CREATE

[jira] [Updated] (FLINK-19949) Unescape CSV format line and field delimiter character

2020-11-03 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-19949: --- Description: We should unescape the line delimiter characters first because the DDL can be read

[jira] [Updated] (FLINK-19949) Unescape CSV format line and field delimiter character

2020-11-03 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-19949: --- Summary: Unescape CSV format line and field delimiter character (was: Unescape CSV format line

[jira] [Commented] (FLINK-19949) Unescape CSV format line delimiter character

2020-11-03 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225244#comment-17225244 ] Danny Chen commented on FLINK-19949: Yes, but the unicode has poor usability. As a user, there would

[jira] [Created] (FLINK-19949) Unescape CSV format line delimiter character

2020-11-03 Thread Danny Chen (Jira)
Danny Chen created FLINK-19949: -- Summary: Unescape CSV format line delimiter character Key: FLINK-19949 URL: https://issues.apache.org/jira/browse/FLINK-19949 Project: Flink Issue Type:

[jira] [Commented] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-26 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220547#comment-17220547 ] Danny Chen commented on FLINK-19779: [~xiaozilong] Yes, the avro schema builder does not allow same

[jira] [Created] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-23 Thread Danny Chen (Jira)
Danny Chen created FLINK-19779: -- Summary: Remove the "record_" field name prefix for Confluent Avro format deserialization Key: FLINK-19779 URL: https://issues.apache.org/jira/browse/FLINK-19779

[jira] [Commented] (FLINK-19668) Fix the plan regression by Calcite upgrade to 1.26

2020-10-18 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216424#comment-17216424 ] Danny Chen commented on FLINK-19668: Another case is

[jira] [Created] (FLINK-19668) Fix the plan regression by Calcite upgrade to 1.26

2020-10-15 Thread Danny Chen (Jira)
Danny Chen created FLINK-19668: -- Summary: Fix the plan regression by Calcite upgrade to 1.26 Key: FLINK-19668 URL: https://issues.apache.org/jira/browse/FLINK-19668 Project: Flink Issue Type:

[jira] [Commented] (FLINK-19567) JoinITCase.testInnerJoinOutputWithPk is unstable for POJO type inference

2020-10-11 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212104#comment-17212104 ] Danny Chen commented on FLINK-19567: I encountered this problem when upgrade the planner Calcite

[jira] [Created] (FLINK-19567) JoinITCase.testInnerJoinOutputWithPk is unstable for POJO type inference

2020-10-11 Thread Danny Chen (Jira)
Danny Chen created FLINK-19567: -- Summary: JoinITCase.testInnerJoinOutputWithPk is unstable for POJO type inference Key: FLINK-19567 URL: https://issues.apache.org/jira/browse/FLINK-19567 Project: Flink

[jira] [Updated] (FLINK-16579) Upgrade Calcite version to 1.26 for Flink SQL

2020-10-08 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16579: --- Summary: Upgrade Calcite version to 1.26 for Flink SQL (was: Upgrade Calcite version to 1.23 for

[jira] [Commented] (FLINK-19175) Tests in JoinITCase do not test BroadcastHashJoin

2020-09-09 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193344#comment-17193344 ] Danny Chen commented on FLINK-19175: Nice catch, [~dwysakowicz], can i take this issue ? > Tests in

[jira] [Commented] (FLINK-19133) User provided kafka partitioners are not initialized correctly

2020-09-03 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190573#comment-17190573 ] Danny Chen commented on FLINK-19133: Hi, [~dwysakowicz], may i take this issue ~ > User provided

[jira] [Commented] (FLINK-19127) Provide a replacement of StreamExecutionEnvironment.createRemoteEnvironment for TableEnvironment

2020-09-03 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190505#comment-17190505 ] Danny Chen commented on FLINK-19127: Thanks, indeed, notebook like zeppelin may need this ~ >

[jira] [Commented] (FLINK-19127) Provide a replacement of StreamExecutionEnvironment.createRemoteEnvironment for TableEnvironment

2020-09-03 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189887#comment-17189887 ] Danny Chen commented on FLINK-19127: Is there any real use cases that can be shared here ? Who will

[jira] [Commented] (FLINK-16528) Support Limit push down for Kafka streaming sources

2020-09-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189016#comment-17189016 ] Danny Chen commented on FLINK-16528: What is the semantics that for an unbounded stream to have a

[jira] [Updated] (FLINK-19108) Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix

2020-09-01 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-19108: --- Description: For query {code:sql} create view tmp_view as select * from ( select f0,

[jira] [Updated] (FLINK-19108) Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix

2020-09-01 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-19108: --- Description: For query {code:sql} create view tmp_view as select * from ( select f0,

[jira] [Created] (FLINK-19108) Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix

2020-09-01 Thread Danny Chen (Jira)
Danny Chen created FLINK-19108: -- Summary: Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix Key: FLINK-19108 URL: https://issues.apache.org/jira/browse/FLINK-19108

[jira] [Comment Edited] (FLINK-19099) consumer kafka message repeat

2020-08-31 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187592#comment-17187592 ] Danny Chen edited comment on FLINK-19099 at 8/31/20, 9:23 AM: -- Before

[jira] [Commented] (FLINK-19099) consumer kafka message repeat

2020-08-31 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187592#comment-17187592 ] Danny Chen commented on FLINK-19099: Before Flink-15221, the SQL Kafka connector only supports "at

[jira] [Commented] (FLINK-19101) The SelectivityEstimator throw an NullPointerException when convertValueInterval with string type

2020-08-31 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187586#comment-17187586 ] Danny Chen commented on FLINK-19101: You may need to provide the data set of the table so that we

[jira] [Commented] (FLINK-19098) Make Rowdata converters public

2020-08-31 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187585#comment-17187585 ] Danny Chen commented on FLINK-19098: Abstract some common part of the code to reuse is usually a

[jira] [Commented] (FLINK-19048) support line format for table connector

2020-08-26 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185080#comment-17185080 ] Danny Chen commented on FLINK-19048: It seems a duplicate of FLINK-14356 > support line format for

[jira] [Commented] (FLINK-18988) Continuous query with LATERAL and LIMIT produces wrong result

2020-08-18 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180207#comment-17180207 ] Danny Chen commented on FLINK-18988: Hi, [~fhueske], i would like to take this issue ~ I guess you

[jira] [Commented] (FLINK-18840) Support StatementSet with DataStream API

2020-08-10 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174121#comment-17174121 ] Danny Chen commented on FLINK-18840: I'm a little confused by this request, what is the case that

[jira] [Commented] (FLINK-18750) SqlValidatorException thrown when select from a view which contains a UDTF call

2020-07-31 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168834#comment-17168834 ] Danny Chen commented on FLINK-18750: The root cause is that, the `LATERAL` keyword of the View

[jira] [Issue Comment Deleted] (FLINK-18750) SqlValidatorException thrown when select from a view which contains a UDTF call

2020-07-31 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-18750: --- Comment: was deleted (was: The problem is because the example function code `UDTF` does not specify

[jira] [Commented] (FLINK-18750) SqlValidatorException thrown when select from a view which contains a UDTF call

2020-07-31 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168682#comment-17168682 ] Danny Chen commented on FLINK-18750: The problem is because the example function code `UDTF` does

[jira] [Created] (FLINK-18777) Supports schema registry catalog

2020-07-30 Thread Danny Chen (Jira)
Danny Chen created FLINK-18777: -- Summary: Supports schema registry catalog Key: FLINK-18777 URL: https://issues.apache.org/jira/browse/FLINK-18777 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-23 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164105#comment-17164105 ] Danny Chen commented on FLINK-16048: Personally i do not have a strong preference too, it seems most

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-21 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162464#comment-17162464 ] Danny Chen commented on FLINK-16048: The schema string can be inferred from the DDL table schema,

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-21 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16048: --- Description: *The background* I found SQL Kafka connector can not consume avro data that was

[jira] [Comment Edited] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160999#comment-17160999 ] Danny Chen edited comment on FLINK-16048 at 7/20/20, 8:35 AM: -- [~ykt836]

[jira] [Comment Edited] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160999#comment-17160999 ] Danny Chen edited comment on FLINK-16048 at 7/20/20, 8:34 AM: -- [~ykt836]

[jira] [Comment Edited] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160999#comment-17160999 ] Danny Chen edited comment on FLINK-16048 at 7/20/20, 8:13 AM: -- [~ykt836]

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-20 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160999#comment-17160999 ] Danny Chen commented on FLINK-16048: [~ykt836] This PR contributes 2 formats of schema registry

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-17 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16048: --- Description: *The background* I found SQL Kafka connector can not consume avro data that was

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-17 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159702#comment-17159702 ] Danny Chen commented on FLINK-16048: I'm hoping to have a consensus about the format id and it's

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-16 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16048: --- Description: *The background* I found SQL Kafka connector can not consume avro data that was

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-16 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16048: --- Description: *The background* I found SQL Kafka connector can not consume avro data that was

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-16 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159687#comment-17159687 ] Danny Chen commented on FLINK-16048: [~anshul.bansal] [~lingyaKK] I'm working on this now, as part

[jira] [Commented] (FLINK-18440) ROW_NUMBER function: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

2020-07-10 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155338#comment-17155338 ] Danny Chen commented on FLINK-18440: I have fired a fix in

[jira] [Commented] (FLINK-18440) ROW_NUMBER function: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

2020-07-10 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155333#comment-17155333 ] Danny Chen commented on FLINK-18440: After some code research, i found that the SqlWindow bounds

[jira] [Created] (FLINK-18500) Make the legacy planner exception more clear when resolving computed columns types for schema

2020-07-06 Thread Danny Chen (Jira)
Danny Chen created FLINK-18500: -- Summary: Make the legacy planner exception more clear when resolving computed columns types for schema Key: FLINK-18500 URL: https://issues.apache.org/jira/browse/FLINK-18500

[jira] [Commented] (FLINK-18487) New table source factory omits unrecognized properties silently

2020-07-05 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151719#comment-17151719 ] Danny Chen commented on FLINK-18487: +1 to have the validation logic in the factory. The FactoryUtil

[jira] [Created] (FLINK-18315) Insert into partitioned table can fail with values

2020-06-15 Thread Danny Chen (Jira)
Danny Chen created FLINK-18315: -- Summary: Insert into partitioned table can fail with values Key: FLINK-18315 URL: https://issues.apache.org/jira/browse/FLINK-18315 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18009) Select an invalid column crashes the SQL CLI

2020-06-05 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126478#comment-17126478 ] Danny Chen commented on FLINK-18009: [~godfreyhe] Please check if this issue is fixed after

[jira] [Commented] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

2020-06-04 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126373#comment-17126373 ] Danny Chen commented on FLINK-16497: I think as a popular streaming engine, ensure good throughput

[jira] [Closed] (FLINK-15126) migrate "show functions" from sql cli to sql parser

2020-06-04 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-15126. -- Resolution: Fixed > migrate "show functions" from sql cli to sql parser >

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

2020-06-04 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-13437: --- Fix Version/s: (was: 1.10.2) (was: 1.11.0) 1.12.0 >

[jira] [Updated] (FLINK-17686) Add document to dataGen, print, blackhole connectors

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17686: --- Priority: Critical (was: Major) > Add document to dataGen, print, blackhole connectors >

[jira] [Updated] (FLINK-17831) Add documentation for the new Kafka connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17831: --- Priority: Critical (was: Major) > Add documentation for the new Kafka connector >

[jira] [Updated] (FLINK-17776) Add documentation for DDL in hive dialect

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17776: --- Priority: Critical (was: Major) > Add documentation for DDL in hive dialect >

[jira] [Updated] (FLINK-16975) Add docs for FileSystem connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16975: --- Priority: Critical (was: Major) > Add docs for FileSystem connector >

[jira] [Updated] (FLINK-17599) Update documents due to FLIP-84

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17599: --- Priority: Critical (was: Major) > Update documents due to FLIP-84 >

[jira] [Updated] (FLINK-17832) Add documentation for the new Elasticsearch connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17832: --- Priority: Critical (was: Major) > Add documentation for the new Elasticsearch connector >

[jira] [Updated] (FLINK-18065) Add documentation for new scalar/table functions

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-18065: --- Priority: Critical (was: Major) > Add documentation for new scalar/table functions >

[jira] [Updated] (FLINK-17829) Add documentation for the new JDBC connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17829: --- Priority: Critical (was: Major) > Add documentation for the new JDBC connector >

[jira] [Updated] (FLINK-18066) Add documentation for how to develop a new table source/sink

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-18066: --- Priority: Critical (was: Major) > Add documentation for how to develop a new table source/sink >

[jira] [Updated] (FLINK-17406) Add documentation about dynamic table options

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17406: --- Priority: Critical (was: Major) > Add documentation about dynamic table options >

  1   2   3   4   >