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
[
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.
[
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
> --
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:
[
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
[
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
[
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
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
Shuyi Chen created FLINK-10516:
--
Summary: YarnApplicationMasterRunner fail to initialize FileSystem
with correct Flink Configuration during setup
Key: FLINK-10516
URL: https://issues.apache.org/jira/browse/FLINK-1051
[
https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16644150#comment-16644150
]
Shuyi Chen commented on FLINK-10516:
Hi [~till.rohrmann], how do you want to proceed
[
https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16648664#comment-16648664
]
Shuyi Chen commented on FLINK-10516:
This is fixed in 1.7.0 with 5e90ed95a580aefd84b
[
https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16648665#comment-16648665
]
Shuyi Chen commented on FLINK-10516:
[~till.rohrmann], [~aljoscha], do you want me t
[
https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693833#comment-16693833
]
Shuyi Chen commented on FLINK-10868:
Hi [~till.rohrmann], the following describes th
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693835#comment-16693835
]
Shuyi Chen commented on FLINK-10848:
[~till.rohrmann], can you help take a look at t
[
https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696440#comment-16696440
]
Shuyi Chen commented on FLINK-9477:
---
Thanks [~x1q1j1]. Once Calcite 1.18 is released an
[
https://issues.apache.org/jira/browse/FLINK-11006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16699379#comment-16699379
]
Shuyi Chen commented on FLINK-11006:
This is a duplicate of
[FLINK-10076|https://is
[
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
> -
>
>
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
[
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
[
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:
-
[
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
[
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
> ---
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
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
[
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
[
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:
-
[
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:
-
[
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:
-
[
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
[
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
[
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
[
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
[
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"
>
[
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.
[
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
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
[
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
[
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
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
[
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
[
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
[
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
[
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
[
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
[
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
> --
>
[
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
[
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
[
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
>
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
[
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/
[
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, ...
[
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, ...
[
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
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
[
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
> -
>
>
[
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 colum
[
https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515386#comment-16515386
]
Shuyi Chen commented on FLINK-9606:
---
I think this is duplicate of
[FLINK-2169|https://
[
https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16525753#comment-16525753
]
Shuyi Chen commented on FLINK-6962:
---
Hi [~shenyufeng], I am finalizing the DDL design d
[
https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16445560#comment-16445560
]
Shuyi Chen commented on FLINK-8286:
---
Hi [~till.rohrmann] and [~aljoscha], the context is
[
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 the
[
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 Flink-Yar
[
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 integrati
[
https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447411#comment-16447411
]
Shuyi Chen commented on FLINK-8286:
---
Hi [~till.rohrmann] and [~aljoscha], spent some tim
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
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16464544#comment-16464544
]
Shuyi Chen commented on FLINK-7001:
---
Hi [~pgrulich], the paper is a nice read. And the t
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: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16474801#comment-16474801
]
Shuyi Chen commented on FLINK-8866:
---
Hi [~walterddr], [~twalthr], [~fhueske], thanks a l
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16474801#comment-16474801
]
Shuyi Chen edited comment on FLINK-8866 at 5/14/18 9:07 PM:
Hi
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
Issue
[
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. Howe
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16490026#comment-16490026
]
Shuyi Chen commented on FLINK-9430:
---
The JSON object can be a int, float, double, boolea
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494761#comment-16494761
]
Shuyi Chen commented on FLINK-9430:
---
Hi [~twalthr], I've attached the PR. Having an end
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
[
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
[
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.
[
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
[
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
[
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
[
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
[
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
[
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
[
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
> --
>
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
[
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
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
[
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],
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
[
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
[
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
[
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
> ---
[
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
[
https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16414618#comment-16414618
]
Shuyi Chen commented on FLINK-9059:
---
Hi [~twalthr], thanks a lot for the comments. In th
[
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 instatiate
[
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 instantia
[
https://issues.apache.org/jira/browse/FLINK-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16414626#comment-16414626
]
Shuyi Chen commented on FLINK-9049:
---
Thanks a lot, [~twalthr]. Assigned
[FLINK-8866|htt
[
https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415146#comment-16415146
]
Shuyi Chen commented on FLINK-8981:
---
Hi [~tzulitai], I plan to work on it this week. Yes
[
https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417997#comment-16417997
]
Shuyi Chen commented on FLINK-8981:
---
Setting up a real YARN cluster from the binary migh
[
https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425926#comment-16425926
]
Shuyi Chen commented on FLINK-9134:
---
Hi [~twalthr], this is duplicate of
[FLINK-9015|ht
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16426316#comment-16426316
]
Shuyi Chen commented on FLINK-7151:
---
I don't have a concrete timeline, but will try to i
1 - 100 of 195 matches
Mail list logo
