Hi yu,
Thanks for your reply. I have some inline comment.
Yu Li 于2019年4月28日周日 下午12:24写道：
> Glad to see discussions around QueryableState in mailing list, and it seems
> we have included a bigger scope in the discussion, that what's the data
> model in Flink and how to (or is it possible to) use
Zhanchun Zhang created FLINK-12354:
--
Summary: Add Reverse function supported in Table API and SQL
Key: FLINK-12354
URL: https://issues.apache.org/jira/browse/FLINK-12354
Project: Flink
Issue
Yun Tang created FLINK-12353:
Summary: Add missing module to collect_japicmp_reports.sh
Key: FLINK-12353
URL: https://issues.apache.org/jira/browse/FLINK-12353
Project: Flink
Issue Type: Bug
Thank you for your reminder, I will pay attention to this issue in the future.
I read some flink source code and saw that there are a lot of new features of
java8, such as CompletableFuture and Lambda expressions, which causes flink do
not run in jdk 1.7 environment, so you may need to upgrade y
Jiangjie Qin created FLINK-12352:
Summary: [FLIP-36] [Phase 1] Support cache() / invalidateCache()
in Table with default ShuffleService and NetworkStack
Key: FLINK-12352
URL: https://issues.apache.org/jira/browse/
Dear flinker:
Look at the contradiction between event time and natural time from
EventTimeTrigger.java (the window at the time of the break and the end of the
window at the end of the end must not be "real time"):
From the default EventTimeTrigger source code, I found that only onElement
met
Glad to see discussions around QueryableState in mailing list, and it seems
we have included a bigger scope in the discussion, that what's the data
model in Flink and how to (or is it possible to) use Flink as a database. I
suggest to open another thread for this bigger topic and personally I think
Jark Wu created FLINK-12351:
---
Summary: AsyncWaitOperator should deep copy StreamElement when
object reuse is enabled
Key: FLINK-12351
URL: https://issues.apache.org/jira/browse/FLINK-12351
Project: Flink
Yu Li created FLINK-12350:
-
Summary: RocksDBStateBackendTest doesn't cover the incremental
checkpoint code path
Key: FLINK-12350
URL: https://issues.apache.org/jira/browse/FLINK-12350
Project: Flink
Ji Liu created FLINK-12349:
--
Summary: [Java] Improve performance of
BaseValueVector#getValidityBufferSizeFromCount
Key: FLINK-12349
URL: https://issues.apache.org/jira/browse/FLINK-12349
Project: Flink
Jing Zhang created FLINK-12348:
--
Summary: Use TableConfig in api module to replace TableConfig in
blink-planner module.
Key: FLINK-12348
URL: https://issues.apache.org/jira/browse/FLINK-12348
Project: Fl
Flink源码中用到了很多java1.8的特性，所以用jdk1.7是不行的
发自我的 iPhone
> 在 2019年4月26日，17:48，胡逸才 写道：
>
> At present, all YARN clusters adopt JAVA 7 environment.
>
> While trying to use FLINK to handle the deployment of flow processing
> business scenarios, it was found that FLINK ON YARN mode always failed to
> p
Chesnay Schepler created FLINK-12347:
Summary: flink-table-runtime-blink is missing scala suffix
Key: FLINK-12347
URL: https://issues.apache.org/jira/browse/FLINK-12347
Project: Flink
Iss
Chesnay Schepler created FLINK-12346:
Summary: Scala-suffix check broken on Travis
Key: FLINK-12346
URL: https://issues.apache.org/jira/browse/FLINK-12346
Project: Flink
Issue Type: Bug
godfrey he created FLINK-12345:
--
Summary: Add support for generating optimized logical plan for
stream window aggregate
Key: FLINK-12345
URL: https://issues.apache.org/jira/browse/FLINK-12345
Project: Fl
TisonKun created FLINK-12344:
Summary: Remove legacy runtime messages
Key: FLINK-12344
URL: https://issues.apache.org/jira/browse/FLINK-12344
Project: Flink
Issue Type: Sub-task
Compone
Hi, dev-owner:
I'm not quite understand the mail, can you tell me what's it point to ?
Thanks,
Aitozi
On 2019/4/27, 1:40 AM, "dev-h...@flink.apache.org"
wrote:
Hi! This is the ezmlm program. I'm managing the
dev@flink.apache.org mailing list.
I'm working for my owner, who c
17 matches
Mail list logo
