Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task FLINK-33525

FLINK-28045 Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API

Unassigned Alexander Fedulov Major Open Unresolved  
Sub-task FLINK-33326

FLINK-28045 Remove usage of FromElementsFunction

Alexander Fedulov Alexander Fedulov Major Open Unresolved  
Sub-task FLINK-32713

FLINK-28045 Cascade deprecation to non-private methods that reference SourceFunction

Alexander Fedulov Alexander Fedulov Major Resolved Fixed  
Sub-task FLINK-32696

FLINK-28045 Promote Kinesis connector support to PublicEvolving

Unassigned Alexander Fedulov Major Open Unresolved  
Sub-task FLINK-32695

FLINK-28045 Migrate SourceFunction in Tests to Source V2 API

Alexander Fedulov Alexander Fedulov Major Open Unresolved  
Sub-task FLINK-32694

FLINK-28045 Migrate ParallelSourceFunction classes to Source V2 API or prepare for removal

Alexander Fedulov Alexander Fedulov Major Open Unresolved  
Sub-task FLINK-32673

FLINK-28045 Migrage Google PubSub connector to V2

Unassigned Alexander Fedulov Major Open Unresolved  
Sub-task FLINK-32672

FLINK-28045 Migrate RabbitMQ connector to Source V2 API

Unassigned Alexander Fedulov Major Open Unresolved  
Sub-task FLINK-32670

FLINK-28045 Cascade deprecation to classes that implement SourceFunction

Alexander Fedulov Alexander Fedulov Major Resolved Resolved  
Sub-task FLINK-28229

FLINK-28045 Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods

Alexander Fedulov Alexander Fedulov Major Closed Fixed  
Sub-task FLINK-28227

FLINK-28045 Migrate o.a.f.streaming.examples to the new Source API

Alexander Fedulov Alexander Fedulov Major Closed Done  
Sub-task FLINK-28055

FLINK-28045 Introduce Source API utilities for throttling number of records emitted per second.

Alexander Fedulov Alexander Fedulov Major Resolved Implemented  
Sub-task FLINK-28051

FLINK-28045 Promote ExternallyInducedSourceReader to non-experimental @Public

Unassigned Alexander Fedulov Major Open Unresolved  
Sub-task FLINK-28050

FLINK-28045 Introduce Source API alternative to SourceExecutionContext#fromElements(*) methods

Alexander Fedulov Alexander Fedulov Major Closed Fixed  
Sub-task FLINK-28048

FLINK-28045 Introduce Source API alternative to FiniteTestSource

Alexander Fedulov Alexander Fedulov Major Resolved Implemented  
Sub-task FLINK-28047

FLINK-28045 Annotate StreamExecutionEnvironment#readFile()/readTextFile(*) methods deprecated in favor of FileSource#forRecordStreamFormat/forBulkFileFormat

Alexander Fedulov Alexander Fedulov Major Closed Fixed  
Sub-task FLINK-28046

FLINK-28045 Annotate SourceFunction as deprecated

Alexander Fedulov Alexander Fedulov Major Resolved Resolved  

Cancel