[jira] [Created] (FLINK-13372) Timestamp conversion bug in non-blink Table/SQL runtime

2019-07-22 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-13372: -- Summary: Timestamp conversion bug in non-blink Table/SQL runtime Key: FLINK-13372 URL: https://issues.apache.org/jira/browse/FLINK-13372 Project: Flink Issue

[jira] [Created] (FLINK-11914) Expose a REST endpoint in JobManager to disconnect specific TaskManager

2019-03-13 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-11914: -- Summary: Expose a REST endpoint in JobManager to disconnect specific TaskManager Key: FLINK-11914 URL: https://issues.apache.org/jira/browse/FLINK-11914 Project: Flink

[jira] [Created] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

2018-11-10 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-10848: -- Summary: Flink's Yarn ResourceManager can allocate too many excess containers Key: FLINK-10848 URL: https://issues.apache.org/jira/browse/FLINK-10848 Project: Flink

[jira] [Created] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

2018-10-09 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-10516: -- Summary: YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup Key: FLINK-10516 URL:

[jira] [Created] (FLINK-10187) Fix LogicalUnnestRule to match Correlate/Uncollect correctly

2018-08-21 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-10187: -- Summary: Fix LogicalUnnestRule to match Correlate/Uncollect correctly Key: FLINK-10187 URL: https://issues.apache.org/jira/browse/FLINK-10187 Project: Flink

[jira] [Created] (FLINK-10076) Upgrade Calcite dependency to 1.18

2018-08-06 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-10076: -- Summary: Upgrade Calcite dependency to 1.18 Key: FLINK-10076 URL: https://issues.apache.org/jira/browse/FLINK-10076 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-9523) Add Kafka examples for Flink Table/SQL API

2018-06-04 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9523: - Summary: Add Kafka examples for Flink Table/SQL API Key: FLINK-9523 URL: https://issues.apache.org/jira/browse/FLINK-9523 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

2018-05-30 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9477: - Summary: Support SQL 2016 JSON functions in Flink SQL Key: FLINK-9477 URL: https://issues.apache.org/jira/browse/FLINK-9477 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9327) Support explicit ROW value constructor in Flink SQL

2018-05-09 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9327: - Summary: Support explicit ROW value constructor in Flink SQL Key: FLINK-9327 URL: https://issues.apache.org/jira/browse/FLINK-9327 Project: Flink Issue Type:

[jira] [Created] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

2018-04-22 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9235: - Summary: Add Integration test for Flink-Yarn-Kerberos integration for flip-6 Key: FLINK-9235 URL: https://issues.apache.org/jira/browse/FLINK-9235 Project: Flink

[jira] [Created] (FLINK-9171) Flink HCatolog integration

2018-04-13 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9171: - Summary: Flink HCatolog integration Key: FLINK-9171 URL: https://issues.apache.org/jira/browse/FLINK-9171 Project: Flink Issue Type: Task Reporter:

[jira] [Created] (FLINK-9170) HCatolog integration with Table/SQL API

2018-04-13 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9170: - Summary: HCatolog integration with Table/SQL API Key: FLINK-9170 URL: https://issues.apache.org/jira/browse/FLINK-9170 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9161) Support AS STRUCT syntax to create named STRUCT in SQL

2018-04-12 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9161: - Summary: Support AS STRUCT syntax to create named STRUCT in SQL Key: FLINK-9161 URL: https://issues.apache.org/jira/browse/FLINK-9161 Project: Flink Issue Type:

[jira] [Created] (FLINK-9049) Create unified interfaces to configure and instatiate TableSink

2018-03-21 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9049: - Summary: Create unified interfaces to configure and instatiate TableSink Key: FLINK-9049 URL: https://issues.apache.org/jira/browse/FLINK-9049 Project: Flink

[jira] [Created] (FLINK-9015) Upgrade Calcite dependency to 1.17

2018-03-16 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9015: - Summary: Upgrade Calcite dependency to 1.17 Key: FLINK-9015 URL: https://issues.apache.org/jira/browse/FLINK-9015 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-02-05 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8562: - Summary: Fix YARNSessionFIFOSecuredITCase Key: FLINK-8562 URL: https://issues.apache.org/jira/browse/FLINK-8562 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8509) Remove SqlGroupedWindowFunction from Flink repo

2018-01-24 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8509: - Summary: Remove SqlGroupedWindowFunction from Flink repo Key: FLINK-8509 URL: https://issues.apache.org/jira/browse/FLINK-8509 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-8508) Remove RexSimplify from Flink repo

