[jira] [Comment Edited] (FLINK-12214) Add JobListener to capture job submission process

2019-04-16 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819215#comment-16819215 ] Jeff Zhang edited comment on FLINK-12214 at 4/16/19 4:22 PM: -

[jira] [Updated] (FLINK-12214) Add JobListener to capture job submission process

2019-04-16 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Description: Third party library would like to add some hook when submitting jobs. So it would be n

[jira] [Commented] (FLINK-12214) Add JobListener to capture job submission process

2019-04-16 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819578#comment-16819578 ] Jeff Zhang commented on FLINK-12214: [~till.rohrmann] I think this issue is orthogon

[jira] [Created] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-1: -- Summary: No way to ship custom jars to yarn cluster in scala-shell Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink Issue T

[jira] [Assigned] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-1: -- Assignee: Jeff Zhang > No way to ship custom jars to yarn cluster in scala-shell > --

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Component/s: Deployment / YARN > No way to ship custom jars to yarn cluster in scala-shell > ---

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Affects Version/s: 1.8.0 > No way to ship custom jars to yarn cluster in scala-shell > -

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Description: If user use `flink run` to submit flink jars, he could build uber jar to include all it

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Description: If user use `flink run` to submit flink jars, he could build uber jar to include all it

[jira] [Updated] (FLINK-12222) `start-scala-shell -a ` doesn't ship jars to yarn container

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Summary: `start-scala-shell -a ` doesn't ship jars to yarn container (was: No way to ship custom ja

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Issue Type: Bug (was: New Feature) > No way to ship custom jars to yarn cluster in scala-shell > --

[jira] [Updated] (FLINK-12222) 'start-scala-shell -a ' doesn't ship jars to yarn container

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Summary: 'start-scala-shell -a ' doesn't ship jars to yarn container (was: `start-scala-shell -a `

[jira] [Updated] (FLINK-12222) 'start-scala-shell -a ' doesn't ship jars to yarn container

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Description: If user use `flink run` to submit flink jars, he could build uber jar to include all it

[jira] [Commented] (FLINK-12214) Add JobListener to capture job submission process

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820127#comment-16820127 ] Jeff Zhang commented on FLINK-12214: [~till.rohrmann] I understand your concern of a

