[jira] [Reopened] (FLINK-16789) Retrieve JMXRMI information via REST API or WebUI

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reopened FLINK-16789: --- > Retrieve JMXRMI information via REST API or WebUI > -

[jira] [Updated] (FLINK-16789) Retrieve JMXRMI information via REST API or WebUI

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16789: -- Summary: Retrieve JMXRMI information via REST API or WebUI (was: Support JMX RMI random port assign

[jira] [Commented] (FLINK-16789) Support JMX RMI random port assign & retrieval via JMXConnectorServer

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186045#comment-17186045 ] Rong Rong commented on FLINK-16789: --- oops. yes you are right [~chesnay]. the closed PR doesn't contain

[jira] [Commented] (FLINK-16789) Support JMX RMI random port assign & retrieval via JMXConnectorServer

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186002#comment-17186002 ] Rong Rong commented on FLINK-16789: --- After discussion in

[jira] [Closed] (FLINK-16789) Support JMX RMI random port assign & retrieval via JMXConnectorServer

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-16789. - Resolution: Won't Fix > Support JMX RMI random port assign & retrieval via JMXConnectorServer >

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

[ 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 random port assign & retrieval via JMXConnectorServer (was: Support JMX RMI

[jira] [Commented] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR

[ https://issues.apache.org/jira/browse/FLINK-18045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124277#comment-17124277 ] Rong Rong commented on FLINK-18045: --- yeah. that makes sense. +1 on the proposed solution #2 > Newest

[jira] [Commented] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR

[ https://issues.apache.org/jira/browse/FLINK-18045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123885#comment-17123885 ] Rong Rong commented on FLINK-18045: --- Yes. I think specifically checking auth method as Kerberos is the

[jira] [Updated] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-17386: -- Component/s: Deployment / YARN > Exception in HadoopSecurityContextFactory.createContext while no >

[jira] [Updated] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-17386: -- Affects Version/s: 1.11.0 > Exception in HadoopSecurityContextFactory.createContext while no >

[jira] [Closed] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-17386. - Fix Version/s: 1.11.0 Resolution: Fixed > Exception in

[jira] [Commented] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109703#comment-17109703 ] Rong Rong commented on FLINK-17386: --- closed via: 1892bedeea9fa118b6e3bcb572f63c2e7f6d83e3 > Exception

[jira] [Comment Edited] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094595#comment-17094595 ] Rong Rong edited comment on FLINK-17386 at 4/29/20, 2:15 PM: - I just create

[jira] [Assigned] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-17386: - Assignee: Rong Rong > Exception in HadoopSecurityContextFactory.createContext while no >

[jira] [Commented] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094595#comment-17094595 ] Rong Rong commented on FLINK-17386: --- hmm. that's not what I expected. I have 2 theories: 1. in 1.10

[jira] [Commented] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094152#comment-17094152 ] Rong Rong commented on FLINK-17386: --- I might have some idea on why this is happening. but just to be

[jira] [Commented] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094149#comment-17094149 ] Rong Rong commented on FLINK-17386: --- hmm. interesting. Just to understand more clearer, you are

[jira] [Commented] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092732#comment-17092732 ] Rong Rong commented on FLINK-17386: --- could you provide more information on how to reproduce this

[jira] [Commented] (FLINK-16733) Refactor YarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-16733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084212#comment-17084212 ] Rong Rong commented on FLINK-16733: --- +1 to see this going. BTW do we have a higher level plan for how

[jira] [Commented] (FLINK-16522) Use type hints to declare the signature of the methods

[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076873#comment-17076873 ] Rong Rong commented on FLINK-16522: --- Thanks for the clarification. huge +1. looking forward to this :)

[jira] [Updated] (FLINK-16522) Use type hints to declare the signature of the methods

[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16522: -- Description: [Type Hints|https://www.python.org/dev/peps/pep-0484/] was introduced in Python 3.5 and

[jira] [Updated] (FLINK-16522) Use type hints to declare the signature of the methods

[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16522: -- Description: [Type Hints|https://www.python.org/dev/peps/pep-0484/] was introduced in Python 3.5 and

[jira] [Commented] (FLINK-16522) Use type hints to declare the signature of the methods

[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072854#comment-17072854 ] Rong Rong commented on FLINK-16522: --- Is this Jira referring to TypeChecking as well? 

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

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067714#comment-17067714 ] Rong Rong edited comment on FLINK-16789 at 3/26/20, 3:03 PM: - Yes. I agree.

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067714#comment-17067714 ] Rong Rong commented on FLINK-16789: --- Yes. I agree. in fact the {{JMXServer}} class in the reporter can

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

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067343#comment-17067343 ] Rong Rong commented on FLINK-16789: --- I've share a code snippet in 

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

[ 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

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

[ 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

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

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] [Commented] (FLINK-5552) Make the JMX port available through RESTful API

[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067341#comment-17067341 ] Rong Rong commented on FLINK-5552: -- Oops.. I just realized that I am not talking about the exact same

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

[ https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067335#comment-17067335 ] Rong Rong commented on FLINK-16483: --- yeah. I took a look and seems like simply align the version works

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

[ 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] [Comment Edited] (FLINK-5552) Make the JMX port available through RESTful API

[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067236#comment-17067236 ] Rong Rong edited comment on FLINK-5552 at 3/26/20, 12:00 AM: - Yes. I think

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

[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067236#comment-17067236 ] Rong Rong commented on FLINK-5552: -- Yes. I think having it in the log is possible. however, based on my

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

[ https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067073#comment-17067073 ] Rong Rong commented on FLINK-16483: --- Hi Here, I am getting this error after rebasing this PR. {code}

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

[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064900#comment-17064900 ] Rong Rong commented on FLINK-5552: -- Hi, I would like to follow up on this ticket per some recent ML

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

[ 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

[jira] [Resolved] (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 resolved FLINK-11271. --- Fix Version/s: 1.11.0 Resolution: Fixed Converted FLINK-16224 into a separate issue since it

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

[ 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

[jira] [Commented] (FLINK-16241) Remove the license and notice file in flink-ml-lib module on release-1.10 branch

[ https://issues.apache.org/jira/browse/FLINK-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043664#comment-17043664 ] Rong Rong commented on FLINK-16241: --- I think removing the license seems to be more reasonable. Even if

[jira] [Created] (FLINK-16236) Fix YARNSessionFIFOSecuredITCase not loading the correct security context factory

Rong Rong created FLINK-16236: - Summary: Fix YARNSessionFIFOSecuredITCase not loading the correct security context factory Key: FLINK-16236 URL: https://issues.apache.org/jira/browse/FLINK-16236 Project:

[jira] [Updated] (FLINK-15561) Unify Kerberos credentials checking

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Summary: Unify Kerberos credentials checking (was: Improve Kerberos delegation token login ) >

[jira] [Resolved] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong resolved FLINK-15561. --- Resolution: Fixed > Improve Kerberos delegation token login >

[jira] [Commented] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042273#comment-17042273 ] Rong Rong commented on FLINK-15561: --- fixed: master: 57c33961a55cff1068345198cb4669d9f1313bf8

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

[ https://issues.apache.org/jira/browse/FLINK-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-16224: -- Description: Currently the SecureTestEnvironment doesn't support Hadoop delegation token, which

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

Rong Rong created FLINK-16224: - Summary: Refine Hadoop Delegation Token based testing framework Key: FLINK-16224 URL: https://issues.apache.org/jira/browse/FLINK-16224 Project: Flink Issue Type:

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Fix Version/s: (was: 1.9.3) > Improve Kerberos delegation token login >

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Description: Inspired by the discussion in 

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Parent: FLINK-11271 Issue Type: Sub-task (was: Bug) > Improve Kerberos delegation token

[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: -- Fix Version/s: 1.11.0 > Allow pre-install Kerberos authentication keytab discovery on YARN >

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Issue Type: Bug (was: Improvement) > Improve Kerberos delegation token login >

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Fix Version/s: 1.10.1 1.9.3 > Improve Kerberos delegation token login >

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Fix Version/s: (was: 1.10.1) (was: 1.9.3) > Improve Kerberos delegation

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Issue Type: Improvement (was: Bug) > Improve Kerberos delegation token login >

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Description: Inspired by the discussion in 

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Description: Inspired by the discussion in 

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021129#comment-17021129 ] Rong Rong commented on FLINK-15447: --- Oops. i think i completely misunderstood your intention

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020757#comment-17020757 ] Rong Rong commented on FLINK-15447: --- Thanks [~victor-wong] for the explanation. I think I understood

[jira] [Commented] (FLINK-15671) Provide one place for Docker Images with all supported cluster modes

[ https://issues.apache.org/jira/browse/FLINK-15671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020506#comment-17020506 ] Rong Rong commented on FLINK-15671: --- Huge +1 on this.  Thanks [~sewen] for bringing this to

[jira] [Comment Edited] (FLINK-14460) Active Kubernetes integration phase2 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020505#comment-17020505 ] Rong Rong edited comment on FLINK-14460 at 1/21/20 7:21 PM: Thanks for

[jira] [Commented] (FLINK-14460) Active Kubernetes integration phase2 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020505#comment-17020505 ] Rong Rong commented on FLINK-14460: --- Thanks for sharing [~fly_in_gis]. * FLINK-15671 seems like a

[jira] [Comment Edited] (FLINK-14460) Active Kubernetes integration phase2 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019642#comment-17019642 ] Rong Rong edited comment on FLINK-14460 at 1/20/20 5:13 PM: Thanks

[jira] [Commented] (FLINK-14460) Active Kubernetes integration phase2 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019642#comment-17019642 ] Rong Rong commented on FLINK-14460: --- Thanks [~fly_in_gis] for driving this. Really looking forward to

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018645#comment-17018645 ] Rong Rong edited comment on FLINK-15447 at 1/18/20 5:02 PM: Ahh. I see your

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018645#comment-17018645 ] Rong Rong edited comment on FLINK-15447 at 1/18/20 5:01 PM: Ahh. I see your

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018645#comment-17018645 ] Rong Rong edited comment on FLINK-15447 at 1/18/20 5:01 PM: Ahh. I see your

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018645#comment-17018645 ] Rong Rong commented on FLINK-15447: --- Ahh. I see your intention. Let me clarify what I understood.

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018177#comment-17018177 ] Rong Rong commented on FLINK-15447: --- as far as I can tell, {{java.io.tmpdir}} is controlled by

[jira] [Commented] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015545#comment-17015545 ] Rong Rong commented on FLINK-15561: --- made a simple change on issue #2 and it looks good, maybe we can

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15561: -- Description: Currently the security HadoopModule handles delegation token login seems to be not

[jira] [Created] (FLINK-15561) Improve Kerberos delegation token login

Rong Rong created FLINK-15561: - Summary: Improve Kerberos delegation token login Key: FLINK-15561 URL: https://issues.apache.org/jira/browse/FLINK-15561 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[jira] [Created] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

Rong Rong created FLINK-15475: - Summary: Add isOutputTypeUsed() API to Transformation Key: FLINK-15475 URL: https://issues.apache.org/jira/browse/FLINK-15475 Project: Flink Issue Type:

[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=17007605#comment-17007605 ] Rong Rong commented on FLINK-11120: --- Hi [~x1q1j1] yes it will be in 1.10 release and it has already

[jira] [Assigned] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on azure

[ https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-15451: - Assignee: (was: Rong Rong) >

[jira] [Assigned] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on azure

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

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997757#comment-16997757 ] Rong Rong commented on FLINK-9630: -- Hi All, is this connected somehow with FLINK-8497? We are

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997755#comment-16997755 ] Rong Rong commented on FLINK-9630: -- Hi All, Is this a duplicate of FLINK-8497 ? >

[jira] [Issue Comment Deleted] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9630: - Comment: was deleted (was: Hi All, Is this a duplicate of FLINK-8497 ?) > Kafka09PartitionDiscoverer

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

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

[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=16990570#comment-16990570 ] Rong Rong commented on FLINK-11120: --- closed via: master: (9320f344f37019b9b389ef06477c8049e9fa3218,

[jira] [Commented] (FLINK-14729) Multi-topics consuming from KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985127#comment-16985127 ] Rong Rong commented on FLINK-14729: --- Hi [~fangpengcheng95] [~50man] I think it would be nice if you

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

[ https://issues.apache.org/jira/browse/FLINK-14153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960191#comment-16960191 ] Rong Rong commented on FLINK-14153: --- Committed via: 23a34b818d8267d16f6c22c77b79c67387da5e88 > Add to

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

[ https://issues.apache.org/jira/browse/FLINK-14153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960191#comment-16960191 ] Rong Rong edited comment on FLINK-14153 at 10/25/19 10:43 PM: -- merged to

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

[ 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 >

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

[ 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 >

[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=16955236#comment-16955236 ] Rong Rong commented on FLINK-12399: --- merged to 1.9: c1019105c22455c554ab91b9fc2ef8512873bee8 >

[jira] [Updated] (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 updated FLINK-12399: -- Fix Version/s: 1.9.2 > FilterableTableSource does not use filters on job run >

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

[ https://issues.apache.org/jira/browse/FLINK-14442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954803#comment-16954803 ] Rong Rong commented on FLINK-14442: --- Hi [~javadevmtl] sorry I misunderstood your intention in the

[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=16932569#comment-16932569 ] Rong Rong commented on FLINK-11936: --- [~danny0405] yes. I think that would be great. > Remove

[jira] [Comment Edited] (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 edited comment on FLINK-12399 at 9/4/19 4:28 PM: --- Hi [~josh.bradt].

[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=16921546#comment-16921546 ] Rong Rong commented on FLINK-12399: --- Hi [~fhueske]. would you please kindly take a look at 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=16907465#comment-16907465 ] Rong Rong commented on FLINK-13548: --- Thanks for the feedback [~till.rohrmann]. Yes I think so too. And

[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=16904697#comment-16904697 ] Rong Rong commented on FLINK-13548: --- Hi [~boswell] thanks for the contribution. I just come to

[jira] [Commented] (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:comment-tabpanel=16903441#comment-16903441 ] Rong Rong commented on FLINK-13603: --- to answer your questions [~jacky.du0...@gmail.com], any critical

[jira] [Commented] (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:comment-tabpanel=16903440#comment-16903440 ] Rong Rong commented on FLINK-13603: --- Based on what I saw. FLINK-12848 is labeled as improvement so I

[jira] [Commented] (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:comment-tabpanel=16903404#comment-16903404 ] Rong Rong commented on FLINK-13603: --- Hi [~jacky.du0...@gmail.com]. I wouldn't think they are

  1   2   3   4   5   >