2018-01-24 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8508: - Summary: Remove RexSimplify from Flink repo Key: FLINK-8508 URL: https://issues.apache.org/jira/browse/FLINK-8508 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-8507) Upgrade Calcite dependency to 1.16

2018-01-24 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8507: - Summary: Upgrade Calcite dependency to 1.16 Key: FLINK-8507 URL: https://issues.apache.org/jira/browse/FLINK-8507 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-8401) Allow subclass to override write-failure behavior in CassandraOutputFormat

2018-01-10 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8401: - Summary: Allow subclass to override write-failure behavior in CassandraOutputFormat Key: FLINK-8401 URL: https://issues.apache.org/jira/browse/FLINK-8401 Project: Flink

[jira] [Created] (FLINK-8397) Support ROW type in CassandraOutputFormat

2018-01-09 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8397: - Summary: Support ROW type in CassandraOutputFormat Key: FLINK-8397 URL: https://issues.apache.org/jira/browse/FLINK-8397 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8286) Investigate Flink-Yarn-Kerberos integration for flip-6

2017-12-18 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8286: - Summary: Investigate Flink-Yarn-Kerberos integration for flip-6 Key: FLINK-8286 URL: https://issues.apache.org/jira/browse/FLINK-8286 Project: Flink Issue Type:

[jira] [Created] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working

2017-12-17 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8275: - Summary: Flink YARN deployment with Kerberos enabled not working Key: FLINK-8275 URL: https://issues.apache.org/jira/browse/FLINK-8275 Project: Flink Issue Type:

[jira] [Created] (FLINK-8039) Support "CREATE TYPE" DDL in Flink SQL

2017-11-08 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8039: - Summary: Support "CREATE TYPE" DDL in Flink SQL Key: FLINK-8039 URL: https://issues.apache.org/jira/browse/FLINK-8039 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-8003) Support Calcite's ROW value constructor in Flink SQL

2017-11-06 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8003: - Summary: Support Calcite's ROW value constructor in Flink SQL Key: FLINK-8003 URL: https://issues.apache.org/jira/browse/FLINK-8003 Project: Flink Issue Type: New

[jira] [Created] (FLINK-7860) Support YARN proxy user in Flink (impersonation)

2017-10-17 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-7860: - Summary: Support YARN proxy user in Flink (impersonation) Key: FLINK-7860 URL: https://issues.apache.org/jira/browse/FLINK-7860 Project: Flink Issue Type: New

[jira] [Created] (FLINK-7690) Do not call actorSystem.awaitTermination from the main akka message handling thread

2017-09-26 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-7690: - Summary: Do not call actorSystem.awaitTermination from the main akka message handling thread Key: FLINK-7690 URL: https://issues.apache.org/jira/browse/FLINK-7690 Project:

[jira] [Created] (FLINK-7658) Support COLLECT Aggregate function in Flink TABLE API

2017-09-20 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-7658: - Summary: Support COLLECT Aggregate function in Flink TABLE API Key: FLINK-7658 URL: https://issues.apache.org/jira/browse/FLINK-7658 Project: Flink Issue Type:

[jira] [Created] (FLINK-7546) Support SUBMULTISET_OF Operator for Multiset SQL type

2017-08-28 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-7546: - Summary: Support SUBMULTISET_OF Operator for Multiset SQL type Key: FLINK-7546 URL: https://issues.apache.org/jira/browse/FLINK-7546 Project: Flink Issue Type:

[jira] [Created] (FLINK-7545) Support MEMBER OF Operator for Multiset SQL type

2017-08-28 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-7545: - Summary: Support MEMBER OF Operator for Multiset SQL type Key: FLINK-7545 URL: https://issues.apache.org/jira/browse/FLINK-7545 Project: Flink Issue Type: New

[jira] [Created] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

2017-08-22 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-7491: - Summary: Support COLLECT Aggregate function in Flink SQL Key: FLINK-7491 URL: https://issues.apache.org/jira/browse/FLINK-7491 Project: Flink Issue Type: New

[jira] [Created] (FLINK-7003) "select * from" in Flink SQL should not flatten all fields in the table by default

2017-06-25 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-7003: - Summary: "select * from" in Flink SQL should not flatten all fields in the table by default Key: FLINK-7003 URL: https://issues.apache.org/jira/browse/FLINK-7003 Project: