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

2019-03-02 Thread Rong Rong (JIRA)
[ 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: [https://docs.google.com

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

2019-03-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782461#comment-16782461 ] Rong Rong commented on FLINK-11453: --- Per the discussion of the community, we will move

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

2019-03-02 Thread Rong Rong (JIRA)
[ 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-11453) Support SliceStream with forwardable pane info

2019-03-02 Thread Rong Rong (JIRA)
[ 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] [Updated] (FLINK-11454) Support MergedStream operation

2019-03-02 Thread Rong Rong (JIRA)
[ 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 MergedStream

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

2019-03-02 Thread Rong Rong (JIRA)
[ 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 opera

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

2019-03-02 Thread Rong Rong (JIRA)
[ 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] [Closed] (FLINK-11456) Improve window operator with sliding window assigners

2019-03-02 Thread Rong Rong (JIRA)
[ 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-11455) Support evictor operations on slicing and merging operators

2019-03-02 Thread Rong Rong (JIRA)
[ 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 oper

[jira] [Commented] (FLINK-14442) Add time based interval execution to JDBC connectors.

2019-10-18 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16954803#comment-16954803 ] Rong Rong commented on FLINK-14442: --- Hi [~javadevmtl] sorry I misunderstood your inten

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

2019-10-19 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-12399: -- Fix Version/s: 1.9.2 > FilterableTableSource does not use filters on job run > ---

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

2019-10-19 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955236#comment-16955236 ] Rong Rong commented on FLINK-12399: --- merged to 1.9: c1019105c22455c554ab91b9fc2ef85128

[jira] [Updated] (FLINK-14153) Add to BLAS a method that performs DenseMatrix and SparseVector multiplication.

2019-10-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-14153: -- Fix Version/s: 1.10.0 > Add to BLAS a method that performs DenseMatrix and SparseVector > multiplicat

[jira] [Resolved] (FLINK-14153) Add to BLAS a method that performs DenseMatrix and SparseVector multiplication.

2019-10-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong resolved FLINK-14153. --- Resolution: Fixed > Add to BLAS a method that performs DenseMatrix and SparseVector > multiplicatio

[jira] [Commented] (FLINK-14153) Add to BLAS a method that performs DenseMatrix and SparseVector multiplication.

2019-10-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960191#comment-16960191 ] Rong Rong commented on FLINK-14153: --- Committed via: 23a34b818d8267d16f6c22c77b79c67387

[jira] [Comment Edited] (FLINK-14153) Add to BLAS a method that performs DenseMatrix and SparseVector multiplication.

2019-10-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960191#comment-16960191 ] Rong Rong edited comment on FLINK-14153 at 10/25/19 10:43 PM:

[jira] [Updated] (FLINK-16224) Refine Hadoop Delegation Token based testing framework

2020-03-19 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16224: -- Parent: (was: FLINK-11271) Issue Type: Improvement (was: Sub-task) > Refine Hadoop Delega

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

2020-03-19 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong resolved FLINK-11271. --- Fix Version/s: 1.11.0 Resolution: Fixed Converted FLINK-16224 into a separate issue since it

[jira] [Updated] (FLINK-5552) Make the JMX port available through RESTful API

2020-03-23 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-5552: - Description: Currently, JMXReporter will create a server for JMX viewer retrieving JMX stat. The port ca

[jira] [Commented] (FLINK-5552) Make the JMX port available through RESTful API

2020-03-23 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064900#comment-17064900 ] Rong Rong commented on FLINK-5552: -- Hi, I would like to follow up on this ticket per som

[jira] [Commented] (FLINK-16483) Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067073#comment-17067073 ] Rong Rong commented on FLINK-16483: --- Hi Here, I am getting this error after rebasing t

[jira] [Comment Edited] (FLINK-5552) Make the JMX port available through RESTful API

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067236#comment-17067236 ] Rong Rong edited comment on FLINK-5552 at 3/26/20, 12:00 AM: -

[jira] [Commented] (FLINK-5552) Make the JMX port available through RESTful API

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067236#comment-17067236 ] Rong Rong commented on FLINK-5552: -- Yes. I think having it in the log is possible. howev

[jira] [Assigned] (FLINK-5552) Make the JMX port available through RESTful API

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-5552: Assignee: Rong Rong > Make the JMX port available through RESTful API > --

[jira] [Commented] (FLINK-16483) Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067335#comment-17067335 ] Rong Rong commented on FLINK-16483: --- yeah. I took a look and seems like simply align t

[jira] [Commented] (FLINK-5552) Make the JMX port available through RESTful API

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067341#comment-17067341 ] Rong Rong commented on FLINK-5552: -- Oops.. I just realized that I am not talking about t

[jira] [Created] (FLINK-16789) Support JMX RMI via JMXConnectorServer

2020-03-25 Thread Rong Rong (Jira)
Rong Rong created FLINK-16789: - Summary: Support JMX RMI via JMXConnectorServer Key: FLINK-16789 URL: https://issues.apache.org/jira/browse/FLINK-16789 Project: Flink Issue Type: New Feature

[jira] [Issue Comment Deleted] (FLINK-5552) Make the JMX port available through RESTful API

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-5552: - Comment: was deleted (was: Yes. I think having it in the log is possible. however, based on my experienc

[jira] [Updated] (FLINK-16789) Support JMX RMI via JMXConnectorServer

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16789: -- Description: Currently there are no easy way to assign jmxrmi port to a running Flink job. The typica

[jira] [Commented] (FLINK-16789) Support JMX RMI via JMXConnectorServer

2020-03-25 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067343#comment-17067343 ] Rong Rong commented on FLINK-16789: --- I've share a code snippet in  [https://github.com

[jira] [Commented] (FLINK-16789) Support JMX RMI via JMXConnectorServer

2020-03-26 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067714#comment-17067714 ] Rong Rong commented on FLINK-16789: --- Yes. I agree. in fact the {{JMXServer}} class in

[jira] [Updated] (FLINK-16789) Support JMX RMI port retrieval via JMXConnectorServer

2020-03-26 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16789: -- Summary: Support JMX RMI port retrieval via JMXConnectorServer (was: Support JMX RMI via JMXConnector

[jira] [Comment Edited] (FLINK-16789) Support JMX RMI port retrieval via JMXConnectorServer

2020-03-26 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067714#comment-17067714 ] Rong Rong edited comment on FLINK-16789 at 3/26/20, 3:03 PM: -

[jira] [Closed] (FLINK-9232) Add harness test for AggregationCodeGenerator

2018-12-12 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-9232. Resolution: Duplicate > Add harness test for AggregationCodeGenerator > --

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-12 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Description: Currently flink-yarn assumes keytab is shipped as application master environment local r

[jira] [Comment Edited] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-14 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721857#comment-16721857 ] Rong Rong edited comment on FLINK-11088 at 12/14/18 11:03 PM:

[jira] [Commented] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2018-12-14 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721857#comment-16721857 ] Rong Rong commented on FLINK-11088: --- I further dig into the details on the document on

[jira] [Created] (FLINK-11271) Improve Kerberos Credential Distribution

2019-01-04 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11271: - Summary: Improve Kerberos Credential Distribution Key: FLINK-11271 URL: https://issues.apache.org/jira/browse/FLINK-11271 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication Keytab discovery on YARN

2019-01-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Summary: Improve Kerberos Authentication Keytab discovery on YARN (was: Improve Kerberos Authenticati

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

2019-01-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-11271 > Improve Kerberos Authentication

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

2019-01-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11276: - Assignee: Rong Rong > Slicing Window Optimization > --- > >

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

2019-01-07 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11276: - Summary: Slicing Window Optimization Key: FLINK-11276 URL: https://issues.apache.org/jira/browse/FLINK-11276 Project: Flink Issue Type: New Feature Rep

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

2019-01-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Affects Version/s: 1.7.0 > Slicing Window Optimization > --- > >

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

2019-01-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Component/s: DataStream API > Slicing Window Optimization > --- > >

[jira] [Created] (FLINK-11453) Support SliceWindow with forwardable pane info

2019-01-29 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11453: - Summary: Support SliceWindow with forwardable pane info Key: FLINK-11453 URL: https://issues.apache.org/jira/browse/FLINK-11453 Project: Flink Issue Type: Sub-tas

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

2019-01-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11453: -- Summary: Support SliceStream with forwardable pane info (was: Support SliceWindow with forwardable p

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

2019-01-29 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11454: - Summary: Support MergedStream operation Key: FLINK-11454 URL: https://issues.apache.org/jira/browse/FLINK-11454 Project: Flink Issue Type: Sub-task Compo

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

2019-01-29 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11455: - Summary: Support evictor operations on slicing and merging operators Key: FLINK-11455 URL: https://issues.apache.org/jira/browse/FLINK-11455 Project: Flink Issue

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

2019-01-29 Thread Rong Rong (JIRA)
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: S

<    1   2   3   4   5