flink-table-api

12 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
"Cannot map checkpoint/savepoint state for operator" when using fromChangelogStream
user_144419250
•
1
1
53
flink-table-api savepoints apache-flink
Unexpected type: BINARY
user_13453030
•
1
0
38
flink-table-api flink-sql flink-streaming apache-flink scala
java.lang.NoClassDefFoundError: org/apache/flink/table/types/logical/LogicalTypeRoot
user_13453030
•
1
1
89
flink-table-api flink-streaming apache-flink scala java
How to convert a Table to a DataStream containing array types (Flink)?
user_44784120
•
5
1
391
flink-table-api flink-streaming apache-flink
Apache Flink 1.14.0 - Unable to use python UDF through SQL DDL in Java
user_99290670
•
3
2
434
flink-table-api apache-flink user-defined-functions
Flink sink filesystem as parquet - error on saving nested data
user_126451320
•
3
2
236
flink-table-api flink-sql apache-flink parquet
Flink Sql not converting RAW('org.apache.avro.util.Utf8', '...') to String
user_19302590
•
2
0
333
flink-table-api flink-sql apache-flink
Flink nested classes toDataStream conversion error
user_13373380
•
2
1
378
flink-table-api flink-streaming apache-flink
Flink Table-API and DataStream ProcessFunction
user_44784120
•
2
1
171
flink-table-api flink-streaming apache-flink
How to assign a unique ID to each row in a table in the Flink Table API?
user_24827440
•
2
0
507
flink-table-api flink-sql flink-streaming apache-flink
Hot Questions