Can anyone help?
Best,
wangsan
environment repeatedly.
Should we eliminate the side effect of DataStreamRel#translateToPlan ?
Best, Wangsan
appendix
tenv.registerTableSource("test_source", sourceTable)
val t = tenv.sqlQuery("SELECT * from test_source")
println(tenv.explain(t))
pr
on same
RelNode several times, the same operators are added in execution environment
more than once, but actually we need that for only one time. Correct me if I
misunderstood that.
I will open an issue late this day, if this is indeed a problem.
Best,
wangsan
> On Aug 21, 2018, at 10
am wrong.
——
wangsan
before the connection is
closed?
May be we could use a Timer to test the connection periodically and keep it
alive. What do you think?
I will open a jira and try to work on that issue.
Best,
wangsan
> On Jul 10, 2018, at 8:38 PM, Hequn Cheng wrote:
>
> Hi wangsan,
>
> I
implemented this at
https://github.com/apache/flink/pull/6301
<https://github.com/apache/flink/pull/6301>, It would be kind of you to review
this.
Best,
wangsan
> On Jul 11, 2018, at 2:25 PM, Hequn Cheng wrote:
>
> Hi wangsan,
>
> What I mean is establishing a connection
merged. We have used that in our internal Flink
version, and for now it works well. May be you can take a look at it.
Best,
wangsan
> On Oct 24, 2018, at 9:31 AM, yinhua.dai wrote:
>
> Hi Timo,
>
> I write simple testing code for the issue, please checkout
> https://gi
, may be we should consider this
feature in future?
Best,
wangsan
wangsan created FLINK-10290:
---
Summary: Conversion error in StreamScan and BatchScan
Key: FLINK-10290
URL: https://issues.apache.org/jira/browse/FLINK-10290
Project: Flink
Issue Type: Bug
wangsan created FLINK-9794:
--
Summary: JDBCOutputFormat does not consider idle connection and
multithreads synchronization
Key: FLINK-9794
URL: https://issues.apache.org/jira/browse/FLINK-9794
Project: Flink
wangsan created FLINK-10553:
---
Summary: Unified table sink and source name in SQL statement
Key: FLINK-10553
URL: https://issues.apache.org/jira/browse/FLINK-10553
Project: Flink
Issue Type: Bug
wangsan created FLINK-10770:
---
Summary: Some generated functions are not opened properly.
Key: FLINK-10770
URL: https://issues.apache.org/jira/browse/FLINK-10770
Project: Flink
Issue Type: Bug
wangsan created FLINK-11687:
---
Summary: Remove useless code in StreamingJobGraphGenerator
Key: FLINK-11687
URL: https://issues.apache.org/jira/browse/FLINK-11687
Project: Flink
Issue Type: Task
wangsan created FLINK-13823:
---
Summary: Incorrect debug log in CompileUtils
Key: FLINK-13823
URL: https://issues.apache.org/jira/browse/FLINK-13823
Project: Flink
Issue Type: Bug
wangsan created FLINK-15548:
---
Summary: Make KeyedCoProcessOperatorWithWatermarkDelay extends
KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator
Key: FLINK-15548
URL: https://issues.apache.org/jira/browse
wangsan created FLINK-18596:
---
Summary: Derive format schema from table schema may get error
result
Key: FLINK-18596
URL: https://issues.apache.org/jira/browse/FLINK-18596
Project: Flink
Issue
wangsan created FLINK-20768:
---
Summary: Support routing field for Elasticsearch connector
Key: FLINK-20768
URL: https://issues.apache.org/jira/browse/FLINK-20768
Project: Flink
Issue Type
wangsan created FLINK-20624:
---
Summary: Refactor StreamExecJoinRule、StreamExecIntervalJoinRule
and StreamExecTemporalJoinRule
Key: FLINK-20624
URL: https://issues.apache.org/jira/browse/FLINK-20624
Project
18 matches
Mail list logo
