[jira] [Created] (FLINK-16934) Change default planner to blink

Kurt Young created FLINK-16934: -- Summary: Change default planner to blink Key: FLINK-16934 URL: https://issues.apache.org/jira/browse/FLINK-16934 Project: Flink Issue Type: Improvement

[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=17073304#comment-17073304 ] Kurt Young commented on FLINK-16924: Agreed with [~twalthr] , I don't think TableEnvironment is

[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=17073299#comment-17073299 ] Kurt Young edited comment on FLINK-16917 at 4/2/20, 1:52 AM: - I think the

[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=17073299#comment-17073299 ] Kurt Young commented on FLINK-16917: I think the root cause is tpc-ds tests have slowed down a lot.

[jira] [Updated] (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:all-tabpanel ] Kurt Young updated FLINK-16917: --- Attachment: image-2020-04-02-09-32-52-979.png > "TPC-DS end-to-end test (Blink planner)" gets stuck

[jira] [Updated] (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:all-tabpanel ] Kurt Young updated FLINK-16917: --- Summary: "TPC-DS end-to-end test (Blink planner)" gets stuck (was: "TPC-H end-to-end test (Blink

[jira] [Assigned] (FLINK-16906) Various tests failing with: Could not register mbeans javax.management.InstanceAlreadyExistsException

[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16906: -- Assignee: d > Various tests failing with: Could not register mbeans >

[jira] [Assigned] (FLINK-16906) Various tests failing with: Could not register mbeans javax.management.InstanceAlreadyExistsException

[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16906: -- Assignee: Danny Chen (was: d) > Various tests failing with: Could not register mbeans >

[jira] [Comment Edited] (FLINK-16889) Support converting BIGINT to TIMESTAMP for TO_TIMESTAMP function

[ https://issues.apache.org/jira/browse/FLINK-16889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072467#comment-17072467 ] Kurt Young edited comment on FLINK-16889 at 4/1/20, 7:24 AM: - I'm afraid

[jira] [Commented] (FLINK-16889) Support converting BIGINT to TIMESTAMP for TO_TIMESTAMP function

[ https://issues.apache.org/jira/browse/FLINK-16889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072467#comment-17072467 ] Kurt Young commented on FLINK-16889: I'm afraid that users maybe expect the timestamp will be

[jira] [Commented] (FLINK-16889) Support converting BIGINT to TIMESTAMP for TO_TIMESTAMP function

[ https://issues.apache.org/jira/browse/FLINK-16889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072304#comment-17072304 ] Kurt Young commented on FLINK-16889: Which time zone we will use when converting BIGINT to

[jira] [Closed] (FLINK-16870) OrcTableSource throws NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-16870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16870. -- Resolution: Duplicate > OrcTableSource throws NullPointerException >

[jira] [Commented] (FLINK-16870) OrcTableSource throws NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-16870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071496#comment-17071496 ] Kurt Young commented on FLINK-16870: [~nikobearrr] Not yet, but it will be included in 1.10.1, which

[jira] [Commented] (FLINK-16870) OrcTableSource throws NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-16870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071371#comment-17071371 ] Kurt Young commented on FLINK-16870: I think this is the same with FLINK-16646, could you check

[jira] [Closed] (FLINK-15809) component stack page needs to be updated for blink planner

[ https://issues.apache.org/jira/browse/FLINK-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15809. -- Fix Version/s: (was: 1.10.1) (was: 1.11.0) Resolution: Invalid >

[jira] [Commented] (FLINK-15809) component stack page needs to be updated for blink planner

[ https://issues.apache.org/jira/browse/FLINK-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068449#comment-17068449 ] Kurt Young commented on FLINK-15809: Closing this since component page has been deleted. >

[jira] [Commented] (FLINK-16156) TableAggregateITCase.testGroupByFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068447#comment-17068447 ] Kurt Young commented on FLINK-16156: Close this for now  >

[jira] [Closed] (FLINK-16156) TableAggregateITCase.testGroupByFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16156. -- Fix Version/s: (was: 1.10.1) (was: 1.11.0) Resolution: Cannot

[jira] [Assigned] (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 reassigned FLINK-16823: -- Assignee: Zhenghua Gao > The functioin TIMESTAMPDIFF doesn't perform expected result >

[jira] [Commented] (FLINK-16818) Optimize data skew when flink write data to hive dynamic partition table

[ https://issues.apache.org/jira/browse/FLINK-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068362#comment-17068362 ] Kurt Young commented on FLINK-16818: Can you share the execution graph? To be more specific, is

[jira] [Commented] (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:comment-tabpanel=17068358#comment-17068358 ] Kurt Young commented on FLINK-16823: Yes, this is a bug. [~docete] could you take a look at this? >

[jira] [Updated] (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 updated FLINK-16823: --- Priority: Major (was: Minor) > The functioin TIMESTAMPDIFF doesn't perform expected result >

[jira] [Updated] (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 updated FLINK-16823: --- Affects Version/s: 1.9.1 1.10.0 > The functioin TIMESTAMPDIFF doesn't

[jira] [Commented] (FLINK-16156) TableAggregateITCase.testGroupByFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064620#comment-17064620 ] Kurt Young commented on FLINK-16156: TableAggregateITCase.testGroupByFlatAggregate seems to be a

[jira] [Commented] (FLINK-16156) TableAggregateITCase.testGroupByFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064619#comment-17064619 ] Kurt Young commented on FLINK-16156: FunctionITCase.testDynamicTableFunction  has been fixed in

[jira] [Updated] (FLINK-15984) support hive stream table sink

[ https://issues.apache.org/jira/browse/FLINK-15984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15984: --- Fix Version/s: (was: 1.11.0) > support hive stream table sink > --

[jira] [Updated] (FLINK-15983) add native reader for Hive parquet files

[ https://issues.apache.org/jira/browse/FLINK-15983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15983: --- Fix Version/s: (was: 1.11.0) > add native reader for Hive parquet files >

[jira] [Updated] (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 updated FLINK-16662: --- Component/s: (was: API / DataStream) Table SQL / Planner > Blink Planner

[jira] [Commented] (FLINK-16659) flink 1.9.1 流排序（普通模式、CEP模式）多并发情况下分组异常

[ https://issues.apache.org/jira/browse/FLINK-16659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061732#comment-17061732 ] Kurt Young commented on FLINK-16659: hi, can you translate these to English? > flink 1.9.1

[jira] [Updated] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16648: --- Fix Version/s: (was: 1.10.1) 1.11.0 > Clean up the input parameter

[jira] [Commented] (FLINK-16141) HiveTableSourceTest unstable

[ https://issues.apache.org/jira/browse/FLINK-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061500#comment-17061500 ] Kurt Young commented on FLINK-16141: I will close this for now since this hasn't reproduce for a

[jira] [Closed] (FLINK-16141) HiveTableSourceTest unstable

[ https://issues.apache.org/jira/browse/FLINK-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16141. -- Fix Version/s: (was: 1.11.0) Resolution: Cannot Reproduce > HiveTableSourceTest unstable >

[jira] [Updated] (FLINK-16432) Building Hive connector gives problems

[ https://issues.apache.org/jira/browse/FLINK-16432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16432: --- Affects Version/s: (was: 1.11.0) > Building Hive connector gives problems >

[jira] [Assigned] (FLINK-16646) flink read orc file throw a NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-16646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16646: -- Assignee: Jun Zhang > flink read orc file throw a NullPointerException >

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashed on traivs

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061486#comment-17061486 ] Kurt Young commented on FLINK-16636: another instance: 

[jira] [Assigned] (FLINK-16361) FLIP-84: Improve & Refactor API of TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16361: -- Assignee: godfrey he > FLIP-84: Improve & Refactor API of TableEnvironment >

[jira] [Commented] (FLINK-16643) flink-connector-hive_2.11 build fails on retrieving javax.jms:jms:jar:1.1

[ https://issues.apache.org/jira/browse/FLINK-16643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061471#comment-17061471 ] Kurt Young commented on FLINK-16643: another similar issue: FLINK-16432 cc [~lzljs3620320] >

[jira] [Created] (FLINK-16642) CSV TableSource / TableSink shouldn't be in flink-table-api-java-bridge package

Kurt Young created FLINK-16642: -- Summary: CSV TableSource / TableSink shouldn't be in flink-table-api-java-bridge package Key: FLINK-16642 URL: https://issues.apache.org/jira/browse/FLINK-16642 Project:

[jira] [Closed] (FLINK-16639) Flink SQL Kafka source connector, add the no json format filter params when format.type is json

[ https://issues.apache.org/jira/browse/FLINK-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16639. -- Fix Version/s: (was: 1.10.2) Resolution: Invalid > Flink SQL Kafka source connector, add

[jira] [Reopened] (FLINK-16639) Flink SQL Kafka source connector, add the no json format filter params when format.type is json

[ https://issues.apache.org/jira/browse/FLINK-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-16639: > Flink SQL Kafka source connector, add the no json format filter params when > format.type is json

[jira] [Commented] (FLINK-16639) Flink SQL Kafka source connector, add the no json format filter params when format.type is json

[ https://issues.apache.org/jira/browse/FLINK-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061351#comment-17061351 ] Kurt Young commented on FLINK-16639: does current \{{format.ignore-parse-errors}} meet your

[jira] [Updated] (FLINK-16627) Remove keys with null value in json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16627: --- Component/s: Table SQL / Planner > Remove keys with null value in json >

[jira] [Assigned] (FLINK-16627) Remove keys with null value in json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16627: -- Assignee: jackray wang > Remove keys with null value in json >

[jira] [Commented] (FLINK-16627) Remove keys with null value in json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060872#comment-17060872 ] Kurt Young commented on FLINK-16627: Sounds good to me. I will assign this to you [~jackray],

[jira] [Reopened] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-16627: > when insert into kafkas ,how can i remove the keys with null values of json >

[jira] [Updated] (FLINK-16627) Remove keys with null value in json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16627: --- Summary: Remove keys with null value in json (was: when insert into kafkas ,how can i remove the

[jira] [Commented] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060865#comment-17060865 ] Kurt Young commented on FLINK-16627: I see, i misunderstood this issue. If we delete all keys with

[jira] [Updated] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16627: --- Component/s: (was: Table SQL / Client) Formats (JSON, Avro, Parquet, ORC,

[jira] [Assigned] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14807: -- Assignee: Caizhi Weng > Add Table#collect api for fetching data to client >

[jira] [Closed] (FLINK-16623) add the shorthand 'desc' for describe on sql client

[ https://issues.apache.org/jira/browse/FLINK-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16623. -- Resolution: Fixed merge to master: 9242daf12ae858db9cab9ec72bdbeaa61e37a948 > add the shorthand

[jira] [Assigned] (FLINK-16623) add the shorthand 'desc' for describe on sql client

[ https://issues.apache.org/jira/browse/FLINK-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16623: -- Assignee: Jun Zhang > add the shorthand 'desc' for describe on sql client >

[jira] [Closed] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16627. -- Resolution: Invalid > when insert into kafkas ,how can i remove the keys with null values of json >

[jira] [Commented] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060651#comment-17060651 ] Kurt Young commented on FLINK-16627: BTW, such issue should be reported to user mailing thread, I

[jira] [Commented] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060650#comment-17060650 ] Kurt Young commented on FLINK-16627: why don't add a "where svt is not null" before inserting into

[jira] [Updated] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the Table

[ https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16622: --- Component/s: (was: API / Core) Table SQL / API > Type ARRAY of table field

[jira] [Commented] (FLINK-16609) Promotes the column name representation of SQL-CLI

[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059995#comment-17059995 ] Kurt Young commented on FLINK-16609: It's a good improvement. +1 for this. > Promotes the column

[jira] [Commented] (FLINK-16589) Flink Table SQL fails/crashes with big queries with lots of fields

[ https://issues.apache.org/jira/browse/FLINK-16589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058673#comment-17058673 ] Kurt Young commented on FLINK-16589: The root cause is here: Code of method

[jira] [Commented] (FLINK-16575) develop HBaseCatalog to integrate HBase metadata into Flink

[ https://issues.apache.org/jira/browse/FLINK-16575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058637#comment-17058637 ] Kurt Young commented on FLINK-16575: Could you explain how do you deal with such free schema storage

[jira] [Updated] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

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

[jira] [Closed] (FLINK-16464) result-mode tableau may shift when content contains Chinese String in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-16464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16464. -- Resolution: Fixed fixed in master: 22915d051d614249ea2d2eae4a2366b5533136d8 > result-mode tableau

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058332#comment-17058332 ] Kurt Young commented on FLINK-16379: Empty table is a useful corner case to test query correctness,

[jira] [Closed] (FLINK-16539) sql client set param error

[ https://issues.apache.org/jira/browse/FLINK-16539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16539. -- Resolution: Fixed merge to master: 625da7b51004bbda8cd97c46208766ba98c63288 > sql client set param

[jira] [Assigned] (FLINK-16567) Get the API error of the StreamQueryConfig on Page "Query Configuration"

[ https://issues.apache.org/jira/browse/FLINK-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16567: -- Assignee: jinhai > Get the API error of the StreamQueryConfig on Page "Query Configuration"

[jira] [Commented] (FLINK-16567) Get the API error of the StreamQueryConfig on Page "Query Configuration"

[ https://issues.apache.org/jira/browse/FLINK-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057766#comment-17057766 ] Kurt Young commented on FLINK-16567: [~csbliss] thanks for reporting this, I've assigned to you. >

[jira] [Assigned] (FLINK-16539) sql client set param error

[ https://issues.apache.org/jira/browse/FLINK-16539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16539: -- Assignee: Jun Zhang > sql client set param error > -- > >

[jira] [Commented] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057572#comment-17057572 ] Kurt Young commented on FLINK-16343: Thanks [~jark], and sorry for the false alarm. I will change

[jira] [Updated] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16343: --- Fix Version/s: (was: 1.10.1) > Improve exception message when reading an unbounded source in

[jira] [Updated] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16343: --- Issue Type: Improvement (was: Bug) > Improve exception message when reading an unbounded source in

[jira] [Commented] (FLINK-16539) sql client set param error

[ https://issues.apache.org/jira/browse/FLINK-16539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056767#comment-17056767 ] Kurt Young commented on FLINK-16539: Looks like we forgot to trim the value somewhere. [~zhangjun] 

[jira] [Updated] (FLINK-16539) sql client set param error

[ https://issues.apache.org/jira/browse/FLINK-16539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16539: --- Component/s: (was: Command Line Client) Table SQL / Client > sql client set

[jira] [Created] (FLINK-16534) Support specify savepoint path when submitting sql job through sql client

Kurt Young created FLINK-16534: -- Summary: Support specify savepoint path when submitting sql job through sql client Key: FLINK-16534 URL: https://issues.apache.org/jira/browse/FLINK-16534 Project: Flink

[jira] [Commented] (FLINK-16526) Escape character doesn't work for computed column

[ https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056587#comment-17056587 ] Kurt Young commented on FLINK-16526: cc [~danny0405] > Escape character doesn't work for computed

[jira] [Comment Edited] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055885#comment-17055885 ] Kurt Young edited comment on FLINK-16379 at 3/10/20, 12:15 PM: --- The other

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055885#comment-17055885 ] Kurt Young commented on FLINK-16379: The other use cases you mentioned make sense to me. But it

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055871#comment-17055871 ] Kurt Young commented on FLINK-16379: For types that needs more information, we can also choose

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055718#comment-17055718 ] Kurt Young commented on FLINK-16379: It this is the case, why not just only support objects with

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055513#comment-17055513 ] Kurt Young commented on FLINK-16379: I have quite opposite opinion, IMO `fromElements` is a superset

[jira] [Updated] (FLINK-16384) Support SHOW CREATE TABLE command in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-16384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16384: --- Fix Version/s: 1.11.0 > Support SHOW CREATE TABLE command in SQL Client >

[jira] [Commented] (FLINK-16485) Support vectorized Python UDF in the batch mode of old planner

[ https://issues.apache.org/jira/browse/FLINK-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054950#comment-17054950 ] Kurt Young commented on FLINK-16485: [~dian.fu] Thanks for the clarification.  > Support vectorized

[jira] [Commented] (FLINK-16485) Support vectorized Python UDF in the batch mode of old planner

[ https://issues.apache.org/jira/browse/FLINK-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054792#comment-17054792 ] Kurt Young commented on FLINK-16485: DataSet means the whole batch processing stack includes DataSet

[jira] [Commented] (FLINK-16485) Support vectorized Python UDF in the batch mode of old planner

[ https://issues.apache.org/jira/browse/FLINK-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054728#comment-17054728 ] Kurt Young commented on FLINK-16485: It's not only about the legacy planner, but also it might

[jira] [Commented] (FLINK-16485) Support vectorized Python UDF in the batch mode of old planner

[ https://issues.apache.org/jira/browse/FLINK-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054389#comment-17054389 ] Kurt Young commented on FLINK-16485: Is this necessary? I thought we've already stop adding new

[jira] [Assigned] (FLINK-16463) CodeGenUtils generates code that has two semicolons for GroupingWindowAggsHandler in blink

[ https://issues.apache.org/jira/browse/FLINK-16463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16463: -- Assignee: hehuiyuan > CodeGenUtils generates code that has two semicolons for >

[jira] [Commented] (FLINK-16463) CodeGenUtils generates code that has two semicolons for GroupingWindowAggsHandler in blink

[ https://issues.apache.org/jira/browse/FLINK-16463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053873#comment-17053873 ] Kurt Young commented on FLINK-16463: [~hehuiyuan] assigned to you. > CodeGenUtils generates code

[jira] [Commented] (FLINK-16463) CodeGenUtils generates code that has two semicolons for GroupingWindowAggsHandler in blink

[ https://issues.apache.org/jira/browse/FLINK-16463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053456#comment-17053456 ] Kurt Young commented on FLINK-16463: [~hehuiyuan] would you like to fix this? > CodeGenUtils

[jira] [Assigned] (FLINK-16464) result-mode tableau may shift when content contains Chinese String in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-16464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16464: -- Assignee: Kurt Young > result-mode tableau may shift when content contains Chinese String

[jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result

[ https://issues.apache.org/jira/browse/FLINK-16466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16466: --- Fix Version/s: 1.11.0 > Group by on event time should produce insert only result >

[jira] [Created] (FLINK-16466) Group by on event time should produce insert only result

Kurt Young created FLINK-16466: -- Summary: Group by on event time should produce insert only result Key: FLINK-16466 URL: https://issues.apache.org/jira/browse/FLINK-16466 Project: Flink Issue

[jira] [Closed] (FLINK-16362) Remove deprecated method in StreamTableSink

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

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050192#comment-17050192 ] Kurt Young commented on FLINK-16379: I'm not sure let TableEnvironment providing API related to

[jira] [Closed] (FLINK-12814) Support a traditional and scrolling view of result (non-interactive)

[ https://issues.apache.org/jira/browse/FLINK-12814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12814. -- Resolution: Fixed merged in master: 242efcdc3170341c5f8ccef5b29f3317cead3fa3 > Support a traditional

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049215#comment-17049215 ] Kurt Young commented on FLINK-16379: Is this the same with FLINK-16327? > Introduce fromValues in

[jira] [Commented] (FLINK-16382) SQL CLI should support command history file

[ https://issues.apache.org/jira/browse/FLINK-16382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049201#comment-17049201 ] Kurt Young commented on FLINK-16382: +1, I also find it inconvenient for loosing history each time i

[jira] [Updated] (FLINK-16382) SQL CLI should support command history file

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

[jira] [Assigned] (FLINK-12814) Support a traditional and scrolling view of result (non-interactive)

[ https://issues.apache.org/jira/browse/FLINK-12814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-12814: -- Assignee: Kurt Young (was: Zhenghua Gao) > Support a traditional and scrolling view of

[jira] [Created] (FLINK-16343) Failed to read a table with watermark in batch mode

Kurt Young created FLINK-16343: -- Summary: Failed to read a table with watermark in batch mode Key: FLINK-16343 URL: https://issues.apache.org/jira/browse/FLINK-16343 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046394#comment-17046394 ] Kurt Young edited comment on FLINK-14807 at 2/27/20 9:30 AM: - {quote}The

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046394#comment-17046394 ] Kurt Young commented on FLINK-14807: {quote}The communication channel is always needed whether it is

[jira] [Comment Edited] (FLINK-16296) Improve performance of BaseRowSerializer#serialize() for GenericRow

[ https://issues.apache.org/jira/browse/FLINK-16296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046366#comment-17046366 ] Kurt Young edited comment on FLINK-16296 at 2/27/20 9:07 AM: - The reason

[jira] [Comment Edited] (FLINK-16296) Improve performance of BaseRowSerializer#serialize() for GenericRow

[ https://issues.apache.org/jira/browse/FLINK-16296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046366#comment-17046366 ] Kurt Young edited comment on FLINK-16296 at 2/27/20 9:07 AM: - The reason

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