Hi shaoxuan:
Does the table API'S StreamSQL grammar is compatible with calcite's StreamSQL
grammar?
1、In calcite, the tumble window is realized by using function tumble or hop.
And the function must be used with group by, like this:
SELECT
TUMBLE_END(rowtime, INTERVAL '30' MINUTE, TIME '0:
o in my opinion, the grammar which is marked red should be compatible with
calcite's StreamSQL grammar.
By the way, thanks very much for telling me the modified content in Flink
StreamSQL. I will look the new proposal .
Thanks!
发件人: Sean Wang [mailto:wshaox...@gmail.com]
发送时间: 2016年10月13日 16:29
收
Wang; Timo Walther
主题: Re: 答复: RE：[DISCUSS] FLIP-11: Table API Stream Aggregations
Hi Zhangrucong,
yes, we want to use Calcite's SQL parser including its window syntax, i.e.,
- the standard SQL OVER windows (in streaming with a few restriction such as no
different partitionings or orders)
Hi:
The following syntax, I think it is sub query. In the calcite, it is optimal
to semi-join.
SELECT STREAM amount,
(SELECT id FROM inputstream1) AS field1 FROM inputstream2
In my opinion, If the unbounded stream join the unbounded stream, there is
no result. The stream may join with str
Hi:
I want to use the ACL of Zookeeper. So I configure the following
configurations:
1、 high-availability.zookeeper.path.root: flink234
2、 high-availability.zookeeper.client.acl: creator
3、 zookeeper.sasl.disable: false
But， I use ZK client to get the ACL, the result is :
[cid:image00
Hi:
We want to download the binaries and source code of flink 1.3.0 release from
https://flink.apache.org/downloads.html. I use the fllowing link:
[cid:image001.png@01D2E046.E3727F70]\
But the package size is not correct.
[cid:image002.png@01D2E046.E3727F70]
And the souce code is also not
thru.
Consider use third party site for images.
Thanks
On Wed, Jun 7, 2017 at 8:05 PM, Zhangrucong wrote:
> Hi:
>
>We want to download the binaries and source code of flink 1.3.0
> release from https://flink.apache.org/downloads.html. I use the fllowing
> link:
>
>
>
Jun 7, 2017 at 8:27 PM, Zhangrucong wrote:
> Sorry, Ted. I put the images in attachments, can you see it?
>
> We want to download the binaries and source code of flink 1.3.0
> release from https://flink.apache.org/downloads.html. I use the link
> which is showed in image of bina
...@gmail.com]
发送时间: 2017年6月8日 12:12
收件人: Zhangrucong
抄送: dev@flink.apache.org
主题: Re: About flink 1.3.0 release packages.
From #2, you need to choose a mirror site.
What you have downloaded should be an html page.
> On Jun 7, 2017, at 8:48 PM, Zhangrucong wrote:
>
> Hi Ted:
>
: Zhangrucong
抄送: dev@flink.apache.org
主题: Re: About flink 1.3.0 release packages.
Do you not see multiple choices under:
http://www.apache.org/dyn/closer.lua/flink/flink-1.3.0/flink-1.3.0-bin-hadoop27-scala_2.11.tgz
If not, try using the following link:
http://www-us.apache.org/dist/flink/flink-1.3.0
Hi Ted:
I modify the link http://archive.apache.org/dist/flink/flink-1.2.1/ to
http://archive.apache.org/dist/flink/flink-1.3.0/
The http://archive.apache.org/dist/flink/flink-1.3.0/ is exist. But there is no
link in downloads html to redirect there.
Thanks a lot!
发件人: Zhangrucong
发送时间: 2017年6
Congrats Shaoxuan!
-邮件原件-
发件人: Fabian Hueske [mailto:fhue...@gmail.com]
发送时间: 2017年6月22日 4:19
收件人: dev@flink.apache.org
主题: [ANNOUNCE] New Flink committer Shaoxuan Wang
Hi everybody,
On behalf of the PMC, I'm very happy to announce that Shaoxuan Wang has
accepted the invitation of the
zhangrucong created FLINK-2487:
--
Summary: the array has out of bounds
Key: FLINK-2487
URL: https://issues.apache.org/jira/browse/FLINK-2487
Project: Flink
Issue Type: Bug
Components
zhangrucong created FLINK-2531:
--
Summary: combining the "if" branch to improve the performance
Key: FLINK-2531
URL: https://issues.apache.org/jira/browse/FLINK-2531
Project: Flink
zhangrucong created FLINK-2532:
--
Summary: The function name and the variable name are same, it is
confusing
Key: FLINK-2532
URL: https://issues.apache.org/jira/browse/FLINK-2532
Project: Flink
15 matches
Mail list logo
