Hi there,
I am looking art using Flink to implement a fan-out of events, but
discovered a couple of issues attempting to implement on AWS Kinesis
Analytics:
- the version of Flink is pinned to 1.13.2
- there is currently no version of Pyflink that supports OutputTag
Does anyone know if it is poss
Hi, Yang!
When you say the operator uses native k8s integration by default, does that
mean there is a way to change that to use standalone K8s? I haven't seen
anything about that in the docs, besides a mention that standalone support
is coming in version 1.2 of the operator.
Thanks,
Javier
On
Hello,
I want to make the input record be the content of a field in the output record.
Can this be achieved with the Flink-SQL DSL?
Let's say I'm getting an input that looks like this:
{
...
"fields": [{
"name": "intField",
"type": "int"
}, {
"
