[jira] [Updated] (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:all-tabpanel ] Shuyi Chen updated FLINK-9059: -- Description: 1) Add a common property called "type" with single value 'source'. 2) in yaml file, replace

[jira] [Assigned] (FLINK-8988) End-to-end test: Cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8988: - Assignee: Shuyi Chen > End-to-end test: Cassandra connector > ---

[jira] [Commented] (FLINK-8988) End-to-end test: Cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410784#comment-16410784 ] Shuyi Chen commented on FLINK-8988: --- [~till.rohrmann] that sounds a good idea. I can hel

[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&focusedCommentId=16410237#comment-16410237 ] Shuyi Chen commented on FLINK-9049: --- Good point, [~fhueske]. Just created a JIRA for thi

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

Shuyi Chen created FLINK-9059: - Summary: Add support for unified table source and sink declaration in environment file Key: FLINK-9059 URL: https://issues.apache.org/jira/browse/FLINK-9059 Project: Flink

[jira] [Updated] (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:all-tabpanel ] Shuyi Chen updated FLINK-9049: -- Description: This is a similar effort to [FLINK-8240|https://issues.apache.org/jira/browse/FLINK-8240],

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

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 Issu

[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&focusedCommentId=16403335#comment-16403335 ] Shuyi Chen commented on FLINK-7151: --- [~yinhua], yes, you should be able to implement you

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

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 Repor

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

[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8981: - Assignee: Shuyi Chen > End-to-end test: Kerberos security > -- >

[jira] [Commented] (FLINK-8988) End-to-end test: Cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402515#comment-16402515 ] Shuyi Chen commented on FLINK-8988: --- [~till.rohrmann], wondering if the current Cassandr

[jira] [Comment Edited] (FLINK-8988) End-to-end test: Cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402515#comment-16402515 ] Shuyi Chen edited comment on FLINK-8988 at 3/16/18 8:50 PM: Hi

[jira] [Comment Edited] (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&focusedCommentId=16401583#comment-16401583 ] Shuyi Chen edited comment on FLINK-7151 at 3/16/18 8:20 AM: Hi

[jira] [Comment Edited] (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&focusedCommentId=16401583#comment-16401583 ] Shuyi Chen edited comment on FLINK-7151 at 3/16/18 8:20 AM: Hi

[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&focusedCommentId=16401583#comment-16401583 ] Shuyi Chen commented on FLINK-7151: --- Hi [~yinhua], I am actively working on a design doc

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16400990#comment-16400990 ] Shuyi Chen commented on FLINK-8903: --- Hi [~fhueske], please work on it if you are already

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16400925#comment-16400925 ] Shuyi Chen commented on FLINK-8903: --- [~fhueske], I can help take a look at this issue.

[jira] [Assigned] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8903: - Assignee: Shuyi Chen > Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken

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

[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354623#comment-16354623 ] Shuyi Chen commented on FLINK-8562: --- Hi, [~tzulitai], could you please help take a look

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

[ https://issues.apache.org/jira/browse/FLINK-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8507: - Assignee: Shuyi Chen > Upgrade Calcite dependency to 1.16 > -- >

[jira] [Assigned] (FLINK-8563) Support consecutive DOT operators

[ https://issues.apache.org/jira/browse/FLINK-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8563: - Assignee: Shuyi Chen > Support consecutive DOT operators > -- >

[jira] [Commented] (FLINK-8563) Support consecutive DOT operators

[ https://issues.apache.org/jira/browse/FLINK-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16353571#comment-16353571 ] Shuyi Chen commented on FLINK-8563: --- I think once we upgrade to 1.16, consecutive DOT op

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

[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8562: -- Description: Currently, YARNSessionFIFOSecuredITCase will not fail even if the current Flink YARN Kerber

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

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 Components

[jira] [Updated] (FLINK-7923) Support accessing subfields of a Composite element in an Object Array type column

[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-7923: -- Fix Version/s: 1.5.0 > Support accessing subfields of a Composite element in an Object Array type > col

[jira] [Updated] (FLINK-7923) Support accessing subfields of a Composite element in an Object Array type column

[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-7923: -- Issue Type: New Feature (was: Bug) Summary: Support accessing subfields of a Composite element in

[jira] [Updated] (FLINK-8003) Support named ROW in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8003: -- Summary: Support named ROW in Flink SQL (was: Support Calcite's ROW value constructor in Flink SQL) >

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

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

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 Compone

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

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 Compone

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

[ https://issues.apache.org/jira/browse/FLINK-8397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8397: -- Component/s: Cassandra Connector > Support ROW type in CassandraOutputFormat > -

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

[ https://issues.apache.org/jira/browse/FLINK-8401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8401: -- Component/s: Cassandra Connector > Allow subclass to override write-failure behavior in CassandraOutputF

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

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] [Updated] (FLINK-8397) Support ROW type in CassandraOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-8397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8397: -- Environment: (was: Currently, only tuple is supported.) Description: Currently, only tuple is sup

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

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] [Comment Edited] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working

[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317067#comment-16317067 ] Shuyi Chen edited comment on FLINK-8275 at 1/8/18 10:00 PM: Hi

[jira] [Updated] (FLINK-8390) Refactor Hadoop kerberos integration test code

[ https://issues.apache.org/jira/browse/FLINK-8390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8390: -- Description: As suggested in [Flink-8270| https://issues.apache.org/jira/browse/FLINK-8270] and [Flink-

[jira] [Created] (FLINK-8390) Refactor Hadoop kerberos integration test code

Shuyi Chen created FLINK-8390: - Summary: Refactor Hadoop kerberos integration test code Key: FLINK-8390 URL: https://issues.apache.org/jira/browse/FLINK-8390 Project: Flink Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317067#comment-16317067 ] Shuyi Chen edited comment on FLINK-8275 at 1/8/18 9:12 PM: --- Hi,

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

[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317067#comment-16317067 ] Shuyi Chen commented on FLINK-8275: --- [~tzulitai], [~eronwright], I've added unittest to

[jira] [Assigned] (FLINK-8329) Move YarnClient out of YarnClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8329: - Assignee: Shuyi Chen (was: Till Rohrmann) > Move YarnClient out of YarnClusterClient > -

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16312201#comment-16312201 ] Shuyi Chen commented on FLINK-7860: --- Also, we would like to add this support for batch j

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16312065#comment-16312065 ] Shuyi Chen commented on FLINK-7860: --- If you look at the [documentation | https://hadoop

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16310633#comment-16310633 ] Shuyi Chen commented on FLINK-7860: --- I assume in the doAs block, it will be run as "joe"

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16310583#comment-16310583 ] Shuyi Chen commented on FLINK-7860: --- Using the HADOOP_PROXY_USER env variable would be g

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16310570#comment-16310570 ] Shuyi Chen commented on FLINK-7860: --- Hi [~eronwright], thanks for the response. The "Fli

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16295656#comment-16295656 ] Shuyi Chen edited comment on FLINK-7860 at 12/18/17 9:11 PM: -

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

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: Ta

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16295656#comment-16295656 ] Shuyi Chen commented on FLINK-7860: --- [~eronwright] can you take a look at this as well?

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16294694#comment-16294694 ] Shuyi Chen edited comment on FLINK-7860 at 12/18/17 9:01 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16294694#comment-16294694 ] Shuyi Chen commented on FLINK-7860: --- I am proposing adding the following new options: se

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

[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8275: -- Description: The local keytab path in YarnTaskManagerRunner is incorrectly set to the ApplicationMaster'

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

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] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16252876#comment-16252876 ] Shuyi Chen commented on FLINK-7923: --- Already sent out PR for Calcite-2016 to modify the

[jira] [Assigned] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-7923: - Assignee: Shuyi Chen > SQL parser exception when accessing subfields of a Composite element in an

[jira] [Assigned] (FLINK-7934) Upgrade Calcite dependency to 1.15

[ https://issues.apache.org/jira/browse/FLINK-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-7934: - Assignee: Shuyi Chen > Upgrade Calcite dependency to 1.15 > -- >

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

[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245361#comment-16245361 ] Shuyi Chen edited comment on FLINK-7003 at 11/9/17 8:28 AM: ad

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

[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245361#comment-16245361 ] Shuyi Chen commented on FLINK-7003: --- added [link pull request|https://github.com/apache

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

[ https://issues.apache.org/jira/browse/FLINK-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8003: -- Comment: was deleted (was: We want to use the row value constructor and CAST to create a named row, or

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

[ https://issues.apache.org/jira/browse/FLINK-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-8003: -- Description: We want to use the row value constructor and CAST to create a named row, or even nested na

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

[ https://issues.apache.org/jira/browse/FLINK-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244937#comment-16244937 ] Shuyi Chen commented on FLINK-8003: --- We want to use the row value constructor and CAST t

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

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] [Commented] (FLINK-5176) Properly wait for component shutdown in Runner components

[ https://issues.apache.org/jira/browse/FLINK-5176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243534#comment-16243534 ] Shuyi Chen commented on FLINK-5176: --- [~till.rohrmann] is this still an issue? > Properl

[jira] [Comment Edited] (FLINK-5176) Properly wait for component shutdown in Runner components

[ https://issues.apache.org/jira/browse/FLINK-5176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243534#comment-16243534 ] Shuyi Chen edited comment on FLINK-5176 at 11/8/17 8:41 AM: Hi

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

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] [Assigned] (FLINK-7003) "select * from" in Flink SQL should not flatten all fields in the table by default

[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-7003: - Assignee: Shuyi Chen > "select * from" in Flink SQL should not flatten all fields in the table by

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16219771#comment-16219771 ] Shuyi Chen commented on FLINK-7923: --- We need to fix Calcite first probably in release 1.

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

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 Feat

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186602#comment-16186602 ] Shuyi Chen commented on FLINK-7491: --- [~fhueske] can you help take another look at the PR

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

[ https://issues.apache.org/jira/browse/FLINK-7690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-7690. - Resolution: Fixed > Do not call actorSystem.awaitTermination from the main akka message handling > thread

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

[ https://issues.apache.org/jira/browse/FLINK-7690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16180464#comment-16180464 ] Shuyi Chen commented on FLINK-7690: --- Just verified with the latest master, I think http

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

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] [Assigned] (FLINK-5176) Properly wait for component shutdown in Runner components

[ https://issues.apache.org/jira/browse/FLINK-5176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-5176: - Assignee: Shuyi Chen > Properly wait for component shutdown in Runner components > --

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175494#comment-16175494 ] Shuyi Chen commented on FLINK-4319: --- Hi [~till.rohrmann], thanks a lot for the pointers.

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

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: New

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16154802#comment-16154802 ] Shuyi Chen commented on FLINK-7491: --- Thanks a lot, [~fhueske]. > Support COLLECT Aggreg

[jira] [Comment Edited] (FLINK-4319) Rework Cluster Management (FLIP-6)

[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16151309#comment-16151309 ] Shuyi Chen edited comment on FLINK-4319 at 9/1/17 11:48 PM: Hi

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16151309#comment-16151309 ] Shuyi Chen commented on FLINK-4319: --- Hi Till, I am looking into integrating Flink with

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150155#comment-16150155 ] Shuyi Chen commented on FLINK-7491: --- Hi [~fhue...@gmail.com], I've updated the PR descri

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144282#comment-16144282 ] Shuyi Chen edited comment on FLINK-7491 at 8/29/17 11:16 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144282#comment-16144282 ] Shuyi Chen edited comment on FLINK-7491 at 8/29/17 11:15 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144282#comment-16144282 ] Shuyi Chen edited comment on FLINK-7491 at 8/29/17 11:15 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144282#comment-16144282 ] Shuyi Chen commented on FLINK-7491: --- Hi [~jark], thanks for the response. However, I am

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

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: New

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

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 Feat

[jira] [Assigned] (FLINK-3431) Add retrying logic for RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-3431: - Assignee: Shuyi Chen > Add retrying logic for RocksDB snapshots > ---

[jira] [Commented] (FLINK-3431) Add retrying logic for RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142536#comment-16142536 ] Shuyi Chen commented on FLINK-3431: --- Anyone looking at this issue? I can take a look oth

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142277#comment-16142277 ] Shuyi Chen edited comment on FLINK-7491 at 8/25/17 10:15 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142277#comment-16142277 ] Shuyi Chen commented on FLINK-7491: --- Thanks for reviewing the PR. [~jark] I think Multi

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

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 Featu

[jira] [Commented] (FLINK-7179) ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-7179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103533#comment-16103533 ] Shuyi Chen commented on FLINK-7179: --- [~fhueske] I think the problem is in PushProjectInt

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

[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-7003: -- Description: Currently, CompositeRelDataType is extended from RelRecordType(StructKind.PEEK_FIELDS, ...

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

[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-7003: -- Description: Currently, CompositeRelDataType is extended from RelRecordType(StructKind.PEEK_FIELDS, ...

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

[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062561#comment-16062561 ] Shuyi Chen commented on FLINK-7003: --- I've created https://issues.apache.org/jira/browse/

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

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: F

<    1   2