Timo Walther created FLINK-38103:
Summary: DataTypeFactory cannot restore inline structured types
Key: FLINK-38103
URL: https://issues.apache.org/jira/browse/FLINK-38103
Project: Flink
Issue
Timo Walther created FLINK-38090:
Summary: TableResult.collect() returns incorrect SQL inline
structured types
Key: FLINK-38090
URL: https://issues.apache.org/jira/browse/FLINK-38090
Project: Flink
Timo Walther created FLINK-37974:
Summary: Avoid confusion when declaring table arguments
Key: FLINK-37974
URL: https://issues.apache.org/jira/browse/FLINK-37974
Project: Flink
Issue Type: Su
Timo Walther created FLINK-37956:
Summary: Update SQL gateway for inline structured types
Key: FLINK-37956
URL: https://issues.apache.org/jira/browse/FLINK-37956
Project: Flink
Issue Type: Su
Timo Walther created FLINK-37862:
Summary: Implement data type improvements for StructuredType
Key: FLINK-37862
URL: https://issues.apache.org/jira/browse/FLINK-37862
Project: Flink
Issue Typ
Timo Walther created FLINK-37861:
Summary: FLIP-520: Simplify StructuredType handling
Key: FLINK-37861
URL: https://issues.apache.org/jira/browse/FLINK-37861
Project: Flink
Issue Type: New Fe
Timo Walther created FLINK-37763:
Summary: Support multiple tables with set semantics
Key: FLINK-37763
URL: https://issues.apache.org/jira/browse/FLINK-37763
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-37745:
Summary: ChangelogModeJsonSerializer doesn't handle partial deletes
Key: FLINK-37745
URL: https://issues.apache.org/jira/browse/FLINK-37745
Project: Flink
Is
Timo Walther created FLINK-37671:
Summary: ChangelogMode.toString returns invalid string for partial
deletes
Key: FLINK-37671
URL: https://issues.apache.org/jira/browse/FLINK-37671
Project: Flink
Timo Walther created FLINK-37651:
Summary: Simplify StaticArgument builders for easier type inference
Key: FLINK-37651
URL: https://issues.apache.org/jira/browse/FLINK-37651
Project: Flink
Is
Timo Walther created FLINK-37632:
Summary: Add ChangelogFunction interface
Key: FLINK-37632
URL: https://issues.apache.org/jira/browse/FLINK-37632
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-37599:
Summary: Consider on_time argument for column expansion
Key: FLINK-37599
URL: https://issues.apache.org/jira/browse/FLINK-37599
Project: Flink
Issue Type: Su
Timo Walther created FLINK-37598:
Summary: Support ListView and MapView in PTFs
Key: FLINK-37598
URL: https://issues.apache.org/jira/browse/FLINK-37598
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-37547:
Summary: Add initial document for PTFs
Key: FLINK-37547
URL: https://issues.apache.org/jira/browse/FLINK-37547
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-37466:
Summary: A helper function for DEFAULT in Table API
Key: FLINK-37466
URL: https://issues.apache.org/jira/browse/FLINK-37466
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-37446:
Summary: Support asArgument in Table API
Key: FLINK-37446
URL: https://issues.apache.org/jira/browse/FLINK-37446
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-37457:
Summary: Support asArgument in Python Table API
Key: FLINK-37457
URL: https://issues.apache.org/jira/browse/FLINK-37457
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-37423:
Summary: Add support for PTFs in Table API
Key: FLINK-37423
URL: https://issues.apache.org/jira/browse/FLINK-37423
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-37402:
Summary: SQL testing sources produce incorrect watermarks
Key: FLINK-37402
URL: https://issues.apache.org/jira/browse/FLINK-37402
Project: Flink
Issue Type:
Timo Walther created FLINK-37302:
Summary: Support timers in PTFs
Key: FLINK-37302
URL: https://issues.apache.org/jira/browse/FLINK-37302
Project: Flink
Issue Type: Sub-task
Compone
Timo Walther created FLINK-37269:
Summary: Add new DESCRIPTOR data type
Key: FLINK-37269
URL: https://issues.apache.org/jira/browse/FLINK-37269
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-37219:
Summary: Support value state in PTFs
Key: FLINK-37219
URL: https://issues.apache.org/jira/browse/FLINK-37219
Project: Flink
Issue Type: Sub-task
Co
Timo Walther created FLINK-37211:
Summary: Fix field resolution for PARTITION BY/ORDER BY
Key: FLINK-37211
URL: https://issues.apache.org/jira/browse/FLINK-37211
Project: Flink
Issue Type: Su
Timo Walther created FLINK-37180:
Summary: Implement StreamOperator for PTF
Key: FLINK-37180
URL: https://issues.apache.org/jira/browse/FLINK-37180
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-37167:
Summary: Fix operand reordering in SqlValidatorImpl for
tableCharacteristics
Key: FLINK-37167
URL: https://issues.apache.org/jira/browse/FLINK-37167
Project: Flink
Timo Walther created FLINK-37076:
Summary: Support PTF skeleton in planner
Key: FLINK-37076
URL: https://issues.apache.org/jira/browse/FLINK-37076
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-36937:
Summary: Integrate PTF TypeInference into Table API
Key: FLINK-36937
URL: https://issues.apache.org/jira/browse/FLINK-36937
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-36789:
Summary: Update FunctionHint and ArgumentHint with StaticArguments
Key: FLINK-36789
URL: https://issues.apache.org/jira/browse/FLINK-36789
Project: Flink
Iss
Timo Walther created FLINK-36707:
Summary: Integrate PTF TypeInference into Calcite validator
Key: FLINK-36707
URL: https://issues.apache.org/jira/browse/FLINK-36707
Project: Flink
Issue Type
Timo Walther created FLINK-36706:
Summary: Update TypeInferenceExtractor for PTFs
Key: FLINK-36706
URL: https://issues.apache.org/jira/browse/FLINK-36706
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-36704:
Summary: Update TypeInference with StaticArgument and
StateTypeStrategy
Key: FLINK-36704
URL: https://issues.apache.org/jira/browse/FLINK-36704
Project: Flink
Timo Walther created FLINK-36705:
Summary: Add ProcessTableFunction class and annotations
Key: FLINK-36705
URL: https://issues.apache.org/jira/browse/FLINK-36705
Project: Flink
Issue Type: Su
Timo Walther created FLINK-36703:
Summary: FLIP-440: User-defined SQL operators /
ProcessTableFunction (PTF)
Key: FLINK-36703
URL: https://issues.apache.org/jira/browse/FLINK-36703
Project: Flink
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: Su
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: Sub-ta
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: Fli
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 Ty
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: S
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: Sub-t
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: F
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 Type:
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 Ty
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 Ty
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
Issue
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: Improveme
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
Is
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 Type
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: Su
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
Issue
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: Sub-ta
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: S
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
Com
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: Sub-tas
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: Sub-tas
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: Sub-ta
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: Sub-task
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
Is
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
Proje
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 Ty
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: Sub-t
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 Type:
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 Type:
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: S
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: Sub-ta
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
C
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: Su
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: Sub-ta
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
1 - 100 of 732 matches
Mail list logo
