[ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee

Hi all, I'm very happy to announce that Jingsong Lee has joined the Flink PMC! Jingsong became a Flink committer in Feb 2020 and has been continuously contributing to the project since then, mainly in Flink SQL. He has been quite active in the mailing list, fixing bugs, helping verifying releases

Re: [VOTE] FLIP-228: Support Within between events in CEP Pattern

+1 (binding) Looking forward :) Thanks, Martijn Op ma 13 jun. 2022 om 04:16 schreef Nicholas : > Hi everyone， > > > > > Thanks for feedback for FLIP-228: Support Within between events in CEP > Pattern[1] on the discussion thread[2]. I'd like to start a VOTE thread for > FLIP-228. > > The vote w

Re: [DISCUSS] FLIP-240: Introduce "ANALYZE TABLE" Syntax

Hi Ingo, The semantics does not distinguish batch and streaming, It works for both batch and streaming, but the result of unbounded sources is meaningless. Currently, I throw exception for streaming mode, and we can support streaming mode with bounded source in the future. Best, Godfrey Ingo Bür

Re: [DISCUSS] FLIP-240: Introduce "ANALYZE TABLE" Syntax

Hi Godfrey, thank you for the explanation. A SELECT is definitely more generic and will work for all connectors automatically. As such I think it's a good baseline solution regardless. We can also think about allowing connector-specific optimizations in the future, but I do like your idea of

[jira] [Created] (FLINK-28015) FROM_UNIXTIME could not be used in Table API

Dian Fu created FLINK-28015: --- Summary: FROM_UNIXTIME could not be used in Table API Key: FLINK-28015 URL: https://issues.apache.org/jira/browse/FLINK-28015 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-240: Introduce "ANALYZE TABLE" Syntax

Hi Ingo, Thanks for the inputs. I think converting `ANALYZE TABLE` to `SELECT` statement is more generic approach. Because query plan optimization is more generic, we can provide more optimization rules to optimize not only `SELECT` statement converted from `ANALYZE TABLE` but also the `SELECT`

Re: [DISCUSS] FLIP-240: Introduce "ANALYZE TABLE" Syntax

Hi cao, Thanks for the feedback. AFAK, unlike databases' behavior, the statistics will not collected automatically when writing data for many big data compute engines. FLIP-231[1] has introduced SupportsStatisticsReport interface which the planner will collect the statistics from connector when s

[VOTE] FLIP-228: Support Within between events in CEP Pattern

Hi everyone， Thanks for feedback for FLIP-228: Support Within between events in CEP Pattern[1] on the discussion thread[2]. I'd like to start a VOTE thread for FLIP-228. The vote will be open for at least 72 hours unless there is an objection or not enough votes. Regards, Nicholas Jian

[jira] [Created] (FLINK-28014) Extract snapshot related methods to SnapshotManager

Caizhi Weng created FLINK-28014: --- Summary: Extract snapshot related methods to SnapshotManager Key: FLINK-28014 URL: https://issues.apache.org/jira/browse/FLINK-28014 Project: Flink Issue Type:

[RESULT][VOTE] FLIP-223: Support HiveServer2 Endpoint

Hi dev, FLIP-223: Support HiveServer2 Endpoint[1] has been accepted. There are 3 binding votes, 3 non-binding votes[2]. - Jark Wu(binding) - godfrey he(binding) - Nicholas Jiang(non-binding) - Jingsong Li(binding) - Jing Ge(non-binding) - Luning Wang(non-binding) None against. Thanks again for

[jira] [Created] (FLINK-28013) java.lang.ClassNotFoundException: org.apache.flink.hbase.shaded.io.netty.channel.EventLoopGroup

JasonLee created FLINK-28013: Summary: java.lang.ClassNotFoundException: org.apache.flink.hbase.shaded.io.netty.channel.EventLoopGroup Key: FLINK-28013 URL: https://issues.apache.org/jira/browse/FLINK-28013

[jira] [Created] (FLINK-28012) Add built-in support for fetching jar from GCS (Google Cloud Storage)

Xin Hao created FLINK-28012: --- Summary: Add built-in support for fetching jar from GCS (Google Cloud Storage) Key: FLINK-28012 URL: https://issues.apache.org/jira/browse/FLINK-28012 Project: Flink