[DISCUSS] FLIP-187: Adaptive Batch Job Scheduler

2021-10-20 Thread Lijie Wang
Hi all, Zhu Zhu and I propose to introduce a new job scheduler to Flink: adaptive batch job scheduler. The new scheduler can automatically decide parallelisms of job vertices for batch jobs, according to the size of data volume each vertex needs to process. Major benefits of this scheduler

[jira] [Created] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index

2021-09-25 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-24375: -- Summary: The name of flush thread in RecordWriter should contain subtask index Key: FLINK-24375 URL: https://issues.apache.org/jira/browse/FLINK-24375 Project: Flink

Re: [ANNOUNCE] New Apache Flink Committer - Yuan Mei

2021-07-07 Thread Lijie Wang
Congratulations, Yuan. Zakelly Lan 于2021年7月8日周四 上午10:16写道： > Congratulations, Yuan. > > Best, > Zakelly > > On Thu, Jul 8, 2021 at 10:14 AM Yun Tang wrote: > > > Congratulations, Yuan > > > > Best > > Yun Tang > > > > From: Yu Li > > Sent: Thursday, July 8,

Re: [ANNOUNCE] New Apache Flink Committer - Yang Wang

2021-07-07 Thread Lijie Wang
Congratulations Yang! Till Rohrmann 于2021年7月7日周三 下午5:29写道： > Congratulations, Yang! > > Cheers, > Till > > On Wed, Jul 7, 2021 at 9:41 AM Roman Khachatryan wrote: > > > Congrats! > > > > Regards, > > Roman > > > > > > On Wed, Jul 7, 2021 at 8:28 AM Qingsheng Ren wrote: > > > > > >

Re: [ANNOUNCE] New PMC member: Guowei Ma

2021-07-07 Thread Lijie Wang
Congratulations, Guowei Ma! Till Rohrmann 于2021年7月7日周三 下午5:30写道： > Congratulations, Guowei! > > Cheers, > Till > > On Wed, Jul 7, 2021 at 9:41 AM Roman Khachatryan wrote: > > > Congratulations! > > > > Regards, > > Roman > > > > On Wed, Jul 7, 2021 at 8:24 AM Rui Li wrote: > > > > > >

Re: Re: [ANNOUNCE] New PMC member: Arvid Heise

2021-06-24 Thread Lijie Wang
Congratulations! Igal Shilman 于2021年6月24日周四 下午5:46写道： > Congratulations Arvid! > Super well deserved! > > > On Thu, Jun 24, 2021 at 11:33 AM 刘建刚 wrote: > > > Congratulations > > > > Best > > liujiangang > > > > Matthias Pohl 于2021年6月23日周三 下午2:11写道： > > > > > Congratulations, Arvid! :-) > > >

[jira] [Created] (FLINK-20725) TableFunction#getTypeInference is not work well for JdbcRowDataLookupFunction, it's always throws Exception

2020-12-22 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-20725: -- Summary: TableFunction#getTypeInference is not work well for JdbcRowDataLookupFunction, it's always throws Exception Key: FLINK-20725 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-20160) Implement standard metrics in JDBC connectors.

2020-11-13 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-20160: -- Summary: Implement standard metrics in JDBC connectors. Key: FLINK-20160 URL: https://issues.apache.org/jira/browse/FLINK-20160 Project: Flink Issue Type: Sub

Re:[ANNOUNCE] Apache Flink 1.11.2 released

2020-09-18 Thread Lijie Wang
Congratulations! Thanks @ZhuZhu for driving this release ! On 09/17/2020 13:29，Zhu Zhu wrote： The Apache Flink community is very happy to announce the release of Apache Flink 1.11.2, which is the second bugfix release for the Apache Flink 1.11 series. Apache Flink® is an open-source stream

[jira] [Created] (FLINK-18442) Move `testSessionWindowsWithContinuousEventTimeTrigger` to `ContinuousEventTimeTriggerTest`

2020-06-28 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-18442: -- Summary: Move `testSessionWindowsWithContinuousEventTimeTrigger` to `ContinuousEventTimeTriggerTest` Key: FLINK-18442 URL: https://issues.apache.org/jira/browse/FLINK-18442

[jira] [Created] (FLINK-17296) Support "create table if not exists" in JDBC table sink.

2020-04-21 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-17296: -- Summary: Support "create table if not exists" in JDBC table sink. Key: FLINK-17296 URL: https://issues.apache.org/jira/browse/FLINK-17296 Project: Flink

[jira] [Created] (FLINK-17294) Using "DataSource" instead of "DriverManager" to get connection in JDBC connector

2020-04-21 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-17294: -- Summary: Using "DataSource" instead of "DriverManager" to get connection in JDBC connector Key: FLINK-17294 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-17178) Provide "ALL" cache strategy in LookupFunction

2020-04-16 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-17178: -- Summary: Provide "ALL" cache strategy in LookupFunction Key: FLINK-17178 URL: https://issues.apache.org/jira/browse/FLINK-17178 Project: Flink Issue

<    1   2   3