Questions about flink-streaming
Read more about flink-streaming
python (12.9k questions)
javascript (9.2k questions)
reactjs (4.7k questions)
java (4.2k questions)
java (4.2k questions)
c# (3.5k questions)
c# (3.5k questions)
html (3.3k questions)
What's the correct way to pass environment variables to a keyed function and how could it be used with the KeyedOneInputStreamOperatorTestHarness
I need to pass some configuration to a custom KeyedProcessFunction and I would like to test it with KeyedOneInputStreamOperatorTestHarness. What's the proper way to handle this?
I've looked to the doc...
Carlos Miguel Santos
Votes: 0
Answers: 1
How to convert a Table to a DataStream containing array types (Flink)?
I have issues concerning the table-api of Flink (1.13+). I have a POJO containing several fields, one of them being:
List<String> my_list;
I create my table using the following declaration for...
Fray
Votes: 0
Answers: 1
Flink Table API : AppendStreamTableSink doesn't support consuming update changes which is produced by node GroupAggregate
I am trying to generate aggregates on a Streaming Source and when i try to run the Table API queries i am getting the following Error.
AppendStreamTableSink doesn't support consuming update changes wh...
Sateesh K
Votes: 0
Answers: 1
Pyflink session window aggregation by separate keys
I'm trying to wrap my head around the pyflink datastream api.
My use case is the following:
The source is a kinesis datastream consisting of the following:
cookie
cluster
dim0
dim1
dim2
time_event...
irr_pie
Votes: 0
Answers: 0