Step 1 of 4: Choose Issues

Cancel

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

FLINK-19976 Add documentation for batch mode in StreamTableEnvironment

Timo Walther Timo Walther Blocker Closed Fixed  
Sub-task FLINK-23768

FLINK-19976 Test StreamTableEnvironment batch mode in Python

Dian Fu Timo Walther Major Closed Done  
Sub-task FLINK-23707

FLINK-19976 Use consistent managed memory weights for StreamNode

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23646

FLINK-19976 Use pipeline name consistently across DataStream API and Table API

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23498

FLINK-19976 Use a layered configuration in Executor and Planner

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23482

FLINK-19976 Simplify BlinkExecutorFactory stack

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23424

FLINK-19976 Disable key sorting for Transformations created within table planner

Timo Walther Timo Walther Major Closed Not A Problem  
Sub-task FLINK-23402

FLINK-19976 Expose a consistent GlobalDataExchangeMode

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23373

FLINK-19976 Support object reuse disabled in OperatorChain

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23372

FLINK-19976 Disable AllVerticesInSameSlotSharingGroupByDefault in DataStream batch mode

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23371

FLINK-19976 Disable AutoWatermarkInterval for bounded legacy sources

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23370

FLINK-19976 Propagate Boundedness of SourceFunctionProvider to Transformation

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-23330

FLINK-19976 Deprecate toAppendStream and toRetractStream

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-22911

FLINK-19976 Align FLIP-136 (Improve interoperability between DataStream and Table API) in PyFlink Table API

Huang Xingbo Dian Fu Major Resolved Done  
Sub-task FLINK-22666

FLINK-19976 Make structured type's fields more lenient during casting

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-22590

FLINK-19976 Add Scala implicit conversions for new API methods

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-22537

FLINK-19976 Add documentation how to interact with DataStream API

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-22378

FLINK-19976 Type mismatch when declaring SOURCE_WATERMARK on TIMESTAMP_LTZ column

Timo Walther Timo Walther Critical Closed Fixed  
Sub-task FLINK-22138

FLINK-19976 Allow casting between row and structured type

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-21934

FLINK-19976 Add new StreamTableEnvironment.toDataStream

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-21872

FLINK-19976 Create a utility to create DataStream API's DataType and Schema

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-20971

FLINK-19976 Allow SQL expressions in Table API

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-20897

FLINK-19976 Support DataStream batch mode in StreamTableEnvironment

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-20862

FLINK-19976 Add a converter from TypeInformation to DataType

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-20019

FLINK-19976 Support all conversion classes in Row.equals/hashCode

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-19981

FLINK-19976 Improve dealing with Row in DataStream API

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-19980

FLINK-19976 Add StreamTableEnvironment.to/fromChangelogStream

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-19977

FLINK-19976 Add new StreamTableEnvironment.fromDataStream

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-18840

FLINK-19976 Add StreamStatementSet.attachAsDataStream

Timo Walther Timo Walther Major Closed Fixed  
Sub-task FLINK-17793

FLINK-19976 Replace TableSchema with dedicated CatalogSchema

Timo Walther Timo Walther Major Closed Fixed  

Cancel