ltiple extends in the future, instead of
just allowing a direct single subclass?
On Thu, Sep 15, 2022 at 4:42 PM Jonathan Weaver
wrote:
> I am having an issue with the automatic type inference with SQL engine in
> an AsyncTableFunction class.
>
> I am extending AsyncTableFunction in a Bas
I am having an issue with the automatic type inference with SQL engine in
an AsyncTableFunction class.
I am extending AsyncTableFunction in a BaseClass (common code).
Then extending again for some specific implementations.
FinalClass extends BaseClass
If I use BaseClass it correctly infers the
I think the piece you are missing is you cannot guarantee where the
function will run in general. It may get sent to several different task
executors, and each executor may not be on the same machine or JVM so the
code has to init once distributed at least once.
You have to think that every functi
I am working on developing a custom source with the new Source api.
What I'm noticing is that during periods of low incoming data it repeatedly
will shutdown and restart the fetchers when the split assignments are empty
and periodically added.
I get log message such as
org.apache.flink.connector
I'm doing a POC on moving an existing Datastream API job to use Table SQL
to make it more accessible for some of my teammates.
However I'm at a loss on how to handle watermarking in a similar way to how
it was handled in the Datastream API.
In the existing job a CDC stream is read, and 3 SQL tabl
Using the latest SNAPSHOT BUILD.
If I have a column definition as
.column(
"events",
DataTypes.ARRAY(
DataTypes.ROW(
DataTypes.FIELD("status",
DataTypes.STRING().notNull()),
DataTypes.FIELD("times
ot a correct
> type, the serializer just fails hard.
>
> Please correct me if I misunderstood what you're doing, and in case
> provide more info about what your goal and how you've implemented the job.
>
> FG
>
> On Wed, Feb 16, 2022 at 4:02 AM Jonathan Weaver
&
or the community to help.
>
> On Tue, 15 Feb 2022, 23:33 Jonathan Weaver,
> wrote:
>
>> I'm getting the following exception running locally from my IDE
>> (IntelliJ) but seems to not occur
>> when running on a cluster. I'm assuming it may be related to memory
&g
I'm getting the following exception running locally from my IDE (IntelliJ)
but seems to not occur
when running on a cluster. I'm assuming it may be related to memory
settings on the runtime (machine has 64GB of ram avail) but not sure what
setting to try and change.
Caused by: java.lang.IndexOutOf
I'm attempting to do a proof of concept conversion of a DataStream based
Flink program over to using almost entirely Table SQL.
I have a primary CDC stream (an unbounded scan table source) that does two
joins to LookupTableSource tables and then on to a sink.
In the datastream program the only wa
10 matches
Mail list logo
