[jira] [Assigned] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-14055: -- Assignee: Zhenqiu Huang > Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" >

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

[ https://issues.apache.org/jira/browse/FLINK-13372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894932#comment-16894932 ] Shuyi Chen commented on FLINK-13372: I'll provide a fix for 1.9.0. > Timestamp conversion bug in

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

[ https://issues.apache.org/jira/browse/FLINK-13372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-13372: --- Description: Currently, in the non-blink table/SQL runtime, Flink used

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

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] [Commented] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880947#comment-16880947 ] Shuyi Chen commented on FLINK-13132: Hi [~till.rohrmann], as [~ZhenqiuHuang] mentioned, we have a

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

[ https://issues.apache.org/jira/browse/FLINK-11914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16810193#comment-16810193 ] Shuyi Chen commented on FLINK-11914: Hi [~feng.xu], I dont think we should expose an Akka endpoint

[jira] [Commented] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809002#comment-16809002 ] Shuyi Chen commented on FLINK-11912: Hi [~aitozi], the current approach does the following: 1) as

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

[ https://issues.apache.org/jira/browse/FLINK-11914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803209#comment-16803209 ] Shuyi Chen commented on FLINK-11914: Hi [~Zentol], thanks a lot for the comments. cc

[jira] [Commented] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802858#comment-16802858 ] Shuyi Chen commented on FLINK-11912: Hi [~becket_qin], thanks a lot for your comments. The use of

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

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802008#comment-16802008 ] Shuyi Chen commented on FLINK-9477: --- That sounds like a good idea. I will split the tasks according to

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

[ https://issues.apache.org/jira/browse/FLINK-11914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793176#comment-16793176 ] Shuyi Chen commented on FLINK-11914: [~gjy], thanks a lot for the quick reply. Yes, to kill the TM

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

[ https://issues.apache.org/jira/browse/FLINK-11914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792207#comment-16792207 ] Shuyi Chen commented on FLINK-11914: Hi [~Zentol], [~trohrm...@apache.org], [~gyao], what do you

[jira] [Comment Edited] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/14/19 12:24 AM: -- Hi

[jira] [Comment Edited] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/14/19 12:22 AM: -- Hi

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

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] [Comment Edited] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/13/19 10:36 PM: -- Hi

[jira] [Comment Edited] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/13/19 10:29 PM: -- Hi

[jira] [Commented] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792155#comment-16792155 ] Shuyi Chen commented on FLINK-11912: Hi [~tzulitai], I've attached a proposed change

[jira] [Updated] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-11912: --- Summary: Expose per partition Kafka lag metric in Flink Kafka connector (was: Expose per partition

[jira] [Updated] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-11912: --- Description: In production, it's important that we expose the Kafka lag by partition metric in

[jira] [Created] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka consumer

Shuyi Chen created FLINK-11912: -- Summary: Expose per partition Kafka lag metric in Flink Kafka consumer Key: FLINK-11912 URL: https://issues.apache.org/jira/browse/FLINK-11912 Project: Flink

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751269#comment-16751269 ] Shuyi Chen commented on FLINK-7608: --- [~Zentol], Thanks a lot, I found it. > LatencyGauge change to

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750675#comment-16750675 ] Shuyi Chen commented on FLINK-7608: --- [~Zentol], [~aljoscha], it appears that after this PR, I can no

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740797#comment-16740797 ] Shuyi Chen commented on FLINK-10848: Also, can you please also help me take a look at

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740796#comment-16740796 ] Shuyi Chen commented on FLINK-10848: Thanks a lot for fixing the issue, [~till.rohrmann]. One

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735050#comment-16735050 ] Shuyi Chen commented on FLINK-10848: Hi [~gjy], we are running on 2.7.2. Can you share the steps to

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16734963#comment-16734963 ] Shuyi Chen commented on FLINK-10848: Fixed in 1.6: 7cc4c6f3e5e84efc067f2f2179648e31e5defa27 Fixed in

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen resolved FLINK-10848. Resolution: Fixed > Flink's Yarn ResourceManager can allocate too many excess containers >

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16734322#comment-16734322 ] Shuyi Chen commented on FLINK-10848: Fixed in master: e26d90fc86b266978b4bac84fe02ca34b62983fe.

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16733245#comment-16733245 ] Shuyi Chen commented on FLINK-10848: [~xinpu], thanks for sharing your thoughts. You are right,

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16726502#comment-16726502 ] Shuyi Chen commented on FLINK-10848: [~xinpu], the ContainerRequests are sent during the heartbeat

[jira] [Closed] (FLINK-11006) Update Calcite dependency to 1.18

[ https://issues.apache.org/jira/browse/FLINK-11006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-11006. -- Resolution: Duplicate > Update Calcite dependency to 1.18 > - > >

[jira] [Commented] (FLINK-11006) Update Calcite dependency to 1.18

[ https://issues.apache.org/jira/browse/FLINK-11006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699379#comment-16699379 ] Shuyi Chen commented on FLINK-11006: This is a duplicate of

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

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16696440#comment-16696440 ] Shuyi Chen commented on FLINK-9477: --- Thanks [~x1q1j1]. Once Calcite 1.18 is released and we upgrade to

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693835#comment-16693835 ] Shuyi Chen commented on FLINK-10848: [~till.rohrmann], can you help take a look at this PR? Thanks a

[jira] [Commented] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693833#comment-16693833 ] Shuyi Chen commented on FLINK-10868: Hi [~till.rohrmann], the following describes the the problem

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

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] [Commented] (FLINK-6962) Add a table SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672624#comment-16672624 ] Shuyi Chen commented on FLINK-6962: --- Design doc is attached. > Add a table SQL DDL >

[jira] [Commented] (FLINK-10232) Add a SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672623#comment-16672623 ] Shuyi Chen commented on FLINK-10232: Design doc is attached. > Add a SQL DDL > - > >

[jira] [Commented] (FLINK-10231) Add a view SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671204#comment-16671204 ] Shuyi Chen commented on FLINK-10231: I somewhat agree that registerTable to be replaced with

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

[ https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16648665#comment-16648665 ] Shuyi Chen commented on FLINK-10516: [~till.rohrmann], [~aljoscha], do you want me to cherry pick

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

[ https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16648664#comment-16648664 ] Shuyi Chen commented on FLINK-10516: This is fixed in 1.7.0 with

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

[ https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644150#comment-16644150 ] Shuyi Chen commented on FLINK-10516: Hi [~till.rohrmann], how do you want to proceed? I can either

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

Shuyi Chen created FLINK-10516: -- Summary: YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup Key: FLINK-10516 URL:

[jira] [Assigned] (FLINK-10232) Add a SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-10232: -- Assignee: Shuyi Chen > Add a SQL DDL > - > > Key: FLINK-10232 >

[jira] [Assigned] (FLINK-6962) Add a table SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-6962: - Assignee: Shuyi Chen (was: lincoln.lee) > Add a table SQL DDL > --- > >

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

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] [Commented] (FLINK-10163) Support CREATE VIEW in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-10163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584645#comment-16584645 ] Shuyi Chen commented on FLINK-10163: I think we can add this ticket as part of the DDL Flip, what do

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

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] [Closed] (FLINK-9134) Update Calcite dependency to 1.17

[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-9134. - Resolution: Fixed > Update Calcite dependency to 1.17 > - > >

[jira] [Closed] (FLINK-9135) Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed

[ https://issues.apache.org/jira/browse/FLINK-9135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-9135. - Resolution: Fixed > Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed >

[jira] [Commented] (FLINK-9135) Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed

[ https://issues.apache.org/jira/browse/FLINK-9135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16570890#comment-16570890 ] Shuyi Chen commented on FLINK-9135: --- Addressed in pull request

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16570889#comment-16570889 ] Shuyi Chen commented on FLINK-9134: --- PR merged. > Update Calcite dependency to 1.17 >

[jira] [Assigned] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped

[ https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-9891: - Assignee: Shuyi Chen > Flink cluster is not shutdown in YARN mode when Flink client is stopped

[jira] [Commented] (FLINK-6962) SQL DDL for input and output tables

[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525753#comment-16525753 ] Shuyi Chen commented on FLINK-6962: --- Hi [~shenyufeng], I am finalizing the DDL design doc and should

[jira] [Commented] (FLINK-9606) Support ParquetTableSource

[ https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515386#comment-16515386 ] Shuyi Chen commented on FLINK-9606: --- I think this is duplicate of

[jira] [Updated] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9559: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-9134 > The type of a union of CHAR

[jira] [Closed] (FLINK-9482) Not applicable functions for TIME

[ https://issues.apache.org/jira/browse/FLINK-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-9482. - Resolution: Fixed > Not applicable functions for TIME > - > >

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

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

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] [Commented] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF

[ https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494761#comment-16494761 ] Shuyi Chen commented on FLINK-9430: --- Hi [~twalthr], I've attached the PR. Having an end-to-end JSON

[jira] [Commented] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF

[ https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490026#comment-16490026 ] Shuyi Chen commented on FLINK-9430: --- The JSON object can be a int, float, double, boolean, array, map or

[jira] [Updated] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF

[ https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9430: -- Description: We want to add a SQL UDF to access specific element in a JSON string using JSON path.

[jira] [Created] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF

Shuyi Chen created FLINK-9430: - Summary: Support Casting of Object to Primitive types for Flink SQL UDF Key: FLINK-9430 URL: https://issues.apache.org/jira/browse/FLINK-9430 Project: Flink

[jira] [Comment Edited] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

[ https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16474801#comment-16474801 ] Shuyi Chen edited comment on FLINK-8866 at 5/14/18 9:07 PM: Hi [~walterddr],

[jira] [Commented] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

[ https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16474801#comment-16474801 ] Shuyi Chen commented on FLINK-8866: --- Hi [~walterddr], [~twalthr], [~fhueske], thanks a lot for the

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

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] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

[ https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464544#comment-16464544 ] Shuyi Chen commented on FLINK-7001: --- Hi [~pgrulich], the paper is a nice read. And the technique applies

[jira] [Assigned] (FLINK-7151) FLINK SQL support create temporary function and table

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-7151: - Assignee: Shuyi Chen (was: yuemeng) > FLINK SQL support create temporary function and table >

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

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] [Commented] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6

[ https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447411#comment-16447411 ] Shuyi Chen commented on FLINK-8286: --- Hi [~till.rohrmann] and [~aljoscha], spent some time on this, the

[jira] [Updated] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6

[ https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8286: -- Description: The current Flink-Yarn-Kerberos in Flip-6 is broken. (was: The current ) > Fix

[jira] [Updated] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6

[ https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8286: -- Summary: Fix Flink-Yarn-Kerberos integration for flip-6 (was: Investigate Flink-Yarn-Kerberos

[jira] [Updated] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6

[ https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8286: -- Description: The current (was: We've found some issues with the Flink-Yarn-Kerberos integration in

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

[ https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445560#comment-16445560 ] Shuyi Chen commented on FLINK-8286: --- Hi [~till.rohrmann] and [~aljoscha], the context is that there is a

[jira] [Updated] (FLINK-9157) Support Apache HCatalog in SQL client

[ https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9157: -- Summary: Support Apache HCatalog in SQL client (was: Support for commonly used external catalog) >

[jira] [Updated] (FLINK-1466) Add InputFormat to read HCatalog tables

[ https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-1466: -- Issue Type: Sub-task (was: New Feature) Parent: FLINK-9171 > Add InputFormat to read HCatalog

[jira] [Updated] (FLINK-9157) Support for commonly used external catalog

[ https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9157: -- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7594) > Support for commonly used

[jira] [Updated] (FLINK-9157) Support for commonly used external catalog

[ https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9157: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-9171 > Support for commonly used external

[jira] [Updated] (FLINK-1913) Document how to access data in HCatalog

[ https://issues.apache.org/jira/browse/FLINK-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-1913: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-9171 > Document how to access data in HCatalog >

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

[ https://issues.apache.org/jira/browse/FLINK-9170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9170: -- Issue Type: Sub-task (was: New Feature) Parent: FLINK-9171 > HCatolog integration with

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

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

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] [Assigned] (FLINK-1913) Document how to access data in HCatalog

[ https://issues.apache.org/jira/browse/FLINK-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-1913: - Assignee: Zhenqiu Huang > Document how to access data in HCatalog >

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

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] [Updated] (FLINK-9161) Support STRUCT syntax to create named STRUCT in SQL

[ https://issues.apache.org/jira/browse/FLINK-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9161: -- Summary: Support STRUCT syntax to create named STRUCT in SQL (was: Support AS STRUCT syntax to create

[jira] [Assigned] (FLINK-9135) Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed

[ https://issues.apache.org/jira/browse/FLINK-9135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-9135: - Assignee: Shuyi Chen > Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed >

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

[ https://issues.apache.org/jira/browse/FLINK-9015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-9015. - Resolution: Duplicate > Upgrade Calcite dependency to 1.17 > -- > >

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

[ https://issues.apache.org/jira/browse/FLINK-9015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426458#comment-16426458 ] Shuyi Chen commented on FLINK-9015: --- Duplicate of

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426455#comment-16426455 ] Shuyi Chen commented on FLINK-9134: --- Actually, let's close

[jira] [Reopened] (FLINK-9134) Update Calcite dependency to 1.17

[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reopened FLINK-9134: --- Assignee: Shuyi Chen > Update Calcite dependency to 1.17 > - > >

[jira] [Closed] (FLINK-9134) Update Calcite dependency to 1.17

[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-9134. - Resolution: Duplicate > Update Calcite dependency to 1.17 > - > >

[jira] [Commented] (FLINK-7151) FLINK SQL support create temporary function and table

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426316#comment-16426316 ] Shuyi Chen commented on FLINK-7151: --- I don't have a concrete timeline, but will try to implement the

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16425926#comment-16425926 ] Shuyi Chen commented on FLINK-9134: --- Hi [~twalthr], this is duplicate of

[jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security

[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417997#comment-16417997 ] Shuyi Chen commented on FLINK-8981: --- Setting up a real YARN cluster from the binary might be tricky as

[jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security

[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16415146#comment-16415146 ] Shuyi Chen commented on FLINK-8981: --- Hi [~tzulitai], I plan to work on it this week. Yes, I agree we

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

[ https://issues.apache.org/jira/browse/FLINK-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16414626#comment-16414626 ] Shuyi Chen commented on FLINK-9049: --- Thanks a lot, [~twalthr]. Assigned

[jira] [Updated] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

[ https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8866: -- Description: Similar to the efforts done in FLINK-8240. We need unified ways to configure and

[jira] [Assigned] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

[ https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8866: - Assignee: Shuyi Chen (was: Timo Walther) > Create unified interfaces to configure and

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16414618#comment-16414618 ] Shuyi Chen commented on FLINK-9059: --- Hi [~twalthr], thanks a lot for the comments. In the Pull Request,

  1   2   >