Fairly new to Flink here so this might be a newbie mistake, but here's the
problem. I created the following table and view:
> CREATE TABLE test (
>
> event_time TIMESTAMP(3),
>
> symbol STRING,
>
> price DOUBLE,
>
> WATERMARK FOR event_time AS event_time - INT
Forgot to mention, I am using Flink 1.12.
On Fri, Jan 29, 2021 at 10:11 AM Patrick Angeles
wrote:
> Fairly new to Flink here so this might be a newbie mistake, but here's the
> problem. I created the following table and view:
>
>
>> CREATE TABLE test (
>>
>
.html#selecting-group-window-start-and-end-timestamps
>
> Seth
>
> On Fri, Jan 29, 2021 at 9:14 AM Patrick Angeles
> wrote:
>
>> Forgot to mention, I am using Flink 1.12.
>>
>> On Fri, Jan 29, 2021 at 10:11 AM Patrick Angeles <
>> patrickange...@gmail.co
Another (hopefully newbie) question. Trying to use LEAD/LAG over window
functions. I get the following error. The exact same query works properly
using FIRST_VALUE instead of LEAD.
Thanks in advance...
- Patrick
Flink SQL> describe l1_min ;
+---++--+-+--
>
>> Hi Patrick,
>>
>> I could imagine that LEAD/LAG are translated into RANK/ROW_NUMBER
>> operations that are not supported in this context.
>>
>> But I will loop in @Jark who might know more about the limitaitons here.
>>
>> Regards,
>>
Wondering if anyone has seen this before, and has any suggestions. I have a
UDTF with the following signature:
public void eval(LocalDateTime startTime, LocalDateTime endTime, Duration
> step) {
According to the docs, this should be mapped from the following SQL snippet:
... LATERAL TABLE func(
e;
> } else {
> return isDatetime(type) || isNumeric(type) || isString(type) ||
> isBoolean(type);
> }
> }
Seems like a bug?
On Wed, Feb 17, 2021 at 5:55 PM Patrick Angeles
wrote:
> Wondering if anyone has seen this before, and has any suggestions. I have
> a UDTF
NVM. Found the actual source on Calcite trunk. Looks like interval type
(and a few others) are not yet supported.
https://github.com/apache/calcite/blob/master/core/src/main/java/org/apache/calcite/sql/type/SqlTypeUtil.java
On Wed, Feb 17, 2021 at 8:11 PM Patrick Angeles
wrote:
> For s
d be nice to solve
> it on both the Calcite and Flink side.
>
> Thanks,
> Timo
>
>
> On 18.02.21 06:02, Patrick Angeles wrote:
> > NVM. Found the actual source on Calcite trunk. Looks like interval type
> > (and a few others) are not yet supported.
> >
> >
Hey all,
Trying to follow FLINK-13448. Seems like all the subtasks, save for one on
documentation, are completed... does this mean there will be an arm64
binary available in the next release (1.14)?
Hey all,
I thought this might be of interest to the community. Basically, we took
Jark Wu's demo (
https://flink.apache.org/2020/07/28/flink-sql-demo-building-e2e-streaming-application.html)
and replaced Kafka with Redpanda:
https://vectorized.io/blog/redpanda-flink-docker/
Regards,
P
11 matches
Mail list logo
