Hi,
Is there any overhead to go from stream to table for sql query execution and go
back to stream for sink?
or is it better to do full streaming tabke/sql api (with table source and table
sink)?
Thx
eric
This message contains confidential information and is intended only for the
individual(s)
Hello
Working with flink 1.12.1 i read in the doc that Processing-time temporal
join is supported for kv like join but when i try i get a:
Exception in thread "main" org.apache.flink.table.api.TableException:
Processing-time temporal join is not supported yet.
at
org.apache.flink.table.pla
]. I'm gonna add Leonard to the
> thread. Maybe, he has a workaround for your case.
>
> Best,
> Matthias
>
> [1] https://issues.apache.org/jira/browse/FLINK-19830
>
> On Fri, Feb 26, 2021 at 11:40 AM eric hoffmann
> wrote:
>
>> Hello
>> Working with fl
2021年2月26日，23:41，Matthias Pohl 写道：
>>
>> Hi Eric,
>> it looks like you ran into FLINK-19830 [1]. I'm gonna add Leonard to the
>> thread. Maybe, he has a workaround for your case.
>>
>> Best,
>> Matthias
>>
>> [1] https://issues.apache.or
Hi, i use a jobcluster (1 manager and 1 worker) in kubernetes for streaming
application, i would like to have the lightest possible solution, is it
possible to use a localenvironment (manager and worker embeded) and still have
HA with zookeeper in this mode?, I mean kubernetes will restart the j
Hi.
I need to compute an euclidian distance between an input Vector and a full
dataset stored in Cassandra and keep the n lowest value. The Cassandra
dataset is evolving (mutable). I could do this on a batch job, but i will
have to triger it each time and the input are more like a slow stream, but
Hi
Is it possible to call batch job on a streaming context?
what i want to do is:
for a given input event, fetch cassandra elements based on event data,
apply transformation on them and apply a ranking when all elements fetched
by cassandra are processed.
If i do this in batch mode i would have to
Hi,
In a Kubernetes delpoyment, im not able to display metrics in the dashboard, I
try to expose and fix the metrics.internal.query-service.port variable
But nothing. Do you have any ideas?
Thx
Eric
Hi all, is there any reason to not use rowdata in the streaming api?, i
usualy use row type, any limitation after to go from and to table?
Eric
Hi ,
Im using flink 1.15, i mostly use datastream api, do you suggest i use row
or genericrowdata that inherit rowdata for my data structure?
Thx
10 matches
Mail list logo
