[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638202#comment-17638202
]
yuemeng commented on FLINK-29801:
-
[~ruanhang1993] Here is my email(272614...@qq.com)
>
[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638122#comment-17638122
]
yuemeng commented on FLINK-29801:
-
[~ruanhang1993] I will review this FLIP later and looking forward
[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636464#comment-17636464
]
yuemeng commented on FLINK-29801:
-
Hi [~ruanhang1993], [~zhuzh]
A further consideration is good, very
[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635341#comment-17635341
]
yuemeng commented on FLINK-29801:
-
[~ruanhang1993] [~zhuzh]
Firstly, thanks a lot for your reply
The
[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626423#comment-17626423
]
yuemeng commented on FLINK-29801:
-
[~danny0405] Can you review this improvement, we need this to report
[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626419#comment-17626419
]
yuemeng commented on FLINK-29801:
-
[~jark] [~rmetzger] Can you review this improvement, because we
yuemeng created FLINK-29801:
---
Summary: OperatorCoordinator need open the way to operate
metricGroup interface
Key: FLINK-29801
URL: https://issues.apache.org/jira/browse/FLINK-29801
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269941#comment-17269941
]
yuemeng commented on FLINK-20935:
-
[~trohrmann], i had updated the pr, can u review it. thanks
> can't
[
https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17268446#comment-17268446
]
yuemeng commented on FLINK-20935:
-
[~trohrmann] ,yes ,JerryTaoTao is myself.i will take a look at your
[
https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264565#comment-17264565
]
yuemeng edited comment on FLINK-20935 at 1/18/21, 2:44 AM:
---
[~trohrmann]
[
https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264565#comment-17264565
]
yuemeng edited comment on FLINK-20935 at 1/14/21, 3:02 AM:
---
[~trohrmann]
[
https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264565#comment-17264565
]
yuemeng commented on FLINK-20935:
-
[~trohrmann] [~fly_in_gis]，yes,this is a good way to fixed this
[
https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263861#comment-17263861
]
yuemeng commented on FLINK-20935:
-
[~fly_in_gis]，yes ,i set fs.default-scheme to hdfs, but create tmp
yuemeng created FLINK-20935:
---
Summary: can't write flink configuration to tmp file and add it to
local resource in yarn session mode
Key: FLINK-20935
URL: https://issues.apache.org/jira/browse/FLINK-20935
[
https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng closed FLINK-14666.
---
Resolution: Implemented
> support multiple catalog in flink table sql
>
[
https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971278#comment-16971278
]
yuemeng commented on FLINK-14666:
-
[~dwysakowicz] I will close the issue because of your new feature in
[
https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970052#comment-16970052
]
yuemeng commented on FLINK-14666:
-
[~dwysakowicz] thanks for your reply
The fully qualified name will
[
https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970052#comment-16970052
]
yuemeng edited comment on FLINK-14666 at 11/8/19 10:40 AM:
---
[~dwysakowicz]
[
https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969951#comment-16969951
]
yuemeng commented on FLINK-14666:
-
[~ykt836] but when you select some field from temporary table to our
[
https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969842#comment-16969842
]
yuemeng edited comment on FLINK-14666 at 11/8/19 5:27 AM:
--
[~ykt836][~jark]
can
[
https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969842#comment-16969842
]
yuemeng commented on FLINK-14666:
-
[~ykt836][~jark]
can you check this issue, thanks
> support multiple
yuemeng created FLINK-14666:
---
Summary: support multiple catalog in flink table sql
Key: FLINK-14666
URL: https://issues.apache.org/jira/browse/FLINK-14666
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng reassigned FLINK-6065:
--
Assignee: yuemeng
> Make TransportClient for ES5 pluggable
> --
>
[
https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708480#comment-16708480
]
yuemeng commented on FLINK-11057:
-
[~twalthr]
thanks for your reply,FLINK-10474 can resolve this issue
[
https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-11057:
Description:
{code:java}
select action , count ( * ) as cnt from user_action where action in ( 'view' ,
[
https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-11057:
Description:
{code:java}
select action , count ( * ) as cnt from user_action where action in ( 'view' ,
yuemeng created FLINK-11057:
---
Summary: where in grammar will cause stream inner join loigcal
Key: FLINK-11057
URL: https://issues.apache.org/jira/browse/FLINK-11057
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng reassigned FLINK-5726:
--
Assignee: yuemeng
> Add the RocketMQ plugin for the Apache Flink
>
[
https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng closed FLINK-9329.
--
Resolution: Invalid
> hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table
> source
[
https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9329:
---
Description:
{code:java}
Examples:
KafkaTableSource source = Kafka010JsonTableSource.builder()
[
https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9329:
---
Description:
{code:java}
KafkaTableSource source = Kafka010JsonTableSource.builder()
yuemeng created FLINK-9329:
--
Summary: hasRowtimeAttribute will throw NPE if user use
setProctimeAttribute for table source
Key: FLINK-9329
URL: https://issues.apache.org/jira/browse/FLINK-9329
Project:
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468219#comment-16468219
]
yuemeng edited comment on FLINK-9201 at 5/9/18 2:12 AM:
[~aljoscha]
thanks for
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16468219#comment-16468219
]
yuemeng commented on FLINK-9201:
[~aljoscha]
thanks for your suggest
i will move the test to
[
https://issues.apache.org/jira/browse/FLINK-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng closed FLINK-7146.
--
Resolution: Duplicate
> FLINK SQLs support DDL
> --
>
> Key: FLINK-7146
>
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460606#comment-16460606
]
yuemeng commented on FLINK-9201:
[~jark]，[~StephanEwen]
can you check this issue？
thanks
> same
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16453759#comment-16453759
]
yuemeng commented on FLINK-9201:
hi [~till.rohrmann]
can you check this issue?
> same merge window will
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16453759#comment-16453759
]
yuemeng edited comment on FLINK-9201 at 4/26/18 9:40 AM:
-
hi [~till.rohrmann]
can
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---
Summary: same merge window will be fired twice if watermark already passed
the new merged window (was: same
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---
Summary: same merge window will be fired twice if watermark already passed
the merge window (was: same merge
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---
Description:
sum with session window,.suppose the session gap is 3 seconds and
allowedlateness is 60 seconds
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---
Description:
sum with session window,.suppose the session gap is 3 seconds and
allowedlateness is 60 seconds
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---
Description:
sum with session window,.suppose the session gap is 3 seconds and
allowedlateness is 60 seconds
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---
Description:
sum with session window,.suppose the session gap is 3 seconds and
allowedlateness is 60 seconds
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---
Description:
sum with session window,.suppose the session gap is 3 seconds and
allowedlateness is 60 seconds
yuemeng created FLINK-9201:
--
Summary: same merge window will fire twice if watermark already
pass the window for merge windows
Key: FLINK-9201
URL: https://issues.apache.org/jira/browse/FLINK-9201
Project:
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---
Summary: same merge window will be fired twice if watermark already pass
the new merged window (was: same
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng reassigned FLINK-7309:
--
Assignee: (was: yuemeng)
> NullPointerException in CodeGenUtils.timePointToInternalCode()
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng reassigned FLINK-7309:
--
Assignee: yuemeng (was: Sihua Zhou)
> NullPointerException in CodeGenUtils.timePointToInternalCode()
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng reassigned FLINK-7309:
--
Assignee: Sihua Zhou
> NullPointerException in CodeGenUtils.timePointToInternalCode() generated code
>
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112117#comment-16112117
]
yuemeng commented on FLINK-7076:
[~till.rohrmann]
To support dynamic scaling,for my understand. we need to
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng reassigned FLINK-7076:
--
Assignee: yuemeng
> Implement container release to support dynamic scaling
>
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089346#comment-16089346
]
yuemeng commented on FLINK-7151:
[~fhueske]
can you assgin this issue to me ,i want to implement this for
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16083845#comment-16083845
]
yuemeng commented on FLINK-7151:
[~jark]
yes,extend the ExternalCatalog to support register external
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16083380#comment-16083380
]
yuemeng commented on FLINK-7151:
[~fhueske]
thanks for your reply.
I will split this issue with two
[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng closed FLINK-7145.
--
Resolution: Duplicate
> Flink SQL API should support multiple parameters for UserDefinedAggFunction
>
[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16082075#comment-16082075
]
yuemeng commented on FLINK-7145:
[~fhueske]
can you tell me where i can run follow sql
{code}
SELECT
[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16082016#comment-16082016
]
yuemeng commented on FLINK-7145:
[~jark]
TopN with different accumulate(...),there are some question:
[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16082016#comment-16082016
]
yuemeng edited comment on FLINK-7145 at 7/11/17 10:34 AM:
--
[~jark]
[~fhueske]
yuemeng created FLINK-7151:
--
Summary: FLINK SQL support create temporary function and table
Key: FLINK-7151
URL: https://issues.apache.org/jira/browse/FLINK-7151
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16082009#comment-16082009
]
yuemeng commented on FLINK-7148:
[~fhueske]
thanks ,i will do that.
> Flink SQL API support DDL
>
[
https://issues.apache.org/jira/browse/FLINK-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081965#comment-16081965
]
yuemeng commented on FLINK-7148:
[~jark]
[~fhueske]
this is duplicate with FLINK-6962,i wil close this
[
https://issues.apache.org/jira/browse/FLINK-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng closed FLINK-7148.
--
Resolution: Duplicate
> Flink SQL API support DDL
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081965#comment-16081965
]
yuemeng edited comment on FLINK-7148 at 7/11/17 9:29 AM:
-
[~jark]
[~fhueske]
this
[
https://issues.apache.org/jira/browse/FLINK-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081862#comment-16081862
]
yuemeng commented on FLINK-7148:
[~fhueske]
can you check this feature?
If so, can you assign this issue
[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081877#comment-16081877
]
yuemeng commented on FLINK-7145:
[~fhueske]
ok ,thanks for your reply,
I see, I will close this iusse .
[
https://issues.apache.org/jira/browse/FLINK-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-7148:
---
Issue Type: New Feature (was: Bug)
> Flink SQL API support DDL
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081847#comment-16081847
]
yuemeng commented on FLINK-7145:
[~fhueske]
thanks a lot for reply.
some days ago, when i try to make
[
https://issues.apache.org/jira/browse/FLINK-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-7148:
---
Priority: Critical (was: Major)
> Flink SQL API support DDL
> --
>
>
yuemeng created FLINK-7148:
--
Summary: Flink SQL API support DDL
Key: FLINK-7148
URL: https://issues.apache.org/jira/browse/FLINK-7148
Project: Flink
Issue Type: Bug
Components: Table API
[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081847#comment-16081847
]
yuemeng edited comment on FLINK-7145 at 7/11/17 8:20 AM:
-
[~fhueske]
thanks a lot
yuemeng created FLINK-7146:
--
Summary: FLINK SQLs support DDL
Key: FLINK-7146
URL: https://issues.apache.org/jira/browse/FLINK-7146
Project: Flink
Issue Type: Sub-task
Components: Table
yuemeng created FLINK-7145:
--
Summary: Flink SQL API should support multiple parameters for
UserDefinedAggFunction
Key: FLINK-7145
URL: https://issues.apache.org/jira/browse/FLINK-7145
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-5324:
---
Attachment: 0001-FLINK-5324-yarn-JVM-Opitons-will-work-for-both-YarnA.patch
> JVM Opitons will be work both
[
https://issues.apache.org/jira/browse/FLINK-5324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-5324:
---
Description:
YarnApplicationMasterRunner and YarnTaskManager both use follow code to get jvm
options
{code}
yuemeng created FLINK-5324:
--
Summary: JVM Opitons will be work both for
YarnApplicationMasterRunner and YarnTaskManager with yarn mode
Key: FLINK-5324
URL: https://issues.apache.org/jira/browse/FLINK-5324
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
*class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Attachment: 0001-class-KafkaTableSource-should-be-public.patch
> class KafkaTableSource should be public just
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
*** class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is
yuemeng created FLINK-4879:
--
Summary: class KafkaTableSource should be public just like
KafkaTableSink
Key: FLINK-4879
URL: https://issues.apache.org/jira/browse/FLINK-4879
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4827:
---
Attachment: 0001-The-scala-example-of-SQL-on-Streaming-Tables-with-wr.patch
> The scala example of SQL on
[
https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4827:
---
Summary: The scala example of SQL on Streaming Tables with wrong variable
name in flink document (was: The
[
https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4827:
---
Description:
val env = StreamExecutionEnvironment.getExecutionEnvironment
val tEnv =
[
https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4827:
---
Description:
val env = StreamExecutionEnvironment.getExecutionEnvironment
val tEnv =
[
https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4827:
---
Summary: The code example use scala of SQL on Streaming Tables with wrong
variable name in flink document
[
https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4827:
---
Summary: The example use scala of SQL on Streaming Tables with wrong
variable name (was: Sql on streaming
[
https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4827:
---
Description:
val env = StreamExecutionEnvironment.getExecutionEnvironment
val tEnv =
yuemeng created FLINK-4827:
--
Summary: Sql on streaming example use scala with wrong variable
name
Key: FLINK-4827
URL: https://issues.apache.org/jira/browse/FLINK-4827
Project: Flink
Issue Type:
91 matches
Mail list logo
