eam/kinesis/#kinesis-streams-sink
>
> Best,
> Aleksandr
>
>
> On Thu, 23 May 2024 at 17:19, Nick Hecht
> wrote:
>
>> Hello,
>>
>> I am currently having issues trying to use the python flink 1.18
>> Datastream api with the Amazon Kinesis Data Streams Connect
27;t understand what I'm missing. The jar
I'm using should have everything.
anyone else have similar issues? or know what I might need to do?
Thank you,
Nick Hecht
ck.
> Can you try `cascading window aggregation` here[1] if it meets your needs?
>
> [1]
> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/window-agg/#cascading-window-aggregation
>
>
> --
> Best！
> Xuyang
>
>
> At 2024-03-1
ver(lit(1).hour).every(lit(2).seconds).on(col("proc_time"
)).alias("slide_window")
)
.group_by(col("a"),col("b"),col("slide_window")).select(
col("a"),
col("b"),
second_process(
col("a"),
col("b"),
col("first_out"),
).alias("second_out"),
)
).execute().print()
second_stage.wait()
My first stage and sql parts are working fine. I'm not sure how to pass in
a valid time value into my second stage because I cannot add it to my first
stage group.
Any advice would be appreciated!
Thank you!
Nick Hecht
