[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&focusedCommentId=17186045#comment-17186045 ] Rong Rong commented on FLINK-16789: --- oops. yes you are right [~chesnay]. the closed PR

[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&focusedCommentId=17186002#comment-17186002 ] Rong Rong commented on FLINK-16789: --- After discussion in [#13163|https://github.com/ap

[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&focusedCommentId=17124277#comment-17124277 ] Rong Rong commented on FLINK-18045: --- yeah. that makes sense. +1 on the proposed soluti

[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&focusedCommentId=17123885#comment-17123885 ] Rong Rong commented on FLINK-18045: --- Yes. I think specifically checking auth method as

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

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

[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 HadoopSecurityContextFactory.createContext

[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&focusedCommentId=17109703#comment-17109703 ] Rong Rong commented on FLINK-17386: --- closed via: 1892bedeea9fa118b6e3bcb572f63c2e7f6d8

[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&focusedCommentId=17094595#comment-17094595 ] Rong Rong edited comment on FLINK-17386 at 4/29/20, 2:15 PM: -

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

[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&focusedCommentId=17094595#comment-17094595 ] Rong Rong commented on FLINK-17386: --- hmm. that's not what I expected. I have 2 theorie

[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&focusedCommentId=17094152#comment-17094152 ] Rong Rong commented on FLINK-17386: --- I might have some idea on why this is happening.

[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&focusedCommentId=17094149#comment-17094149 ] Rong Rong commented on FLINK-17386: --- hmm. interesting. Just to understand more cleare

[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&focusedCommentId=17092732#comment-17092732 ] Rong Rong commented on FLINK-17386: --- could you provide more information on how to repr

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

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

[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&focusedCommentId=17076873#comment-17076873 ] Rong Rong commented on FLINK-16522: --- Thanks for the clarification. huge +1. looking fo

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

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

[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&focusedCommentId=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&focusedCommentId=17067714#comment-17067714 ] Rong Rong edited comment on FLINK-16789 at 3/26/20, 3:03 PM: -

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

[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&focusedCommentId=17067714#comment-17067714 ] Rong Rong commented on FLINK-16789: --- Yes. I agree. in fact the {{JMXServer}} class in

[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&focusedCommentId=17067343#comment-17067343 ] Rong Rong commented on FLINK-16789: --- I've share a code snippet in  [https://github.com

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

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

[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&focusedCommentId=17067341#comment-17067341 ] Rong Rong commented on FLINK-5552: -- Oops.. I just realized that I am not talking about t

[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&focusedCommentId=17067335#comment-17067335 ] Rong Rong commented on FLINK-16483: --- yeah. I took a look and seems like simply align t

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

[ 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] [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&focusedCommentId=17067073#comment-17067073 ] Rong Rong commented on FLINK-16483: --- Hi Here, I am getting this error after rebasing t

[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&focusedCommentId=17064900#comment-17064900 ] Rong Rong commented on FLINK-5552: -- Hi, I would like to follow up on this ticket per som

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

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

[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&focusedCommentId=17043664#comment-17043664 ] Rong Rong commented on FLINK-16241: --- I think removing the license seems to be more rea

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

[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&focusedCommentId=17042273#comment-17042273 ] Rong Rong commented on FLINK-15561: --- fixed: master: 57c33961a55cff1068345198cb4669d9f

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

[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  [http://apache-flink-user-mailing-list-archive.2336050.n4.

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

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

[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  [http://apache-flink-user-mailing-list-archive.2336050.n4.

[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  [http://apache-flink-user-mailing-list-archive.2336050.n4.

[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&focusedCommentId=17021129#comment-17021129 ] Rong Rong commented on FLINK-15447: --- Oops. i think i completely misunderstood your int

[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&focusedCommentId=17020757#comment-17020757 ] Rong Rong commented on FLINK-15447: --- Thanks [~victor-wong] for the explanation. I thin

[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&focusedCommentId=17020506#comment-17020506 ] Rong Rong commented on FLINK-15671: --- Huge +1 on this.  Thanks [~sewen] for bringing t

[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&focusedCommentId=17020505#comment-17020505 ] Rong Rong edited comment on FLINK-14460 at 1/21/20 7:21 PM:

[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&focusedCommentId=17020505#comment-17020505 ] Rong Rong commented on FLINK-14460: --- Thanks for sharing [~fly_in_gis]. * FLINK-15671

[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&focusedCommentId=17019642#comment-17019642 ] Rong Rong edited comment on FLINK-14460 at 1/20/20 5:13 PM:

[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&focusedCommentId=17019642#comment-17019642 ] Rong Rong commented on FLINK-14460: --- Thanks [~fly_in_gis] for driving this. Really loo

[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&focusedCommentId=17018645#comment-17018645 ] Rong Rong edited comment on FLINK-15447 at 1/18/20 5:02 PM:

[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&focusedCommentId=17018645#comment-17018645 ] Rong Rong edited comment on FLINK-15447 at 1/18/20 5:01 PM:

[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&focusedCommentId=17018645#comment-17018645 ] Rong Rong edited comment on FLINK-15447 at 1/18/20 5:01 PM:

[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&focusedCommentId=17018645#comment-17018645 ] Rong Rong commented on FLINK-15447: --- Ahh. I see your intention. Let me clarify what I

[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&focusedCommentId=17018177#comment-17018177 ] Rong Rong commented on FLINK-15447: --- as far as I can tell, {{java.io.tmpdir}} is contr

[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&focusedCommentId=17015545#comment-17015545 ] Rong Rong commented on FLINK-15561: --- made a simple change on issue #2 and it looks goo

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

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

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

[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) > TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerPr

[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 > TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailur

[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&focusedCommentId=16997757#comment-16997757 ] Rong Rong commented on FLINK-9630: -- Hi All, is this connected somehow with FLINK-8497?

[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&focusedCommentId=16997755#comment-16997755 ] Rong Rong commented on FLINK-9630: -- Hi All, Is this a duplicate of FLINK-8497 ? > Kafk

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

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

[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&focusedCommentId=16985127#comment-16985127 ] Rong Rong commented on FLINK-14729: --- Hi [~fangpengcheng95] [~50man] I think it would b

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

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

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

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

[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&focusedCommentId=16954803#comment-16954803 ] Rong Rong commented on FLINK-14442: --- Hi [~javadevmtl] sorry I misunderstood your inten

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

[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&focusedCommentId=16833107#comment-16833107 ] Rong Rong edited comment on FLINK-12399 at 9/4/19 4:28 PM: --- Hi

[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&focusedCommentId=16921546#comment-16921546 ] Rong Rong commented on FLINK-12399: --- Hi [~fhueske]. would you please kindly take a loo

[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&focusedCommentId=16907465#comment-16907465 ] Rong Rong commented on FLINK-13548: --- Thanks for the feedback [~till.rohrmann]. Yes I t

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

[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&focusedCommentId=16903441#comment-16903441 ] Rong Rong commented on FLINK-13603: --- to answer your questions [~jacky.du0...@gmail.com

[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&focusedCommentId=16903440#comment-16903440 ] Rong Rong commented on FLINK-13603: --- Based on what I saw. FLINK-12848 is labeled as im

[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&focusedCommentId=16903404#comment-16903404 ] Rong Rong commented on FLINK-13603: --- Hi [~jacky.du0...@gmail.com]. I wouldn't think th

  1   2   3   4   5   >