[jira] [Updated] (FLINK-12214) Add JobListener (hook) to in job lifecycle

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Summary: Add JobListener (hook) to in job lifecycle (was: Add JobListener to capture job submission

[jira] [Updated] (FLINK-12214) Add JobListener (hook) in flink job lifecycle

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Summary: Add JobListener (hook) in flink job lifecycle (was: Add JobListener (hook) to in job lifec

[jira] [Updated] (FLINK-12214) Add JobListener(hook) in flink job lifecycle

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Summary: Add JobListener(hook) in flink job lifecycle (was: Add JobListener (hook) in flink job lif

[jira] [Created] (FLINK-12272) Enable session in ExecutionEnvironment

2019-04-20 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-12272: -- Summary: Enable session in ExecutionEnvironment Key: FLINK-12272 URL: https://issues.apache.org/jira/browse/FLINK-12272 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-12272) Enable session in ExecutionEnvironment

2019-04-20 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12272: --- Component/s: API / DataSet > Enable session in ExecutionEnvironment > --

[jira] [Updated] (FLINK-12272) Enable session in ExecutionEnvironment

2019-04-20 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12272: --- Affects Version/s: 1.8.0 > Enable session in ExecutionEnvironment >

[jira] [Assigned] (FLINK-12272) Enable session in ExecutionEnvironment

2019-04-20 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-12272: -- Assignee: Jeff Zhang > Enable session in ExecutionEnvironment > -

[jira] [Created] (FLINK-12283) Allow non static UDF

2019-04-21 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-12283: -- Summary: Allow non static UDF Key: FLINK-12283 URL: https://issues.apache.org/jira/browse/FLINK-12283 Project: Flink Issue Type: New Feature Components

[jira] [Updated] (FLINK-12283) Allow non static UDF

2019-04-21 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12283: --- Issue Type: Improvement (was: New Feature) > Allow non static UDF > > >

[jira] [Assigned] (FLINK-12283) Allow non static UDF

2019-04-21 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-12283: -- Assignee: Jeff Zhang > Allow non static UDF > > > Key: F

[jira] [Updated] (FLINK-12283) Allow non-static inner UDF

2019-04-22 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12283: --- Summary: Allow non-static inner UDF (was: Allow non static UDF) > Allow non-static inner UDF >

[jira] [Commented] (FLINK-12283) Allow non-static inner UDF

2019-04-22 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823603#comment-16823603 ] Jeff Zhang commented on FLINK-12283: Thanks [~phoenixjiangnan], I have updated the t

[jira] [Updated] (FLINK-12283) Allow non-static inner class as UDF

2019-04-22 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12283: --- Summary: Allow non-static inner class as UDF (was: Allow non-static inner UDF) > Allow non-static

[jira] [Created] (FLINK-12422) Remove IN_TESTS for make test code and production code consistent

2019-05-06 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-12422: -- Summary: Remove IN_TESTS for make test code and production code consistent Key: FLINK-12422 URL: https://issues.apache.org/jira/browse/FLINK-12422 Project: Flink

[jira] [Commented] (FLINK-12422) Remove IN_TESTS for make test code and production code consistent

2019-05-07 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834627#comment-16834627 ] Jeff Zhang commented on FLINK-12422: [~yanghua] Thanks for taking over this ticket,

[jira] [Created] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

2019-03-19 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-11970: -- Summary: TableEnvironment#registerFunction should overwrite if the same name function existed. Key: FLINK-11970 URL: https://issues.apache.org/jira/browse/FLINK-11970 Pr

[jira] [Commented] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

2019-03-26 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16801504#comment-16801504 ] Jeff Zhang commented on FLINK-12002: This is a very useful features, specially for s

[jira] [Comment Edited] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

2019-03-26 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16801504#comment-16801504 ] Jeff Zhang edited comment on FLINK-12002 at 3/26/19 9:17 AM: -

[jira] [Created] (FLINK-12027) Flink Web UI is not accessible in local mode

2019-03-26 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-12027: -- Summary: Flink Web UI is not accessible in local mode Key: FLINK-12027 URL: https://issues.apache.org/jira/browse/FLINK-12027 Project: Flink Issue Type: Improvem

[jira] [Updated] (FLINK-12027) Flink Web UI is not accessible in local mode

2019-03-26 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12027: --- Description: When I use flink in local mode (LocalEnvironment), I can not access flink web ui. That

[jira] [Commented] (FLINK-12027) Flink Web UI is not accessible in local mode

2019-03-28 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16804507#comment-16804507 ] Jeff Zhang commented on FLINK-12027: Oops, I didn't there's such api createLocalEnvi

[jira] [Commented] (FLINK-12027) Flink Web UI is not accessible in local mode

2019-03-28 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16804512#comment-16804512 ] Jeff Zhang commented on FLINK-12027: Unfortunately, web ui is still not accessible e

[jira] [Commented] (FLINK-12027) Flink Web UI is not accessible in local mode

2019-03-29 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16804708#comment-16804708 ] Jeff Zhang commented on FLINK-12027: [~Zentol] I don't see RestServerEndpoint, but o

[jira] [Assigned] (FLINK-12159) Enable YarnMiniCluster integration test under non-secure mode

2019-04-10 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-12159: -- Assignee: Jeff Zhang > Enable YarnMiniCluster integration test under non-secure mode > --

[jira] [Created] (FLINK-12159) Enable YarnMiniCluster integration test under non-secure mode

2019-04-10 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-12159: -- Summary: Enable YarnMiniCluster integration test under non-secure mode Key: FLINK-12159 URL: https://issues.apache.org/jira/browse/FLINK-12159 Project: Flink Is

[jira] [Created] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15562: -- Summary: Unable to create walk through project Key: FLINK-15562 URL: https://issues.apache.org/jira/browse/FLINK-15562 Project: Flink Issue Type: Bug Affects

[jira] [Updated] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15562: --- Component/s: Documentation > Unable to create walk through project > ---

[jira] [Created] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15566: -- Summary: Flink implicitly order the fields in PojoTypeInfo Key: FLINK-15566 URL: https://issues.apache.org/jira/browse/FLINK-15566 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014100#comment-17014100 ] Jeff Zhang commented on FLINK-15566: [~aljoscha] Could you take a look at this issue

[jira] [Updated] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15566: --- Description: I don't know why flink would do that, but this cause my user defined function behavior

[jira] [Updated] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15566: --- Description: I don't know why flink would do that, but this cause my user defined function behavior

[jira] [Created] (FLINK-15569) Incorrect sample code in udf document

2020-01-13 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15569: -- Summary: Incorrect sample code in udf document Key: FLINK-15569 URL: https://issues.apache.org/jira/browse/FLINK-15569 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014340#comment-17014340 ] Jeff Zhang commented on FLINK-15566: [~twalthr] When will FLIP-65 be completed ? >

[jira] [Updated] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

2020-01-14 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15592: --- Summary: Streaming sql throw hive exception when it doesn't use any hive table (was: Streaming sql

[jira] [Created] (FLINK-15592) Streaming sql throw hive related sql when it doesn't use any hive table

2020-01-14 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15592: -- Summary: Streaming sql throw hive related sql when it doesn't use any hive table Key: FLINK-15592 URL: https://issues.apache.org/jira/browse/FLINK-15592 Project: Flink

[jira] [Commented] (FLINK-15635) Allow passing a ClassLoader to EnvironmentSettings

2020-01-17 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018069#comment-17018069 ] Jeff Zhang commented on FLINK-15635: [~twalthr] Would this affect the ClassLoader in

[jira] [Commented] (FLINK-15644) Add support for SQL query validation

2020-01-18 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018592#comment-17018592 ] Jeff Zhang commented on FLINK-15644: [~fhueske] Will DDL/DML also be verified ? > A

[jira] [Created] (FLINK-15858) Unable to use HiveCatalog and kafka together

2020-02-02 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15858: -- Summary: Unable to use HiveCatalog and kafka together Key: FLINK-15858 URL: https://issues.apache.org/jira/browse/FLINK-15858 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

2020-02-02 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028713#comment-17028713 ] Jeff Zhang commented on FLINK-15858: \cc [~lirui] [~lzljs3620320] > Unable to use H

[jira] [Updated] (FLINK-15858) Unable to use HiveCatalog and kafka together

2020-02-03 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15858: --- Priority: Blocker (was: Critical) > Unable to use HiveCatalog and kafka together >

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

2020-02-03 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029495#comment-17029495 ] Jeff Zhang commented on FLINK-15858: In that case, it is a regression issue, definit

[jira] [Created] (FLINK-18167) Flink Job hangs there when one vertex is failed and another is cancelled.

2020-06-06 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-18167: -- Summary: Flink Job hangs there when one vertex is failed and another is cancelled. Key: FLINK-18167 URL: https://issues.apache.org/jira/browse/FLINK-18167 Project: Flink

[jira] [Updated] (FLINK-17788) scala shell in yarn mode is broken

2020-06-10 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-17788: --- Affects Version/s: 1.10.1 > scala shell in yarn mode is broken > --

[jira] [Created] (FLINK-17870) scala shell jars are missing to be shipped to cluster

2020-05-21 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17870: -- Summary: scala shell jars are missing to be shipped to cluster Key: FLINK-17870 URL: https://issues.apache.org/jira/browse/FLINK-17870 Project: Flink Issue Type:

[jira] [Updated] (FLINK-17870) dependent jars are missing to be shipped to cluster in scala shell

2020-05-21 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-17870: --- Summary: dependent jars are missing to be shipped to cluster in scala shell (was: scala shell jars

[jira] [Created] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17889: -- Summary: flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory Key: FLINK-17889 URL: https://issues.apache.org/jira/browse

[jira] [Commented] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114191#comment-17114191 ] Jeff Zhang commented on FLINK-17889: \cc [~lirui] [~lzljs3620320] > flink-connector

[jira] [Updated] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-17889: --- Description: These 2 classes are in flink-connector-hive jar's SPI config file {code:java} org.apach

[jira] [Created] (FLINK-17944) Wrong output in sql client's table mode

2020-05-26 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17944: -- Summary: Wrong output in sql client's table mode Key: FLINK-17944 URL: https://issues.apache.org/jira/browse/FLINK-17944 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-17944) Wrong output in sql client's table mode

2020-05-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116765#comment-17116765 ] Jeff Zhang commented on FLINK-17944: I will make a PR for it > Wrong output in sql

[jira] [Commented] (FLINK-17788) scala shell in yarn mode is broken

2020-05-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116822#comment-17116822 ] Jeff Zhang commented on FLINK-17788: [~kkl0u] The phenomenon I see is that when I la

[jira] [Commented] (FLINK-17788) scala shell in yarn mode is broken

2020-05-27 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118249#comment-17118249 ] Jeff Zhang commented on FLINK-17788: Yes,each time when I call execute(), scala shel

[jira] [Comment Edited] (FLINK-17788) scala shell in yarn mode is broken

2020-05-27 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118249#comment-17118249 ] Jeff Zhang edited comment on FLINK-17788 at 5/28/20, 2:45 AM:

[jira] [Updated] (FLINK-17944) Wrong output in sql client's table mode

2020-05-27 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-17944: --- Issue Type: Bug (was: Improvement) > Wrong output in sql client's table mode >

[jira] [Comment Edited] (FLINK-17788) scala shell in yarn mode is broken

2020-05-27 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118249#comment-17118249 ] Jeff Zhang edited comment on FLINK-17788 at 5/28/20, 3:09 AM:

[jira] [Commented] (FLINK-17788) scala shell in yarn mode is broken

2020-06-01 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120871#comment-17120871 ] Jeff Zhang commented on FLINK-17788: [~kkl0u] The second yarn app fail to launch due

[jira] [Commented] (FLINK-10911) Flink's flink-scala-shell is not working with Scala 2.12

2020-04-23 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090401#comment-17090401 ] Jeff Zhang commented on FLINK-10911: I will take a look at this issue > Flink's fli

[jira] [Commented] (FLINK-10911) Flink's flink-scala-shell is not working with Scala 2.12

2020-04-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091594#comment-17091594 ] Jeff Zhang commented on FLINK-10911: [~aljoscha] [~trohrmann] [~chesnay]  I tested i

[jira] [Commented] (FLINK-10911) Flink's flink-scala-shell is not working with Scala 2.12

2020-04-25 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092156#comment-17092156 ] Jeff Zhang commented on FLINK-10911: [~trohrmann] We still need to enable scala-2.12

[jira] [Updated] (FLINK-10911) Enable flink-scala-shell with Scala 2.12

2020-04-25 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-10911: --- Summary: Enable flink-scala-shell with Scala 2.12 (was: Flink's flink-scala-shell is not working wi

[jira] [Commented] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082194#comment-17082194 ] Jeff Zhang commented on FLINK-17114: I think it depends what is the default python i

[jira] [Commented] (FLINK-17124) The PyFlink Job runs into infinite loop if the UDF file imports job code.

2020-04-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082394#comment-17082394 ] Jeff Zhang commented on FLINK-17124: Should it be a blocker issue for 1.10.1 ? > Th

[jira] [Updated] (FLINK-13811) Support converting flink table to pandas dataframe

2020-04-14 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-13811: --- Description: Pandas dataframe is the de facto standard tableau data format of python community. It w

[jira] [Commented] (FLINK-16936) TablEnv creation and planner execution must be in the same thread

2020-04-16 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084996#comment-17084996 ] Jeff Zhang commented on FLINK-16936: [~ykt836] Is multiple-thread support not on the

[jira] [Commented] (FLINK-16936) TablEnv creation and planner execution must be in the same thread

2020-04-16 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085046#comment-17085046 ] Jeff Zhang commented on FLINK-16936: Good, thanks for let me know FLIP-84 will make

[jira] [Comment Edited] (FLINK-17225) Support native k8s for scala shell

2020-04-17 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085889#comment-17085889 ] Jeff Zhang edited comment on FLINK-17225 at 4/17/20, 3:59 PM:

[jira] [Commented] (FLINK-17225) Support native k8s for scala shell

2020-04-17 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085889#comment-17085889 ] Jeff Zhang commented on FLINK-17225: Thanks [~fly_in_gis]  [~chesnay] Why does scal

[jira] [Commented] (FLINK-16266) es6 & 7 table sql connector conflicts each other

2020-02-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044013#comment-17044013 ] Jeff Zhang commented on FLINK-16266: I believe this could be resolved via plugin mec

[jira] [Commented] (FLINK-16266) es6 & 7 table sql connector conflicts each other

2020-02-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044016#comment-17044016 ] Jeff Zhang commented on FLINK-16266: BTW, IMHO I don't think it is best practice to

[jira] [Commented] (FLINK-16266) es6 & 7 table sql connector conflicts each other

2020-02-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044043#comment-17044043 ] Jeff Zhang commented on FLINK-16266: AFAIK plugin mechanism is not ready for connect

[jira] [Created] (FLINK-16286) Support select from nothing

2020-02-25 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-16286: -- Summary: Support select from nothing Key: FLINK-16286 URL: https://issues.apache.org/jira/browse/FLINK-16286 Project: Flink Issue Type: New Feature Affects V

[jira] [Updated] (FLINK-16286) Support select from nothing

2020-02-25 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16286: --- Component/s: Table SQL / API > Support select from nothing > --- > >

[jira] [Commented] (FLINK-16286) Support select from nothing

2020-02-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045228#comment-17045228 ] Jeff Zhang commented on FLINK-16286: Is it supported in 1.10 ? I just tried flink 1.

[jira] [Commented] (FLINK-16286) Support select from nothing

2020-02-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045244#comment-17045244 ] Jeff Zhang commented on FLINK-16286: Sorry, my fault.  I used double quote which cau

[jira] [Closed] (FLINK-16286) Support select from nothing

2020-02-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang closed FLINK-16286. -- Resolution: Invalid > Support select from nothing > --- > > Ke

[jira] [Comment Edited] (FLINK-14991) Export `FLINK_HOME` environment variable to all the entrypoint

2020-02-28 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16985271#comment-16985271 ] Jeff Zhang edited comment on FLINK-14991 at 2/28/20 1:43 PM: -

[jira] [Commented] (FLINK-16418) Hide hive version to avoid user confuse

2020-03-04 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051021#comment-17051021 ] Jeff Zhang commented on FLINK-16418: [~lzljs3620320] Do you mean to detect hive vers

[jira] [Created] (FLINK-13379) Make Flink work without flink-shaded-hadoop jar

2019-07-23 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13379: -- Summary: Make Flink work without flink-shaded-hadoop jar Key: FLINK-13379 URL: https://issues.apache.org/jira/browse/FLINK-13379 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-13379) Make Flink work without flink-shaded-hadoop jar

2019-07-23 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16890791#comment-16890791 ] Jeff Zhang commented on FLINK-13379: For this ticket, I would propose to add hadoop

[jira] [Commented] (FLINK-13379) Document how to use Flink with vanilla Hadoop Jars

2019-07-24 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891689#comment-16891689 ] Jeff Zhang commented on FLINK-13379: [~aljoscha] I may misunderstand you. I thought

[jira] [Created] (FLINK-13411) SqlClient swallow the error when fails to submit job

2019-07-24 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13411: -- Summary: SqlClient swallow the error when fails to submit job Key: FLINK-13411 URL: https://issues.apache.org/jira/browse/FLINK-13411 Project: Flink Issue Type:

[jira] [Created] (FLINK-13413) Put flink-table jar under lib folder

2019-07-24 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13413: -- Summary: Put flink-table jar under lib folder Key: FLINK-13413 URL: https://issues.apache.org/jira/browse/FLINK-13413 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13415) Document how to use hive connector in scala shell

2019-07-24 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13415: -- Summary: Document how to use hive connector in scala shell Key: FLINK-13415 URL: https://issues.apache.org/jira/browse/FLINK-13415 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-13399) Create two separate uber jars for each planner

2019-07-25 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892492#comment-16892492 ] Jeff Zhang commented on FLINK-13399: How about putting them in lib/planner like foll

[jira] [Created] (FLINK-13420) Supported hive versions are hard coded

2019-07-25 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13420: -- Summary: Supported hive versions are hard coded Key: FLINK-13420 URL: https://issues.apache.org/jira/browse/FLINK-13420 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-13420) Supported hive versions are hard coded

2019-07-25 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-13420: --- Description: Currently, the supported hive versions are hardcoded in [HiveShimLoader|[https://github

<    1   2   3   4   >