[jira] [Assigned] (FLINK-18028) E2E tests manually for Kafka 2 all kinds of other connectors

[ https://issues.apache.org/jira/browse/FLINK-18028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18028: -- Assignee: Shengkai Fang > E2E tests manually for Kafka 2 all kinds of other connectors >

[jira] [Assigned] (FLINK-18029) Add more ITCases for Kafka with new formats

[ https://issues.apache.org/jira/browse/FLINK-18029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18029: -- Assignee: Jark Wu > Add more ITCases for Kafka with new formats > ---

[jira] [Assigned] (FLINK-18078) E2E tests manually for Hive streaming dim join

[ https://issues.apache.org/jira/browse/FLINK-18078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18078: -- Assignee: Rui Li > E2E tests manually for Hive streaming dim join > -

[jira] [Assigned] (FLINK-18077) E2E tests manually for Hive streaming source

[ https://issues.apache.org/jira/browse/FLINK-18077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18077: -- Assignee: Jingsong Lee > E2E tests manually for Hive streaming source > -

[jira] [Assigned] (FLINK-18023) E2E tests manually for new filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-18023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18023: -- Assignee: Jingsong Lee > E2E tests manually for new filesystem connector > --

[jira] [Assigned] (FLINK-18025) E2E tests manually for Hive streaming sink

[ https://issues.apache.org/jira/browse/FLINK-18025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18025: -- Assignee: Rui Li > E2E tests manually for Hive streaming sink > -

[jira] [Assigned] (FLINK-18024) E2E tests manually for new Hive dependency jars

[ https://issues.apache.org/jira/browse/FLINK-18024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18024: -- Assignee: Jingsong Lee > E2E tests manually for new Hive dependency jars > --

[jira] [Assigned] (FLINK-18022) Add e2e test for new streaming file sink

[ https://issues.apache.org/jira/browse/FLINK-18022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18022: -- Assignee: Jingsong Lee > Add e2e test for new streaming file sink > -

[jira] [Updated] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15066: --- Priority: Blocker (was: Major) > Cannot run multiple `insert into csvTable values ()` > ---

[jira] [Updated] (FLINK-16627) Support only generate non-null values when serializing into JSON

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16627: --- Issue Type: New Feature (was: Improvement) > Support only generate non-null values when serializing

[jira] [Updated] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16175: --- Issue Type: New Feature (was: Improvement) > Add config option to switch case sensitive for column

[jira] [Updated] (FLINK-16627) Support only generate non-null values when serializing into JSON

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16627: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support only generate non-null values w

[jira] [Updated] (FLINK-7151) Support function DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-7151: -- Fix Version/s: (was: 1.11.0) > Support function DDL > > > Key:

[jira] [Updated] (FLINK-15585) Improve function identifier string in plan digest

[ https://issues.apache.org/jira/browse/FLINK-15585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15585: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Improve function identifier string in p

[jira] [Updated] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16175: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Add config option to switch case sensit

[jira] [Updated] (FLINK-12256) Implement Confluent Schema Registry Catalog

[ https://issues.apache.org/jira/browse/FLINK-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-12256: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Implement Confluent Schema Registry Cat

[jira] [Updated] (FLINK-17198) [Umbrella] DDL and DML compatibility for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-17198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17198: --- Summary: [Umbrella] DDL and DML compatibility for Hive connector (was: DDL and DML compatibility fo

[jira] [Updated] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14364: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Allow comments fail when not ignore par

[jira] [Updated] (FLINK-17717) Throws for DDL create temporary system function with composite table path

[ https://issues.apache.org/jira/browse/FLINK-17717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17717: --- Priority: Critical (was: Major) > Throws for DDL create temporary system function with composite ta

[jira] [Updated] (FLINK-17113) Refactor view support in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17113: --- Priority: Critical (was: Major) > Refactor view support in SQL Client > ---

[jira] [Updated] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

[ https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16577: --- Priority: Critical (was: Major) > Exception will be thrown when computing columnInterval relmetadat

[jira] [Updated] (FLINK-17101) [Umbrella] 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 updated FLINK-17101: --- Summary: [Umbrella] Supports dynamic table options for Flink SQL (was: Supports dynamic table optio

[jira] [Updated] (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:all-tabpanel ] Kurt Young updated FLINK-16589: --- Priority: Critical (was: Major) > Flink Table SQL fails/crashes with big queries with lots of field

[jira] [Assigned] (FLINK-18046) Decimal column stats not supported for Hive table

[ https://issues.apache.org/jira/browse/FLINK-18046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18046: -- Assignee: Rui Li > Decimal column stats not supported for Hive table > --

[jira] [Updated] (FLINK-18046) Decimal column stats not supported for Hive table

[ https://issues.apache.org/jira/browse/FLINK-18046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18046: --- Priority: Critical (was: Major) > Decimal column stats not supported for Hive table > -

[jira] [Updated] (FLINK-16743) [Umbrella] Introduce datagen, print, blackhole connectors

[ https://issues.apache.org/jira/browse/FLINK-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16743: --- Summary: [Umbrella] Introduce datagen, print, blackhole connectors (was: Introduce datagen, print,

[jira] [Updated] (FLINK-15609) Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions

[ https://issues.apache.org/jira/browse/FLINK-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15609: --- Fix Version/s: (was: 1.11.0) > Add blink built-in functions from FlinkSqlOperatorTable to > Bui

[jira] [Updated] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17625: --- Priority: Critical (was: Major) > Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction > --

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17553: --- Priority: Critical (was: Major) > Constant exists in group window key leads to error: Unsupported

[jira] [Updated] (FLINK-16451) listagg with distinct for over window codegen error

[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16451: --- Priority: Critical (was: Major) > listagg with distinct for over window codegen error > --

[jira] [Assigned] (FLINK-18030) Hive UDF doesn't accept empty string literal parameter

[ https://issues.apache.org/jira/browse/FLINK-18030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18030: -- Assignee: Rui Li > Hive UDF doesn't accept empty string literal parameter > -

[jira] [Assigned] (FLINK-18076) Sql client uses wrong class loader when parsing queries

[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18076: -- Assignee: Caizhi Weng > Sql client uses wrong class loader when parsing queries > ---

[jira] [Assigned] (FLINK-18061) TableResult#collect should return closeable iterator to avoid resource leak

[ https://issues.apache.org/jira/browse/FLINK-18061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18061: -- Assignee: godfrey he > TableResult#collect should return closeable iterator to avoid resource

[jira] [Updated] (FLINK-17948) Sql client lost precision for Timestamp and Decimal Data type

[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17948: --- Fix Version/s: (was: 1.11.0) > Sql client lost precision for Timestamp and Decimal Data type > -

[jira] [Updated] (FLINK-17895) Default value of rows-per-second in datagen can be limited

[ https://issues.apache.org/jira/browse/FLINK-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17895: --- Fix Version/s: (was: 1.11.0) > Default value of rows-per-second in datagen can be limited >

[jira] [Updated] (FLINK-17022) Flink SQL ROW_NUMBER() Exception: TableException: This calc has no useful projection and no filter. It should be removed by CalcRemoveRule.

[ https://issues.apache.org/jira/browse/FLINK-17022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17022: --- Fix Version/s: (was: 1.11.0) > Flink SQL ROW_NUMBER() Exception: TableException: This calc has n

[jira] [Assigned] (FLINK-17635) Add documentation about view support

[ https://issues.apache.org/jira/browse/FLINK-17635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17635: -- Assignee: Leonard Xu (was: Caizhi Weng) > Add documentation about view support > --

[jira] [Assigned] (FLINK-18076) Sql client uses wrong class loader when parsing queries

[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18076: -- Assignee: Leonard Xu (was: Caizhi Weng) > Sql client uses wrong class loader when parsing qu

[jira] [Updated] (FLINK-18092) E2E tests manually for HBase

[ https://issues.apache.org/jira/browse/FLINK-18092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18092: --- Component/s: Connectors / HBase > E2E tests manually for HBase > > >

[jira] [Updated] (FLINK-18092) E2E tests manually for HBase

[ https://issues.apache.org/jira/browse/FLINK-18092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18092: --- Priority: Blocker (was: Major) > E2E tests manually for HBase > > >

[jira] [Updated] (FLINK-18093) E2E tests manually for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18093: --- Priority: Blocker (was: Major) > E2E tests manually for Elasticsearch Sink > --

[jira] [Updated] (FLINK-18093) E2E tests manually for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18093: --- Component/s: Connectors / ElasticSearch > E2E tests manually for Elasticsearch Sink > --

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

[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&focusedCommentId=17089520#comment-17089520 ] Kurt Young commented on FLINK-17312: [~zhanglun] Thanks for bringing this up. Could

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

[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&focusedCommentId=17089636#comment-17089636 ] Kurt Young commented on FLINK-17326: [~jackylau] please report sql gateway's issue t

[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] [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] [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] [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&focusedCommentId=17090646#comment-17090646 ] Kurt Young edited comment on FLINK-16636 at 4/23/20, 2:13 PM:

[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&focusedCommentId=17090646#comment-17090646 ] Kurt Young commented on FLINK-16636: [~rmetzger] Is it possible to use JDK9 to execu

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

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

[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&focusedCommentId=17091418#comment-17091418 ] Kurt Young commented on FLINK-17312: Adding savepoint dir to yaml file seems to be a

[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&focusedCommentId=17091995#comment-17091995 ] Kurt Young commented on FLINK-17312: [~zhanglun] Yes, I was aware of your proposal a

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

[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-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] [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&focusedCommentId=17092632#comment-17092632 ] Kurt Young commented on FLINK-15591: I think [~docete] is doing this, right? > make

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

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

[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&focusedCommentId=17092683#comment-17092683 ] Kurt Young commented on FLINK-15591: what about temporary table? > make up for feat

[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&focusedCommentId=17092721#comment-17092721 ] Kurt Young commented on FLINK-15591: [~docete] Thanks, I will assign this to you. >

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

[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-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-16636) TableEnvironmentITCase is crashing on Travis

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

[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: Sub-tas

[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&focusedCommentId=17094070#comment-17094070 ] Kurt Young commented on FLINK-17420: [~Leonard Xu] Thanks, I will assign this to you

[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] [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-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] [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 > Table#

[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] [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 T

[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] [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&focusedCommentId=17095271#comment-17095271 ] Kurt Young commented on FLINK-17117: [~hehuiyuan] Thanks for the fix, I will try to

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

[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&focusedCommentId=17100373#comment-17100373 ] Kurt Young commented on FLINK-16998: Keep internal row's header makes sense, especia

[jira] [Closed] (FLINK-16029) Remove register source and sink in test cases of blink planner

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

[jira] [Assigned] (FLINK-17112) Support DESCRIBE view_name in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17112: -- Assignee: Zhenghua Gao > Support DESCRIBE view_name in Flink SQL > --

[jira] [Closed] (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 closed FLINK-17251. -- Resolution: Fixed master: 1de54fe48472b43e469cccbb95935d46163c8b16 > supports INSERT statement in Tab

[jira] [Closed] (FLINK-17267) supports EXPLAIN statement in TableEnvironment#executeSql and Table#explain api

[ https://issues.apache.org/jira/browse/FLINK-17267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17267. -- Assignee: godfrey he Resolution: Fixed master: 59ca355f05b668f1cb41cae02ce182ccc7c4d707 ~  4959e

[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&focusedCommentId=17083013#comment-17083013 ] Kurt Young commented on FLINK-17128: Yes, I think [~lzljs3620320] is right. One of

[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&focusedCommentId=17083227#comment-17083227 ] Kurt Young commented on FLINK-16767: It is possible that this is the reason of FLINK

[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&focusedCommentId=17083230#comment-17083230 ] Kurt Young commented on FLINK-17139: Are you using sql cli? > The sub-plan reuse op

[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: 0f835845b5e6222e6f7c73f778474cc1d7236a1

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

[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&focusedCommentId=17084067#comment-17084067 ] Kurt Young commented on FLINK-17117: Assigned to you [~hehuiyuan], thanks for the fi

[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&focusedCommentId=17084097#comment-17084097 ] Kurt Young commented on FLINK-8864: --- Hi [~Sergey Nuyanzin], would you still like to fin

[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-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&focusedCommentId=17084540#comment-17084540 ] Kurt Young commented on FLINK-16662: [~zhanglibing1...@126.com] I've assigned this t

[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&focusedCommentId=17084544#comment-17084544 ] Kurt Young commented on FLINK-17171: Similar with FLINK-16662? > Blink planner fail

[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-17178) Provide "ALL" cache strategy in LookupFunction

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

[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&focusedCommentId=17085021#comment-17085021 ] Kurt Young commented on FLINK-17178: How can cache all provides latest records? I ca

[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&focusedCommentId=17085031#comment-17085031 ] Kurt Young commented on FLINK-16936: [~zjffdu] As far as I know, I didn't see this o

[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&focusedCommentId=17085042#comment-17085042 ] Kurt Young commented on FLINK-17192: According to your stack, you are running a Data

<    4   5   6   7   8   9   10   11   12   13   >