godfrey he created FLINK-20858:
--
Summary: Port StreamExecPythonGroupWindowAggregate and
BatchExecPythonGroupWindowAggregate to Java
Key: FLINK-20858
URL: https://issues.apache.org/jira/browse/FLINK-20858
godfrey he created FLINK-20856:
--
Summary: Separate the implementation of stream window aggregate
nodes
Key: FLINK-20856
URL: https://issues.apache.org/jira/browse/FLINK-20856
Project: Flink
godfrey he created FLINK-20821:
--
Summary: `select row(map[1,2],'ab')` parses failed
Key: FLINK-20821
URL: https://issues.apache.org/jira/browse/FLINK-20821
Project: Flink
Issue Type: Bug
godfrey he created FLINK-20751:
--
Summary: Port batch python aggregate nodes to Java
Key: FLINK-20751
URL: https://issues.apache.org/jira/browse/FLINK-20751
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20750:
--
Summary: Port stream python aggregate nodes to Java
Key: FLINK-20750
URL: https://issues.apache.org/jira/browse/FLINK-20750
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20738:
--
Summary: Separate the implementation of batch aggregate nodes
Key: FLINK-20738
URL: https://issues.apache.org/jira/browse/FLINK-20738
Project: Flink
Issue Type
godfrey he created FLINK-20737:
--
Summary: Separate the implementation of stream aggregate nodes
Key: FLINK-20737
URL: https://issues.apache.org/jira/browse/FLINK-20737
Project: Flink
Issue
godfrey he created FLINK-20719:
--
Summary: Change BatchExecNode & StreamExecNode to interface and
make each node extended from ExecNodeBase directly
Key: FLINK-20719
URL: https://issues.apache.org/jira/browse/F
godfrey he created FLINK-20709:
--
Summary: Separate the implementation of StreamExecMiniBatchAssigner
Key: FLINK-20709
URL: https://issues.apache.org/jira/browse/FLINK-20709
Project: Flink
Issue
godfrey he created FLINK-20708:
--
Summary: Separate the implementation of StreamExecDropUpdateBefore
Key: FLINK-20708
URL: https://issues.apache.org/jira/browse/FLINK-20708
Project: Flink
Issue
godfrey he created FLINK-20707:
--
Summary: Separate the implementation of BatchExecExpand and
StreamExecExpand
Key: FLINK-20707
URL: https://issues.apache.org/jira/browse/FLINK-20707
Project: Flink
godfrey he created FLINK-20706:
--
Summary: Separate the implementation of BatchExecUnion and
StreamExecUnion
Key: FLINK-20706
URL: https://issues.apache.org/jira/browse/FLINK-20706
Project: Flink
godfrey he created FLINK-20705:
--
Summary: Separate the implementation of BatchExecValues and
StreamExecValues
Key: FLINK-20705
URL: https://issues.apache.org/jira/browse/FLINK-20705
Project: Flink
godfrey he created FLINK-20693:
--
Summary: Port BatchExecPythonCorrelate and
StreamExecPythonCorrelate to Java
Key: FLINK-20693
URL: https://issues.apache.org/jira/browse/FLINK-20693
Project: Flink
godfrey he created FLINK-20690:
--
Summary: Separate the implementation of BatchExecCorrelate and
StreamExecCorrelate
Key: FLINK-20690
URL: https://issues.apache.org/jira/browse/FLINK-20690
Project: Flink
godfrey he created FLINK-20673:
--
Summary: ExecNode#getOutputType method should return LogicalType
instead of RowType
Key: FLINK-20673
URL: https://issues.apache.org/jira/browse/FLINK-20673
Project
godfrey he created FLINK-20668:
--
Summary: Introduce translateToExecNode method for FlinkPhysicalRel
Key: FLINK-20668
URL: https://issues.apache.org/jira/browse/FLINK-20668
Project: Flink
Issue
godfrey he created FLINK-20623:
--
Summary: Separate the implementation of StreamExecWatermarkAssigner
Key: FLINK-20623
URL: https://issues.apache.org/jira/browse/FLINK-20623
Project: Flink
Issue
godfrey he created FLINK-20622:
--
Summary: Separate the implementation of
StreamExecChangelogNormalize
Key: FLINK-20622
URL: https://issues.apache.org/jira/browse/FLINK-20622
Project: Flink
godfrey he created FLINK-20620:
--
Summary: Port StreamExecPythonCalc to java
Key: FLINK-20620
URL: https://issues.apache.org/jira/browse/FLINK-20620
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20610:
--
Summary: Separate the implementation of BatchExecCalc and
StreamExecCalc
Key: FLINK-20610
URL: https://issues.apache.org/jira/browse/FLINK-20610
Project: Flink
godfrey he created FLINK-20609:
--
Summary: Separate the implementation of BatchExecDataStreamScan
and StreamExecDataStreamScan
Key: FLINK-20609
URL: https://issues.apache.org/jira/browse/FLINK-20609
godfrey he created FLINK-20608:
--
Summary: Separate the implementation of
BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan
Key: FLINK-20608
URL: https://issues.apache.org/jira/browse/FLINK-20608
godfrey he created FLINK-20516:
--
Summary: Separate the implementation of BatchExecTableSourceScan
and StreamExecTableSourceScan
Key: FLINK-20516
URL: https://issues.apache.org/jira/browse/FLINK-20516
godfrey he created FLINK-20515:
--
Summary: Separate the implementation of BatchExecMultipleInput and
StreamExecMultipleInput
Key: FLINK-20515
URL: https://issues.apache.org/jira/browse/FLINK-20515
godfrey he created FLINK-20513:
--
Summary: Separate the implementation of BatchExecExchange and
StreamExecExchange
Key: FLINK-20513
URL: https://issues.apache.org/jira/browse/FLINK-20513
Project: Flink
godfrey he created FLINK-20512:
--
Summary: Introduce getDescription, getOutputType, replaceInputEdge
methods for ExecNode
Key: FLINK-20512
URL: https://issues.apache.org/jira/browse/FLINK-20512
Project
godfrey he created FLINK-20511:
--
Summary: Deprecate the classes in scala `nodes.exec` package
Key: FLINK-20511
URL: https://issues.apache.org/jira/browse/FLINK-20511
Project: Flink
Issue Type
godfrey he created FLINK-20509:
--
Summary: Refactor verifyPlan method in TableTestBase
Key: FLINK-20509
URL: https://issues.apache.org/jira/browse/FLINK-20509
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20490:
--
Summary: Don't share inputs between FlinkPhysicalRel and ExecNode
Key: FLINK-20490
URL: https://issues.apache.org/jira/browse/FLINK-20490
Project: Flink
Issue
godfrey he created FLINK-20478:
--
Summary: Show "Optimized Execution Plan" instead of "Physical
Execution Plan" in explain result
Key: FLINK-20478
URL: https://issues.apache.org/jir
godfrey he created FLINK-20437:
--
Summary: Port ExecNode to Java
Key: FLINK-20437
URL: https://issues.apache.org/jira/browse/FLINK-20437
Project: Flink
Issue Type: Sub-task
Reporter
godfrey he created FLINK-20436:
--
Summary: Simplify type parameter of ExecNod
Key: FLINK-20436
URL: https://issues.apache.org/jira/browse/FLINK-20436
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20435:
--
Summary: Refactor ExecNode
Key: FLINK-20435
URL: https://issues.apache.org/jira/browse/FLINK-20435
Project: Flink
Issue Type: Improvement
Reporter
godfrey he created FLINK-20322:
--
Summary: Rename table.optimizer.union-all-as-breakpoint-disabled
to table.optimizer.union-all-as-breakpoint.enabled
Key: FLINK-20322
URL: https://issues.apache.org/jira/browse/FLINK
godfrey he created FLINK-20293:
--
Summary: Remove the useless constructor of
ContinuousFileMonitoringFunction
Key: FLINK-20293
URL: https://issues.apache.org/jira/browse/FLINK-20293
Project: Flink
godfrey he created FLINK-20255:
--
Summary: Nested decorrelate failed
Key: FLINK-20255
URL: https://issues.apache.org/jira/browse/FLINK-20255
Project: Flink
Issue Type: Bug
Components
godfrey he created FLINK-20070:
--
Summary: NPE in
SourceCoordinatorProviderTest.testCheckpointAndReset
Key: FLINK-20070
URL: https://issues.apache.org/jira/browse/FLINK-20070
Project: Flink
Congratulations! Congxian
Best,
Godfrey
Fabian Hueske 于2020年11月2日周一 下午7:00写道：
> Congrats Congxian!
>
> Cheers, Fabian
>
> Am Mo., 2. Nov. 2020 um 10:33 Uhr schrieb Yang Wang >:
>
> > Congratulations Congxian!
> >
> > Best,
> > Yang
> >
> > Zhu Zhu 于2020年11月2日周一 下午5:14写道：
> >
> > > Congrats
godfrey he created FLINK-19925:
--
Summary: Errors$NativeIoException: readAddress(..) failed:
Connection reset by peer
Key: FLINK-19925
URL: https://issues.apache.org/jira/browse/FLINK-19925
Project
godfrey he created FLINK-19822:
--
Summary: remove redundant shuffle for stream
Key: FLINK-19822
URL: https://issues.apache.org/jira/browse/FLINK-19822
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-19737:
--
Summary: Introduce TableOperatorWrapperGenerator to translate
transformation DAG in a multiple-input node to TableOperatorWrapper DAG
Key: FLINK-19737
URL: https://issues.apache.org
+1
Jingsong Li 于2020年10月19日周一 上午10:54写道：
> +1
>
> On Fri, Oct 16, 2020 at 2:33 PM Leonard Xu wrote:
>
> > +1
> >
> > Best,
> > Leonard
> >
> > > 在 2020年10月16日，11:01，Jark Wu 写道：
> > >
> > > +1
> > >
> > > On Fri, 16 Oct 2020 at 10:27, admin <17626017...@163.com> wrote:
> > >
> > >> +1
> > >>
>
Congratulations, Zhu
Godfrey,
Best
刘 芃成 于2020年10月10日周六 下午1:03写道：
> Congratulations, Zhu!
>
> Best,
> Pengcheng
>
> 在 2020/10/10 上午11:14，“Kurt Young” 写入:
>
> Congratulations, Zhu Zhu!
>
> Best,
> Kurt
>
>
> On Sat, Oct 10, 2020 at 11:03 AM Yang Wang
> wrote:
>
> >
Hi devs,
I would like to start the discussion about supporting multiple input for
blink planner.
As FLIP-92[1] introduces multiple-input stream operator, we can merge the
operators connected by forward shuffle into multiple input operator. So
that the network shuffle can be changed to local
gt;
>>
>>
>> --Original Mail --
>> Sender:Dawid Wysakowicz
>> Send Date:Thu Sep 17 14:45:55 2020
>> Recipients:Flink Dev , 贺小令
>> Subject:Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He
>> Congratulations!
>>
>> On 16/09/20
Congratulations!
Regards,
Godfrey
Yun Tang 于2020年9月17日周四 下午2:22写道：
> Thanks for all your kind welcome and very glad to be one of the
> committers of Flink community.
>
> Best
> Yun Tang
>
>
> From: Congxian Qiu
> Sent: Wednesday, September 16, 2020 13:10
>
Congratulations!
Best,
Godfrey
Igal Shilman 于2020年9月16日周三 下午4:35写道：
> Thank you all very much for your kind welcome :-)
>
> Thanks,
> Igal.
>
> On Wed, Sep 16, 2020 at 8:50 AM Kostas Kloudas wrote:
>
> > Congratulations Igal and welcome!
> >
> > Kostas
> >
> > On Wed, Sep 16, 2020 at 6:37 AM
Congratulations!
Best,
Godfrey
Guowei Ma 于2020年9月16日周三 下午12:38写道：
> Congratulations :)
>
> Best,
> Guowei
>
>
> On Tue, Sep 15, 2020 at 6:14 PM Matthias Pohl
> wrote:
>
> > Congrats!
> >
> > Best,
> > Matthias
> >
> > On Tue, Sep 15, 2020 at 9:26 AM Dawid Wysakowicz >
> > wrote:
> >
> > >
Congrats David!
Best,
Godfrey
Danny Chan 于2020年8月13日周四 上午8:57写道：
> Congratulations, David!
>
> jincheng sun 于2020年8月13日 周四上午8:54写道：
>
> > Congrats and welcome David!
> >
> > Best,
> > Jincheng
> >
> >
> > David Anderson 于2020年8月13日周四 上午2:51写道：
> >
> > > Thank you one and all for the warm
godfrey he created FLINK-18853:
--
Summary: Supports properties from flink-conf.yaml for SET command
in sql client
Key: FLINK-18853
URL: https://issues.apache.org/jira/browse/FLINK-18853
Project: Flink
+1 (non-binding) from my side
Best,
Godfrey
Leonard Xu 于2020年8月4日周二 上午11:07写道：
> Hi all,
>
> I would like to start the vote for FLIP-132 [1], which has been discussed
> and
> reached a consensus in the discussion thread [2].
>
> The vote will be open until 7th August (72h), unless there is an
Hi,
u...@flink.apache.org is used for question discussions,
dev@flink.apache.org is used for development related discussions.
Regarding the exception, that indicates flink-table-blink_xx.jar is not in
the classpath,
please check it.
Best,
Godfrey
魏烽 于2020年8月5日周三 下午5:15写道：
> Hi
>
>I have
Thanks Lennard for driving this FLIP.
Looks good to me.
Best,
Godfrey
Jark Wu 于2020年8月3日周一 下午12:04写道：
> Thanks Leonard for the great FLIP. I think it is in very good shape.
> +1 to start a vote.
>
> Best,
> Jark
>
> On Fri, 31 Jul 2020 at 17:56, Fabian Hueske wrote:
>
> > Hi Leonard,
> >
> >
godfrey he created FLINK-18791:
--
Summary: Simplify the logic of SqlCommandParser and CliClient
Key: FLINK-18791
URL: https://issues.apache.org/jira/browse/FLINK-18791
Project: Flink
Issue Type
godfrey he created FLINK-18789:
--
Summary: Use TableEnvironment#executeSql to execute insert
statement in sql client
Key: FLINK-18789
URL: https://issues.apache.org/jira/browse/FLINK-18789
Project: Flink
godfrey he created FLINK-18788:
--
Summary: Refactor sql-client based the proposed interfaces of
FLIP-84
Key: FLINK-18788
URL: https://issues.apache.org/jira/browse/FLINK-18788
Project: Flink
Thanks Jingsong for bringing up this discussion,
and thanks Kurt for the detailed thoughts.
First of all, I also think it's a very useful feature to expose more
ability for table source.
1) If we want to support [1], it's seem that SupportsParallelismReport
does not meet the requirement: If
t suitable for
> executing sql files
>
> godfrey he 于2020年7月29日周三 上午9:56写道：
>
>> hi Jun,
>>
>> Currently, sql client has supported -u option, just like:
>> ./bin/sql-client.sh embedded -u "insert_statement".
>>
>> There is already a JIRA [
hi Jun,
Currently, sql client has supported -u option, just like:
./bin/sql-client.sh embedded -u "insert_statement".
There is already a JIRA [1] that wants to support -f option
[1] https://issues.apache.org/jira/browse/FLINK-12828
Best,
Godfrey
Jun Zhang 于2020年7月29日周三 上午9:22写道：
> I want
godfrey he created FLINK-18731:
--
Summary: The monotonicity of UNIX_TIMESTAMP function is not correct
Key: FLINK-18731
URL: https://issues.apache.org/jira/browse/FLINK-18731
Project: Flink
Issue
Hi Seth,
Thanks for bringing up this topic.
I think the second approach is a more generic solution.
Other connectors can also benefit from this.
We also keep the flexibility for generating random timestamps for some
scenarios.
Best,
Godfrey
Seth Wiesman 于2020年7月24日周五 下午11:30写道：
> Hi everyone,
godfrey he created FLINK-18717:
--
Summary: reuse MiniCluster in table integration test class ?
Key: FLINK-18717
URL: https://issues.apache.org/jira/browse/FLINK-18717
Project: Flink
Issue Type
, 21:53 Yang Wang wrote:
> >
> > > Congratulations Piotr!
> > >
> > >
> > > Best,
> > > Yang
> > >
> > > Dan Zou 于2020年7月8日周三 下午10:36写道：
> > >
> > > > Congratulations!
> > > >
> > > > Best,
> > > > Dan Zou
> > > >
> > > > > 2020年7月8日 下午5:25，godfrey he 写道：
> > > > >
> > > > > Congratulations
> > > >
> > > >
> > >
> >
>
godfrey he created FLINK-18651:
--
Summary: implicitly cast the time attribute to regular TIMESTAMP
type in regular join
Key: FLINK-18651
URL: https://issues.apache.org/jira/browse/FLINK-18651
Project
godfrey he created FLINK-18621:
--
Summary: Simplify the methods of Executor interface in sql client
Key: FLINK-18621
URL: https://issues.apache.org/jira/browse/FLINK-18621
Project: Flink
Issue
godfrey he created FLINK-18550:
--
Summary: use TableResult#collect to get select result for sql
client
Key: FLINK-18550
URL: https://issues.apache.org/jira/browse/FLINK-18550
Project: Flink
+1 for a quick release to fix those blocker/critical bugs.
Best,
Godfrey
Congxian Qiu 于2020年7月10日周五 上午10:30写道：
> +1 for a quick bug fix release for 1.11
>
> Best,
> Congxian
>
>
> Yu Li 于2020年7月10日周五 上午9:37写道：
>
> > +1, thanks Jark for bringing this up and Dian for volunteering as our
> >
Congratulations Piotr!
Best,
Godfrey
Yun Tang 于2020年7月8日周三 下午5:22写道：
> Congratulations, Piotr!
>
> Best
> Yun Tang
>
> From: Danny Chan
> Sent: Wednesday, July 8, 2020 15:46
> To: dev@flink.apache.org
> Subject: Re: [ANNOUNCE] New PMC member: Piotr Nowojski
>
Congratulations!
Thanks Zhijiang and Piotr for the great work, and thanks everyone for their
contribution!
Best,
Godfrey
Benchao Li 于2020年7月8日周三 下午12:39写道：
> Congratulations! Thanks Zhijiang & Piotr for the great work as release
> managers.
>
> Rui Li 于2020年7月8日周三 上午11:38写道：
>
>>
godfrey he created FLINK-18399:
--
Summary: TableResult#print can not print the result of unbounded
stream query
Key: FLINK-18399
URL: https://issues.apache.org/jira/browse/FLINK-18399
Project: Flink
Hi Fabian, Jack, Timo
Thanks for the suggestions.
Regarding the SQL syntax, BEGIN is more popular than START. I'm fine with
the syntax Timo suggested.
Regarding whether this should be implemented in Flink's SQL core. I think
there are three things to consider:
First one, do we need to unify
Congratulations Yu!
Rui Li 于2020年6月17日周三 下午1:15写道：
> Congratulations!
>
> On Wed, Jun 17, 2020 at 11:58 AM Xingbo Huang wrote:
>
> > Congratulations Yu! Well deserved
> >
> > Best,
> > Xingbo
> >
> > Peter Huang 于2020年6月17日周三 上午11:51写道：
> >
> > > Congratulations Yu!
> > >
> > > On Tue, Jun
godfrey he created FLINK-18337:
--
Summary: Introduce TableResult#await method to wait data ready
Key: FLINK-18337
URL: https://issues.apache.org/jira/browse/FLINK-18337
Project: Flink
Issue Type
Congratulations, Benchao!
Best,
Godfrey
Yun Gao 于2020年6月11日周四 上午8:57写道：
> Congratulations, Benchao!
>
> Best,
> Yun
>
> --
> Sender:Danny Chan
> Date:2020/06/10 20:01:01
> Recipient:
> Theme:Re: [ANNOUNCE] New Flink Committer:
godfrey he created FLINK-18180:
--
Summary: unify the logic of time attribute derivation for both
batch and streaming
Key: FLINK-18180
URL: https://issues.apache.org/jira/browse/FLINK-18180
Project: Flink
godfrey he created FLINK-18061:
--
Summary: TableResult#collect should return closeable iterator to
avoid resource leak
Key: FLINK-18061
URL: https://issues.apache.org/jira/browse/FLINK-18061
Project
godfrey he created FLINK-18059:
--
Summary: Can not execute create/drop catalog statement in sql
client
Key: FLINK-18059
URL: https://issues.apache.org/jira/browse/FLINK-18059
Project: Flink
godfrey he created FLINK-18055:
--
Summary: Catalog does not exist in SQL Client
Key: FLINK-18055
URL: https://issues.apache.org/jira/browse/FLINK-18055
Project: Flink
Issue Type: Bug
godfrey he created FLINK-17996:
--
Summary: NEP in
CatalogTableStatisticsConverter.convertToColumnStats method
Key: FLINK-17996
URL: https://issues.apache.org/jira/browse/FLINK-17996
Project: Flink
godfrey he created FLINK-17774:
--
Summary: Support all kinds of changes for select result
Key: FLINK-17774
URL: https://issues.apache.org/jira/browse/FLINK-17774
Project: Flink
Issue Type: Sub
ient
> for users.
>
> Thanks, Fabian
>
> Am Do., 7. Mai 2020 um 09:31 Uhr schrieb godfrey he :
>
>> Hi fabian,
>> Thanks for you suggestions.
>>
>> Agree with you that `UNQ(f2, f3)` is more clear.
>>
>> A table can have only ONE primary key,
&g
godfrey he created FLINK-17753:
--
Summary: watermark defined in ddl does not work in Table api
Key: FLINK-17753
URL: https://issues.apache.org/jira/browse/FLINK-17753
Project: Flink
Issue Type
godfrey he created FLINK-17751:
--
Summary: proctime defined in ddl can't work with over window in
Table api
Key: FLINK-17751
URL: https://issues.apache.org/jira/browse/FLINK-17751
Project: Flink
godfrey he created FLINK-17728:
--
Summary: use sql parser to parse a statement in sql client
Key: FLINK-17728
URL: https://issues.apache.org/jira/browse/FLINK-17728
Project: Flink
Issue Type
| TIMESTAMP(3)| false | (NULL) | (NULL)
> | f4.nested.rowtime - INTERVAL '3' SECOND |
>
> ++---+---+---+-+-------+
>
> Thanks,
> Fabian
>
> Am Mi., 6. Mai 2020 um 17:51 Uhr schrieb godfrey he :
>
>> Hi @fhue...@gmail.com @Tim
LL) | (NULL)| f4 - INTERVAL '3' SECOND |
++--+---+---+---+--+
WDYT ?
Best,
Godfrey
godfrey he 于2020年4月30日周四 下午11:57写道：
> Hi Fabian,
>
&g
s that it is not field that can be queried but meta
> > information on an existing field.
> > For the user it is important to know that a certain field has a
> watermark.
> > Otherwise, certain queries cannot be correctly specified.
> > Also there might be support for multiple
| NO | | NULL| |
> > | age | int | YES | | NULL| |
> > +---+--+--+-+-+---+
> > 3 rows in set (0.01 sec)
> >
> > Here, PRIMARY KEY is marked in the Key column of the id field.
> > We could do the
nce/pages/viewpage.action?pageId=134745878
[2]
https://github.com/apache/flink/blob/master/flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java
[3] https://github.com/apache/flink/pull/11892
godfrey he 于2020年4月6日周一 下午10:38写道：
> Hi Timo,
>
> S
NT | (NULL) |
| f1 |INT | a + 1 |
| f2 |TIMESTAMP(3) | (NULL) |
| WATERMARK | (NULL) | c AS now() |
+-+-+-+
FLINK-17112
godfrey he 于2020年4月6日周一 下午10:38写道：
> Hi Timo,
>
> Sorry f
godfrey he created FLINK-17405:
--
Summary: add test cases for cancel job in SQL client
Key: FLINK-17405
URL: https://issues.apache.org/jira/browse/FLINK-17405
Project: Flink
Issue Type
godfrey he created FLINK-17399:
--
Summary: CsvTableSink should also extend from OverwritableTableSink
Key: FLINK-17399
URL: https://issues.apache.org/jira/browse/FLINK-17399
Project: Flink
Issue
godfrey he created FLINK-17383:
--
Summary: flink legacy planner should not use CollectionEnvironment
any more
Key: FLINK-17383
URL: https://issues.apache.org/jira/browse/FLINK-17383
Project: Flink
godfrey he created FLINK-17267:
--
Summary: supports EXPLAIN statement in TableEnvironment#executeSql
and Table#explain api
Key: FLINK-17267
URL: https://issues.apache.org/jira/browse/FLINK-17267
Project
godfrey he created FLINK-17252:
--
Summary: TableEnvironment#executeSql supports SELECT statement and
Table introduces execute method
Key: FLINK-17252
URL: https://issues.apache.org/jira/browse/FLINK-17252
godfrey he created FLINK-17251:
--
Summary: TableEnvironment#executeSql supports INSERT statement
Key: FLINK-17251
URL: https://issues.apache.org/jira/browse/FLINK-17251
Project: Flink
Issue Type
Congratulations, Hequn!
Best,
Godfrey
Leonard Xu 于2020年4月17日周五 下午4:30写道：
> Congratulations!
>
> Best,
> Leonard Xu
> > 在 2020年4月17日，15:46，Benchao Li 写道：
> >
> > Congratulations Hequn!
> >
> > Stephan Ewen 于2020年4月17日周五 下午3:42写道：
> >
> >> Congrats!
> >>
> >> On Fri, Apr 17, 2020 at 9:40 AM
Thanks a lot for driving this, Yu!
Some users are already asking "where to download release-1.10.1?"
Looking forward to the rc.
Best,
Godfrey
Hequn Cheng 于2020年4月16日周四 下午12:45写道：
> Thanks a lot for your great work Yu! Looking forward to the RC.
>
> Best, Hequn
>
> On Thu, Apr 16, 2020 at 10:35
Big +1.
This will improve user experience (special for Flink new users).
We answered so many questions about "class not found".
Best,
Godfrey
Dian Fu 于2020年4月15日周三 下午4:30写道：
> +1 to this proposal.
>
> Missing connector jars is also a big problem for PyFlink users. Currently,
> after a Python
201 - 300 of 453 matches
Mail list logo
