[jira] [Commented] (FLINK-16998) Add a changeflag to Row type

[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100373#comment-17100373 ] Kurt Young commented on FLINK-16998: Keep internal row's header makes sense, especially when we want

[jira] [Closed] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15591. -- Resolution: Fixed master: dca4a774ff75cb6d79d0c825311a56e151357027 > make up for feature parity by

[jira] [Commented] (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:comment-tabpanel=17095271#comment-17095271 ] Kurt Young commented on FLINK-17117: [~hehuiyuan] Thanks for the fix, I will try to find some time

[jira] [Updated] (FLINK-15678) Optimize producing primary key without row number in special Top 1

[ https://issues.apache.org/jira/browse/FLINK-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15678: --- Issue Type: Improvement (was: Bug) > Optimize producing primary key without row number in special

[jira] [Updated] (FLINK-15655) Refactor equals code generation in blink

[ https://issues.apache.org/jira/browse/FLINK-15655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15655: --- Issue Type: Improvement (was: Bug) > Refactor equals code generation in blink >

[jira] [Updated] (FLINK-17433) [umbrella] Real time hive integration

[ https://issues.apache.org/jira/browse/FLINK-17433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17433: --- Issue Type: New Feature (was: Bug) > [umbrella] Real time hive integration >

[jira] [Assigned] (FLINK-17251) supports INSERT statement in TableEnvironment#executeSql and Table#executeInsert api

[ https://issues.apache.org/jira/browse/FLINK-17251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17251: -- Assignee: godfrey he > supports INSERT statement in TableEnvironment#executeSql and >

[jira] [Assigned] (FLINK-17431) Implement table DDLs for Hive dialect part 1

[ https://issues.apache.org/jira/browse/FLINK-17431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17431: -- Assignee: Rui Li > Implement table DDLs for Hive dialect part 1 >

[jira] [Closed] (FLINK-17111) Support SHOW VIEWS in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17111. -- Resolution: Fixed master: ea5111607cb3557308de7665b25c6f737132d1b3 > Support SHOW VIEWS in Flink SQL

[jira] [Assigned] (FLINK-17420) Cannot alias Tuple and Row fields when converting DataStream to Table

[ https://issues.apache.org/jira/browse/FLINK-17420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17420: -- Assignee: Leonard Xu > Cannot alias Tuple and Row fields when converting DataStream to Table

[jira] [Commented] (FLINK-17420) Cannot alias Tuple and Row fields when converting DataStream to Table

[ https://issues.apache.org/jira/browse/FLINK-17420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094070#comment-17094070 ] Kurt Young commented on FLINK-17420: [~Leonard Xu] Thanks, I will assign this to you  > Cannot

[jira] [Created] (FLINK-17406) add documentation about dynamic table options

Kurt Young created FLINK-17406: -- Summary: add documentation about dynamic table options Key: FLINK-17406 URL: https://issues.apache.org/jira/browse/FLINK-17406 Project: Flink Issue Type:

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093120#comment-17093120 ] Kurt Young commented on FLINK-16636: So only blink planner module tests will be executed serially?

[jira] [Updated] (FLINK-17392) enable configuring minicluster resources in Flink SQL in IDE

[ https://issues.apache.org/jira/browse/FLINK-17392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17392: --- Fix Version/s: (was: 1.11.0) > enable configuring minicluster resources in Flink SQL in IDE >

[jira] [Commented] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092721#comment-17092721 ] Kurt Young commented on FLINK-15591: [~docete] Thanks, I will assign this to you. > make up for

[jira] [Assigned] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15591: -- Assignee: Zhenghua Gao (was: Kurt Young) > make up for feature parity by supporting CREATE

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15591: --- Affects Version/s: 1.10.0 > make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15591: --- Fix Version/s: 1.11.0 > make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[jira] [Commented] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092683#comment-17092683 ] Kurt Young commented on FLINK-15591: what about temporary table? > make up for feature parity by

[jira] [Updated] (FLINK-17339) Change default planner to blink and update test cases in both planners

[ https://issues.apache.org/jira/browse/FLINK-17339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17339: --- Component/s: Table SQL / API > Change default planner to blink and update test cases in both

[jira] [Closed] (FLINK-17339) Change default planner to blink and update test cases in both planners

[ https://issues.apache.org/jira/browse/FLINK-17339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17339. -- Resolution: Fixed master:   f0a4b09319211391dcfd09198e360f48102a9991 ~ 

[jira] [Commented] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092632#comment-17092632 ] Kurt Young commented on FLINK-15591: I think [~docete] is doing this, right? > make up for feature

[jira] [Closed] (FLINK-15985) offload runtime params from DDL to table hints in DML/queries

[ https://issues.apache.org/jira/browse/FLINK-15985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15985. -- Resolution: Duplicate > offload runtime params from DDL to table hints in DML/queries >

[jira] [Updated] (FLINK-15986) Support setting or changing session properties in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-15986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15986: --- Fix Version/s: (was: 1.11.0) > Support setting or changing session properties in Flink SQL >

[jira] [Closed] (FLINK-16935) Open or delete ignored test cases in blink planner

[ https://issues.apache.org/jira/browse/FLINK-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16935. -- Resolution: Fixed master: 490e2af0f9cc3021b6423535768e9f3604b27519 > Open or delete ignored test

[jira] [Commented] (FLINK-17312) Support sql client start with restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091995#comment-17091995 ] Kurt Young commented on FLINK-17312: [~zhanglun] Yes, I was aware of your proposal and design. The

[jira] [Commented] (FLINK-17312) Support sql client start with savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091418#comment-17091418 ] Kurt Young commented on FLINK-17312: Adding savepoint dir to yaml file seems to be a little bit

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

Kurt Young created FLINK-17371: -- Summary: Failed to cast decimal from string or double Key: FLINK-17371 URL: https://issues.apache.org/jira/browse/FLINK-17371 Project: Flink Issue Type:

[jira] [Created] (FLINK-17362) Improve table examples to reflect latest status

Kurt Young created FLINK-17362: -- Summary: Improve table examples to reflect latest status Key: FLINK-17362 URL: https://issues.apache.org/jira/browse/FLINK-17362 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090646#comment-17090646 ] Kurt Young edited comment on FLINK-16636 at 4/23/20, 2:13 PM: -- [~rmetzger] 

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090646#comment-17090646 ] Kurt Young commented on FLINK-16636: [~rmetzger] Is it possible to use JDK9 to executing these

[jira] [Created] (FLINK-17340) Update docs which related to default planner changes

Kurt Young created FLINK-17340: -- Summary: Update docs which related to default planner changes Key: FLINK-17340 URL: https://issues.apache.org/jira/browse/FLINK-17340 Project: Flink Issue Type:

[jira] [Created] (FLINK-17339) Change default planner to blink and update test cases in both planners

Kurt Young created FLINK-17339: -- Summary: Change default planner to blink and update test cases in both planners Key: FLINK-17339 URL: https://issues.apache.org/jira/browse/FLINK-17339 Project: Flink

[jira] [Assigned] (FLINK-16935) Open or delete ignored test cases in blink planner

[ https://issues.apache.org/jira/browse/FLINK-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16935: -- Assignee: Kurt Young > Open or delete ignored test cases in blink planner >

[jira] [Closed] (FLINK-17326) flink sql gateway should support persist meta information such as SessionContext in order to recover

[ https://issues.apache.org/jira/browse/FLINK-17326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17326. -- Resolution: Invalid > flink sql gateway should support persist meta information such as >

[jira] [Commented] (FLINK-17326) flink sql gateway should support persist meta information such as SessionContext in order to recover

[ https://issues.apache.org/jira/browse/FLINK-17326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089636#comment-17089636 ] Kurt Young commented on FLINK-17326: [~jackylau] please report sql gateway's issue to its own

[jira] [Commented] (FLINK-17312) Support sql client savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089520#comment-17089520 ] Kurt Young commented on FLINK-17312: [~zhanglun] Thanks for bringing this up. Could you explain how

[jira] [Assigned] (FLINK-17105) FLIP-71: E2E view support for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17105: -- Assignee: Zhenghua Gao > FLIP-71: E2E view support for Flink SQL >

[jira] [Closed] (FLINK-17106) Support create/drop view in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17106. -- Assignee: Zhenghua Gao Resolution: Fixed master: 322d58913b67d5a4de5b9f9d9b663e39f8d0b76c >

[jira] [Commented] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable

[ https://issues.apache.org/jira/browse/FLINK-17310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089196#comment-17089196 ] Kurt Young commented on FLINK-17310: Assigned to you [~zhanglibing1...@126.com] > Test blink

[jira] [Assigned] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable

[ https://issues.apache.org/jira/browse/FLINK-17310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17310: -- Assignee: LionelZ > Test blink planner failed to generate JobGraph when the checkpoint mode

[jira] [Closed] (FLINK-17296) Support "create table if not exists" in JDBC table sink.

[ https://issues.apache.org/jira/browse/FLINK-17296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17296. -- Resolution: Duplicate > Support "create table if not exists" in JDBC table sink. >

[jira] [Commented] (FLINK-17296) Support "create table if not exists" in JDBC table sink.

[ https://issues.apache.org/jira/browse/FLINK-17296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088627#comment-17088627 ] Kurt Young commented on FLINK-17296: cc [~Leonard Xu], I think this is ongoing with FLINK-16294 >

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088353#comment-17088353 ] Kurt Young commented on FLINK-16636: If there is indeed some memory leak, we should be able to

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088349#comment-17088349 ] Kurt Young commented on FLINK-16636: That's the weird thing. We've configured the JVM with 2GM heap

[jira] [Closed] (FLINK-17263) Remove RepeatFamilyOperandTypeChecker in blink planner and replace it with calcite's CompositeOperandTypeChecker

[ https://issues.apache.org/jira/browse/FLINK-17263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17263. -- Fix Version/s: 1.11.0 Assignee: Terry Wang Resolution: Fixed master: 

[jira] [Commented] (FLINK-16364) Deprecate the methods in TableEnvironment proposed by FLIP-84

[ https://issues.apache.org/jira/browse/FLINK-16364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087767#comment-17087767 ] Kurt Young commented on FLINK-16364: Once you deprecated them, please also change the usage in test

[jira] [Updated] (FLINK-17235) Dynamic table options will not work when there doesn't exist a space between + and OPTIONS

[ https://issues.apache.org/jira/browse/FLINK-17235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17235: --- Parent: (was: FLINK-17101) Issue Type: Bug (was: Sub-task) > Dynamic table options

[jira] [Updated] (FLINK-17234) Show more error messages in taskmanager's log

[ https://issues.apache.org/jira/browse/FLINK-17234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17234: --- Component/s: (was: Formats (JSON, Avro, Parquet, ORC, SequenceFile)) > Show more error messages

[jira] [Assigned] (FLINK-17101) Supports dynamic table options for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17101: -- Assignee: Danny Chen > Supports dynamic table options for Flink SQL >

[jira] [Created] (FLINK-17235) Dynamic table options will not work when there doesn't exist a space between + and OPTIONS

Kurt Young created FLINK-17235: -- Summary: Dynamic table options will not work when there doesn't exist a space between + and OPTIONS Key: FLINK-17235 URL: https://issues.apache.org/jira/browse/FLINK-17235

[jira] [Closed] (FLINK-16366) Introduce executeSql method in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16366. -- Resolution: Fixed master: e0d2db7e2015aad73a1eda092a600cf92c78bb43 > Introduce executeSql method in

[jira] [Closed] (FLINK-17234) Show more error messages in taskmanager's log

[ https://issues.apache.org/jira/browse/FLINK-17234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17234. -- Resolution: Duplicate > Show more error messages in taskmanager's log >

[jira] [Commented] (FLINK-17234) Show more error messages in taskmanager's log

[ https://issues.apache.org/jira/browse/FLINK-17234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086881#comment-17086881 ] Kurt Young commented on FLINK-17234: [~godfreyhe] Thanks > Show more error messages in

[jira] [Created] (FLINK-17234) Show more error messages in taskmanager's log

Kurt Young created FLINK-17234: -- Summary: Show more error messages in taskmanager's log Key: FLINK-17234 URL: https://issues.apache.org/jira/browse/FLINK-17234 Project: Flink Issue Type:

[jira] [Updated] (FLINK-17234) Show more error messages in taskmanager's log

[ https://issues.apache.org/jira/browse/FLINK-17234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17234: --- Description: I created a csv table in sql client and trying to view the table content by executing

[jira] [Updated] (FLINK-16217) SQL Client crashed when any uncatched exception is thrown

[ https://issues.apache.org/jira/browse/FLINK-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16217: --- Fix Version/s: (was: 1.10.1) > SQL Client crashed when any uncatched exception is thrown >

[jira] [Updated] (FLINK-16217) SQL Client crashed when any uncatched exception is thrown

[ https://issues.apache.org/jira/browse/FLINK-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16217: --- Issue Type: Improvement (was: Bug) > SQL Client crashed when any uncatched exception is thrown >

[jira] [Commented] (FLINK-16217) SQL Client crashed when any uncatched exception is thrown

[ https://issues.apache.org/jira/browse/FLINK-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086453#comment-17086453 ] Kurt Young commented on FLINK-16217: I change the issue type from bug to improvement, and also

[jira] [Assigned] (FLINK-17126) Correct the execution behavior of BatchTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17126: -- Assignee: godfrey he > Correct the execution behavior of BatchTableEnvironment >

[jira] [Closed] (FLINK-16535) BatchTableSink#emitDataSet returns DataSink

[ https://issues.apache.org/jira/browse/FLINK-16535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16535. -- > BatchTableSink#emitDataSet returns DataSink > --- > >

[jira] [Closed] (FLINK-16363) Correct the execution behavior of TableEnvironment and StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16363. -- > Correct the execution behavior of TableEnvironment and StreamTableEnvironment >

[jira] [Assigned] (FLINK-16366) Introduce executeSql method in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16366: -- Assignee: godfrey he > Introduce executeSql method in TableEnvironment >

[jira] [Created] (FLINK-17233) Remove copied methods from Calcite introduced by fixing TIMESTAMPDIFF

Kurt Young created FLINK-17233: -- Summary: Remove copied methods from Calcite introduced by fixing TIMESTAMPDIFF Key: FLINK-17233 URL: https://issues.apache.org/jira/browse/FLINK-17233 Project: Flink

[jira] [Closed] (FLINK-16823) The functioin TIMESTAMPDIFF doesn't perform expected result

[ https://issues.apache.org/jira/browse/FLINK-16823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16823. -- Fix Version/s: 1.11.0 Resolution: Fixed master: 591527798bf0d7f2a3884934b6260af9b84f3bf2 >

[jira] [Closed] (FLINK-17179) Set row time attribute not working in connector descriptor

[ https://issues.apache.org/jira/browse/FLINK-17179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17179. -- Resolution: Duplicate > Set row time attribute not working in connector descriptor >

[jira] [Assigned] (FLINK-16160) Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

[ https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16160: -- Assignee: Zhenghua Gao > Schema#proctime and Schema#rowtime don't work in

[jira] [Closed] (FLINK-8864) Add CLI query history in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-8864. - Fix Version/s: 1.11.0 Resolution: Fixed master: a20ed14374c75d95a0fda5d33bea7f902088d670 > Add

[jira] [Commented] (FLINK-17192) java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: The record exceeds the maximum size of

[ https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085042#comment-17085042 ] Kurt Young commented on FLINK-17192: According to your stack, you are running a DataSet job, right?

[jira] [Commented] (FLINK-16936) TablEnv creation and planner execution must be in the same thread

[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085031#comment-17085031 ] Kurt Young commented on FLINK-16936: [~zjffdu] As far as I know, I didn't see this on the roadmap.

[jira] [Commented] (FLINK-17178) Provide "ALL" cache strategy in LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-17178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085021#comment-17085021 ] Kurt Young commented on FLINK-17178: How can cache all provides latest records? I can only imagine

[jira] [Commented] (FLINK-17178) Provide "ALL" cache strategy in LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-17178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084906#comment-17084906 ] Kurt Young commented on FLINK-17178: Firstly, I'm not sure we should introduce CachedLookupFunction

[jira] [Assigned] (FLINK-8864) Add CLI query history in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-8864: - Assignee: Kurt Young (was: Sergey Nuyanzin) > Add CLI query history in SQL Client >

[jira] [Commented] (FLINK-17171) Blink planner fails to compile Table program with POJO source

[ https://issues.apache.org/jira/browse/FLINK-17171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084544#comment-17084544 ] Kurt Young commented on FLINK-17171: Similar with FLINK-16662? > Blink planner fails to compile

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084540#comment-17084540 ] Kurt Young commented on FLINK-16662: [~zhanglibing1...@126.com] I've assigned this to you.  > Blink

[jira] [Assigned] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16662: -- Assignee: LionelZ > Blink Planner failed to generate JobGraph for POJO DataStream converting

[jira] [Commented] (FLINK-8864) Add CLI query history in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084097#comment-17084097 ] Kurt Young commented on FLINK-8864: --- Hi [~Sergey Nuyanzin], would you still like to finish this issue?

[jira] [Commented] (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:comment-tabpanel=17084067#comment-17084067 ] Kurt Young commented on FLINK-17117: Assigned to you [~hehuiyuan], thanks for the fix > There are

[jira] [Assigned] (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 reassigned FLINK-17117: -- Assignee: hehuiyuan > There are an useless cast operation for sql on blink when generate

[jira] [Closed] (FLINK-17103) Supports dynamic table options for Blink planner

[ https://issues.apache.org/jira/browse/FLINK-17103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17103. -- Assignee: Danny Chen Resolution: Fixed merged to master: 

[jira] [Commented] (FLINK-17139) The sub-plan reuse optimizer can't reuse sub-plan that from different sql node tree 

[ https://issues.apache.org/jira/browse/FLINK-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083230#comment-17083230 ] Kurt Young commented on FLINK-17139: Are you using sql cli? > The sub-plan reuse optimizer can't

[jira] [Commented] (FLINK-16767) Failed to read Hive table with RegexSerDe

[ https://issues.apache.org/jira/browse/FLINK-16767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083227#comment-17083227 ] Kurt Young commented on FLINK-16767: It is possible that this is the reason of FLINK-17138? >

[jira] [Commented] (FLINK-17128) Add isBounded to TableSinkFactory#Context

[ https://issues.apache.org/jira/browse/FLINK-17128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083013#comment-17083013 ] Kurt Young commented on FLINK-17128: Yes, I think [~lzljs3620320] is right. One of the essential

[jira] [Assigned] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16636: -- Assignee: Caizhi Weng > TableEnvironmentITCase is crashing on Travis >

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078294#comment-17078294 ] Kurt Young commented on FLINK-16636: Stuck with `TableUtilsStreamingITCase`, it's more and more

[jira] [Updated] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16924: --- Component/s: (was: Table SQL / Planner) Table SQL / API >

[jira] [Updated] (FLINK-16936) TablEnv creation and planner execution must be in the same thread

[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16936: --- Component/s: (was: Table SQL / Planner) Table SQL / API > TablEnv creation and

[jira] [Closed] (FLINK-16936) TablEnv creation and planner execution must be in the same thread

[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16936. -- Resolution: Won't Fix > TablEnv creation and planner execution must be in the same thread >

[jira] [Closed] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16924. -- Resolution: Won't Fix > TableEnvironment#sqlUpdate throw NPE when called in async thread >

[jira] [Commented] (FLINK-16936) TablEnv creation and planner execution must be in the same thread

[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17077961#comment-17077961 ] Kurt Young commented on FLINK-16936: I don't think TableEnvironment can work in multi-thread, and I

[jira] [Commented] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17077960#comment-17077960 ] Kurt Young commented on FLINK-16924: I don't think TableEnvironment can work in multi-thread, and I

[jira] [Commented] (FLINK-16632) Cast string to timestamp fail

[ https://issues.apache.org/jira/browse/FLINK-16632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17075827#comment-17075827 ] Kurt Young commented on FLINK-16632: [~docete] Could you take a look? > Cast string to timestamp

[jira] [Assigned] (FLINK-16632) Cast string to timestamp fail

[ https://issues.apache.org/jira/browse/FLINK-16632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16632: -- Assignee: Zhenghua Gao > Cast string to timestamp fail > - > >

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17075148#comment-17075148 ] Kurt Young commented on FLINK-16636: Two possible non-heap memory producers would be 1) RocksDB

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074402#comment-17074402 ] Kurt Young commented on FLINK-16636: Found 2 suspicious log from the output: The first one is:  

[jira] [Updated] (FLINK-16935) Open or delete ignored test cases in blink planner

[ https://issues.apache.org/jira/browse/FLINK-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16935: --- Description: For example: 

[jira] [Commented] (FLINK-16917) "TPC-DS end-to-end test (Blink planner)" gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073431#comment-17073431 ] Kurt Young commented on FLINK-16917: And I quickly went through other e2e tests between #20200331.7

[jira] [Commented] (FLINK-16917) "TPC-DS end-to-end test (Blink planner)" gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073421#comment-17073421 ] Kurt Young commented on FLINK-16917: [~rmetzger]  You can check out  *#20200331.7

[jira] [Comment Edited] (FLINK-16917) "TPC-DS end-to-end test (Blink planner)" gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073421#comment-17073421 ] Kurt Young edited comment on FLINK-16917 at 4/2/20, 6:49 AM: - [~rmetzger] 

[jira] [Created] (FLINK-16935) Open or delete ignored test cases in blink planner

Kurt Young created FLINK-16935: -- Summary: Open or delete ignored test cases in blink planner Key: FLINK-16935 URL: https://issues.apache.org/jira/browse/FLINK-16935 Project: Flink Issue Type:

<    1   2   3   4   5   6   7   8   9   10   >