[jira] [Created] (FLINK-31667) Should not enforce attached mode in RemoteEnvironment & RemoteStreamEnvironment

2023-03-29 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-31667: -- Summary: Should not enforce attached mode in RemoteEnvironment & RemoteStreamEnvironment Key: FLINK-31667 URL: https://issues.apache.org/jira/browse/FLINK-31667 Project:

[jira] [Created] (FLINK-21607) Twitter table source connector

2021-03-04 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-21607: -- Summary: Twitter table source connector Key: FLINK-21607 URL: https://issues.apache.org/jira/browse/FLINK-21607 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-21607) Twitter table source connector

2021-03-04 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-21607: --- Description: It would be nice to have such flink twitter table source connector. This is

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

[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=17120871#comment-17120871 ] Jeff Zhang commented on FLINK-17788: [~kkl0u] The second yarn app fail to launch due to port

[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=17118249#comment-17118249 ] Jeff Zhang edited comment on FLINK-17788 at 5/28/20, 3:09 AM: -- [~kkl0u]

[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=17118249#comment-17118249 ] Jeff Zhang edited comment on FLINK-17788 at 5/28/20, 2:45 AM: -- [~kkl0u]

[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=17118249#comment-17118249 ] Jeff Zhang commented on FLINK-17788: Yes,each time when I call execute(), scala shell will create a

[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=17116822#comment-17116822 ] Jeff Zhang commented on FLINK-17788: [~kkl0u] The phenomenon I see is that when I launch scala-shell

[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=17116765#comment-17116765 ] Jeff Zhang commented on FLINK-17944: I will make a PR for it > Wrong output in sql client's table

[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-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=17114191#comment-17114191 ] Jeff Zhang commented on FLINK-17889: \cc [~lirui] [~lzljs3620320] > flink-connector-hive jar

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

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

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

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

2020-05-18 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17788: -- Summary: scala shell in yarn mode is broken Key: FLINK-17788 URL: https://issues.apache.org/jira/browse/FLINK-17788 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17763) No log files when starting scala-shell

2020-05-16 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17763: -- Summary: No log files when starting scala-shell Key: FLINK-17763 URL: https://issues.apache.org/jira/browse/FLINK-17763 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17588) Throw exception when hadoop jar is missing in flink scala's yarn mode.

2020-05-08 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17588: -- Summary: Throw exception when hadoop jar is missing in flink scala's yarn mode. Key: FLINK-17588 URL: https://issues.apache.org/jira/browse/FLINK-17588 Project: Flink

[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

[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=17092156#comment-17092156 ] Jeff Zhang commented on FLINK-10911: [~trohrmann] We still need to enable scala-2.12 for flink scala

[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=17091594#comment-17091594 ] Jeff Zhang commented on FLINK-10911: [~aljoscha] [~trohrmann] [~chesnay]  I tested it in my local

[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=17090401#comment-17090401 ] Jeff Zhang commented on FLINK-10911: I will take a look at this issue > Flink's flink-scala-shell

[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=17085889#comment-17085889 ] Jeff Zhang edited comment on FLINK-17225 at 4/17/20, 3:59 PM: -- Thanks

[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=17085889#comment-17085889 ] Jeff Zhang commented on FLINK-17225: Thanks [~fly_in_gis]  [~chesnay] Why does scala 2.12 support

[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=17085046#comment-17085046 ] Jeff Zhang commented on FLINK-16936: Good, thanks for let me know FLIP-84 will make sql execution

[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=17084996#comment-17084996 ] Jeff Zhang commented on FLINK-16936: [~ykt836] Is multiple-thread support not on the roadmap ? IMO,

[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

[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=17082394#comment-17082394 ] Jeff Zhang commented on FLINK-17124: Should it be a blocker issue for 1.10.1 ? > The PyFlink Job

[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=17082194#comment-17082194 ] Jeff Zhang commented on FLINK-17114: I think it depends what is the default python in your machine. 

[jira] [Commented] (FLINK-16969) Unable to use case class in flink scala shell

2020-04-03 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074442#comment-17074442 ] Jeff Zhang commented on FLINK-16969: \cc [~tiwalter] > Unable to use case class in flink scala

[jira] [Updated] (FLINK-16969) Unable to use case class in flink scala shell

2020-04-03 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16969: --- Description: {code:java} case class WC(word: String, count: Int) val wordCounts =

[jira] [Created] (FLINK-16969) Unable to use case class in flink scala shell

2020-04-03 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-16969: -- Summary: Unable to use case class in flink scala shell Key: FLINK-16969 URL: https://issues.apache.org/jira/browse/FLINK-16969 Project: Flink Issue Type: Bug

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

2020-04-02 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073417#comment-17073417 ] Jeff Zhang edited comment on FLINK-16936 at 4/2/20, 6:44 AM: - [~godfreyhe]

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

2020-04-02 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073417#comment-17073417 ] Jeff Zhang edited comment on FLINK-16936 at 4/2/20, 6:44 AM: - [~godfreyhe]

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

2020-04-02 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073417#comment-17073417 ] Jeff Zhang commented on FLINK-16936: [~godfreyhe] [~lzljs3620320] [~danny0405] [~tiwalter] >

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

2020-04-02 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16936: --- Description: I hit this issue in zeppelin. Let me first describe the thread mode of zeppelin. In

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

2020-04-02 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-16936: -- Summary: TablEnv creation and planner execution must be in the same thread Key: FLINK-16936 URL: https://issues.apache.org/jira/browse/FLINK-16936 Project: Flink

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

2020-04-02 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16936: --- Description: I hit this issue in zeppelin. Let me first describe the thread mode of zeppelin. In

[jira] [Comment Edited] (FLINK-16797) Flink doesn't merge multiple sinks into one DAG

2020-03-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067678#comment-17067678 ] Jeff Zhang edited comment on FLINK-16797 at 3/26/20, 1:29 PM: -- Thanks

[jira] [Commented] (FLINK-16797) Flink doesn't merge multiple sinks into one DAG

2020-03-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067678#comment-17067678 ] Jeff Zhang commented on FLINK-16797: Thanks [~godfreyhe] & [~jark]  > Flink doesn't merge multiple

[jira] [Commented] (FLINK-16797) Flink doesn't merge multiple sinks into one DAG

2020-03-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067524#comment-17067524 ] Jeff Zhang commented on FLINK-16797: [~twalthr] I just checked FLIP-84, but it looks like about api

[jira] [Commented] (FLINK-16797) Flink doesn't merge multiple sinks into one DAG

2020-03-26 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067523#comment-17067523 ] Jeff Zhang commented on FLINK-16797: Thanks for the info [~twalthr] > Flink doesn't merge multiple

[jira] [Created] (FLINK-16797) Flink doesn't merge multiple sinks into one DAG

2020-03-26 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-16797: -- Summary: Flink doesn't merge multiple sinks into one DAG Key: FLINK-16797 URL: https://issues.apache.org/jira/browse/FLINK-16797 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16604: --- Priority: Minor (was: Major) > Column key in JM configuration is too narrow >

[jira] [Commented] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059711#comment-17059711 ] Jeff Zhang commented on FLINK-16604: \cc [~vthinkxie] > Column key in JM configuration is too

[jira] [Updated] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16604: --- Attachment: (was: image-2020-03-15-22-21-17-369.png) > Column key in JM configuration is too

[jira] [Updated] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16604: --- Description: See the screenshot   !image-2020-03-15-22-22-01-696.png! was: See the screenshot

[jira] [Updated] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16604: --- Attachment: image-2020-03-15-22-22-01-696.png > Column key in JM configuration is too narrow >

[jira] [Created] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-16604: -- Summary: Column key in JM configuration is too narrow Key: FLINK-16604 URL: https://issues.apache.org/jira/browse/FLINK-16604 Project: Flink Issue Type:

[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=17051021#comment-17051021 ] Jeff Zhang commented on FLINK-16418: [~lzljs3620320] Do you mean to detect hive version for users ? 

[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=16985271#comment-16985271 ] Jeff Zhang edited comment on FLINK-14991 at 2/28/20 1:43 PM: - +1, but it

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

[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=17045244#comment-17045244 ] Jeff Zhang commented on FLINK-16286: Sorry, my fault.  I used double quote which cause the parsing

[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=17045228#comment-17045228 ] Jeff Zhang commented on FLINK-16286: Is it supported in 1.10 ? I just tried flink 1.10  > Support

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

[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=17044043#comment-17044043 ] Jeff Zhang commented on FLINK-16266: AFAIK plugin mechanism is not ready for connectors. Someone

[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=17044016#comment-17044016 ] Jeff Zhang commented on FLINK-16266: BTW, IMHO I don't think it is best practice to put connector

[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=17044013#comment-17044013 ] Jeff Zhang commented on FLINK-16266: I believe this could be resolved via plugin mechanism.  > es6

[jira] [Updated] (FLINK-15935) Unable to use watermark when depends both on flink planner and blink planner

2020-02-05 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15935: --- Component/s: Table SQL / Planner > Unable to use watermark when depends both on flink planner and

[jira] [Updated] (FLINK-15935) Unable to use watermark when depends both on flink planner and blink planner

2020-02-05 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15935: --- Description: Run the following code in module `flink-examples-table` (must be under this module)

[jira] [Commented] (FLINK-15935) Unable to use watermark when depends both on flink planner and blink planner

2020-02-05 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031320#comment-17031320 ] Jeff Zhang commented on FLINK-15935: \cc [~jark] [~lzljs3620320] [~ykt836] [~liyu] [~gjy]  > Unable

[jira] [Created] (FLINK-15935) Unable to use watermark when depends both on flink planner and blink planner

2020-02-05 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15935: -- Summary: Unable to use watermark when depends both on flink planner and blink planner Key: FLINK-15935 URL: https://issues.apache.org/jira/browse/FLINK-15935 Project:

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

2020-02-04 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030299#comment-17030299 ] Jeff Zhang commented on FLINK-15858: [~liyu] [~gjy] This ticket means users unable to use kafka with

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

2020-02-04 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-04 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030295#comment-17030295 ] Jeff Zhang commented on FLINK-15858: [~lzljs3620320] But IIRC, this issue means users unable to use

[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=17029495#comment-17029495 ] Jeff Zhang commented on FLINK-15858: In that case, it is a regression issue, definitely need to fix

[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-02 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028713#comment-17028713 ] Jeff Zhang commented on FLINK-15858: \cc [~lirui] [~lzljs3620320] > Unable to use HiveCatalog and

[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-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=17018592#comment-17018592 ] Jeff Zhang commented on FLINK-15644: [~fhueske] Will DDL/DML also be verified ? > Add support for

[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=17018069#comment-17018069 ] Jeff Zhang commented on FLINK-15635: [~twalthr] Would this affect the ClassLoader in 

[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] [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] [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=17014340#comment-17014340 ] Jeff Zhang commented on FLINK-15566: [~twalthr] When will FLIP-65 be completed ? > Flink implicitly

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

[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

[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=17014100#comment-17014100 ] Jeff Zhang commented on FLINK-15566: [~aljoscha] Could you take a look at this issue ? Seems you are

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

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

[jira] [Updated] (FLINK-15384) Expose JobListener API on TableEnvironment

2020-01-06 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15384: --- Summary: Expose JobListener API on TableEnvironment (was: Allow to pass

[jira] [Created] (FLINK-15439) Incorrect SQL Document about DDL support

2019-12-30 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15439: -- Summary: Incorrect SQL Document about DDL support Key: FLINK-15439 URL: https://issues.apache.org/jira/browse/FLINK-15439 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003500#comment-17003500 ] Jeff Zhang commented on FLINK-15395: [~ykt836] Here's how sql-client execute `insert into`. This is

[jira] [Commented] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003497#comment-17003497 ] Jeff Zhang commented on FLINK-15395: Thanks [~jark] [~ykt836], `sqlUpdate` is the best option,

[jira] [Updated] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15395: --- Description: IIUC, TableEnv#sqlUpdate is used for DDL & DML while TableEnv#sqlQuery is used for

[jira] [Updated] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15395: --- Issue Type: Improvement (was: Bug) > No API for execute insert into statement >

[jira] [Commented] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003474#comment-17003474 ] Jeff Zhang commented on FLINK-15395: \cc [~tiwalter] [~aljoscha] > No API for execute insert into

[jira] [Created] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15395: -- Summary: No API for execute insert into statement Key: FLINK-15395 URL: https://issues.apache.org/jira/browse/FLINK-15395 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

2019-12-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003080#comment-17003080 ] Jeff Zhang edited comment on FLINK-15384 at 12/25/19 5:31 AM: -- [~ykt836] I

[jira] [Commented] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

2019-12-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003080#comment-17003080 ] Jeff Zhang commented on FLINK-15384: [~ykt836] I can do for StreamTableEnvironment, but there's no

[jira] [Comment Edited] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

2019-12-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002847#comment-17002847 ] Jeff Zhang edited comment on FLINK-15384 at 12/24/19 2:01 PM: -- \cc

[jira] [Comment Edited] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

2019-12-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002847#comment-17002847 ] Jeff Zhang edited comment on FLINK-15384 at 12/24/19 2:02 PM: -- \cc

[jira] [Commented] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

2019-12-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002847#comment-17002847 ] Jeff Zhang commented on FLINK-15384: \cc [~aljoscha] [~kkloudas] [~tison] > Allow to pass

[jira] [Updated] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

2019-12-24 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15384: --- Description: In the new approach of creating TableEnvironement, it is not possible to pass

[jira] [Created] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

2019-12-24 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15384: -- Summary: Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment Key: FLINK-15384 URL: https://issues.apache.org/jira/browse/FLINK-15384

  1   2   3   4   >