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

[ https://issues.apache.org/jira/browse/FLINK-22178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-22178: -- Assignee: WeiNan Zhao > Support ignore-first-line option in new csv format >

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

[ https://issues.apache.org/jira/browse/FLINK-24924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444896#comment-17444896 ] Kurt Young commented on FLINK-24924: I would second [~TsReaper] 's concern and i rem

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

[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437101#comment-17437101 ] Kurt Young commented on FLINK-24717: assigned to you [~xuyangzhong] > Push down par

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

[ 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

[ 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

[ 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 suppor

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436653#comment-17436653 ] Kurt Young commented on FLINK-24704: I changed the priority to critical, and we'd be

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

[ 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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436583#comment-17436583 ] Kurt Young commented on FLINK-24704: Thanks for reporting this [~lincoln.86xy], will

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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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 caus

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

[ 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

[ 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

[ 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 operator

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

[ 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

[ 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: F

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

[ 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

[ 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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426946#comment-17426946 ] Kurt Young commented on FLINK-24459: Very nice improvement! [~trushev] > Performanc

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

[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412400#comment-17412400 ] Kurt Young commented on FLINK-24013: would you like to open a PR and I can help revi

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

[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408054#comment-17408054 ] Kurt Young commented on FLINK-24013: I see no harm to adjust the xml to your format,

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

[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408036#comment-17408036 ] Kurt Young commented on FLINK-24013: Found 3 differences: # no license header. If t

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

[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408008#comment-17408008 ] Kurt Young commented on FLINK-24013: What does it look like after been modified auto

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

[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407995#comment-17407995 ] Kurt Young commented on FLINK-24013: Mine works well. Did you have any personal conf

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

[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407735#comment-17407735 ] Kurt Young commented on FLINK-24054: You opinions also make sense in some cases. Tha

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

[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407218#comment-17407218 ] Kurt Young commented on FLINK-24054: The example you gave is test, whose behavior co

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

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

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

[ 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 [~g

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

[ 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

[ 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

[ 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 IDE

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

[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405608#comment-17405608 ] Kurt Young commented on FLINK-24013: Good idea, do you want to open a PR for this? [

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

[ 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 perfo

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

[ 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.

[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361592#comment-17361592 ] Kurt Young commented on FLINK-22015: also fixed in 1.12.5: faf7cc43beebce3fee528ec56

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

[ 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 prod

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

[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350842#comment-17350842 ] Kurt Young commented on FLINK-22472: [~luoyuxia] would you like to take this issue?

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

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344371#comment-17344371 ] Kurt Young commented on FLINK-15440: {quote}if I change the SQL/Table query structur

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

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344224#comment-17344224 ] Kurt Young commented on FLINK-15440: [~Mathieu Druart] IIRC this issue can be addres

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

[ 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 > CatalogFunctionImpl.isG

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

[ 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

[ 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 channel

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

[ 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

[ 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, wh

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

[ 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 W

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

[ 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 iceberg

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

[ 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 cann

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

[ https://issues.apache.org/jira/browse/FLINK-22449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331705#comment-17331705 ] Kurt Young commented on FLINK-22449: Whether changing the result type nullability sh

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

[ https://issues.apache.org/jira/browse/FLINK-22449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331458#comment-17331458 ] Kurt Young commented on FLINK-22449: cc [~godfreyhe] [~wenlong.lwl] Normally, assum

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

[ https://issues.apache.org/jira/browse/FLINK-22182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331451#comment-17331451 ] Kurt Young commented on FLINK-22182: (38, 4) / (38, 4) -> (38, 6)  It seems we didn

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

[ 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

[ 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 usel

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

[ 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: fd8e34c03b663aff96a625ed751b66244

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

[ 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 > ou

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

[ 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

[ 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

[ 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 > Fix

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

[ 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 > PushFilterIntoTableSourceScanRule

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

[ 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: 902a0f54b487ee39a8adb0e04c

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

[ 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

[ 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

[ 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 CliTableauResultView

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

[ https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321901#comment-17321901 ] Kurt Young commented on FLINK-22280: I also think this would be helpful. [~flacombe]

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

[ 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 referenc

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

[ 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

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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-22271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320879#comment-17320879 ] Kurt Young commented on FLINK-22271: This is by design for now, but I think it's als

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

[ 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 Hive(parq

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

[ 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 d

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

[ 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

[ 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 Resolutio

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

[ 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 problem

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

[ 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

[ 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

[ 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 > LocalExecutorITCase.testBatchQuer

[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

[ 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 plan

[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

[ https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319426#comment-17319426 ] Kurt Young commented on FLINK-16584: with 1.13, you can convert Long to TIMESTAMP_LT

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319424#comment-17319424 ] Kurt Young commented on FLINK-15404: Closing this because streaming write to hive is

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

[ 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

[ 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.

[ 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 N

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

[ https://issues.apache.org/jira/browse/FLINK-22201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319023#comment-17319023 ] Kurt Young commented on FLINK-22201: Yes, for streaming mode, we are expecting the f

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

[ https://issues.apache.org/jira/browse/FLINK-22201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319020#comment-17319020 ] Kurt Young commented on FLINK-22201: [~jamii] You didn't really enabled batch execut

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

[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318998#comment-17318998 ] Kurt Young commented on FLINK-22100: [https://dev.azure.com/apache-flink/apache-flin

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

[ 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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-22201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318974#comment-17318974 ] Kurt Young commented on FLINK-22201: [~jamii] Thanks for the reporting. Could you pr

  1   2   3   4   5   6   7   8   9   10   >