[jira] [Created] (FLINK-19566) TableITCase.testCollectWithClose failed with "IllegalStateException: MiniCluster is not yet running or has already been shut down"

2020-10-10 Thread Dian Fu (Jira)
Dian Fu created FLINK-19566: --- Summary: TableITCase.testCollectWithClose failed with "IllegalStateException: MiniCluster is not yet running or has already been shut down" Key: FLINK-19566 URL:

Re:[VOTE] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread hailongwang
+1(non-binding) Best, Hailong Wang At 2020-10-10 17:06:07, "Jark Wu" wrote: >Hi all, > >I would like to start the vote for FLIP-145 [1], which is discussed and >reached consensus in the discussion thread [2]. > >The vote will be open until 13th Oct. (72h), unless there is an objection >or not

Re: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread 刘大龙
+1 > -原始邮件- > 发件人: "Jark Wu" > 发送时间: 2020-10-10 18:50:20 (星期六) > 收件人: dev > 抄送: > 主题: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function > > +1 > > On Sat, 10 Oct 2020 at 18:41, Benchao Li wrote: > > > +1 > > > > Jark Wu 于2020年10月10日周六 下午6:06写道: > > > > > Hi all, >

Re: [VOTE] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Pengcheng Liu
+1, Thanks Jark for driving this. Jark Wu 于2020年10月10日周六 下午6:50写道: > +1 > > On Sat, 10 Oct 2020 at 18:41, Benchao Li wrote: > > > +1 > > > > Jark Wu 于2020年10月10日周六 下午6:06写道: > > > > > Hi all, > > > > > > I would like to start the vote for FLIP-145 [1], which is discussed and > > > reached

Re: [VOTE] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Jark Wu
+1 On Sat, 10 Oct 2020 at 18:41, Benchao Li wrote: > +1 > > Jark Wu 于2020年10月10日周六 下午6:06写道: > > > Hi all, > > > > I would like to start the vote for FLIP-145 [1], which is discussed and > > reached consensus in the discussion thread [2]. > > > > The vote will be open until 13th Oct. (72h),

Re: [VOTE] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Benchao Li
+1 Jark Wu 于2020年10月10日周六 下午6:06写道: > Hi all, > > I would like to start the vote for FLIP-145 [1], which is discussed and > reached consensus in the discussion thread [2]. > > The vote will be open until 13th Oct. (72h), unless there is an objection > or not enough votes. > > Best, > Jark > >

[jira] [Created] (FLINK-19565) java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runti

2020-10-10 Thread yardstrong (Jira)
yardstrong created FLINK-19565: -- Summary: java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runtime.jobgraph.JobVertex

[VOTE] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Jark Wu
Hi all, I would like to start the vote for FLIP-145 [1], which is discussed and reached consensus in the discussion thread [2]. The vote will be open until 13th Oct. (72h), unless there is an objection or not enough votes. Best, Jark [1]:

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Jark Wu
Hi everyone, Thanks everyone for this healthy discussion. I think we have addressed all the concerns. I would continue with a voting. If you have any new objections, feel free to let me know. Best, Jark On Sat, 10 Oct 2020 at 17:54, Jark Wu wrote: > Hi Jingsong, > > That's a good question. I

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Jark Wu
Hi Jingsong, That's a good question. I did have searched a lot and didn't find any system that provides such an out-of-box function. I guess the reason is that in the traditional batch systems, this feature is supported by the over window and they don't need to invent a new function/syntax for

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Jingsong Li
+1 for voting. Thanks Jark for driving. +1 for TVF, It has been put forward by theory and supported by calcite. It will greatly enhance the window related operations. My personal feeling is that after TVF, the following operations can be similar to the traditional batch SQL, as long as the

[jira] [Created] (FLINK-19564) Parquet lack parquet-format-structures dependency

2020-10-10 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-19564: Summary: Parquet lack parquet-format-structures dependency Key: FLINK-19564 URL: https://issues.apache.org/jira/browse/FLINK-19564 Project: Flink Issue

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Jark Wu
Hi Pengcheng, IIUC, the "stream operators" you mean is the non-time operators or called regular operators, such as regular join, regular aggregate. But you may misunderstand me, only the time operators can't be applied after the new window operators, because of missing time attributes. The

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Jark Wu
Hi Danny, Thanks for the hint about named params syntax, I added examples with named params in the FLIP. Best, Jark On Sat, 10 Oct 2020 at 15:03, Pengcheng Liu wrote: > Hi, Jark, > >I've got some different opinions there, I think it's a very common use > case to use >window operators

[jira] [Created] (FLINK-19563) database and table,two option can be combined into one

2020-10-10 Thread Zhengchao Shi (Jira)
Zhengchao Shi created FLINK-19563: - Summary: database and table,two option can be combined into one Key: FLINK-19563 URL: https://issues.apache.org/jira/browse/FLINK-19563 Project: Flink

[jira] [Created] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username

2020-10-10 Thread Zhengchao Shi (Jira)
Zhengchao Shi created FLINK-19562: - Summary: the /flink/docs/docker/run.sh cause an error with numeric username Key: FLINK-19562 URL: https://issues.apache.org/jira/browse/FLINK-19562 Project: Flink

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Pengcheng Liu
Hi, Jark, I've got some different opinions there, I think it's a very common use case to use window operators in combination with streaming operators(even those time operators). (e.g. for some tables, users only care data within a period, but for other tables, they may want the whole

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Danny Chan
Thanks for driving this Jark ~ The FLIP overall looks good, i think the window TVFs would be the main "entry point" syntax for our NTR use cases. The syntax originated from the "One SQL To Rule Them All" paper and i think we have reached an agreement. I want to make some additions to the

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread Benchao Li
Hi Jark, Thanks for your reply, this makes sense to me. The scenario I used above is just a case to explain what I'm concerned about, not necessarily a production use case. We can leave it to the future to see whether other users have these use cases. Then I have no other concerns, +1 to start