I am doing the same thing (migrating from standalone to operator in native
mode) and also have my jar in /opt/flink/lib but for me it works fine, no
class loading errors on app startup.
El vie, 16 sept 2022 a las 9:28, Yaroslav Tkachenko ()
escribió:
> Application mode. I've done a bit more resea
Thanks Marco,
I'll give it a try.
cheers
Noel
On Sat, Sep 17, 2022 at 7:14 PM Marco Villalobos
wrote:
>
> I might need more details, but conceptually, streams can be thought of as
> never ending tables
> and our code as functions applied to them.
>
> JOIN is a concept supported in the SQL API a
Hi, can this test case[1] help for you? You can use SQL like 'insert into ...
select ..., Array[...], MAP[...], Array[MAP[...]] from ...'. If this can not
meet your requirement, what about using UDF[2]?
[1]https://github.com/apache/flink/blob/65907bc5470bc43f0227ab287d2a6f150ba0bc29/flink-con
Hi Satish,
The Elasticsearch sink uses the new Sink, so the only possible metrics that
it can send by default are the ones documented in FLIP-33 [1]. Since the
JDBC connector doesn't use these interfaces, I don't think these metrics
are available out of the box.
Best regards,
Martijn
[1]
https:
