[jira] [Created] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

2019-04-27 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created FLINK-12352: Summary: [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack Key: FLINK-12352 URL:

The contradiction between event time and natural time from EventTimeTrigger

2019-04-27 Thread 邵志鹏
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

[jira] [Created] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

2019-04-27 Thread Jark Wu (JIRA)
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

[jira] [Created] (FLINK-12350) RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

2019-04-27 Thread Yu Li (JIRA)
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

[jira] [Created] (FLINK-12349) [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount

2019-04-27 Thread Ji Liu (JIRA)
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

[jira] [Created] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-04-27 Thread Jing Zhang (JIRA)
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:

Re: How to let Flink 1.7.X run Flink session cluster on YARN in Java 7 default environment

2019-04-27 Thread 126
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 >

[jira] [Created] (FLINK-12347) flink-table-runtime-blink is missing scala suffix

2019-04-27 Thread Chesnay Schepler (JIRA)
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

[jira] [Created] (FLINK-12346) Scala-suffix check broken on Travis

2019-04-27 Thread Chesnay Schepler (JIRA)
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

[jira] [Created] (FLINK-12345) Add support for generating optimized logical plan for stream window aggregate

2019-04-27 Thread godfrey he (JIRA)
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:

[jira] [Created] (FLINK-12344) Remove legacy runtime messages

2019-04-27 Thread TisonKun (JIRA)
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

Re: Warning from dev@flink.apache.org

2019-04-27 Thread aitozi
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