godfrey he created FLINK-17126:
--
Summary: Correct the execution behavior of BatchTableEnvironment
Key: FLINK-17126
URL: https://issues.apache.org/jira/browse/FLINK-17126
Project: Flink
Issue
+1 (non-binding)
Best,
Godfrey
Benchao Li 于2020年4月12日周日 下午12:28写道：
> +1 (non-binding)
>
> zoudan 于2020年4月12日周日 上午9:52写道：
>
> > +1 (non-binding)
> >
> > Best,
> > Dan Zou
> >
> >
> > > 在 2020年4月10日，09:30，Danny Chan 写道：
> > >
> > > +1 from my side.
> > >
> > > Best,
> > > Danny Chan
> > > 在
godfrey he created FLINK-17052:
--
Summary: Introduce PlanGenerator
Key: FLINK-17052
URL: https://issues.apache.org/jira/browse/FLINK-17052
Project: Flink
Issue Type: Sub-task
年4月7日周二 下午2:29写道：
> +1
>
> Best,
>
> Dawid
>
> On 07/04/2020 07:44, godfrey he wrote:
> > Hi, Kurt
> >
> > yes. `TableEnvironement#executeSql` also could execute `SELECT`
> statement,
> > which is similar to `Table#execute`.
> > I add this t
> +1 (binding) for this FLIP
> >
> > Regards,
> > Timo
> >
> >
> > On 06.04.20 16:47, godfrey he wrote:
> > > Hi Timo,
> > >
> > > Sorry for late reply, and thanks for your correction. I have fixed the
> > typo
> >
ets resolved.
>
> Thanks,
> Timo
>
> On 03.04.20 15:12, Terry Wang wrote:
> > +1 (non-binding)
> > Looks great to me, Thanks for driving on this.
> >
> > Best,
> > Terry Wang
> >
> >
> >
> >> 2020年4月3日 21:07，godfrey he 写道：
&g
rephrase this part to:
>
> The FLIP says:
> "For DML and DQL, this method returns TableResult once the job has been
> submitted. For DDL and DCL statements, TableResult is returned once the
> operation has finished."
>
> Regards,
> Timo
>
>
> On 02.04.20 05
]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=134745878
[2]
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-84-Feedback-Summary-td39261.html
Bests,
Godfrey
godfrey he 于2020年3月31日周二 下午8:42写道：
> Hi, Timo
>
> So sorry about that, I'm in
ltilineSql`, I'm afraid sometimes user might
> >> forget to
> >> iterate the returned iterators, e.g. user submits a bunch of DDLs and
> >> expect the
> >> framework will execute them one by one. But it didn't.
> >>
> >> Best,
> >> Kurt
> >>
>
Congratulations to all of you~
Best,
Godfrey
Ismaël Mejía 于2020年4月2日周四 上午6:42写道：
> Congrats everyone!
>
> On Thu, Apr 2, 2020 at 12:16 AM Rong Rong wrote:
> >
> > Congratulations to all!!!
> >
> > --
> > Rong
> >
> > On Wed, Apr 1, 2020 at 2:27 PM Thomas Weise wrote:
> >
> > >
methods still throw a checked
> exception; can we remove that from the FLIP? Also the above mentioned
> `Iterator#next()` would trigger an execution without throwing a checked
> exception.
>
> Thanks,
> Timo
>
> [1]
>
> https://docs.google.com/document/d/1ueLjQWRPdLTFB_TReAyhse
> It would be great if we can add these findings to the FLIP before we
> > start voting.
> >
> > One minor thing: some `execute()` methods still throw a checked
> > exception; can we remove that from the FLIP? Also the above mentioned
> > `Iterator#next()` would t
m all stakeholders.
>
> Thanks,
> Timo
>
> On 31.03.20 08:31, godfrey he wrote:
> > Hi everyone,
> >
> > I'd like to start the vote of FLIP-84[1] again, because we have some
> > feedbacks. The feedbacks are all about new introduced methods, here is
>
godfrey he created FLINK-16881:
--
Summary: use Catalog's total size info in planner
Key: FLINK-16881
URL: https://issues.apache.org/jira/browse/FLINK-16881
Project: Flink
Issue Type: New Feature
Hi everyone,
I'd like to start the vote of FLIP-84[1] again, because we have some
feedbacks. The feedbacks are all about new introduced methods, here is the
discussion thread [2].
The vote will be open for at least 72 hours. Unless there is an objection,
I will try to close it by Apr 3, 2020
) and multiline statements.
> >
> > Having a `executeSqlAsync()` is useful for batch. However, I don't want
> > `sync/async` be the new batch/stream flag. The execution behavior should
> > come from the query itself.
> >
> > Regards,
> > Timo
> >
>
nc
> async because everything should be async
> async because everything should be async
>
> What we should not start for executeAsyncMultilineSql():
>
> sync because DDL
> async because everything should be async
> async because everything should be async
>
>
godfrey he created FLINK-16822:
--
Summary: The config set by SET command does not work
Key: FLINK-16822
URL: https://issues.apache.org/jira/browse/FLINK-16822
Project: Flink
Issue Type: Bug
design already. However, I would rather go for
> non-blocking streaming queries. Also with the `EMIT STREAM` key word in
> mind that we might add to SQL statements soon.
>
> Regards,
> Timo
>
> [1] https://issues.apache.org/jira/browse/FLINK-16761
> [2] https://issues.
t to update the FLIP-84 again and
> have another voting process.
>
> Thanks,
> Timo
>
>
> On 25.03.20 11:17, godfrey he wrote:
> > Hi community,
> > Timo, Fabian and Dawid have some feedbacks about FLIP-84[1]. The
> feedbacks
> > are all about new introduced method
Hi community,
Timo, Fabian and Dawid have some feedbacks about FLIP-84[1]. The feedbacks
are all about new introduced methods. We had a discussion yesterday, and
most of feedbacks have been agreed upon. Here is the conclusions:
*1. about proposed methods in `TableEnvironment`:*
the original
Hi Zhijiang and Piotr,
I think we can remove "FLIP-91 Introduce SQL client gateway and provide
JDBC driver" from the list, because we have decided the first step to
support sql gateway and jdbc driver as ecosystem in ververica, we are not
going to put more effort on it now.
Thanks for updating
godfrey he created FLINK-16535:
--
Summary: BatchTableSink#emitDataSet returns DataSink
Key: FLINK-16535
URL: https://issues.apache.org/jira/browse/FLINK-16535
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-16533:
--
Summary: ExecutionEnvironment supports executing plan
Key: FLINK-16533
URL: https://issues.apache.org/jira/browse/FLINK-16533
Project: Flink
Issue Type: Sub
godfrey he created FLINK-16519:
--
Summary: CheckpointCoordinatorFailureTest logs LinkageErrors
Key: FLINK-16519
URL: https://issues.apache.org/jira/browse/FLINK-16519
Project: Flink
Issue Type
Hi Wei, thanks for the proposal.
I think it's better to give two more examples, one is how to use python UDF
in SQL, another is how to start sql-client.sh with full python dependencies.
Best,
Godfrey
Wei Zhong 于2020年3月9日周一 下午10:09写道：
> Hi everyone,
>
> I would like to start discussion about
godfrey he created FLINK-16367:
--
Summary: Introduce createDmlBatch method in TableEnvironment
Key: FLINK-16367
URL: https://issues.apache.org/jira/browse/FLINK-16367
Project: Flink
Issue Type
godfrey he created FLINK-16366:
--
Summary: Introduce executeStatement method in TableEnvironment
Key: FLINK-16366
URL: https://issues.apache.org/jira/browse/FLINK-16366
Project: Flink
Issue Type
Thanks all for the votes.
So far, we have
- 3 binding +1 votes (Kurt, Jark, Jingsong)
- 2 non-binding +1 votes (Terry, Benchao)
- No -1 votes
The voting time has past and there is enough +1 votes to consider the FLIP-84
approved.
Thank you all.
Best,
Godfrey
godfrey he 于2020年3月2日周一
0:10 PM Benchao Li wrote:
>
> > +1 (non-binding)
> >
> > Jark Wu 于2020年2月28日周五 下午5:11写道：
> >
> > > +1 from my side.
> > >
> > > Best,
> > > Jark
> > >
> > > On Fri, 28 Feb 2020 at 15:07, kant kodali wrote:
> > >
>
godfrey he created FLINK-16364:
--
Summary: Deprecate the methods in TableEnvironment proposed by
FLIP-84
Key: FLINK-16364
URL: https://issues.apache.org/jira/browse/FLINK-16364
Project: Flink
godfrey he created FLINK-16363:
--
Summary: Correct the execution behavior of TableEnvironment and
StreamTableEnvironment
Key: FLINK-16363
URL: https://issues.apache.org/jira/browse/FLINK-16363
Project
godfrey he created FLINK-16362:
--
Summary: remove deprecated method in StreamTableSink
Key: FLINK-16362
URL: https://issues.apache.org/jira/browse/FLINK-16362
Project: Flink
Issue Type
godfrey he created FLINK-16361:
--
Summary: FLIP-84: Improve & Refactor API of TableEnvironment
Key: FLINK-16361
URL: https://issues.apache.org/jira/browse/FLINK-16361
Project: Flink
Issue
planation.
>
> Do we need to clarify this in the FLIP? Maybe this confuses other users as
> well.
>
> godfrey he 于2020年2月28日周五 下午4:54写道：
>
> > Hi Benchao,
> >
> > > I have one question about this FLIP:
> > > executeStatement accepts DML, what
epts DML, what if it's a streaming DML ?
> does it submit the job to cluster directly and blocks forever? what's
> the behavior for the next statements?
>
> nit: there's a typo in "the table describing the result for each kind of
> statement", "*Result Scheam" -&g
urt
> >
> >
> > On Fri, Feb 28, 2020 at 9:15 AM Terry Wang wrote:
> >
> > > I look through the whole design and it’s a big improvement of usability
> > on
> > > TableEnvironment’s api.
> > >
> > > +1 (non-binding)
> > >
>
godfrey he created FLINK-16322:
--
Summary: wrong result after filter push down in parquet table
source
Key: FLINK-16322
URL: https://issues.apache.org/jira/browse/FLINK-16322
Project: Flink
godfrey he created FLINK-16315:
--
Summary: throw JsonMappingException when using
BatchTableEnvironment#explain to get the plan of sql with constant string
Key: FLINK-16315
URL: https://issues.apache.org/jira/browse
Hi everyone,
I'd like to start the vote of FLIP-84[1], which proposes to deprecate some
old APIs and introduce some new APIs in TableEnvironment. This FLIP is
discussed and reached consensus in the discussion thread[2].
The vote will be open for at least 72 hours. Unless there is an objection,
I
godfrey he created FLINK-16195:
--
Summary: append constant field to unique key set on project when
deriving unique keys in FlinkRelMdUniqueKeys
Key: FLINK-16195
URL: https://issues.apache.org/jira/browse/FLINK-16195
Congrats Jingsong! Well deserved.
Best,
godfrey
Jeff Zhang 于2020年2月21日周五 上午11:49写道：
> Congratulations！Jingsong. You deserve it
>
> wenlong.lwl 于2020年2月21日周五 上午11:43写道：
>
>> Congrats Jingsong!
>>
>> On Fri, 21 Feb 2020 at 11:41, Dian Fu wrote:
>>
>> > Congrats Jingsong!
>> >
>> > > 在
`sqlQuery(query)`, we removed
> > > `scan(tableName)` and introduced `from(tableName)`,
> > > and now we want to remove them again. Users will feel like the
> interface
> > is
> > > very unstable, that really frustrates users.
> > > I think we should b
godfrey he created FLINK-16110:
--
Summary: LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*"
and TIMESTAMP(3) *PROCTIME*
Key: FLINK-16110
URL: https://issues.apache.org/jira/browse/F
hi kurt，jark，jingsong
Regarding to "fromQuery", I agree with kurt. In addition, I think `Table
from(String tableName)` should be renamed to `Table fromCatalog(String
tableName)`.
Regarding to the "DmlBatch", DML contains "INSERT", "UPDATE", "DELETE", and
they can be executed in a same batch in
oject? This seems like
> > unit of functionality that would be useful to have separately, and it
> would
> > have a few advantages:
> >
> >- Flink codebase is already very large and hard to maintain
> >- A separate project is simpler to develop, not limited
godfrey he created FLINK-15669:
--
Summary: SQL client can't cancel flink job
Key: FLINK-15669
URL: https://issues.apache.org/jira/browse/FLINK-15669
Project: Flink
Issue Type: Bug
hi Flavio, TableEnvironment.getCompletionHints maybe already meet the
requirement.
Flavio Pompermaier 于2020年1月18日周六 下午3:39写道：
> Why not adding also a suggest() method (also unimplemented initially) that
> would return the list of suitable completions/tokens on the current query?
> How complex
Hi devs,
I've updated the FLIP-91 [0] according to feedbacks. Please take another
look.
Best,
godfrey
[0]
https://docs.google.com/document/d/1DKpFdov1o_ObvrCmU-5xi-VrT6nR2gxq-BbswSSI9j8/
hi kaibo,
As we discuss offline, I think it's a clean way that flink-table provides
an interface (or a tool) to do the sql validation for platform users.
`tEnv.sqlUpdate` or `tEnv.explain(false)` is a temporary solution which
contains too many unrelated logic (just consider the functionality
godfrey he created FLINK-15472:
--
Summary: Support SQL Client Gateway
Key: FLINK-15472
URL: https://issues.apache.org/jira/browse/FLINK-15472
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-15123:
--
Summary: remove uniqueKeys from FlinkStatistic in blink planner
Key: FLINK-15123
URL: https://issues.apache.org/jira/browse/FLINK-15123
Project: Flink
Issue
godfrey he created FLINK-15095:
--
Summary: bridge table schema's primary key to metadata handler in
blink planner
Key: FLINK-15095
URL: https://issues.apache.org/jira/browse/FLINK-15095
Project: Flink
godfrey he created FLINK-15004:
--
Summary: Choose SortMergeJoin instead of HashJoin if the
statistics is unknown
Key: FLINK-15004
URL: https://issues.apache.org/jira/browse/FLINK-15004
Project: Flink
godfrey he created FLINK-15001:
--
Summary: The digest of sub-plan reuse should contain RelNode's
trait
Key: FLINK-15001
URL: https://issues.apache.org/jira/browse/FLINK-15001
Project: Flink
godfrey he created FLINK-14999:
--
Summary: sub-plan reuse should consider
Key: FLINK-14999
URL: https://issues.apache.org/jira/browse/FLINK-14999
Project: Flink
Issue Type: Bug
godfrey he created FLINK-14899:
--
Summary: can not be translated to StreamExecDeduplicate when
PROCTIME is defined in query
Key: FLINK-14899
URL: https://issues.apache.org/jira/browse/FLINK-14899
Project
godfrey he created FLINK-14874:
--
Summary: add local aggregate to solve data skew for ROLLUP/CUBE
case
Key: FLINK-14874
URL: https://issues.apache.org/jira/browse/FLINK-14874
Project: Flink
godfrey he created FLINK-14789:
--
Summary: extends max/min type in ColumnStats from Number to
Comparable
Key: FLINK-14789
URL: https://issues.apache.org/jira/browse/FLINK-14789
Project: Flink
godfrey he created FLINK-14724:
--
Summary: Join condition could be simplified in logical phase
Key: FLINK-14724
URL: https://issues.apache.org/jira/browse/FLINK-14724
Project: Flink
Issue Type
godfrey he created FLINK-14656:
--
Summary: blink planner should convert catalog statistics to
TableStats for permanent table instead of temporary table
Key: FLINK-14656
URL: https://issues.apache.org/jira/browse
godfrey he created FLINK-13708:
--
Summary: transformations should be cleared because a table
environment could execute multiple job
Key: FLINK-13708
URL: https://issues.apache.org/jira/browse/FLINK-13708
godfrey he created FLINK-13611:
--
Summary: Introduce analyze statistic utility to generate table &
column statistics
Key: FLINK-13611
URL: https://issues.apache.org/jira/browse/FLINK-13611
Project: F
godfrey he created FLINK-13563:
--
Summary: TumblingGroupWindow should implement toString method
Key: FLINK-13563
URL: https://issues.apache.org/jira/browse/FLINK-13563
Project: Flink
Issue Type
godfrey he created FLINK-13562:
--
Summary: throws exception when FlinkRelMdColumnInterval meets two
stage stream group aggregate
Key: FLINK-13562
URL: https://issues.apache.org/jira/browse/FLINK-13562
godfrey he created FLINK-13545:
--
Summary: JoinToMultiJoinRule should not match SEMI/ANTI LogicalJoin
Key: FLINK-13545
URL: https://issues.apache.org/jira/browse/FLINK-13545
Project: Flink
Issue
godfrey he created FLINK-13502:
--
Summary: CatalogTableStatisticsConverter should be in
planner.utils package
Key: FLINK-13502
URL: https://issues.apache.org/jira/browse/FLINK-13502
Project: Flink
godfrey he created FLINK-13404:
--
Summary: Port csv factories & validator from flink-table-planner
to flink-csv
Key: FLINK-13404
URL: https://issues.apache.org/jira/browse/FLINK-13404
Project: F
godfrey he created FLINK-13403:
--
Summary: Correct package name after relocation
Key: FLINK-13403
URL: https://issues.apache.org/jira/browse/FLINK-13403
Project: Flink
Issue Type: Bug
godfrey he created FLINK-13347:
--
Summary: should handle new JoinRelType(SEMI/ANTI) in switch case
Key: FLINK-13347
URL: https://issues.apache.org/jira/browse/FLINK-13347
Project: Flink
Issue
godfrey he created FLINK-13269:
--
Summary: copy RelDecorrelator from blink planner to flink planner
to fix CALCITE-3169 & CALCITE-3170
Key: FLINK-13269
URL: https://issues.apache.org/jira/browse/FLINK-1
godfrey he created FLINK-13268:
--
Summary: revert SqlSplittableAggFunction to make two planners
available in one jar
Key: FLINK-13268
URL: https://issues.apache.org/jira/browse/FLINK-13268
Project: Flink
godfrey he created FLINK-13263:
--
Summary: supports explain DAG plan in flink-python
Key: FLINK-13263
URL: https://issues.apache.org/jira/browse/FLINK-13263
Project: Flink
Issue Type: New
godfrey he created FLINK-13185:
--
Summary: Bump Calcite dependency to 1.20.0 in sql parser & flink
planner
Key: FLINK-13185
URL: https://issues.apache.org/jira/browse/FLINK-13185
Project: F
godfrey he created FLINK-13168:
--
Summary: clarify isBatch/isStreaming/isBounded flag in flink
planner and blink planner
Key: FLINK-13168
URL: https://issues.apache.org/jira/browse/FLINK-13168
Project
godfrey he created FLINK-13116:
--
Summary: supports catalog statistic in blink planner
Key: FLINK-13116
URL: https://issues.apache.org/jira/browse/FLINK-13116
Project: Flink
Issue Type: New
godfrey he created FLINK-13115:
--
Summary: Introduce planner rule to support partition pruning for
PartitionableTableSource
Key: FLINK-13115
URL: https://issues.apache.org/jira/browse/FLINK-13115
Project
godfrey he created FLINK-13114:
--
Summary: adapt blink planner to new unified TableEnvironment
Key: FLINK-13114
URL: https://issues.apache.org/jira/browse/FLINK-13114
Project: Flink
Issue Type
godfrey he created FLINK-13088:
--
Summary: Supports execute DAG plan
Key: FLINK-13088
URL: https://issues.apache.org/jira/browse/FLINK-13088
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-13081:
--
Summary: Supports explain and execute DAG plan
Key: FLINK-13081
URL: https://issues.apache.org/jira/browse/FLINK-13081
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-13076:
--
Summary: Bump Calcite dependency to 1.20.0 in blink planner
Key: FLINK-13076
URL: https://issues.apache.org/jira/browse/FLINK-13076
Project: Flink
Issue Type
godfrey he created FLINK-13030:
--
Summary: add more test case for blink planner
Key: FLINK-13030
URL: https://issues.apache.org/jira/browse/FLINK-13030
Project: Flink
Issue Type: Improvement
godfrey he created FLINK-12969:
--
Summary: Remove dependencies on RelNode from TableImpl in blink
planner
Key: FLINK-12969
URL: https://issues.apache.org/jira/browse/FLINK-12969
Project: Flink
godfrey he created FLINK-12937:
--
Summary: Introduce join reorder planner rules in blink planner
Key: FLINK-12937
URL: https://issues.apache.org/jira/browse/FLINK-12937
Project: Flink
Issue Type
godfrey he created FLINK-12888:
--
Summary: Introduce planner rule to push filter into TableSource
Key: FLINK-12888
URL: https://issues.apache.org/jira/browse/FLINK-12888
Project: Flink
Issue
godfrey he created FLINK-12878:
--
Summary: Add travis profile for
flink-table-planner-blink/flink-table-runtime-blink
Key: FLINK-12878
URL: https://issues.apache.org/jira/browse/FLINK-12878
Project
godfrey he created FLINK-12857:
--
Summary: move FilterableTableSource into flink-table-common
Key: FLINK-12857
URL: https://issues.apache.org/jira/browse/FLINK-12857
Project: Flink
Issue Type
godfrey he created FLINK-12856:
--
Summary: Introduce planner rule to push projection into
ProjectableTableSource
Key: FLINK-12856
URL: https://issues.apache.org/jira/browse/FLINK-12856
Project: Flink
godfrey he created FLINK-12815:
--
Summary: Supports CatalogManager in blink planner
Key: FLINK-12815
URL: https://issues.apache.org/jira/browse/FLINK-12815
Project: Flink
Issue Type: Improvement
godfrey he created FLINK-12795:
--
Summary: Extracted creation & configuration of FrameworkConfig &
RelBuilder to separate class in blink planner
Key: FLINK-12795
URL: https://issues.apache.org/jira/browse/FLI
godfrey he created FLINK-12734:
--
Summary: remove getVolcanoPlanner method from FlinkOptimizeContext
and RelNodeBlock does not depend on TableEnvironment
Key: FLINK-12734
URL: https://issues.apache.org/jira/browse
godfrey he created FLINK-12703:
--
Summary: Introduce metadata handlers on SEMI/ATNI join and look up
join
Key: FLINK-12703
URL: https://issues.apache.org/jira/browse/FLINK-12703
Project: Flink
godfrey he created FLINK-12685:
--
Summary: Supports UNNEST query in blink planner
Key: FLINK-12685
URL: https://issues.apache.org/jira/browse/FLINK-12685
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-12665:
--
Summary: Introduce MiniBatchIntervalInferRule and watermark
assigner operators
Key: FLINK-12665
URL: https://issues.apache.org/jira/browse/FLINK-12665
Project: Flink
godfrey he created FLINK-12610:
--
Summary: Introduce planner rules about aggregate
Key: FLINK-12610
URL: https://issues.apache.org/jira/browse/FLINK-12610
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-12600:
--
Summary: Introduce planner rules to do deterministic rewriting on
RelNode
Key: FLINK-12600
URL: https://issues.apache.org/jira/browse/FLINK-12600
Project: Flink
godfrey he created FLINK-12575:
--
Summary: Introduce planner rules to remove redundant shuffle and
collation
Key: FLINK-12575
URL: https://issues.apache.org/jira/browse/FLINK-12575
Project: Flink
godfrey he created FLINK-12559:
--
Summary: Introduce metadata handlers on window aggregate
Key: FLINK-12559
URL: https://issues.apache.org/jira/browse/FLINK-12559
Project: Flink
Issue Type: New
godfrey he created FLINK-12524:
--
Summary: Introduce planner rules about rank
Key: FLINK-12524
URL: https://issues.apache.org/jira/browse/FLINK-12524
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-12519:
--
Summary: Introduce planner rules about semi/anti join
Key: FLINK-12519
URL: https://issues.apache.org/jira/browse/FLINK-12519
Project: Flink
Issue Type: New
301 - 400 of 453 matches
Mail list logo
