|
|
|
FLINK-21909
|
FLINK-21871
Unify API and implementation for Hive and Filesystem source connector
|
Unassigned
|
Jark Wu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-21908
|
FLINK-21871
Support HiveSource to emit watermarks which is extract from partition values
|
Unassigned
|
Jark Wu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-21907
|
FLINK-21871
Support watermark syntax for Hive DDL dialect
|
Unassigned
|
Jark Wu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-21906
|
FLINK-21871
Support computed column syntax for Hive DDL dialect
|
Unassigned
|
Jark Wu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-21905
|
FLINK-21871
Hive streaming source should use FIFO FileSplitAssigner instead of LIFO
|
Unassigned
|
Jark Wu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-21899
|
FLINK-21871
Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21894
|
FLINK-21871
Update type of HiveTablePartition#partitionSpec from Map<String, Object> to Map<String, String>
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-15528
|
FLINK-21871
Support higher precision of TIMESTAMP type as rowtime attribute
|
Unassigned
|
Jark Wu
|
|
Open |
Unresolved
|
|
|
|
|