Timo Walther created FLINK-14437:
Summary: Drop the legacy planner
Key: FLINK-14437
URL: https://issues.apache.org/jira/browse/FLINK-14437
Project: Flink
Issue Type: Sub-task
Compon
Timo Walther created FLINK-14438:
Summary: Fix RowTypeInfo.equals()
Key: FLINK-14438
URL: https://issues.apache.org/jira/browse/FLINK-14438
Project: Flink
Issue Type: Improvement
Co
Timo Walther created FLINK-14903:
Summary: Relax structured types constraints
Key: FLINK-14903
URL: https://issues.apache.org/jira/browse/FLINK-14903
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-14904:
Summary: Rename ANY type to RAW type
Key: FLINK-14904
URL: https://issues.apache.org/jira/browse/FLINK-14904
Project: Flink
Issue Type: Sub-task
Co
Timo Walther created FLINK-14967:
Summary: Add a utility for creating data types via reflection
Key: FLINK-14967
URL: https://issues.apache.org/jira/browse/FLINK-14967
Project: Flink
Issue Ty
Timo Walther created FLINK-14983:
Summary: Add interfaces for input type inference
Key: FLINK-14983
URL: https://issues.apache.org/jira/browse/FLINK-14983
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-15009:
Summary: Add a utility for creating type inference logic via
reflection
Key: FLINK-15009
URL: https://issues.apache.org/jira/browse/FLINK-15009
Project: Flink
Timo Walther created FLINK-15149:
Summary: Merge InputTypeStrategy and InputTypeValidator
Key: FLINK-15149
URL: https://issues.apache.org/jira/browse/FLINK-15149
Project: Flink
Issue Type: Su
Timo Walther created FLINK-15162:
Summary: Merge Java and Scala ClosureCleaner
Key: FLINK-15162
URL: https://issues.apache.org/jira/browse/FLINK-15162
Project: Flink
Issue Type: Improvement
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-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-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-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-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-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-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-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-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-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-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-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-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-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-12251:
Summary: Rework the Table API & SQL type system
Key: FLINK-12251
URL: https://issues.apache.org/jira/browse/FLINK-12251
Project: Flink
Issue Type: Improvemen
Timo Walther created FLINK-12253:
Summary: Setup a class hierarchy for the new type system
Key: FLINK-12253
URL: https://issues.apache.org/jira/browse/FLINK-12253
Project: Flink
Issue Type: S
Timo Walther created FLINK-12254:
Summary: Expose the new type system through the API
Key: FLINK-12254
URL: https://issues.apache.org/jira/browse/FLINK-12254
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-12393:
Summary: Add the user-facing classes of the new type system
Key: FLINK-12393
URL: https://issues.apache.org/jira/browse/FLINK-12393
Project: Flink
Issue Type
Timo Walther created FLINK-12566:
Summary: Remove row interval type
Key: FLINK-12566
URL: https://issues.apache.org/jira/browse/FLINK-12566
Project: Flink
Issue Type: Sub-task
Compo
Timo Walther created FLINK-12710:
Summary: Unify built-in and user-defined functions in the API
Key: FLINK-12710
URL: https://issues.apache.org/jira/browse/FLINK-12710
Project: Flink
Issue Ty
Timo Walther created FLINK-12711:
Summary: Separate function implementation and definition
Key: FLINK-12711
URL: https://issues.apache.org/jira/browse/FLINK-12711
Project: Flink
Issue Type: S
Timo Walther created FLINK-12726:
Summary: Fix ANY type serialization
Key: FLINK-12726
URL: https://issues.apache.org/jira/browse/FLINK-12726
Project: Flink
Issue Type: Sub-task
Com
Timo Walther created FLINK-12769:
Summary: Simplify expression design for symbols
Key: FLINK-12769
URL: https://issues.apache.org/jira/browse/FLINK-12769
Project: Flink
Issue Type: New Featur
Timo Walther created FLINK-12874:
Summary: Improve the semantics of zero length character strings
Key: FLINK-12874
URL: https://issues.apache.org/jira/browse/FLINK-12874
Project: Flink
Issue
Timo Walther created FLINK-12899:
Summary: Introduce a resolved expression with data type
Key: FLINK-12899
URL: https://issues.apache.org/jira/browse/FLINK-12899
Project: Flink
Issue Type: Su
Timo Walther created FLINK-12924:
Summary: Introduce basic type inference interfaces
Key: FLINK-12924
URL: https://issues.apache.org/jira/browse/FLINK-12924
Project: Flink
Issue Type: Sub-tas
Timo Walther created FLINK-12968:
Summary: Add a casting utility
Key: FLINK-12968
URL: https://issues.apache.org/jira/browse/FLINK-12968
Project: Flink
Issue Type: Sub-task
Componen
Timo Walther created FLINK-12996:
Summary: Add predefined type validators, strategies, and
transformations
Key: FLINK-12996
URL: https://issues.apache.org/jira/browse/FLINK-12996
Project: Flink
Timo Walther created FLINK-13028:
Summary: Move expression resolver to flink-table-api-java
Key: FLINK-13028
URL: https://issues.apache.org/jira/browse/FLINK-13028
Project: Flink
Issue Type:
Timo Walther created FLINK-13045:
Summary: Move Scala expression DSL to flink-table-api-scala
Key: FLINK-13045
URL: https://issues.apache.org/jira/browse/FLINK-13045
Project: Flink
Issue Type
Timo Walther created FLINK-13078:
Summary: Add a type parser utility
Key: FLINK-13078
URL: https://issues.apache.org/jira/browse/FLINK-13078
Project: Flink
Issue Type: Sub-task
Comp
Timo Walther created FLINK-13191:
Summary: Add a simplified UDF type extraction
Key: FLINK-13191
URL: https://issues.apache.org/jira/browse/FLINK-13191
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-13262:
Summary: Add documentation for the new Table & SQL API type system
Key: FLINK-13262
URL: https://issues.apache.org/jira/browse/FLINK-13262
Project: Flink
Iss
Timo Walther created FLINK-13264:
Summary: Remove planner class clashes for planner type inference
lookups
Key: FLINK-13264
URL: https://issues.apache.org/jira/browse/FLINK-13264
Project: Flink
Timo Walther created FLINK-13273:
Summary: Allow switching planners in SQL Client
Key: FLINK-13273
URL: https://issues.apache.org/jira/browse/FLINK-13273
Project: Flink
Issue Type: New Featur
Timo Walther created FLINK-13335:
Summary: Align the SQL DDL with FLIP-37
Key: FLINK-13335
URL: https://issues.apache.org/jira/browse/FLINK-13335
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-13350:
Summary: Distinguish between temporary tables and persisted tables
Key: FLINK-13350
URL: https://issues.apache.org/jira/browse/FLINK-13350
Project: Flink
Iss
Timo Walther created FLINK-13385:
Summary: Align Hive data type mapping with FLIP-37
Key: FLINK-13385
URL: https://issues.apache.org/jira/browse/FLINK-13385
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-13400:
Summary: Remove Hive and Hadoop dependencies from SQL Client
Key: FLINK-13400
URL: https://issues.apache.org/jira/browse/FLINK-13400
Project: Flink
Issue Typ
Timo Walther created FLINK-13419:
Summary: TableEnvironment.explain() has side-effects on
ExecutionConfig
Key: FLINK-13419
URL: https://issues.apache.org/jira/browse/FLINK-13419
Project: Flink
Timo Walther created FLINK-13429:
Summary: SQL Client end-to-end test fails on Travis
Key: FLINK-13429
URL: https://issues.apache.org/jira/browse/FLINK-13429
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-13458:
Summary: ThreadLocalCache clashes for Blink planner
Key: FLINK-13458
URL: https://issues.apache.org/jira/browse/FLINK-13458
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-13463:
Summary: SQL VALUES might fail for Blink planner
Key: FLINK-13463
URL: https://issues.apache.org/jira/browse/FLINK-13463
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-13466:
Summary: Rename Batch/StreamTableSourceFactory methods for
avoiding name clashes
Key: FLINK-13466
URL: https://issues.apache.org/jira/browse/FLINK-13466
Project: Flin
Timo Walther created FLINK-13600:
Summary: TableEnvironment.connect() is not usable
Key: FLINK-13600
URL: https://issues.apache.org/jira/browse/FLINK-13600
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-13649:
Summary: Improve error message when job submission was not
successful
Key: FLINK-13649
URL: https://issues.apache.org/jira/browse/FLINK-13649
Project: Flink
Timo Walther created FLINK-13691:
Summary: Remove deprecated query config
Key: FLINK-13691
URL: https://issues.apache.org/jira/browse/FLINK-13691
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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-10229:
Summary: Support listing of views
Key: FLINK-10229
URL: https://issues.apache.org/jira/browse/FLINK-10229
Project: Flink
Issue Type: New Feature
Co
Timo Walther created FLINK-10230:
Summary: Support printing the query of a view
Key: FLINK-10230
URL: https://issues.apache.org/jira/browse/FLINK-10230
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-10231:
Summary: Support views in Table API
Key: FLINK-10231
URL: https://issues.apache.org/jira/browse/FLINK-10231
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-10232:
Summary: Add a SQL DDL
Key: FLINK-10232
URL: https://issues.apache.org/jira/browse/FLINK-10232
Project: Flink
Issue Type: New Feature
Components: T
Timo Walther created FLINK-10258:
Summary: Allow streaming sources to be present for batch
executions
Key: FLINK-10258
URL: https://issues.apache.org/jira/browse/FLINK-10258
Project: Flink
Timo Walther created FLINK-10261:
Summary: INSERT INTO does not work with ORDER BY clause
Key: FLINK-10261
URL: https://issues.apache.org/jira/browse/FLINK-10261
Project: Flink
Issue Type: Bu
Timo Walther created FLINK-10265:
Summary: Configure checkpointing behavior for SQL Client
Key: FLINK-10265
URL: https://issues.apache.org/jira/browse/FLINK-10265
Project: Flink
Issue Type: N
Timo Walther created FLINK-10269:
Summary: Elasticsearch UpdateRequest fail because of binary
incompatibility
Key: FLINK-10269
URL: https://issues.apache.org/jira/browse/FLINK-10269
Project: Flink
Timo Walther created FLINK-10273:
Summary: Access composite type fields after a function
Key: FLINK-10273
URL: https://issues.apache.org/jira/browse/FLINK-10273
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-10448:
Summary: VALUES clause is translated into a separate operator per
value
Key: FLINK-10448
URL: https://issues.apache.org/jira/browse/FLINK-10448
Project: Flink
Timo Walther created FLINK-10568:
Summary: Show correct time attributes when calling
Table.getSchema()
Key: FLINK-10568
URL: https://issues.apache.org/jira/browse/FLINK-10568
Project: Flink
Timo Walther created FLINK-10638:
Summary: Invalid table scan resolution for temporal join queries
Key: FLINK-10638
URL: https://issues.apache.org/jira/browse/FLINK-10638
Project: Flink
Issue
Timo Walther created FLINK-10686:
Summary: Introduce a flink-table-common module
Key: FLINK-10686
URL: https://issues.apache.org/jira/browse/FLINK-10686
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-10687:
Summary: Make flink-formats Scala-free
Key: FLINK-10687
URL: https://issues.apache.org/jira/browse/FLINK-10687
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-10688:
Summary: Remove flink-table dependencies from flink-connectors
Key: FLINK-10688
URL: https://issues.apache.org/jira/browse/FLINK-10688
Project: Flink
Issue
Timo Walther created FLINK-10689:
Summary: Port Table API extension points to flink-table-common
Key: FLINK-10689
URL: https://issues.apache.org/jira/browse/FLINK-10689
Project: Flink
Issue T
Timo Walther created FLINK-10726:
Summary: Streaming SQL end-to-end test fails due to recent
flink-table-common changes
Key: FLINK-10726
URL: https://issues.apache.org/jira/browse/FLINK-10726
Project:
Timo Walther created FLINK-10825:
Summary: ConnectedComponents test instable on Travis
Key: FLINK-10825
URL: https://issues.apache.org/jira/browse/FLINK-10825
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-10826:
Summary: Heavy deployment end-to-end test produces no output on
Travis
Key: FLINK-10826
URL: https://issues.apache.org/jira/browse/FLINK-10826
Project: Flink
Timo Walther created FLINK-10843:
Summary: Make Kafka version definition more flexible for new Kafka
table factory
Key: FLINK-10843
URL: https://issues.apache.org/jira/browse/FLINK-10843
Project: Flin
Timo Walther created FLINK-10845:
Summary: Support DISTINCT aggregates for batch
Key: FLINK-10845
URL: https://issues.apache.org/jira/browse/FLINK-10845
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-10846:
Summary: Add support for IS DISTINCT FROM in code generator
Key: FLINK-10846
URL: https://issues.apache.org/jira/browse/FLINK-10846
Project: Flink
Issue Type
Timo Walther created FLINK-10847:
Summary: Add support for IS NOT DISTINCT FROM in code generator
Key: FLINK-10847
URL: https://issues.apache.org/jira/browse/FLINK-10847
Project: Flink
Issue
Timo Walther created FLINK-10859:
Summary: Queryable state (rocksdb) end-to-end test fails on Travis
Key: FLINK-10859
URL: https://issues.apache.org/jira/browse/FLINK-10859
Project: Flink
Iss
Timo Walther created FLINK-10927:
Summary: Resuming Externalized Checkpoint (r, inc, up) test
instable
Key: FLINK-10927
URL: https://issues.apache.org/jira/browse/FLINK-10927
Project: Flink
Timo Walther created FLINK-11011:
Summary: Elasticsearch 6 sink end-to-end test unstable
Key: FLINK-11011
URL: https://issues.apache.org/jira/browse/FLINK-11011
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-11020:
Summary: Reorder joins only to eliminate cross joins
Key: FLINK-11020
URL: https://issues.apache.org/jira/browse/FLINK-11020
Project: Flink
Issue Type: Impr
1 - 100 of 699 matches
Mail list logo