Timo Walther created FLINK-35001:
Summary: Avoid scientific notation for DOUBLE to STRING
Key: FLINK-35001
URL: https://issues.apache.org/jira/browse/FLINK-35001
Project: Flink
Issue Type:
Timo Walther created FLINK-34902:
Summary: INSERT INTO column mismatch leads to
IndexOutOfBoundsException
Key: FLINK-34902
URL: https://issues.apache.org/jira/browse/FLINK-34902
Project: Flink
Timo Walther created FLINK-34476:
Summary: Window TVFs with named parameters don't support column
expansion
Key: FLINK-34476
URL: https://issues.apache.org/jira/browse/FLINK-34476
Project: Flink
Timo Walther created FLINK-34469:
Summary: Implement TableDistribution toString
Key: FLINK-34469
URL: https://issues.apache.org/jira/browse/FLINK-34469
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-34316:
Summary: Reduce instantiation of ScanRuntimeProvider for in
streaming mode
Key: FLINK-34316
URL: https://issues.apache.org/jira/browse/FLINK-34316
Project: Flink
Timo Walther created FLINK-34095:
Summary: Add a restore test for StreamExecAsyncCalc
Key: FLINK-34095
URL: https://issues.apache.org/jira/browse/FLINK-34095
Project: Flink
Issue Type:
Timo Walther created FLINK-34094:
Summary: Document new AsyncScalarFunction
Key: FLINK-34094
URL: https://issues.apache.org/jira/browse/FLINK-34094
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-33784:
Summary: CatalogStoreFactory can not be configured via
StreamExecutionEnvironment
Key: FLINK-33784
URL: https://issues.apache.org/jira/browse/FLINK-33784
Project:
Timo Walther created FLINK-33666:
Summary: MergeTableLikeUtil uses different constraint name than
Schema
Key: FLINK-33666
URL: https://issues.apache.org/jira/browse/FLINK-33666
Project: Flink
Timo Walther created FLINK-33497:
Summary: Update the Kafka connector to support DISTRIBUTED BY
clause
Key: FLINK-33497
URL: https://issues.apache.org/jira/browse/FLINK-33497
Project: Flink
Timo Walther created FLINK-33496:
Summary: Expose DISTRIBUTED BY clause via parser
Key: FLINK-33496
URL: https://issues.apache.org/jira/browse/FLINK-33496
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-33495:
Summary: Add catalog and connector ability API and validation
Key: FLINK-33495
URL: https://issues.apache.org/jira/browse/FLINK-33495
Project: Flink
Issue
Timo Walther created FLINK-33494:
Summary: FLIP-376: Add DISTRIBUTED BY clause
Key: FLINK-33494
URL: https://issues.apache.org/jira/browse/FLINK-33494
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-33447:
Summary: Avoid CompiledPlan recompilation during loading
Key: FLINK-33447
URL: https://issues.apache.org/jira/browse/FLINK-33447
Project: Flink
Issue Type:
Timo Walther created FLINK-33183:
Summary: Enable metadata columns in NduAnalyzer with retract if
non-virtual
Key: FLINK-33183
URL: https://issues.apache.org/jira/browse/FLINK-33183
Project: Flink
Timo Walther created FLINK-33182:
Summary: Allow metadata columns in NduAnalyzer with
ChangelogNormalize
Key: FLINK-33182
URL: https://issues.apache.org/jira/browse/FLINK-33182
Project: Flink
Timo Walther created FLINK-33169:
Summary: Window TVFs don't consider column expansion
Key: FLINK-33169
URL: https://issues.apache.org/jira/browse/FLINK-33169
Project: Flink
Issue Type:
Timo Walther created FLINK-33028:
Summary: FLIP-348: Make expanding behavior of virtual metadata
columns configurable
Key: FLINK-33028
URL: https://issues.apache.org/jira/browse/FLINK-33028
Project:
Timo Walther created FLINK-32689:
Summary: Insufficient validation for table.local-time-zone
Key: FLINK-32689
URL: https://issues.apache.org/jira/browse/FLINK-32689
Project: Flink
Issue
Timo Walther created FLINK-32657:
Summary: Revert upgrading ExecNode versions for StateMetadata
Key: FLINK-32657
URL: https://issues.apache.org/jira/browse/FLINK-32657
Project: Flink
Issue
Timo Walther created FLINK-32613:
Summary: Disable check for single rowtime attribute for sinks
Key: FLINK-32613
URL: https://issues.apache.org/jira/browse/FLINK-32613
Project: Flink
Issue
Timo Walther created FLINK-32470:
Summary: SqlValidateException should be exposed as
ValidationException
Key: FLINK-32470
URL: https://issues.apache.org/jira/browse/FLINK-32470
Project: Flink
Timo Walther created FLINK-32466:
Summary: Invalid input strategy for CONCAT allows BINARY strings
Key: FLINK-32466
URL: https://issues.apache.org/jira/browse/FLINK-32466
Project: Flink
Timo Walther created FLINK-30226:
Summary: Offer a Identity(De)SerializationSchema
Key: FLINK-30226
URL: https://issues.apache.org/jira/browse/FLINK-30226
Project: Flink
Issue Type:
Timo Walther created FLINK-29379:
Summary: Back ExecutionConfig and CheckpointConfig by Configuration
Key: FLINK-29379
URL: https://issues.apache.org/jira/browse/FLINK-29379
Project: Flink
Timo Walther created FLINK-29309:
Summary: Relax allow-client-job-configurations for Table API and
parameters
Key: FLINK-29309
URL: https://issues.apache.org/jira/browse/FLINK-29309
Project: Flink
Timo Walther created FLINK-29267:
Summary: Support external type systems in DDL
Key: FLINK-29267
URL: https://issues.apache.org/jira/browse/FLINK-29267
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-29035:
Summary: ExpressionReducer does not work with jar resources
Key: FLINK-29035
URL: https://issues.apache.org/jira/browse/FLINK-29035
Project: Flink
Issue
Timo Walther created FLINK-29014:
Summary: Use setting instead of merging for pipeline.jars in
StreamExecutionEnvironment.configure
Key: FLINK-29014
URL: https://issues.apache.org/jira/browse/FLINK-29014
Timo Walther created FLINK-27534:
Summary: Apply scalafmt to 1.15 branch
Key: FLINK-27534
URL: https://issues.apache.org/jira/browse/FLINK-27534
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-27208:
Summary: Update the documentation to configure the IDE with
scalafmt
Key: FLINK-27208
URL: https://issues.apache.org/jira/browse/FLINK-27208
Project: Flink
Timo Walther created FLINK-26843:
Summary: Cleanup code around TableConfig/ReadableConfig
Key: FLINK-26843
URL: https://issues.apache.org/jira/browse/FLINK-26843
Project: Flink
Issue Type:
Timo Walther created FLINK-26725:
Summary: Support the new type inference in Scala Table API
aggregate functions
Key: FLINK-26725
URL: https://issues.apache.org/jira/browse/FLINK-26725
Project: Flink
Timo Walther created FLINK-26712:
Summary: Metadata keys should not conflict with physical columns
Key: FLINK-26712
URL: https://issues.apache.org/jira/browse/FLINK-26712
Project: Flink
Timo Walther created FLINK-26518:
Summary: Support the new type inference in Scala Table API table
functions
Key: FLINK-26518
URL: https://issues.apache.org/jira/browse/FLINK-26518
Project: Flink
Timo Walther created FLINK-26467:
Summary: Compile RowDataToStringConverter lazily
Key: FLINK-26467
URL: https://issues.apache.org/jira/browse/FLINK-26467
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-26434:
Summary: Remove 'table.planner' table config option
Key: FLINK-26434
URL: https://issues.apache.org/jira/browse/FLINK-26434
Project: Flink
Issue Type:
Timo Walther created FLINK-26287:
Summary: Add convenient TableConfig.set
Key: FLINK-26287
URL: https://issues.apache.org/jira/browse/FLINK-26287
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-26283:
Summary: Harden AggregateCall serialization in JSON plan
Key: FLINK-26283
URL: https://issues.apache.org/jira/browse/FLINK-26283
Project: Flink
Issue Type:
Timo Walther created FLINK-26278:
Summary: Add Expressions.col as a synonym for $
Key: FLINK-26278
URL: https://issues.apache.org/jira/browse/FLINK-26278
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-26250:
Summary: Document the upgrade story
Key: FLINK-26250
URL: https://issues.apache.org/jira/browse/FLINK-26250
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-26132:
Summary: Always serialize anonymous table
Key: FLINK-26132
URL: https://issues.apache.org/jira/browse/FLINK-26132
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-26075:
Summary: Persist per-ExecNode configuration
Key: FLINK-26075
URL: https://issues.apache.org/jira/browse/FLINK-26075
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-26055:
Summary: Use new FlinkVersion enum for serde plans
Key: FLINK-26055
URL: https://issues.apache.org/jira/browse/FLINK-26055
Project: Flink
Issue Type:
Timo Walther created FLINK-26044:
Summary: Properly declare internal UNNEST function
Key: FLINK-26044
URL: https://issues.apache.org/jira/browse/FLINK-26044
Project: Flink
Issue Type:
Timo Walther created FLINK-25990:
Summary: Expose uid generator for DataStream/Transformation
providers
Key: FLINK-25990
URL: https://issues.apache.org/jira/browse/FLINK-25990
Project: Flink
Timo Walther created FLINK-25932:
Summary: Introduce ExecNodeContext.generateUid()
Key: FLINK-25932
URL: https://issues.apache.org/jira/browse/FLINK-25932
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-25870:
Summary: Introduce ContextResolvedFunction similar to
ContextResolvedTable
Key: FLINK-25870
URL: https://issues.apache.org/jira/browse/FLINK-25870
Project: Flink
Timo Walther created FLINK-25845:
Summary: Expose plan via SQL COMPILE / EXECUTE PLAN
Key: FLINK-25845
URL: https://issues.apache.org/jira/browse/FLINK-25845
Project: Flink
Issue Type:
Timo Walther created FLINK-25844:
Summary: Expose plan via StatementSet.compilePlan
Key: FLINK-25844
URL: https://issues.apache.org/jira/browse/FLINK-25844
Project: Flink
Issue Type:
Timo Walther created FLINK-25843:
Summary: Expose plan via
Table.compilePlan/TableEnvironment.fromPlan
Key: FLINK-25843
URL: https://issues.apache.org/jira/browse/FLINK-25843
Project: Flink
Timo Walther created FLINK-25841:
Summary: Expose plan via
TableEnvironment.compilePlanSql/executePlan
Key: FLINK-25841
URL: https://issues.apache.org/jira/browse/FLINK-25841
Project: Flink
Timo Walther created FLINK-25826:
Summary: Handle symbols at a central place with serializable format
Key: FLINK-25826
URL: https://issues.apache.org/jira/browse/FLINK-25826
Project: Flink
Timo Walther created FLINK-25805:
Summary: Use compact DataType serialization for default classes
instead of internal ones
Key: FLINK-25805
URL: https://issues.apache.org/jira/browse/FLINK-25805
Timo Walther created FLINK-25769:
Summary: Add internal functions and basic function versioning
Key: FLINK-25769
URL: https://issues.apache.org/jira/browse/FLINK-25769
Project: Flink
Issue
Timo Walther created FLINK-25699:
Summary: Use HashMap for MAP value constructors
Key: FLINK-25699
URL: https://issues.apache.org/jira/browse/FLINK-25699
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-25677:
Summary: Update ReplicateRows to the new type system
Key: FLINK-25677
URL: https://issues.apache.org/jira/browse/FLINK-25677
Project: Flink
Issue Type:
Timo Walther created FLINK-25659:
Summary: LogicalRelDataTypeConverterTest is flaky on Azure
Key: FLINK-25659
URL: https://issues.apache.org/jira/browse/FLINK-25659
Project: Flink
Issue
Timo Walther created FLINK-25609:
Summary: Avoid creating temporary tables for inline tables
Key: FLINK-25609
URL: https://issues.apache.org/jira/browse/FLINK-25609
Project: Flink
Issue
Timo Walther created FLINK-25525:
Summary: flink-examples-table is not runnable in the IDE
Key: FLINK-25525
URL: https://issues.apache.org/jira/browse/FLINK-25525
Project: Flink
Issue Type:
Timo Walther created FLINK-25516:
Summary: Add catalog object compile/restore options
Key: FLINK-25516
URL: https://issues.apache.org/jira/browse/FLINK-25516
Project: Flink
Issue Type:
Timo Walther created FLINK-25487:
Summary: Improve exception when flink-table-runtime is not in
classpath
Key: FLINK-25487
URL: https://issues.apache.org/jira/browse/FLINK-25487
Project: Flink
Timo Walther created FLINK-25392:
Summary: Add new STATEMENT SET syntax
Key: FLINK-25392
URL: https://issues.apache.org/jira/browse/FLINK-25392
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-25391:
Summary: Updating existing table factories for mutable table
options
Key: FLINK-25391
URL: https://issues.apache.org/jira/browse/FLINK-25391
Project: Flink
Timo Walther created FLINK-25390:
Summary: Support mutable options in DynamicTableFactory
Key: FLINK-25390
URL: https://issues.apache.org/jira/browse/FLINK-25390
Project: Flink
Issue Type:
Timo Walther created FLINK-25389:
Summary: Update JSON plan with new ExecNodeMetadata
Key: FLINK-25389
URL: https://issues.apache.org/jira/browse/FLINK-25389
Project: Flink
Issue Type:
Timo Walther created FLINK-25388:
Summary: Add annotation to all StreamExec nodes
Key: FLINK-25388
URL: https://issues.apache.org/jira/browse/FLINK-25388
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-25387:
Summary: Introduce ExecNodeMetadata annotation and tooling
Key: FLINK-25387
URL: https://issues.apache.org/jira/browse/FLINK-25387
Project: Flink
Issue
Timo Walther created FLINK-25386:
Summary: Harden table serialization in JSON plan
Key: FLINK-25386
URL: https://issues.apache.org/jira/browse/FLINK-25386
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-25385:
Summary: Harden function serialization in JSON plan
Key: FLINK-25385
URL: https://issues.apache.org/jira/browse/FLINK-25385
Project: Flink
Issue Type:
Timo Walther created FLINK-25365:
Summary: Remove remaining references to planner from Python
Key: FLINK-25365
URL: https://issues.apache.org/jira/browse/FLINK-25365
Project: Flink
Issue
Timo Walther created FLINK-25364:
Summary: Don't generate code in open() methods of Python operators
Key: FLINK-25364
URL: https://issues.apache.org/jira/browse/FLINK-25364
Project: Flink
Timo Walther created FLINK-25363:
Summary: Replace LogicalWindow and related planner expressions
Key: FLINK-25363
URL: https://issues.apache.org/jira/browse/FLINK-25363
Project: Flink
Issue
Timo Walther created FLINK-25341:
Summary: Improve casting structured type to STRING
Key: FLINK-25341
URL: https://issues.apache.org/jira/browse/FLINK-25341
Project: Flink
Issue Type:
Timo Walther created FLINK-25230:
Summary: Harden type serialization in JSON plan
Key: FLINK-25230
URL: https://issues.apache.org/jira/browse/FLINK-25230
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-25221:
Summary: Allow global table options for all table connectors
Key: FLINK-25221
URL: https://issues.apache.org/jira/browse/FLINK-25221
Project: Flink
Issue
Timo Walther created FLINK-25217:
Summary: FLIP-190: Support Version Upgrades for Table API & SQL
Programs
Key: FLINK-25217
URL: https://issues.apache.org/jira/browse/FLINK-25217
Project: Flink
Timo Walther created FLINK-25199:
Summary: fromValues does not emit final MAX watermark
Key: FLINK-25199
URL: https://issues.apache.org/jira/browse/FLINK-25199
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-24877:
Summary: Implicitly add time attributes for VALUES clause
Key: FLINK-24877
URL: https://issues.apache.org/jira/browse/FLINK-24877
Project: Flink
Issue Type:
Timo Walther created FLINK-24803:
Summary: Fix cast BINARY/VARBINARY to STRING
Key: FLINK-24803
URL: https://issues.apache.org/jira/browse/FLINK-24803
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-24802:
Summary: Improve cast ROW to STRING
Key: FLINK-24802
URL: https://issues.apache.org/jira/browse/FLINK-24802
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-24717:
Summary: Push partitions before filters
Key: FLINK-24717
URL: https://issues.apache.org/jira/browse/FLINK-24717
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-24716:
Summary: Non-equality predicates on partition columns lead to
incorrect plans
Key: FLINK-24716
URL: https://issues.apache.org/jira/browse/FLINK-24716
Project: Flink
Timo Walther created FLINK-24714:
Summary: Validate partition columns for ResolvedCatalogTable
Key: FLINK-24714
URL: https://issues.apache.org/jira/browse/FLINK-24714
Project: Flink
Issue
Timo Walther created FLINK-24700:
Summary: Clarify semantics of filter, projection, partition, and
metadata pushdown
Key: FLINK-24700
URL: https://issues.apache.org/jira/browse/FLINK-24700
Project:
Timo Walther created FLINK-24599:
Summary: Make checking for type root and family less verbose
Key: FLINK-24599
URL: https://issues.apache.org/jira/browse/FLINK-24599
Project: Flink
Issue
Timo Walther created FLINK-24532:
Summary: Invalid deletions for time-versioned join with
ChangelogNormalize
Key: FLINK-24532
URL: https://issues.apache.org/jira/browse/FLINK-24532
Project: Flink
Timo Walther created FLINK-24427:
Summary: Hide Scala in flink-table-planner from API
Key: FLINK-24427
URL: https://issues.apache.org/jira/browse/FLINK-24427
Project: Flink
Issue Type:
Timo Walther created FLINK-24399:
Summary: Make handling of DataType less verbose
Key: FLINK-24399
URL: https://issues.apache.org/jira/browse/FLINK-24399
Project: Flink
Issue Type:
Timo Walther created FLINK-24396:
Summary: Add @Public annotations to Table & SQL API
Key: FLINK-24396
URL: https://issues.apache.org/jira/browse/FLINK-24396
Project: Flink
Issue Type: New
Timo Walther created FLINK-24254:
Summary: Support hints configuration hints
Key: FLINK-24254
URL: https://issues.apache.org/jira/browse/FLINK-24254
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-24186:
Summary: Disable single rowtime column check for collect/print
Key: FLINK-24186
URL: https://issues.apache.org/jira/browse/FLINK-24186
Project: Flink
Issue
Timo Walther created FLINK-24116:
Summary: PRIMARY KEY declaration on insert-only table is not
validated globally
Key: FLINK-24116
URL: https://issues.apache.org/jira/browse/FLINK-24116
Project:
Timo Walther created FLINK-24103:
Summary: Create time-based LAST_VALUE / FIRST_VALUE
Key: FLINK-24103
URL: https://issues.apache.org/jira/browse/FLINK-24103
Project: Flink
Issue Type:
Timo Walther created FLINK-24087:
Summary: Kafka connector StartupMode requires a table dependency
Key: FLINK-24087
URL: https://issues.apache.org/jira/browse/FLINK-24087
Project: Flink
Timo Walther created FLINK-24054:
Summary: Let SinkUpsertMaterializer emit +U instead of only +I
Key: FLINK-24054
URL: https://issues.apache.org/jira/browse/FLINK-24054
Project: Flink
Issue
Timo Walther created FLINK-24033:
Summary: Propagate unique keys for fromChangelogStream
Key: FLINK-24033
URL: https://issues.apache.org/jira/browse/FLINK-24033
Project: Flink
Issue Type:
Timo Walther created FLINK-23920:
Summary: SchemaTranslator looses primary key if schema is inferred
Key: FLINK-23920
URL: https://issues.apache.org/jira/browse/FLINK-23920
Project: Flink
Timo Walther created FLINK-23915:
Summary: Propagate unique keys for temporary tables
Key: FLINK-23915
URL: https://issues.apache.org/jira/browse/FLINK-23915
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-23895:
Summary: Upsert materializer is not inserted for all sink providers
Key: FLINK-23895
URL: https://issues.apache.org/jira/browse/FLINK-23895
Project: Flink
1 - 100 of 668 matches
Mail list logo
