unsubscribe
Hello apache-flink team,
For the last week I am really struggling with setting up EMR to store
stream output to AWS S3.
According to the documentation, if running flink with emr, no manual
adjustments are required, however even having the plugin placed in plugins
folder based on documentation I kee
Hi all,
I wasn't sure if this would be the best audience, if not, please advise if
you know of a better place to ask it. I figured that at least some folks
here either work for Ververica or might have used their platform.
*tl;dr; I'm trying to migrate an existing stateful Flink job to run in
Verv
Hi, IMO, I think you'd better use 'Row' instead of using 'genericrowdata'
because 'GenericRowData' is only one sub-class implement from 'RowData', and
'RowData' has other sub-classes that are used in different scenes.
Actually, the two types can be converted to each other [1].
[1]
https:/
Hi Mike,
I think that's caused by you not having enabled checkpointing. If you
enable that, it should be resolved I think.
Best regards,
Martijn
On Wed, Aug 3, 2022 at 9:01 PM wrote:
>
> Thank you very much Martijn you dedicated your productive time to help me!
> I'm new noob in this subject
For which Scala 2.12 version are you trying to compile? Flink supports
Scala versions up to 2.12.7, since 2.12.8 introduced a binary
incompatibility. Most likely (but not tested) you can compile for a
different Scala version by using mvn clean install -DskipTests
-Djapicmp.skip -Dscala-2.12 -Dscala
Hi Seth,
I think the global watermark / mark as idle is one of the reasons why the
FLIP-27 [1] interfaces were created, while FLIP-180 [2] is also relevant
here. Unfortunately, the FlinkKinesisConsumer is still using the old
interface. I'm not sure it can be properly fixed with the old interfaces.
