Hi, Ipengdream. I will drive this work.
We will support this functionality via hints,
because "distribute by" is not in the sql standard.
But it will be supported in hive dialect.
I will post the FLIP doc recently.
Best,
Godfrey
Jark Wu 于2022年5月9日周一 16:03写道：
>
> We will start a FLIP
k it's a problem. On the contrary, maintaining a separate
> > > repo
> > > > for Gateway will take a lot of
> > > > extra community efforts, e.g., individual CICD, docs, releases.
> > > >
> > > >
> > > > > b) if you wan
Congratulations, Yang!
Best,
Godfrey
Yangze Guo 于2022年5月6日周五 10:17写道：
>
> Congratulations Yang!
>
> Best,
> Yangze Guo
>
> On Fri, May 6, 2022 at 10:11 AM Forward Xu wrote:
> >
> > Congratulations, Yang!
> >
> >
> > Best,
> >
> > Forward
> >
> > Jingsong Li 于2022年5月6日周五 10:07写道：
> >
> > >
Hi Shengkai.
Thanks for driving the proposal, it's been silent too long.
I have a few questions:
about the Architecture
> The architecture of the Gateway is in the following graph.
Is the TableEnvironment shared for all sessions ?
about the REST Endpoint
> /v1/sessions
Are both local file and
Congratulations~
Thanks Yun, Till and Joe for driving this release
and everyone who made this release happen.
Best,
Godfrey
Becket Qin 于2022年5月5日周四 17:39写道：
>
> Hooray! Thanks Yun, Till and Joe for driving the release!
>
> Cheers,
>
> JIangjie (Becket) Qin
>
> On Thu, May 5, 2022 at 5:20 PM
agree here. Many changes are protected by keeping deprecated
> > methods/constructors/classes around for years. And many refactoring are
> > nice also for the Flink community. E.g. easier optimizer rule definition.
> >
> > IMHO the core problem is rather that we don't update C
Hi Konstantin & Chesnay,
Thanks for driving this discussion, I am willing to volunteer as the
release manager for 1.16.
Best,
Godfrey
Konstantin Knauf 于2022年4月26日周二 18:23写道：
>
> Hi everyone,
>
> With Flink 1.15 about to be released, the community has started planning &
> developing features
l. The community should have permission to
> deploy under the groupId.
>
> Best,
> Jark
>
>
> On Sun, 24 Apr 2022 at 16:14, godfrey he wrote:
>
> > Hi, Jing
> > Thanks for sharing the Calcite experiences.
> > About Calcite version upgrading, we should try
causing some unexpected problems.
>
> Thank @Godfrey for driving this discussion in a big scope.
> I think it's a good chance to review these problems and find a solution.
>
> Best,
> Jing Zhang
>
> godfrey he mailto:godfre...@gmail.com>> 于2022年4月22日周五
> 21:40写道：
>
; Is Calcite not creating bugfix releases?
>
> On 22/04/2022 12:26, godfrey he wrote:
> > Thanks for the feedback, guys!
> >
> > For Jingsong's feedback:
> >> ## Do we have the plan to upgrade calcite to 1.31?
> > I think we will upgrade Calcite to 1.31 only
te that we
> > want
> > > to depend on.
> > >
> > > Thank you~
> > >
> > > Xintong Song
> > >
> > >
> > >
> > > On Fri, Apr 22, 2022 at 4:07 PM Chesnay Schepler
> > > wrote:
> > >
> > >
Dear devs,
I would like to open a discussion on the fact that currently many
Flink SQL function
development relies on Calcite releases, which seriously blocks some
Flink SQL's features release.
Therefore, I would like to discuss whether it is possible to solve this problem
by creating Flink's
t; FLIP, we will move the execution to table environment, so here is no public
> api change. Moreover, I have updated the description in Core Code Design
> section.
>
> > -原始邮件-
> > 发件人: "godfrey he"
> > 发送时间: 2022-04-22 12:26:44 (星期五)
> >
hi Ron,
I don't see any section mentioned `delete jar`, could you update it?
Best,
Godfrey
Jing Zhang 于2022年4月21日周四 17:57写道：
>
> Ron,
> +1 (binding)
>
> Thanks for driving this FLIP.
>
> Best,
> Jing Zhang
>
> Jark Wu 于2022年4月21日周四 11:31写道：
>
> > Thanks for driving this work @Ron,
> >
> > +1
godfrey he created FLINK-27272:
--
Summary: The plan for query with local sort is incorrect if
adaptive batch scheduler is enabled
Key: FLINK-27272
URL: https://issues.apache.org/jira/browse/FLINK-27272
godfrey he created FLINK-26756:
--
Summary: Failed to deserialize for match recognize
Key: FLINK-26756
URL: https://issues.apache.org/jira/browse/FLINK-26756
Project: Flink
Issue Type: Bug
Congratulations, Yuan!
Best,
Godfrey
Lijie Wang 于2022年3月15日周二 09:18写道：
>
> Congratulations, Yuan!
>
> Best,
> Lijie
>
> Benchao Li 于2022年3月15日周二 08:18写道：
>
> > Congratulations, Yuan!
> >
> > Yun Gao 于2022年3月15日周二 01:37写道：
> >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Yun Gao
> > >
Congratulations!
Best,
Godfrey
Lincoln Lee 于2022年2月18日周五 14:05写道：
>
> Congratulations Feng and Zhipeng!
>
> Best,
> Lincoln Lee
>
>
> Yuepeng Pan 于2022年2月18日周五 12:45写道：
>
> >
> >
> >
> > Congratulations!
> >
> >
> > Best,
> > Yuepeng Pan
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
Congratulations!
Best,
Godfrey
Lincoln Lee 于2022年2月18日周五 14:07写道：
>
> Congratulations!
>
> Best,
> Lincoln Lee
>
>
> Jingsong Li 于2022年2月18日周五 12:42写道：
>
> > Congratulations!
> >
> > Best,
> > Jingsong
> >
> > On Thu, Feb 17, 2022 at 8:08 PM Jinzhong Li
> > wrote:
> > >
> > > Congratulations!
godfrey he created FLINK-26167:
--
Summary: Explicitly set the partitioner for the sql operators
whose shuffle and sort are removed
Key: FLINK-26167
URL: https://issues.apache.org/jira/browse/FLINK-26167
+1 (binding)
Thanks Jing!
Best,
Godfrey
zst...@163.com 于2022年1月24日周一 20:03写道：
>
> +1 non-binging!
> Thanks Jing for driving this!
> Best,
> Yuan
>
>
>
>
> At 2022-01-24 15:32:18, "wenlong.lwl" wrote:
> >+1 non-binding!
> >
> >Thanks for driving this, Jing!
> >
> >Best,
> >Wenlong
> >
> >On
+1 for the separate repository, and the name "flink-table-store".
Best,
Godfrey
Becket Qin 于2022年1月10日周一 22:22写道：
>
> Thanks for the FLIP, Jingsong.
>
> +1 (binding)
>
> Naming wise, I am also slightly leaning towards calling it
> "flink-table-store".
>
> Thanks,
>
> Jiangjie (Becket) Qin
>
>
godfrey he created FLINK-25474:
--
Summary: Idea Scala plugin can not compile RexExplainUtil
Key: FLINK-25474
URL: https://issues.apache.org/jira/browse/FLINK-25474
Project: Flink
Issue Type
+1 (binding)
Best,
Godfrey
Ingo Bürk 于2021年12月15日周三 16:19写道：
>
> +1 (binding)
>
> Thanks for driving this much needed feature!
>
> On 14.12.21 17:45, Timo Walther wrote:
> > Hi everyone,
> >
> > I'd like to start a vote on FLIP-190: Support Version Upgrades for Table
> > API & SQL Programs [1]
>>>> terminology for the annotation. I changed that to minPlanVersion and
> >>>> minStateVersion.
> >>>>
> >>>> Let me know what you think.
> >>>>
> >>>> Regards,
> >>>> Timo
> >
Congratulations, Ingo!
Best,
Godfrey
Roman Khachatryan 于2021年12月6日周一 下午6:07写道：
>
> Congratulations, Ingo!
>
> Regards,
> Roman
>
>
> On Mon, Dec 6, 2021 at 11:05 AM Yang Wang wrote:
> >
> > Congratulations, Ingo!
> >
> > Best,
> > Yang
> >
> > Sergey Nuyanzin 于2021年12月6日周一 下午3:35写道：
> >
> > >
Congratulations, Matthias!
Best,
Godfrey
Roman Khachatryan 于2021年12月6日周一 下午6:07写道：
>
> Congratulations, Matthias!
>
> Regards,
> Roman
>
>
> On Mon, Dec 6, 2021 at 11:04 AM Yang Wang wrote:
> >
> > Congratulations, Matthias!
> >
> > Best,
> > Yang
> >
> > Sergey Nuyanzin 于2021年12月6日周一
ges.
> >>>>>
> >>>>>> If there are multiple state layouts, which layout the ExecNode
> >> should
> >>>>> use?
> >>>>>
> >>>>> It is not the responsibility of the ExecNode to decide this but the
> >&
Hi, Timo,
Thanks for the detailed explanation.
> We change an operator state of B in Flink 1.16. We perform the change in the
> operator of B in a way to support both state layouts. Thus, no need for a new
> ExecNode version.
I think this design makes thing more complex.
1. If there are
+1 (binding)
Best,
Godfrey
Jark Wu 于2021年11月30日周二 下午5:47写道：
>
> Thanks for the great discussion and updating.
> Still +1 from my side.
>
> Best,
> Jark
>
> On Tue, 30 Nov 2021 at 17:27, Kurt Young wrote:
>
> > +1 from my side.
> >
> > Best,
> > Kurt
> >
> >
> > On Tue, Nov 30, 2021 at 5:12 PM
+1 (binding)
Best,
Godfrey
Jark Wu 于2021年11月24日周三 下午12:02写道：
>
> +1 (binding)
>
> Btw, @JingZhang I think your vote can be counted into binding now.
>
> Best,
> Jark
>
> On Tue, 23 Nov 2021 at 20:19, Jing Zhang wrote:
>
> > +1 (non-binding)
> >
> > Best,
> > Jing Zhang
> >
> > Martijn Visser
Hi Timo,
Thanks for driving this discussion, the sql job's upgrading compatibility always
is a big pain point. In the last version we completed some work, this FLIP will
make the whole upgrade story possible.
I have a few comments:
1) "EXPLAIN PLAN EXECUTE STATEMENT SET BEGIN ... END" is
details in description only.
> > > > > "table.optimizer.operator-name.description-enabled" can not describe
> > > what
> > > > > it means I think.
> > > > > Regarding 2, I agree that it is better to use enum instead of
> &
rs a lot
> >>> easier
> >>> > >> when it comes to understanding logs and reading the UI. Hence +1.
> >>> > >>
> >>> > >> Cheers,
> >>> > >> Till
> >>> > >>
> >>> > >&
Congratulations Fabian!
Best,
Godfrey
Xintong Song 于2021年11月16日周二 上午9:53写道：
>
> Congratulations~!
>
> Thank you~
>
> Xintong Song
>
>
>
> On Tue, Nov 16, 2021 at 9:47 AM Qingsheng Ren wrote:
>
> > Congratulations Fabian!
> >
> > --
> > Best Regards,
> >
> > Qingsheng Ren
> > Email:
Congrats & well deserved, Jing!
Best,
Godfrey
Leonard Xu 于2021年11月16日周二 上午12:11写道：
>
> Congratulations Jing! Well Deserved.
>
>
> > 在 2021年11月15日，22:30，Dawid Wysakowicz 写道：
> >
> > Congrats!
> >
> > On 15/11/2021 14:39, Timo Walther wrote:
> >> Hi everyone,
> >>
> >> On behalf of the PMC, I'm
Congrats & well deserved, Leonard!
Best,
Godfrey
Yuepeng Pan 于2021年11月12日周五 下午2:28写道：
>
> Congrats.
>
> Best,
> Yuepeng Pan.
> At 2021-11-12 12:12:21, "Jark Wu" wrote:
> >Hi everyone,
> >
> >On behalf of the PMC, I'm very happy to announce Leonard Xu as a new Flink
> >committer.
> >
> >Leonard
Congrats, Yangze!
Best,
Godfrey
Yuepeng Pan 于2021年11月12日周五 上午10:49写道：
>
> Congrats.
>
>
> Best,
> Yuepeng Pan.
>
>
>
>
>
>
>
> At 2021-11-12 10:10:43, "Xintong Song" wrote:
> >Hi everyone,
> >
> >On behalf of the PMC, I'm very happy to announce Yangze Guo as a new Flink
> >committer.
> >
>
Thanks for driving this, this improvement solves a long-complained problem, +1
Best,
Godfrey
Jark Wu 于2021年11月11日周四 下午5:40写道：
>
> +1 for this. It looks much more clear and structured.
>
> Best,
> Jark
>
> On Thu, 11 Nov 2021 at 17:23, Chesnay Schepler wrote:
>
> > I'm generally in favor of it,
godfrey he created FLINK-24813:
--
Summary: Improve ImplicitTypeConversionITCase
Key: FLINK-24813
URL: https://issues.apache.org/jira/browse/FLINK-24813
Project: Flink
Issue Type: Improvement
godfrey he created FLINK-24676:
--
Summary: Schema does not match if explain insert statement with
partial column
Key: FLINK-24676
URL: https://issues.apache.org/jira/browse/FLINK-24676
Project: Flink
The Apache Flink community is very happy to announce the release of Apache
Flink 1.11.4, which is the fourth bugfix release for the Apache Flink 1.11
series.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data
Dear all,
I'm happy to announce that we have unanimously approved the release of
1.11.4.
There are 8 approving votes, 3 of which are binding:
* Yun Tang
* Xingbo Huang
* Robert Metzger (binding)
* Jingsong Li
* JING ZHANG
* Leonard Xu
* Dian Fu (binding)
* Yu Li
+1 (non-binding)
- Checked checksums and signatures: OK
- Built from source: OK
- Checked the flink-web PR
- find one typo about flink version
- Submit some jobs from sql-client to local cluster, checked the web-ui,
cp, sp, log, etc: OK
Best,
Godfrey
Robert Metzger 于2021年7月30日周五 下午4:33写道：
+1 (non-binding)
- Checked checksums and signatures: OK
- Built from source: OK
- Checked the flink-web PR
- find one typo about the number of the fixes and improvements
- Submit some jobs from sql-client to local cluster, checked the web-ui,
cp, sp, log, etc: OK
Best,
Godfrey
Xingbo Huang
Hi everyone,
Please review and vote on the release candidate #1 for the version 1.11.4,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
godfrey he created FLINK-23483:
--
Summary: Add document to describe how to submit job to different
executor for sql client
Key: FLINK-23483
URL: https://issues.apache.org/jira/browse/FLINK-23483
Project
t;
> > > [1] https://issues.apache.org/jira/browse/FLINK-21445
> > > [2] https://github.com/apache/flink/pull/16387
> > >
> > > On Wed, Jun 30, 2021 at 2:15 PM godfrey he
> wrote:
> > >
> > >> Hi devs,
> > >>
> > >>
godfrey he created FLINK-23435:
--
Summary: Improve the exception message when a query has lateral
table join without 'AS' which return type is simple type
Key: FLINK-23435
URL: https://issues.apache.org/jira/browse
godfrey he created FLINK-23434:
--
Summary: Inconsistent rowtypes occur in IncrementalAggregateRule
Key: FLINK-23434
URL: https://issues.apache.org/jira/browse/FLINK-23434
Project: Flink
Issue
Congratulations, Yang!
Best,
Godfrey
Lijie Wang 于2021年7月7日周三 下午5:59写道：
> Congratulations Yang!
>
> Till Rohrmann 于2021年7月7日周三 下午5:29写道：
>
> > Congratulations, Yang!
> >
> > Cheers,
> > Till
> >
> > On Wed, Jul 7, 2021 at 9:41 AM Roman Khachatryan
> wrote:
> >
> > > Congrats!
> > >
> > >
Congratulations, Guowei!
Best,
Godfrey
Lijie Wang 于2021年7月7日周三 下午5:57写道：
> Congratulations, Guowei Ma!
>
> Till Rohrmann 于2021年7月7日周三 下午5:30写道：
>
> > Congratulations, Guowei!
> >
> > Cheers,
> > Till
> >
> > On Wed, Jul 7, 2021 at 9:41 AM Roman Khachatryan
> wrote:
> >
> > > Congratulations!
godfrey he created FLINK-23217:
--
Summary: Support StreamExecValues json
serialization/deserialization
Key: FLINK-23217
URL: https://issues.apache.org/jira/browse/FLINK-23217
Project: Flink
Hi devs,
As discussed in [1], I would like to start a discussion for releasing Flink
1.11.4.
I would like to volunteer as the release manger for 1.11.4, and will start
the release process on the next Wednesday (July 7th).
There are 75 issues that have been closed or resolved [2],
and no blocker
+1 for the proposal. Thanks Xintong!
Best,
Godfrey
Rui Li 于2021年6月30日周三 上午11:36写道：
> Thanks Xintong. +1 to the proposal.
>
> On Tue, Jun 29, 2021 at 11:05 AM 刘建刚 wrote:
>
> > +1 for the proposal. Since the test time is long and environment may
> vary,
> > unstable tests are really annoying
godfrey he created FLINK-23094:
--
Summary: encounter thread-safe problem when using
StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads
environment
Key: FLINK-23094
URL: https
Thanks for driving this, Dawid. +1 to the release.
I would also like to volunteer as the release manager for these versions.
Best
Godfrey
Seth Wiesman 于2021年6月22日周二 上午8:39写道：
> +1 to the release.
>
> It would be great if we could get FLINK-23073 into 1.13.2. There's already
> an open PR and
godfrey he created FLINK-22781:
--
Summary: Incorrect result for group window aggregate when
mini-batch is enabled
Key: FLINK-22781
URL: https://issues.apache.org/jira/browse/FLINK-22781
Project: Flink
godfrey he created FLINK-22310:
--
Summary: The result of LogicalWindowJsonDeserializer is incorrect
Key: FLINK-22310
URL: https://issues.apache.org/jira/browse/FLINK-22310
Project: Flink
Issue
godfrey he created FLINK-22298:
--
Summary: The ExecNode's id should always start from 1 in json plan
test
Key: FLINK-22298
URL: https://issues.apache.org/jira/browse/FLINK-22298
Project: Flink
godfrey he created FLINK-22022:
--
Summary: Reduce the ExecNode scan scope to improve performance
when converting json plan to ExecNodeGraph
Key: FLINK-22022
URL: https://issues.apache.org/jira/browse/FLINK-22022
godfrey he created FLINK-21890:
--
Summary: Rename DAGProcessor to ExecNodeGraphProcessor
Key: FLINK-21890
URL: https://issues.apache.org/jira/browse/FLINK-21890
Project: Flink
Issue Type
godfrey he created FLINK-21869:
--
Summary: Support StreamExecTemporalSort json
serialization/deserialization
Key: FLINK-21869
URL: https://issues.apache.org/jira/browse/FLINK-21869
Project: Flink
godfrey he created FLINK-21861:
--
Summary: Support StreamExecIncrementalGroupAggregate json
serialization/deserialization
Key: FLINK-21861
URL: https://issues.apache.org/jira/browse/FLINK-21861
Project
godfrey he created FLINK-21860:
--
Summary: Support StreamExecExpand json
serialization/deserialization
Key: FLINK-21860
URL: https://issues.apache.org/jira/browse/FLINK-21860
Project: Flink
godfrey he created FLINK-21791:
--
Summary: Support StreamExecLocalGroupAggregate and
StreamExecGlobalGroupAggregate json serialization/deserialization
Key: FLINK-21791
URL: https://issues.apache.org/jira/browse/FLINK
godfrey he created FLINK-21750:
--
Summary: Support StreamExecWatermarkAssigner json
serialization/deserialization
Key: FLINK-21750
URL: https://issues.apache.org/jira/browse/FLINK-21750
Project: Flink
godfrey he created FLINK-21730:
--
Summary: Introduce ExecNodeTranslator
Key: FLINK-21730
URL: https://issues.apache.org/jira/browse/FLINK-21730
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-21710:
--
Summary: FlinkRelMdUniqueKeys get incorrect result on TableScan
after project push-down
Key: FLINK-21710
URL: https://issues.apache.org/jira/browse/FLINK-21710
Project
godfrey he created FLINK-21697:
--
Summary: Support StreamExecMiniBatchAssigner json
serialization/deserialization
Key: FLINK-21697
URL: https://issues.apache.org/jira/browse/FLINK-21697
Project: Flink
godfrey he created FLINK-21646:
--
Summary: Support json serialization/deserialization for the states
in StreamExecGroupAggregate
Key: FLINK-21646
URL: https://issues.apache.org/jira/browse/FLINK-21646
godfrey he created FLINK-21645:
--
Summary: Introduce StateDeclaration
Key: FLINK-21645
URL: https://issues.apache.org/jira/browse/FLINK-21645
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-21612:
--
Summary: Support StreamExecGroupAggregate json
serialization/deserialization
Key: FLINK-21612
URL: https://issues.apache.org/jira/browse/FLINK-21612
Project: Flink
+1 (binding)
Best,
Godfrey
Jark Wu 于2021年3月3日周三 上午10:37写道：
> +1 to the updated FLIP.
>
> Best,
> Jark
>
> On Wed, 3 Mar 2021 at 10:30, Leonard Xu wrote:
>
> > +1 (non-binding)
> >
> > The updated FLIP looks well.
> >
> > Best,
> > Leonard
> >
> >
> > > 在 2021年3月2日，22:27，Shengkai Fang 写道：
> >
godfrey he created FLINK-21549:
--
Summary: Support json serialization/deserialization for the
push-down results
Key: FLINK-21549
URL: https://issues.apache.org/jira/browse/FLINK-21549
Project: Flink
+1
Best,
Godfrey
Jark Wu 于2021年2月8日周一 上午11:50写道：
> Thanks for driving this.
>
> +1
>
> Best,
> Jark
>
> On Mon, 8 Feb 2021 at 09:47, Kurt Young wrote:
>
> > +1
> >
> > Best,
> > Kurt
> >
> >
> > On Sun, Feb 7, 2021 at 7:24 PM Rui Li wrote:
> >
> > > Hi everyone,
> > >
> > > I think we have
Hi everyone,
Regarding "table.planner" and "table.execution-mode"
If we define that those two options are just used to initialize the
TableEnvironment, +1 for introducing table options instead of sql-client
options.
Regarding "the sql client, we will maintain two parsers", I want to give
more
godfrey he created FLINK-21245:
--
Summary: Support StreamExecCalc json serialization/deserialization
Key: FLINK-21245
URL: https://issues.apache.org/jira/browse/FLINK-21245
Project: Flink
Issue
Thanks for bringing up the discussion, Rui!
Regarding the DDL part in the "Introduce HiveParser" section,
I would like to choose the second option. Because if we could
use one hive parser to parse all hive SQLs, we need not to copy
Calcite parser code, and the framework and the code will be very
godfrey he created FLINK-21224:
--
Summary: Remove BatchExecExchange and StreamExecExchange, and
replace their functionality with ExecEdge
Key: FLINK-21224
URL: https://issues.apache.org/jira/browse/FLINK-21224
godfrey he created FLINK-21150:
--
Summary: Introduce ExecEdge to connect two ExecNodes
Key: FLINK-21150
URL: https://issues.apache.org/jira/browse/FLINK-21150
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-21105:
--
Summary: Rename ExecEdge to InputProperty
Key: FLINK-21105
URL: https://issues.apache.org/jira/browse/FLINK-21105
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-21097:
--
Summary: Introduce e2e test framework for json plan test
Key: FLINK-21097
URL: https://issues.apache.org/jira/browse/FLINK-21097
Project: Flink
Issue Type: Sub
godfrey he created FLINK-21096:
--
Summary: Introduce ExecNodeGraphJsonPlanGenerator to serialize
ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph
Key: FLINK-21096
URL: https://issues.apache.org
godfrey he created FLINK-21094:
--
Summary: Support StreamExecSink json serialization/deserialization
Key: FLINK-21094
URL: https://issues.apache.org/jira/browse/FLINK-21094
Project: Flink
Issue
godfrey he created FLINK-21093:
--
Summary: Support StreamExecTableSource json
serialization/deserialization
Key: FLINK-21093
URL: https://issues.apache.org/jira/browse/FLINK-21093
Project: Flink
godfrey he created FLINK-21092:
--
Summary: Introduce getJsonPlan, explainJsonPlan and
executeJsonPlan in TableEnvironmentInternal
Key: FLINK-21092
URL: https://issues.apache.org/jira/browse/FLINK-21092
godfrey he created FLINK-21091:
--
Summary: Support ExecNode json serialization/deserialization
Key: FLINK-21091
URL: https://issues.apache.org/jira/browse/FLINK-21091
Project: Flink
Issue Type
godfrey he created FLINK-21041:
--
Summary: Introduce ExecNodeGraph to wrap the ExecNode topology
Key: FLINK-21041
URL: https://issues.apache.org/jira/browse/FLINK-21041
Project: Flink
Issue Type
godfrey he created FLINK-20989:
--
Summary: Functions in ExplodeFunctionUtil should handle null data
to avoid NPE
Key: FLINK-20989
URL: https://issues.apache.org/jira/browse/FLINK-20989
Project: Flink
godfrey he created FLINK-20968:
--
Summary: Remove legacy exec nodes
Key: FLINK-20968
URL: https://issues.apache.org/jira/browse/FLINK-20968
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20966:
--
Summary: Rename StreamExecIntermediateTableScan to
StreamPhysicalIntermediateTableScan
Key: FLINK-20966
URL: https://issues.apache.org/jira/browse/FLINK-20966
Project
godfrey he created FLINK-20949:
--
Summary: Separate the implementation of sink nodes
Key: FLINK-20949
URL: https://issues.apache.org/jira/browse/FLINK-20949
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20948:
--
Summary: Separate the implementation of StreamExecDeduplicate
Key: FLINK-20948
URL: https://issues.apache.org/jira/browse/FLINK-20948
Project: Flink
Issue Type
godfrey he created FLINK-20941:
--
Summary: Separate the implementation of StreamExecMatch
Key: FLINK-20941
URL: https://issues.apache.org/jira/browse/FLINK-20941
Project: Flink
Issue Type: Sub
godfrey he created FLINK-20924:
--
Summary: Port StreamExecPythonOverAggregate and
BatchExecPythonOverAggregate to Java
Key: FLINK-20924
URL: https://issues.apache.org/jira/browse/FLINK-20924
Project
godfrey he created FLINK-20899:
--
Summary: encounter ClassCastException when calculating cost in
HepPlanner
Key: FLINK-20899
URL: https://issues.apache.org/jira/browse/FLINK-20899
Project: Flink
godfrey he created FLINK-20883:
--
Summary: Separate the implementation of BatchExecOverAggregate and
StreamExecOverAggregate
Key: FLINK-20883
URL: https://issues.apache.org/jira/browse/FLINK-20883
godfrey he created FLINK-20879:
--
Summary: Use MemorySize type instead of String type for memory
ConfigOption in ExecutionConfigOptions
Key: FLINK-20879
URL: https://issues.apache.org/jira/browse/FLINK-20879
godfrey he created FLINK-20857:
--
Summary: Separate the implementation of batch window aggregate
nodes
Key: FLINK-20857
URL: https://issues.apache.org/jira/browse/FLINK-20857
Project: Flink
101 - 200 of 453 matches
Mail list logo
