Timo Walther created FLINK-23834:
Summary: Test StreamTableEnvironment batch mode manually
Key: FLINK-23834
URL: https://issues.apache.org/jira/browse/FLINK-23834
Project: Flink
Issue Type: I
Timo Walther created FLINK-23832:
Summary: Add documentation for batch mode in StreamTableEnvironment
Key: FLINK-23832
URL: https://issues.apache.org/jira/browse/FLINK-23832
Project: Flink
Is
Timo Walther created FLINK-23768:
Summary: Test StreamTableEnvironment batch mode in Python
Key: FLINK-23768
URL: https://issues.apache.org/jira/browse/FLINK-23768
Project: Flink
Issue Type:
Timo Walther created FLINK-23707:
Summary: Use consistent managed memory weights for StreamNode
Key: FLINK-23707
URL: https://issues.apache.org/jira/browse/FLINK-23707
Project: Flink
Issue Ty
Timo Walther created FLINK-23663:
Summary: Reduce state size in ChangelogNormalize through filter
push down
Key: FLINK-23663
URL: https://issues.apache.org/jira/browse/FLINK-23663
Project: Flink
Timo Walther created FLINK-23646:
Summary: Use pipeline name consistently across DataStream API and
Table API
Key: FLINK-23646
URL: https://issues.apache.org/jira/browse/FLINK-23646
Project: Flink
Timo Walther created FLINK-23498:
Summary: Use a layered configuration in Executor and Planner
Key: FLINK-23498
URL: https://issues.apache.org/jira/browse/FLINK-23498
Project: Flink
Issue Typ
Timo Walther created FLINK-23482:
Summary: Simplify BlinkExecutorFactory stack
Key: FLINK-23482
URL: https://issues.apache.org/jira/browse/FLINK-23482
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-23470:
Summary: Use blocking shuffles but pipeline within a slot
Key: FLINK-23470
URL: https://issues.apache.org/jira/browse/FLINK-23470
Project: Flink
Issue Type:
Timo Walther created FLINK-23450:
Summary: Properties map is not set in DebeziumAvroFormatFactory
Key: FLINK-23450
URL: https://issues.apache.org/jira/browse/FLINK-23450
Project: Flink
Issue
Timo Walther created FLINK-23426:
Summary: Support changelog processing in batch mode
Key: FLINK-23426
URL: https://issues.apache.org/jira/browse/FLINK-23426
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-23424:
Summary: Disable key sorting for Transformations created within
table planner
Key: FLINK-23424
URL: https://issues.apache.org/jira/browse/FLINK-23424
Project: Flink
Timo Walther created FLINK-23402:
Summary: Expose a consistent GlobalDataExchangeMode
Key: FLINK-23402
URL: https://issues.apache.org/jira/browse/FLINK-23402
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-23384:
Summary: Use upper case name for all BuiltInFunctionDefinitions
Key: FLINK-23384
URL: https://issues.apache.org/jira/browse/FLINK-23384
Project: Flink
Issue
Timo Walther created FLINK-23373:
Summary: Support object reuse disabled in OperatorChain
Key: FLINK-23373
URL: https://issues.apache.org/jira/browse/FLINK-23373
Project: Flink
Issue Type: Su
Timo Walther created FLINK-23372:
Summary: Disable AllVerticesInSameSlotSharingGroupByDefault in
DataStream batch mode
Key: FLINK-23372
URL: https://issues.apache.org/jira/browse/FLINK-23372
Project:
Timo Walther created FLINK-23371:
Summary: Disable AutoWatermarkInterval for bounded legacy sources
Key: FLINK-23371
URL: https://issues.apache.org/jira/browse/FLINK-23371
Project: Flink
Issu
Timo Walther created FLINK-23370:
Summary: Propagate Boundedness of SourceFunctionProvider to
Transformation
Key: FLINK-23370
URL: https://issues.apache.org/jira/browse/FLINK-23370
Project: Flink
Timo Walther created FLINK-23330:
Summary: Deprecate toAppendStream and toRetractStream
Key: FLINK-23330
URL: https://issues.apache.org/jira/browse/FLINK-23330
Project: Flink
Issue Type: Sub-
Timo Walther created FLINK-23320:
Summary: Support semi/anti temporal joins
Key: FLINK-23320
URL: https://issues.apache.org/jira/browse/FLINK-23320
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-23319:
Summary: Support semi/anti lookup joins
Key: FLINK-23319
URL: https://issues.apache.org/jira/browse/FLINK-23319
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-23313:
Summary: Reintroduce temporal table function documentation
Key: FLINK-23313
URL: https://issues.apache.org/jira/browse/FLINK-23313
Project: Flink
Issue Type:
Timo Walther created FLINK-23306:
Summary: FlinkRelMdUniqueKeys causes exception when used with new
Schema
Key: FLINK-23306
URL: https://issues.apache.org/jira/browse/FLINK-23306
Project: Flink
Timo Walther created FLINK-23305:
Summary: Support semi/anti interval joins
Key: FLINK-23305
URL: https://issues.apache.org/jira/browse/FLINK-23305
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-23116:
Summary: Update documentation about TableDescriptors
Key: FLINK-23116
URL: https://issues.apache.org/jira/browse/FLINK-23116
Project: Flink
Issue Type: Sub-t
Timo Walther created FLINK-23072:
Summary: Add benchmarks for SQL internal and external serializers
Key: FLINK-23072
URL: https://issues.apache.org/jira/browse/FLINK-23072
Project: Flink
Issu
Timo Walther created FLINK-23040:
Summary: Consider ConfigOption fallback keys in FactoryUtil
Key: FLINK-23040
URL: https://issues.apache.org/jira/browse/FLINK-23040
Project: Flink
Issue Type
Timo Walther created FLINK-23019:
Summary: Avoid errors when identifiers use reserved keywords
Key: FLINK-23019
URL: https://issues.apache.org/jira/browse/FLINK-23019
Project: Flink
Issue Typ
Timo Walther created FLINK-22916:
Summary: Revisit and close JIRA issues around legacy planner
Key: FLINK-22916
URL: https://issues.apache.org/jira/browse/FLINK-22916
Project: Flink
Issue Typ
Timo Walther created FLINK-22880:
Summary: Remove "blink" term in code base
Key: FLINK-22880
URL: https://issues.apache.org/jira/browse/FLINK-22880
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22879:
Summary: Remove "blink" suffix from table modules
Key: FLINK-22879
URL: https://issues.apache.org/jira/browse/FLINK-22879
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22878:
Summary: Allow placeholder options in format factories
Key: FLINK-22878
URL: https://issues.apache.org/jira/browse/FLINK-22878
Project: Flink
Issue Type: Sub
Timo Walther created FLINK-22877:
Summary: Remove BatchTableEnvironment and related API classes
Key: FLINK-22877
URL: https://issues.apache.org/jira/browse/FLINK-22877
Project: Flink
Issue Ty
Timo Walther created FLINK-22872:
Summary: Remove usages of legacy planner test utilities in Python
Key: FLINK-22872
URL: https://issues.apache.org/jira/browse/FLINK-22872
Project: Flink
Issu
Timo Walther created FLINK-22864:
Summary: Remove the legacy planner code base
Key: FLINK-22864
URL: https://issues.apache.org/jira/browse/FLINK-22864
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22857:
Summary: Add possibility to call built-in functions in
SpecializedFunction
Key: FLINK-22857
URL: https://issues.apache.org/jira/browse/FLINK-22857
Project: Flink
Timo Walther created FLINK-22849:
Summary: Drop remaining usages of legacy planner in E2E tests and
Python
Key: FLINK-22849
URL: https://issues.apache.org/jira/browse/FLINK-22849
Project: Flink
Timo Walther created FLINK-22832:
Summary: Drop usages of legacy planner in SQL Client
Key: FLINK-22832
URL: https://issues.apache.org/jira/browse/FLINK-22832
Project: Flink
Issue Type: Sub-t
Timo Walther created FLINK-22831:
Summary: Drop usages of legacy planner in Scala shell
Key: FLINK-22831
URL: https://issues.apache.org/jira/browse/FLINK-22831
Project: Flink
Issue Type: Sub-
Timo Walther created FLINK-22829:
Summary: Drop usages of legacy planner in Hbase modules
Key: FLINK-22829
URL: https://issues.apache.org/jira/browse/FLINK-22829
Project: Flink
Issue Type: Su
Timo Walther created FLINK-22824:
Summary: Drop usages of legacy planner in Kafka modules
Key: FLINK-22824
URL: https://issues.apache.org/jira/browse/FLINK-22824
Project: Flink
Issue Type: Su
Timo Walther created FLINK-22822:
Summary: Drop usages of legacy planner in JDBC module
Key: FLINK-22822
URL: https://issues.apache.org/jira/browse/FLINK-22822
Project: Flink
Issue Type: Sub-
Timo Walther created FLINK-22813:
Summary: Drop usages of legacy planner in Hive module
Key: FLINK-22813
URL: https://issues.apache.org/jira/browse/FLINK-22813
Project: Flink
Issue Type: Sub-
Timo Walther created FLINK-22811:
Summary: Drop usages of legacy planner in Avro module
Key: FLINK-22811
URL: https://issues.apache.org/jira/browse/FLINK-22811
Project: Flink
Issue Type: Sub-
Timo Walther created FLINK-22810:
Summary: Drop usages of flink-table-planner in Elasticsearch
modules
Key: FLINK-22810
URL: https://issues.apache.org/jira/browse/FLINK-22810
Project: Flink
Timo Walther created FLINK-22782:
Summary: Remove legacy planner from Chinese docs
Key: FLINK-22782
URL: https://issues.apache.org/jira/browse/FLINK-22782
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22774:
Summary: Package flink-sql-connector-kinesis with newer Guava
version
Key: FLINK-22774
URL: https://issues.apache.org/jira/browse/FLINK-22774
Project: Flink
Timo Walther created FLINK-22748:
Summary: Allow dynamic target topic selection in Kafka sinks
Key: FLINK-22748
URL: https://issues.apache.org/jira/browse/FLINK-22748
Project: Flink
Issue Typ
Timo Walther created FLINK-22747:
Summary: Update commons-io to 2.8
Key: FLINK-22747
URL: https://issues.apache.org/jira/browse/FLINK-22747
Project: Flink
Issue Type: Improvement
Co
Timo Walther created FLINK-22744:
Summary: Simplify TableEnvironment.create()
Key: FLINK-22744
URL: https://issues.apache.org/jira/browse/FLINK-22744
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22740:
Summary: Drop legacy planner from docs
Key: FLINK-22740
URL: https://issues.apache.org/jira/browse/FLINK-22740
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22709:
Summary: Drop usages of EnvironmentSettings.useOldPlanner()
Key: FLINK-22709
URL: https://issues.apache.org/jira/browse/FLINK-22709
Project: Flink
Issue Type
Timo Walther created FLINK-22697:
Summary: Clean up examples to not use legacy planner anymore
Key: FLINK-22697
URL: https://issues.apache.org/jira/browse/FLINK-22697
Project: Flink
Issue Typ
Timo Walther created FLINK-22666:
Summary: Add more test cases for brigding to Scala DataStream API
Key: FLINK-22666
URL: https://issues.apache.org/jira/browse/FLINK-22666
Project: Flink
Issu
Timo Walther created FLINK-22623:
Summary: Drop BatchTableSource HBaseTableSource
Key: FLINK-22623
URL: https://issues.apache.org/jira/browse/FLINK-22623
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22622:
Summary: Drop BatchTableSource ParquetTableSource
Key: FLINK-22622
URL: https://issues.apache.org/jira/browse/FLINK-22622
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22620:
Summary: Uncouple OrcTableSource from legacy planner
Key: FLINK-22620
URL: https://issues.apache.org/jira/browse/FLINK-22620
Project: Flink
Issue Type: Sub-t
Timo Walther created FLINK-22619:
Summary: Drop usages of BatchTableEnvironment
Key: FLINK-22619
URL: https://issues.apache.org/jira/browse/FLINK-22619
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22590:
Summary: Add Scala implicit conversions for new API methods
Key: FLINK-22590
URL: https://issues.apache.org/jira/browse/FLINK-22590
Project: Flink
Issue Type
Timo Walther created FLINK-22575:
Summary: Offer a more recent flink-shaded-hadoop-2-uber
Key: FLINK-22575
URL: https://issues.apache.org/jira/browse/FLINK-22575
Project: Flink
Issue Type: Im
Timo Walther created FLINK-22537:
Summary: Add documentation how to interact with DataStream API
Key: FLINK-22537
URL: https://issues.apache.org/jira/browse/FLINK-22537
Project: Flink
Issue T
Timo Walther created FLINK-22426:
Summary: Reduce usage of TableSchema in the planner
Key: FLINK-22426
URL: https://issues.apache.org/jira/browse/FLINK-22426
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-22378:
Summary: Type mismatch when declaring SOURCE_WATERMARK on
TIMESTAMP_LTZ column
Key: FLINK-22378
URL: https://issues.apache.org/jira/browse/FLINK-22378
Project: Flink
Timo Walther created FLINK-22321:
Summary: Drop old user-defined function stack
Key: FLINK-22321
URL: https://issues.apache.org/jira/browse/FLINK-22321
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-22151:
Summary: Implement type inference for agg functions
Key: FLINK-22151
URL: https://issues.apache.org/jira/browse/FLINK-22151
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-22138:
Summary: Better support structured types as toDataStream output
Key: FLINK-22138
URL: https://issues.apache.org/jira/browse/FLINK-22138
Project: Flink
Issue
Timo Walther created FLINK-21989:
Summary: Add a SupportsSourceWatermark ability interface
Key: FLINK-21989
URL: https://issues.apache.org/jira/browse/FLINK-21989
Project: Flink
Issue Type: S
Timo Walther created FLINK-21934:
Summary: Add new StreamTableEnvironment.toDataStream
Key: FLINK-21934
URL: https://issues.apache.org/jira/browse/FLINK-21934
Project: Flink
Issue Type: Sub-t
Timo Walther created FLINK-21913:
Summary: Update DynamicTableFactory.Context to use
ResolvedCatalogTable
Key: FLINK-21913
URL: https://issues.apache.org/jira/browse/FLINK-21913
Project: Flink
Timo Walther created FLINK-21912:
Summary: Introduce Schema and ResolvedSchema in Python API
Key: FLINK-21912
URL: https://issues.apache.org/jira/browse/FLINK-21912
Project: Flink
Issue Type:
Timo Walther created FLINK-21911:
Summary: Support arithmetic MIN/MAX in SQL
Key: FLINK-21911
URL: https://issues.apache.org/jira/browse/FLINK-21911
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-21872:
Summary: Create a utility to create DataStream API's DataType and
Schema
Key: FLINK-21872
URL: https://issues.apache.org/jira/browse/FLINK-21872
Project: Flink
Timo Walther created FLINK-21801:
Summary: Update use new schema in Table, TableResult,
TableOperation
Key: FLINK-21801
URL: https://issues.apache.org/jira/browse/FLINK-21801
Project: Flink
Timo Walther created FLINK-21709:
Summary: Officially deprecate the legacy planner
Key: FLINK-21709
URL: https://issues.apache.org/jira/browse/FLINK-21709
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-21586:
Summary: Implement ResolvedExpression.asSerializableString for SQL
Key: FLINK-21586
URL: https://issues.apache.org/jira/browse/FLINK-21586
Project: Flink
Iss
Timo Walther created FLINK-21435:
Summary: Add a SqlExpression in table-common
Key: FLINK-21435
URL: https://issues.apache.org/jira/browse/FLINK-21435
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-21396:
Summary: Update the Catalog APIs
Key: FLINK-21396
URL: https://issues.apache.org/jira/browse/FLINK-21396
Project: Flink
Issue Type: Sub-task
Compon
Timo Walther created FLINK-21395:
Summary: Implement Schema, ResolvedSchema, SchemaResolver
Key: FLINK-21395
URL: https://issues.apache.org/jira/browse/FLINK-21395
Project: Flink
Issue Type:
Timo Walther created FLINK-21394:
Summary: FLIP-164: Improve Schema Handling in Catalogs
Key: FLINK-21394
URL: https://issues.apache.org/jira/browse/FLINK-21394
Project: Flink
Issue Type: Imp
Timo Walther created FLINK-21392:
Summary: Support to block in connected streams
Key: FLINK-21392
URL: https://issues.apache.org/jira/browse/FLINK-21392
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-21239:
Summary: Upgrade Calcite version to 1.28
Key: FLINK-21239
URL: https://issues.apache.org/jira/browse/FLINK-21239
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-21226:
Summary: Reintroduce TableColumn.of for backwards compatibility
Key: FLINK-21226
URL: https://issues.apache.org/jira/browse/FLINK-21226
Project: Flink
Issue
Timo Walther created FLINK-21225:
Summary: OverConvertRule does not consider distinct
Key: FLINK-21225
URL: https://issues.apache.org/jira/browse/FLINK-21225
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-21149:
Summary: Remove deprecated CatalogTable.getProperties
Key: FLINK-21149
URL: https://issues.apache.org/jira/browse/FLINK-21149
Project: Flink
Issue Type: Sub-
Timo Walther created FLINK-21070:
Summary: Overloaded aggregate functions cause converter errors
Key: FLINK-21070
URL: https://issues.apache.org/jira/browse/FLINK-21070
Project: Flink
Issue T
Timo Walther created FLINK-21050:
Summary: Add an example for complex UDFs
Key: FLINK-21050
URL: https://issues.apache.org/jira/browse/FLINK-21050
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-21013:
Summary: Blink planner does not ingest timestamp into StreamRecord
Key: FLINK-21013
URL: https://issues.apache.org/jira/browse/FLINK-21013
Project: Flink
Iss
Timo Walther created FLINK-20971:
Summary: Allow SQL expressions in Table API
Key: FLINK-20971
URL: https://issues.apache.org/jira/browse/FLINK-20971
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-20942:
Summary: Digest of FLOAT literals throws
UnsupportedOperationException
Key: FLINK-20942
URL: https://issues.apache.org/jira/browse/FLINK-20942
Project: Flink
Timo Walther created FLINK-20897:
Summary: Support DataStream batch mode in StreamTableEnvironment
Key: FLINK-20897
URL: https://issues.apache.org/jira/browse/FLINK-20897
Project: Flink
Issue
Timo Walther created FLINK-20869:
Summary: Support TIMESTAMP WITH TIME ZONE
Key: FLINK-20869
URL: https://issues.apache.org/jira/browse/FLINK-20869
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-20862:
Summary: Add a converter from TypeInformation to DataType
Key: FLINK-20862
URL: https://issues.apache.org/jira/browse/FLINK-20862
Project: Flink
Issue Type:
Timo Walther created FLINK-20613:
Summary: Update TableResult.collect()/TableResult.print() to the
new type system
Key: FLINK-20613
URL: https://issues.apache.org/jira/browse/FLINK-20613
Project: Flin
Timo Walther created FLINK-20539:
Summary: Type mismatch when using ROW in computed column
Key: FLINK-20539
URL: https://issues.apache.org/jira/browse/FLINK-20539
Project: Flink
Issue Type: S
Timo Walther created FLINK-20522:
Summary: Make implementing a built-in function straightforward
Key: FLINK-20522
URL: https://issues.apache.org/jira/browse/FLINK-20522
Project: Flink
Issue T
Timo Walther created FLINK-20485:
Summary: Map views are deserialized multiple times
Key: FLINK-20485
URL: https://issues.apache.org/jira/browse/FLINK-20485
Project: Flink
Issue Type: Sub-tas
Timo Walther created FLINK-20371:
Summary: Add docs for outer interval join
Key: FLINK-20371
URL: https://issues.apache.org/jira/browse/FLINK-20371
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-20346:
Summary: Explain ChangelogMode for sinks
Key: FLINK-20346
URL: https://issues.apache.org/jira/browse/FLINK-20346
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-20323:
Summary: CorrelateSortToRankRule cannot deal with multiple
groupings
Key: FLINK-20323
URL: https://issues.apache.org/jira/browse/FLINK-20323
Project: Flink
Timo Walther created FLINK-20294:
Summary: Expose value format metadata in Kinesis table source
Key: FLINK-20294
URL: https://issues.apache.org/jira/browse/FLINK-20294
Project: Flink
Issue Ty
101 - 200 of 699 matches
Mail list logo
