[jira] [Updated] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-13603: -- Component/s: (was: Formats (JSON, Avro, Parquet, ORC, SequenceFile)) > Flink Table ApI not

[jira] [Comment Edited] (FLINK-13548) Support priority of the Flink YARN application

[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16901356#comment-16901356 ] Rong Rong edited comment on FLINK-13548 at 8/6/19 6:30 PM: --- I think when you

[jira] [Commented] (FLINK-13548) Support priority of the Flink YARN application

[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16901356#comment-16901356 ] Rong Rong commented on FLINK-13548: --- I think when you submit the request for priority that is out of

[jira] [Commented] (FLINK-13548) Support priority of the Flink YARN application

[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900232#comment-16900232 ] Rong Rong commented on FLINK-13548: --- Yes. I think setting it to the default YARN priority (of the

[jira] [Commented] (FLINK-13548) Support priority of the Flink YARN application

[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16899652#comment-16899652 ] Rong Rong commented on FLINK-13548: --- Hi [~boswell], thanks for bringing up this discussion. I think

[jira] [Commented] (FLINK-13347) should handle new JoinRelType(SEMI/ANTI) in switch case

[ https://issues.apache.org/jira/browse/FLINK-13347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897751#comment-16897751 ] Rong Rong commented on FLINK-13347: --- no prob at all... It was me first forgetting to backport to 1.9

[jira] [Commented] (FLINK-13347) should handle new JoinRelType(SEMI/ANTI) in switch case

[ https://issues.apache.org/jira/browse/FLINK-13347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897296#comment-16897296 ] Rong Rong commented on FLINK-13347: --- Hi [~jark] seems like 3f5b1f80bf0551ba2b59d72c48002b1ed5bf65f1 is

[jira] [Commented] (FLINK-13347) should handle new JoinRelType(SEMI/ANTI) in switch case

[ https://issues.apache.org/jira/browse/FLINK-13347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895779#comment-16895779 ] Rong Rong commented on FLINK-13347: --- oops. forgot to backport to 1.9.0 and operate on JIRA. thanks for

[jira] [Created] (FLINK-13389) Setting DataStream return type breaks some type conversion between Table and DataStream

Rong Rong created FLINK-13389: - Summary: Setting DataStream return type breaks some type conversion between Table and DataStream Key: FLINK-13389 URL: https://issues.apache.org/jira/browse/FLINK-13389

[jira] [Closed] (FLINK-11921) Upgrade Calcite dependency to 1.20

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

[jira] [Commented] (FLINK-13185) Bump Calcite dependency to 1.20.0 in sql parser & flink planner

[ https://issues.apache.org/jira/browse/FLINK-13185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882193#comment-16882193 ] Rong Rong commented on FLINK-13185: --- Thanks for the clarification [~godfreyhe]. I don't think

[jira] [Commented] (FLINK-12872) WindowOperator may fail with UnsupportedOperationException when merging windows

[ https://issues.apache.org/jira/browse/FLINK-12872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866178#comment-16866178 ] Rong Rong commented on FLINK-12872: --- This might be a [related

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.20

[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858835#comment-16858835 ] Rong Rong commented on FLINK-11921: --- changed title as discussed: we will skip 1.19, directly go with

[jira] [Updated] (FLINK-11921) Upgrade Calcite dependency to 1.20

[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11921: -- Description: Umbrella issue for all tasks related to the next Calcite upgrade to 1.20.x release We

[jira] [Updated] (FLINK-11921) Upgrade Calcite dependency to 1.20

[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11921: -- Summary: Upgrade Calcite dependency to 1.20 (was: Upgrade Calcite dependency to 1.19) > Upgrade

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.19

[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852147#comment-16852147 ] Rong Rong commented on FLINK-11921: --- Hi [~twalthr], [~danny0405] and I discussed briefly that we will

[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=16841511#comment-16841511 ] Rong Rong commented on FLINK-10232: --- Thanks Danny for bringing this up.  I think we can definitely

[jira] [Commented] (FLINK-12399) FilterableTableSource does not use filters on job run

[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833107#comment-16833107 ] Rong Rong commented on FLINK-12399: --- Hi [~josh.bradt]. I think I found the root cause of this issue.

[jira] [Assigned] (FLINK-12399) FilterableTableSource does not use filters on job run

[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-12399: - Assignee: Rong Rong > FilterableTableSource does not use filters on job run >

[jira] [Comment Edited] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831421#comment-16831421 ] Rong Rong edited comment on FLINK-11909 at 5/4/19 3:28 PM: --- I took some time

[jira] [Comment Edited] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831421#comment-16831421 ] Rong Rong edited comment on FLINK-11909 at 5/2/19 5:40 AM: --- I took some time

[jira] [Comment Edited] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831421#comment-16831421 ] Rong Rong edited comment on FLINK-11909 at 5/2/19 5:39 AM: --- I took some time

[jira] [Commented] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831421#comment-16831421 ] Rong Rong commented on FLINK-11909: --- I took some time to look at the {{AsyncFunction}} API and the

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.19

[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830474#comment-16830474 ] Rong Rong commented on FLINK-11921: --- Thanks for the follow up [~ykt836]. I found the issue and it is

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.19

[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829427#comment-16829427 ] Rong Rong commented on FLINK-11921: --- Closing to the end of this issue. Found out that one of the

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829386#comment-16829386 ] Rong Rong commented on FLINK-11935: --- I think this issue should not block calcite upgrade, we can still

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827666#comment-16827666 ] Rong Rong commented on FLINK-11935: --- I dug a little deeper: I think there are something problematic in

[jira] [Comment Edited] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826601#comment-16826601 ] Rong Rong edited comment on FLINK-11935 at 4/26/19 2:57 AM: hmm. I might've

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826601#comment-16826601 ] Rong Rong commented on FLINK-11935: --- hmm. I might've misunderstood some details. Are you suggesting

[jira] [Comment Edited] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826516#comment-16826516 ] Rong Rong edited comment on FLINK-11935 at 4/26/19 2:19 AM: Hi [~yanghua], I

[jira] [Comment Edited] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826516#comment-16826516 ] Rong Rong edited comment on FLINK-11935 at 4/26/19 2:18 AM: Hi [~yanghua], I

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826516#comment-16826516 ] Rong Rong commented on FLINK-11935: --- Hi [~yanghua], I understand what you said. I think to summarize

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825347#comment-16825347 ] Rong Rong commented on FLINK-11935: --- My feeling is that we should find out why Julian datetime *epoch

[jira] [Commented] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819636#comment-16819636 ] Rong Rong commented on FLINK-11936: --- Sweet. I also think making it pluggable is a good approach. with

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816445#comment-16816445 ] Rong Rong commented on FLINK-11935: --- I think [~julianhyde] is correct. actually I ran the test again

[jira] [Commented] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815489#comment-16815489 ] Rong Rong commented on FLINK-11936: --- After some investigation. seems like our code is far deviated

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805307#comment-16805307 ] Rong Rong commented on FLINK-11935: --- Thanks for checking in [~yanghua]. I think we can skip the

[jira] [Assigned] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11936: - Assignee: Rong Rong > Remove AuxiliaryConverter pull-in from calcite and fix auxiliary

[jira] [Assigned] (FLINK-11921) Upgrade Calcite dependency to 1.19

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

[jira] [Comment Edited] (FLINK-11921) Upgrade Calcite dependency to 1.19

[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802993#comment-16802993 ] Rong Rong edited comment on FLINK-11921 at 3/27/19 4:15 PM: Thanks for the

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.19

[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802993#comment-16802993 ] Rong Rong commented on FLINK-11921: --- Thanks for the notice [~yanghua] Yes. will be happy to take this

[jira] [Updated] (FLINK-11276) Sliding Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Description: This umbrella JIRA focus on the improvement of the existing window operator *WITHOUT*

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Description: This is the umbrella ticket for the improvement discussion in:

[jira] [Updated] (FLINK-11276) Sliding Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Summary: Sliding Window Optimization (was: Slicing Window Optimization) > Sliding Window

[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=16795108#comment-16795108 ] Rong Rong commented on FLINK-11912: --- +1. I think this metrics will be extremely helpful in production

[jira] [Updated] (FLINK-10019) singleton row type objects returned from sub query cannot be chained with other operators

[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-10019: -- Summary: singleton row type objects returned from sub query cannot be chained with other operators

[jira] [Assigned] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11935: - Assignee: (was: Rong Rong) > Remove DateTimeUtils pull-in and fix datetime casting problem

[jira] [Updated] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11936: -- Description: AuxiliaryConverter was pulled in FLINK-6409. Since CALCITE-1761 has been fixed, we

[jira] [Commented] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14

[ https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793957#comment-16793957 ] Rong Rong commented on FLINK-7237: -- oops. I closed this task as duplicate, but it should be invalid.

[jira] [Created] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

Rong Rong created FLINK-11936: - Summary: Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue. Key: FLINK-11936 URL: https://issues.apache.org/jira/browse/FLINK-11936 Project:

[jira] [Closed] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14

[ https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-7237. Resolution: Duplicate > Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14 >

[jira] [Created] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

Rong Rong created FLINK-11935: - Summary: Remove DateTimeUtils pull-in and fix datetime casting problem Key: FLINK-11935 URL: https://issues.apache.org/jira/browse/FLINK-11935 Project: Flink

[jira] [Closed] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-7235. Resolution: Invalid > Backport CALCITE-1884 to the Flink repository before Calcite 1.14 >

[jira] [Commented] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793786#comment-16793786 ] Rong Rong commented on FLINK-7235: -- This {{DateTimeUtils}} is still needed, but in a very different way.

[jira] [Closed] (FLINK-10994) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-10994. - Resolution: Duplicate > The bug of timestampadd handles time > > >

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

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

[jira] [Commented] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792841#comment-16792841 ] Rong Rong commented on FLINK-7235: -- Yes I can take a look :-) > Backport CALCITE-1884 to the Flink

[jira] [Assigned] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-7235: Assignee: Rong Rong (was: Haohui Mai) > Backport CALCITE-1884 to the Flink repository before

[jira] [Updated] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11909: -- Summary: Provide default failure/timeout/backoff handling strategy for AsyncIO functions (was:

[jira] [Updated] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11909: -- Description: Currently Flink AsyncIO by default fails the entire job when async function invoke

[jira] [Updated] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11909: -- Description: Currently Flink AsyncIO by default fails the entire job when async function invoke

[jira] [Updated] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11909: -- Description: Currently Flink AsyncIO by default fails the entire job when async function invoke

[jira] [Assigned] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11909: - Assignee: Rong Rong > Provide default failure/timeout handling strategy for AsyncIO functions

[jira] [Commented] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792294#comment-16792294 ] Rong Rong commented on FLINK-11909: --- [~yanghua] Hi Vino, we haven't reach an agreement and a target

[jira] [Created] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

Rong Rong created FLINK-11909: - Summary: Provide default failure/timeout handling strategy for AsyncIO functions Key: FLINK-11909 URL: https://issues.apache.org/jira/browse/FLINK-11909 Project: Flink

[jira] [Commented] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal

[ https://issues.apache.org/jira/browse/FLINK-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787326#comment-16787326 ] Rong Rong commented on FLINK-9685: -- Hi. I was wondering whether I fully understood the requirement for

[jira] [Updated] (FLINK-11455) Support evictor operations on slicing and merging operators

[ https://issues.apache.org/jira/browse/FLINK-11455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11455: -- Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-11276) > Support evictor

[jira] [Closed] (FLINK-11456) Improve window operator with sliding window assigners

[ https://issues.apache.org/jira/browse/FLINK-11456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-11456. - Resolution: Invalid > Improve window operator with sliding window assigners >

[jira] [Updated] (FLINK-11456) Improve window operator with sliding window assigners

[ https://issues.apache.org/jira/browse/FLINK-11456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11456: -- Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-11276) > Improve window

[jira] [Closed] (FLINK-11455) Support evictor operations on slicing and merging operators

[ https://issues.apache.org/jira/browse/FLINK-11455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-11455. - Resolution: Invalid > Support evictor operations on slicing and merging operators >

[jira] [Updated] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11454: -- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-11276) > Support

[jira] [Updated] (FLINK-11453) Support SliceStream with forwardable pane info

[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11453: -- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-11276) > Support SliceStream

[jira] [Commented] (FLINK-11453) Support SliceStream with forwardable pane info

[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782461#comment-16782461 ] Rong Rong commented on FLINK-11453: --- Per the discussion of the community, we will move the slicing API

[jira] [Closed] (FLINK-11453) Support SliceStream with forwardable pane info

[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-11453. - Resolution: Invalid > Support SliceStream with forwardable pane info >

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Description: This is the umbrella ticket for the improvement discussion in:

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Description: This is the umbrella ticket for the improvement discussion in:

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Description: This is the umbrella ticket for the improvement discussion in:

[jira] [Updated] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11569: -- Description: Seems like the "toString" method for Row type is only concatenating all fields using

[jira] [Commented] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16775409#comment-16775409 ] Rong Rong commented on FLINK-11569: --- agree this will result in many test fixes, and not just limited

[jira] [Updated] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11569: -- Description: Seems like the "toString" method for Row type is only concatenating all fields using

[jira] [Commented] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774734#comment-16774734 ] Rong Rong commented on FLINK-11569: --- [~twalthr] [~fhueske] any thought on this JIRA? my feeling is

[jira] [Comment Edited] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774734#comment-16774734 ] Rong Rong edited comment on FLINK-11569 at 2/22/19 3:45 AM: [~twalthr]

[jira] [Updated] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11569: -- Description: Seems like the "toString" method for Row type is only concatenating all fields using

[jira] [Commented] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774586#comment-16774586 ] Rong Rong commented on FLINK-11454: --- Yes [~fhueske]. I think your summary is absolutely on point. 1.

[jira] [Commented] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771340#comment-16771340 ] Rong Rong commented on FLINK-11454: --- Yes Thanks [~fhueske] for the feedback.   *Regarding moving the

[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=16771321#comment-16771321 ] Rong Rong commented on FLINK-7001: -- Thanks [~jark] for the response. Yes, the Blink implementation of

[jira] [Commented] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769779#comment-16769779 ] Rong Rong commented on FLINK-11454: --- Initial thought was to use the

[jira] [Updated] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11454: -- Description: Following SlicedStream, the mergedStream operator merges results from sliced stream and

[jira] [Updated] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11454: -- Description: {{Following SlicedStream, the mergedStream operator merges results from sliced stream

[jira] [Updated] (FLINK-11589) Introduce service provider pattern for user to dynamically load SecurityFactory classes

[ https://issues.apache.org/jira/browse/FLINK-11589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11589: -- Description: Currently there are only 3 security modules in Flink - Hadoop, Zookeeper and JaaS, all

[jira] [Updated] (FLINK-11088) Allow pre-install Kerberos authentication keytab discovery on YARN

[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Summary: Allow pre-install Kerberos authentication keytab discovery on YARN (was: Allow Pre-install

[jira] [Created] (FLINK-11589) Introduce service provider pattern for user to dynamically load SecurityFactory classes

Rong Rong created FLINK-11589: - Summary: Introduce service provider pattern for user to dynamically load SecurityFactory classes Key: FLINK-11589 URL: https://issues.apache.org/jira/browse/FLINK-11589

[jira] [Updated] (FLINK-11088) Allow Pre-install Kerberos Authentication Keytab discovery on YARN

[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Summary: Allow Pre-install Kerberos Authentication Keytab discovery on YARN (was: Improve Kerberos

[jira] [Updated] (FLINK-11271) Improvement to Kerberos Security

[ https://issues.apache.org/jira/browse/FLINK-11271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11271: -- Summary: Improvement to Kerberos Security (was: Improve Kerberos Credential Distribution) >

[jira] [Updated] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11569: -- Description: Seems like the "toString" method for Row type is only concatenating all fields using

[jira] [Created] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

Rong Rong created FLINK-11569: - Summary: Row type does not serialize in to readable format when invoke "toString" method Key: FLINK-11569 URL: https://issues.apache.org/jira/browse/FLINK-11569 Project:

[jira] [Commented] (FLINK-11120) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763801#comment-16763801 ] Rong Rong commented on FLINK-11120: --- Hi [~x1q1j1] I am currently working on 1.18 upgrade, can you

[jira] [Assigned] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11454: - Assignee: Rong Rong > Support MergedStream operation > -- > >

[jira] [Assigned] (FLINK-11453) Support SliceStream with forwardable pane info

[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11453: - Assignee: Rong Rong > Support SliceStream with forwardable pane info >

[jira] [Created] (FLINK-11456) Improve window operator with sliding window assigners

Rong Rong created FLINK-11456: - Summary: Improve window operator with sliding window assigners Key: FLINK-11456 URL: https://issues.apache.org/jira/browse/FLINK-11456 Project: Flink Issue Type:

<    1   2   3   4   5   >