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:
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
Affect
[
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
especially
[
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
> --
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
[
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
[
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:
[
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
>
[
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:
[
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
[
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
[
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
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
[
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
[
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
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
[
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
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:
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
Comp
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
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
[
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
[
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
[
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
[
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
[
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:
[
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
[
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
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-16969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074442#comment-17074442
]
Jeff Zhang commented on FLINK-16969:
\cc [~tiwalter]
> Unable to use case class in
[
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 = benv.fromElements(
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
[
https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073417#comment-17073417
]
Jeff Zhang edited comment on FLINK-16936 at 4/2/20, 6:44 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073417#comment-17073417
]
Jeff Zhang edited comment on FLINK-16936 at 4/2/20, 6:44 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073417#comment-17073417
]
Jeff Zhang commented on FLINK-16936:
[~godfreyhe] [~lzljs3620320] [~danny0405] [~tiw
[
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 Ze
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
[
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 Ze
[
https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067678#comment-17067678
]
Jeff Zhang edited comment on FLINK-16797 at 3/26/20, 1:29 PM:
[
https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067678#comment-17067678
]
Jeff Zhang commented on FLINK-16797:
Thanks [~godfreyhe] & [~jark]
> Flink doesn't
[
https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067524#comment-17067524
]
Jeff Zhang commented on FLINK-16797:
[~twalthr] I just checked FLIP-84, but it looks
[
https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067523#comment-17067523
]
Jeff Zhang commented on FLINK-16797:
Thanks for the info [~twalthr]
> Flink doesn't
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
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059711#comment-17059711
]
Jeff Zhang commented on FLINK-16604:
\cc [~vthinkxie]
> Column key in JM configurat
[
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 nar
[
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
[
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
> -
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: Improvem
[
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
[
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:
-
[
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
[
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
[
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.
[
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
> ---
>
>
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
[
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
[
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
[
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
[
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 bl
[
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)
{c
[
https://issues.apache.org/jira/browse/FLINK-15935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031320#comment-17031320
]
Jeff Zhang commented on FLINK-15935:
\cc [~jark] [~lzljs3620320] [~ykt836] [~liyu] [
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: Fli
[
https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030299#comment-17030299
]
Jeff Zhang commented on FLINK-15858:
[~liyu] [~gjy] This ticket means users unable t
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030295#comment-17030295
]
Jeff Zhang commented on FLINK-15858:
[~lzljs3620320] But IIRC, this issue means user
[
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
[
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
>
[
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
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
[
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
[
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
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
[
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
[
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 ?
>
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
[
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
[
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
[
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
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
[
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
> ---
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
[
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
ExecutionEnvironment/Stream
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
[
https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003500#comment-17003500
]
Jeff Zhang commented on FLINK-15395:
[~ykt836] Here's how sql-client execute `insert
[
https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003497#comment-17003497
]
Jeff Zhang commented on FLINK-15395:
Thanks [~jark] [~ykt836], `sqlUpdate` is the be
[
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 sel
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003474#comment-17003474
]
Jeff Zhang commented on FLINK-15395:
\cc [~tiwalter] [~aljoscha]
> No API for execu
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
[
https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003080#comment-17003080
]
Jeff Zhang edited comment on FLINK-15384 at 12/25/19 5:31 AM:
[
https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003080#comment-17003080
]
Jeff Zhang commented on FLINK-15384:
[~ykt836] I can do for StreamTableEnvironment,
[
https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002847#comment-17002847
]
Jeff Zhang edited comment on FLINK-15384 at 12/24/19 2:01 PM:
[
https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002847#comment-17002847
]
Jeff Zhang edited comment on FLINK-15384 at 12/24/19 2:02 PM:
[
https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002847#comment-17002847
]
Jeff Zhang commented on FLINK-15384:
\cc [~aljoscha] [~kkloudas] [~tison]
> Allow t
[
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
Executio
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
Projec
1 - 100 of 314 matches
Mail list logo
