Hi, Kaibo Zhou ~
There are several phrases that a SQL text get to execution graph what can be
run with Flink runtime:
1. Sql Parse: parse the sql text to AST(sql node tree)
2. Sql node(row type) validation, this includes the tables/schema inference
3. Sql-to-rel conversion, convert the sql node
Hi Peter,
Certainly, we could add a 'if-else' in `AbstractJobClusterExecutor` to
handle different deploy mode. However, i
think we need to avoid executing any user program code in cluster
deploy-mode including in the `ExecutionEnvironment`.
Let's wait for some feedback from FLIP-73's author @Aljosc
xiaojin.wy created FLINK-15437:
--
Summary: Start session with property of
"-Dtaskmanager.memory.process.size" not work
Key: FLINK-15437
URL: https://issues.apache.org/jira/browse/FLINK-15437
Project: Flin
Hi, Jingsong,
Thank you very much for your suggestion.
I verified that use `tEnv.sqlUpdate("xxx")` and `tEnv.explain(false)` to do
validation, it works.
But this method needs the connector jar, which is very inconvenient to use.
Hi, Danny,
Many thanks for providing very useful explanations.
T
Jörn Kottmann created FLINK-15438:
-
Summary: Counter metrics are incorrectly reported as total counts
to DataDog
Key: FLINK-15438
URL: https://issues.apache.org/jira/browse/FLINK-15438
Project: Flink
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
Kurt Young created FLINK-15440:
--
Summary: Enable savepoint support for Table & SQL program
Key: FLINK-15440
URL: https://issues.apache.org/jira/browse/FLINK-15440
Project: Flink
Issue Type: New
Jark Wu created FLINK-15441:
---
Summary: Refactor StreamExecWindowJoin to extends
CommonPhysicalJoin
Key: FLINK-15441
URL: https://issues.apache.org/jira/browse/FLINK-15441
Project: Flink
Issue Type
Yangze Guo created FLINK-15442:
--
Summary: Harden the Avro Confluent Schema Registry nightly
end-to-end test
Key: FLINK-15442
URL: https://issues.apache.org/jira/browse/FLINK-15442
Project: Flink
Hi Jark, Hequn,
I have updated the documentation.
Best,
Forward
Forward Xu 于2019年12月29日周日 下午4:01写道：
> Hi Jark, Hequn,
>
> Thank you very much, Introducing new `TableSymbol`s sounds like a good
> idea. +1 for the proposal.
>
> I think this idea is good, I will add this in the documentation.
>
yexianxun created FLINK-15443:
-
Summary: Use JDBC connector write FLOAT value occur
ClassCastException
Key: FLINK-15443
URL: https://issues.apache.org/jira/browse/FLINK-15443
Project: Flink
Issu
zhijiang created FLINK-15444:
Summary: Make the component AbstractInvokable in
CheckpointBarrierHandler NonNull
Key: FLINK-15444
URL: https://issues.apache.org/jira/browse/FLINK-15444
Project: Flink
12 matches
Mail list logo
