|
|
|
FLINK-34340
|
FLINK-24438
Implement DDB Streams Table API support
|
Unassigned
|
Danny Cranmer
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-33180
|
FLINK-24438
Implement support for processing subset of shards/traffic
|
Unassigned
|
Chandra Prakash
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-32097
|
FLINK-24438
Implement support for Kinesis deaggregation
|
Unassigned
|
Hong Liang Teoh
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-31989
|
FLINK-24438
Update documentation
|
Unassigned
|
Hong Liang Teoh
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-31988
|
FLINK-24438
Implement Python wrapper for new KDS source
|
Unassigned
|
Hong Liang Teoh
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-31987
|
FLINK-24438
Implement KDS Table API support
|
Burak Ozakinci
|
Hong Liang Teoh
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-31986
|
FLINK-24438
Implement Integration test for FLIP-27 DataStreams API
|
Elphas Toringepi
|
Hong Liang Teoh
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-31980
|
FLINK-24438
Implement support for EFO in new KDS Source
|
Hong Liang Teoh
|
Hong Liang Teoh
|
|
Open |
Unresolved
|
|
|
|
|