[jira] [Commented] (FLINK-24924) TO_TIMESTAMP and TO_DATE should fail

2021-11-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444896#comment-17444896 ] Kurt Young commented on FLINK-24924: I would second [~TsReaper] 's concern and i remember we have

[jira] [Commented] (FLINK-24717) Push down partitions before filters

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437101#comment-17437101 ] Kurt Young commented on FLINK-24717: assigned to you [~xuyangzhong] > Push down partitions before

[jira] [Assigned] (FLINK-24717) Push down partitions before filters

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-24717: -- Assignee: xuyang > Push down partitions before filters > ---

[jira] [Updated] (FLINK-24717) Push down partitions before filters

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24717: --- Fix Version/s: 1.15.0 > Push down partitions before filters > --- >

[jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24536: --- Fix Version/s: (was: 1.14.1) 1.15.0 > flink sql where condition is not

[jira] [Updated] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24704: --- Priority: Critical (was: Minor) > Exception occurs when the input record loses monotonicity on the

[jira] [Commented] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436653#comment-17436653 ] Kurt Young commented on FLINK-24704: I changed the priority to critical, and we'd better to also

[jira] [Updated] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24704: --- Fix Version/s: 1.14.1 > Exception occurs when the input record loses monotonicity on the sort key

[jira] [Updated] (FLINK-24691) FLINK SQL SUM() causes a precision error

2021-10-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24691: --- Priority: Critical (was: Major) > FLINK SQL SUM() causes a precision error >

[jira] [Updated] (FLINK-24691) FLINK SQL SUM() causes a precision error

2021-10-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24691: --- Fix Version/s: 1.14.1 1.15.0 > FLINK SQL SUM() causes a precision error >

[jira] [Commented] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-10-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436583#comment-17436583 ] Kurt Young commented on FLINK-24704: Thanks for reporting this [~lincoln.86xy], will this leads to

[jira] [Updated] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24708: --- Fix Version/s: 1.13.4 1.14.1 > `ConvertToNotInOrInRule` has a bug which leads to

[jira] [Updated] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24708: --- Fix Version/s: 1.15.0 > `ConvertToNotInOrInRule` has a bug which leads to wrong result >

[jira] [Updated] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24708: --- Priority: Critical (was: Major) > `ConvertToNotInOrInRule` has a bug which leads to wrong result >

[jira] [Updated] (FLINK-23015) Implement streaming window Deduplicate operator

2021-10-24 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-23015: --- Fix Version/s: 1.15.0 > Implement streaming window Deduplicate operator >

[jira] [Updated] (FLINK-21327) Support window TVF in batch mode

2021-10-24 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-21327: --- Fix Version/s: 1.15.0 > Support window TVF in batch mode > > >

[jira] [Updated] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion

2021-10-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-23865: --- Component/s: (was: Table SQL / Planner) Table SQL / API > Class cast error

[jira] [Updated] (FLINK-18996) Avoid disorder for time interval join

2021-10-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18996: --- Fix Version/s: 1.15.0 > Avoid disorder for time interval join >

[jira] [Updated] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

2021-10-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22826: --- Fix Version/s: 1.15.0 > flink sql1.13.1 causes data loss based on change log stream data join >

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2021-10-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17337: --- Fix Version/s: 1.15.0 > Send UPDATE messages instead of INSERT and DELETE in streaming join

[jira] [Updated] (FLINK-23379) interval left join null value result out of order

2021-10-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-23379: --- Fix Version/s: 1.15.0 > interval left join null value result out of order >

[jira] [Updated] (FLINK-23740) SQL Full Outer Join bug

2021-10-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-23740: --- Fix Version/s: 1.15.0 > SQL Full Outer Join bug > --- > > Key:

[jira] [Updated] (FLINK-23997) Improvement for SQL windowing table-valued function

2021-10-20 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-23997: --- Fix Version/s: 1.15.0 > Improvement for SQL windowing table-valued function >

[jira] [Updated] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24459: --- Fix Version/s: 1.15.0 > Performance improvement of file sink on Nexmark >

[jira] [Closed] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-24459. -- Resolution: Fixed merged: 624372376a09df53e23bb615e5293a6caa296c47 > Performance improvement of file

[jira] [Updated] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24459: --- Affects Version/s: 1.14.0 > Performance improvement of file sink on Nexmark >

[jira] [Commented] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426946#comment-17426946 ] Kurt Young commented on FLINK-24459: Very nice improvement! [~trushev] > Performance improvement of

[jira] [Commented] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-09-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412400#comment-17412400 ] Kurt Young commented on FLINK-24013: would you like to open a PR and I can help reviewing [~chesnay]

[jira] [Commented] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-09-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408054#comment-17408054 ] Kurt Young commented on FLINK-24013: I see no harm to adjust the xml to your format, at least my

[jira] [Commented] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-09-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408036#comment-17408036 ] Kurt Young commented on FLINK-24013: Found 3 differences: # no license header. If this is fine with

[jira] [Commented] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-09-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408008#comment-17408008 ] Kurt Young commented on FLINK-24013: What does it look like after been modified automatically? >

[jira] [Commented] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-09-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407995#comment-17407995 ] Kurt Young commented on FLINK-24013: Mine works well. Did you have any personal configure with

[jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-08-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407735#comment-17407735 ] Kurt Young commented on FLINK-24054: You opinions also make sense in some cases. That's exactly what

[jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-08-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407218#comment-17407218 ] Kurt Young commented on FLINK-24054: The example you gave is test, whose behavior could be changed &

[jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-08-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407171#comment-17407171 ] Kurt Young commented on FLINK-24054: In most cases, +I and -D are easier to handle, and are

[jira] [Closed] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-08-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-24013. -- Resolution: Fixed merged via f2b0e4345564f420ff652f757f716426cb538d45 Thanks for the contribution

[jira] [Assigned] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-08-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-24013: -- Assignee: gaoyajun02 > Add IssueNavigationLink for IDEA > >

[jira] [Updated] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-08-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24013: --- Fix Version/s: (was: 1.14.1) 1.14.0 > Add IssueNavigationLink for IDEA >

[jira] [Updated] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-08-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24013: --- Affects Version/s: (was: 1.14.1) 1.14.0 > Add IssueNavigationLink for

[jira] [Commented] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-08-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405608#comment-17405608 ] Kurt Young commented on FLINK-24013: Good idea, do you want to open a PR for this? [~gaoyajun02] >

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

2021-06-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22994: --- Component/s: (was: Table SQL / Planner) Table SQL / Runtime > Improve the

[jira] [Updated] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result.

2021-06-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22015: --- Fix Version/s: 1.12.5 > SQL filter containing OR and IS NULL will produce an incorrect result. >

[jira] [Commented] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result.

2021-06-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361592#comment-17361592 ] Kurt Young commented on FLINK-22015: also fixed in 1.12.5: faf7cc43beebce3fee528ec5637e9387b95bec99

[jira] [Assigned] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-05-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-22472: -- Assignee: luoyuxia > The real partition data produced time is behind meta(_SUCCESS) file

[jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-05-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350842#comment-17350842 ] Kurt Young commented on FLINK-22472: [~luoyuxia] would you like to take this issue? > The real

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

2021-05-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344371#comment-17344371 ] Kurt Young commented on FLINK-15440: {quote}if I change the SQL/Table query structure I will not be

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

2021-05-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344224#comment-17344224 ] Kurt Young commented on FLINK-15440: [~Mathieu Druart] IIRC this issue can be addressed by setting

[jira] [Updated] (FLINK-22632) CatalogFunctionImpl.isGeneric should use ContextClassLoader

2021-05-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22632: --- Component/s: (was: Table SQL / API) Connectors / Hive >

[jira] [Assigned] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL

2021-04-30 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15376: -- Assignee: Danny Chen > support "CREATE TABLE AS" in Flink SQL >

[jira] [Updated] (FLINK-11864) Let compressed channel reader/writer reuse the logic of AsynchronousFileIOChannel

2021-04-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11864: --- Component/s: (was: Runtime / Task) Table SQL / Runtime > Let compressed

[jira] [Closed] (FLINK-4864) Shade Calcite dependency in flink-table

2021-04-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-4864. - Assignee: Jark Wu Resolution: Fixed > Shade Calcite dependency in flink-table >

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

2021-04-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-21923: --- Fix Version/s: (was: 1.13.0) 1.13.1 > SplitAggregateRule will be abnormal,

[jira] [Updated] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

2021-04-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22463: --- Fix Version/s: (was: 1.13.0) 1.13.1 > IllegalArgumentException is thrown in

[jira] [Updated] (FLINK-21247) flink iceberg table map cannot convert to datastream

2021-04-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-21247: --- Fix Version/s: (was: 1.13.0) 1.13.1 1.14.0 > flink

[jira] [Updated] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

2021-04-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-19449: --- Fix Version/s: (was: 1.13.0) 1.13.1 1.14.0 > LEAD/LAG

[jira] [Commented] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer

2021-04-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331705#comment-17331705 ] Kurt Young commented on FLINK-22449: Whether changing the result type nullability should be align

[jira] [Commented] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer

2021-04-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331458#comment-17331458 ] Kurt Young commented on FLINK-22449: cc [~godfreyhe] [~wenlong.lwl] Normally, assume the result

[jira] [Commented] (FLINK-22182) Incorrect round when dividing decimals

2021-04-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331451#comment-17331451 ] Kurt Young commented on FLINK-22182: (38, 4) / (38, 4) -> (38, 6)  It seems we didn't give enough

[jira] [Closed] (FLINK-13734) Support DDL in SQL CLI

2021-04-22 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13734. -- Resolution: Implemented I believe this is already supported.  > Support DDL in SQL CLI >

[jira] [Updated] (FLINK-17117) There are an useless cast operation for sql on blink when generate code

2021-04-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17117: --- Component/s: (was: Table SQL / Planner) Table SQL / Runtime > There are an

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

2021-04-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-20855. -- Resolution: Fixed Thanks [~hejiefang] for the contribution. Merged: 

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

2021-04-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22100. -- Resolution: Duplicate > BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no >

[jira] [Closed] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

2021-04-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-20254. -- Resolution: Duplicate > HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out >

[jira] [Closed] (FLINK-22129) OrcFileSystemITCase hangs on azure

2021-04-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22129. -- Resolution: Duplicate > OrcFileSystemITCase hangs on azure > -- > >

[jira] [Closed] (FLINK-22308) Fix CliTableauResultView print results after cancel in STREAMING mode

2021-04-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22308. -- Assignee: Shengkai Fang Resolution: Fixed fixed: e4a2738e8b9badf37eab4874109a3e49ad47a341 >

[jira] [Closed] (FLINK-22016) PushFilterIntoTableSourceScanRule fails to deal with NULLs

2021-04-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22016. -- Resolution: Fixed fixed: 1562ed02796798ad450b3d4a778974ec086e0419 >

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

2021-04-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-20761. -- Resolution: Fixed 1.13.0: 45e2fb584579952d6abc9a4507cbc3b09b071c12 1.12.3: 

[jira] [Closed] (FLINK-22293) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

2021-04-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22293. -- Resolution: Duplicate > Throw IllegalArgumentException when getNumFiles with partitions on different

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

2021-04-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13437: --- Fix Version/s: (was: 1.13.0) > Add Hive SQL E2E test > - > >

[jira] [Closed] (FLINK-22169) Beautify the CliTableauResultView when print

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22169. -- Resolution: Fixed fixed: 326a564ebc0e397654ccd4e5a83a77ef811c6a76 > Beautify the

[jira] [Commented] (FLINK-22280) Add XML output format for Flink Table

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321901#comment-17321901 ] Kurt Young commented on FLINK-22280: I also think this would be helpful. [~flacombe] > Add XML

[jira] [Closed] (FLINK-21660) CREATE TABLE LIKE cannot reference tables in HiveCatalog

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21660. -- Resolution: Fixed fixed: 5b9e7882207357120717966d8bf7efd53c53ede5 > CREATE TABLE LIKE cannot

[jira] [Closed] (FLINK-22278) Refactor sql client's DynamicResult

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22278. -- Resolution: Duplicate created twice by accident > Refactor sql client's DynamicResult >

[jira] [Created] (FLINK-22278) Refactor sql client's DynamicResult

2021-04-14 Thread Kurt Young (Jira)
Kurt Young created FLINK-22278: -- Summary: Refactor sql client's DynamicResult Key: FLINK-22278 URL: https://issues.apache.org/jira/browse/FLINK-22278 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22277) Refactor sql client's DynamicResult

2021-04-14 Thread Kurt Young (Jira)
Kurt Young created FLINK-22277: -- Summary: Refactor sql client's DynamicResult Key: FLINK-22277 URL: https://issues.apache.org/jira/browse/FLINK-22277 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-22271) FlinkSQL Read Hive(parquet file) field does not exist

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22271: --- Issue Type: New Feature (was: Bug) > FlinkSQL Read Hive(parquet file) field does not exist >

[jira] [Commented] (FLINK-22271) FlinkSQL Read Hive(parquet file) field does not exist

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320879#comment-17320879 ] Kurt Young commented on FLINK-22271: This is by design for now, but I think it's also useful if we

[jira] [Updated] (FLINK-22271) FlinkSQL Read Hive(parquet file) field does not exist

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22271: --- Component/s: (was: Connectors / Hive) Table SQL / API > FlinkSQL Read

[jira] [Closed] (FLINK-21592) RemoveSingleAggregateRule fails due to nullability mismatch

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21592. -- Resolution: Fixed fixed: b22bc62ae59d3ccaef95507897c7725970e4e5c3 > RemoveSingleAggregateRule fails

[jira] [Updated] (FLINK-21592) RemoveSingleAggregateRule fails due to nullability mismatch

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-21592: --- Affects Version/s: 1.12.2 > RemoveSingleAggregateRule fails due to nullability mismatch >

[jira] [Closed] (FLINK-22207) Hive Catalog retrieve Flink Properties error

2021-04-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22207. -- Fix Version/s: (was: 1.12.1) 1.13.0 Assignee: wangzeyu

[jira] [Updated] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

2021-04-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22263: --- Component/s: Table SQL / Planner > Using TIMESTAMPADD function with partition value has some

[jira] [Updated] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

2021-04-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22263: --- Affects Version/s: 1.12.2 > Using TIMESTAMPADD function with partition value has some problem when

[jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client

2021-04-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22065: --- Summary: Improve the error message when input invalid command in the sql client (was: Beautify the

[jira] [Closed] (FLINK-21748) LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21748. -- Resolution: Fixed fixed: b78ce3b9713c7b2792629d509a3951a96829012d >

[jira] [Closed] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16584. -- Fix Version/s: 1.13.0 Resolution: Fixed > Whether to support the long type field in table

[jira] [Commented] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319426#comment-17319426 ] Kurt Young commented on FLINK-16584: with 1.13, you can convert Long to TIMESTAMP_LTZ with builtin

[jira] [Closed] (FLINK-15404) How to insert hive table in streaming mode and blink planner

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15404. -- Resolution: Fixed > How to insert hive table in streaming mode and blink planner >

[jira] [Commented] (FLINK-15404) How to insert hive table in streaming mode and blink planner

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319424#comment-17319424 ] Kurt Young commented on FLINK-15404: Closing this because streaming write to hive is already

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

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22075: --- Fix Version/s: (was: 1.13.0) > Incorrect null outputs in left join >

[jira] [Closed] (FLINK-21162) FLINK SQL IF function semantic incorrect

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21162. -- Resolution: Fixed > FLINK SQL IF function semantic incorrect >

[jira] [Closed] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result.

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22015. -- Resolution: Fixed fixed: a3be1cc5ed55d8d93a56fa22d3f3421ae6b65722 > SQL filter containing OR and IS

[jira] [Commented] (FLINK-22201) Incorrect output for simple sql query

2021-04-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319023#comment-17319023 ] Kurt Young commented on FLINK-22201: Yes, for streaming mode, we are expecting the final result

[jira] [Commented] (FLINK-22201) Incorrect output for simple sql query

2021-04-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319020#comment-17319020 ] Kurt Young commented on FLINK-22201: [~jamii] You didn't really enabled batch execution mode because

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

2021-04-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318998#comment-17318998 ] Kurt Young commented on FLINK-22100:

[jira] [Closed] (FLINK-22193) HiveTableSinkITCase.testNonPartStreamingMrWrite fail

2021-04-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22193. -- Resolution: Duplicate > HiveTableSinkITCase.testNonPartStreamingMrWrite fail >

[jira] [Closed] (FLINK-22192) HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail

2021-04-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22192. -- Resolution: Duplicate > HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail >

[jira] [Updated] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager

2021-04-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22189: --- Priority: Major (was: Blocker) > Flink SQL Client Hudi batch write crashes JobManager >

[jira] [Commented] (FLINK-22201) Incorrect output for simple sql query

2021-04-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318974#comment-17318974 ] Kurt Young commented on FLINK-22201: [~jamii] Thanks for the reporting. Could you provide some

[jira] [Assigned] (FLINK-22178) Support ignore-first-line option in new csv format

2021-04-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-22178: -- Assignee: jinfeng > Support ignore-first-line option in new csv format >

  1   2   3   4   5   6   7   8   9   10   >