Timo Walther created FLINK-20072:
Summary: Add documentation for FLIP-107
Key: FLINK-20072
URL: https://issues.apache.org/jira/browse/FLINK-20072
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-20060:
Summary: Add a Collector to KinsesisDeserializationSchema
Key: FLINK-20060
URL: https://issues.apache.org/jira/browse/FLINK-20060
Project: Flink
Issue Type:
Timo Walther created FLINK-20019:
Summary: Support all conversion classes in Row.equals/hashCode
Key: FLINK-20019
URL: https://issues.apache.org/jira/browse/FLINK-20019
Project: Flink
Issue
Timo Walther created FLINK-19981:
Summary: Improve dealing with Row in DataStream API
Key: FLINK-19981
URL: https://issues.apache.org/jira/browse/FLINK-19981
Project: Flink
Issue Type:
Timo Walther created FLINK-19980:
Summary: Add StreamTableEnvironment.to/fromChangelogStream
Key: FLINK-19980
URL: https://issues.apache.org/jira/browse/FLINK-19980
Project: Flink
Issue
Timo Walther created FLINK-19978:
Summary: Add StreamStatementSet.attachToStream
Key: FLINK-19978
URL: https://issues.apache.org/jira/browse/FLINK-19978
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19977:
Summary: Add new toDataStream and toDataStream
Key: FLINK-19977
URL: https://issues.apache.org/jira/browse/FLINK-19977
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19976:
Summary: FLIP-136: Improve interoperability between DataStream and
Table API
Key: FLINK-19976
URL: https://issues.apache.org/jira/browse/FLINK-19976
Project: Flink
Timo Walther created FLINK-19820:
Summary: TableEnvironment init fails with JDK9
Key: FLINK-19820
URL: https://issues.apache.org/jira/browse/FLINK-19820
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-19792:
Summary: Interval join with equal time attributes is not recognized
Key: FLINK-19792
URL: https://issues.apache.org/jira/browse/FLINK-19792
Project: Flink
Timo Walther created FLINK-19672:
Summary: Merge kafka-connector-base into flink-connector-kafka
Key: FLINK-19672
URL: https://issues.apache.org/jira/browse/FLINK-19672
Project: Flink
Issue
Timo Walther created FLINK-19453:
Summary: Deprecate old source and sink interfaces
Key: FLINK-19453
URL: https://issues.apache.org/jira/browse/FLINK-19453
Project: Flink
Issue Type:
Timo Walther created FLINK-19395:
Summary: Replace SqlConversionException with either TableException
or ValidationException
Key: FLINK-19395
URL: https://issues.apache.org/jira/browse/FLINK-19395
Timo Walther created FLINK-19371:
Summary: Support table transformations in SQL
Key: FLINK-19371
URL: https://issues.apache.org/jira/browse/FLINK-19371
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-19341:
Summary: Update API module for FLIP-107
Key: FLINK-19341
URL: https://issues.apache.org/jira/browse/FLINK-19341
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19294:
Summary: Support key and value formats in Kafka connector
Key: FLINK-19294
URL: https://issues.apache.org/jira/browse/FLINK-19294
Project: Flink
Issue Type:
Timo Walther created FLINK-19276:
Summary: Allow to read metadata for Debezium format
Key: FLINK-19276
URL: https://issues.apache.org/jira/browse/FLINK-19276
Project: Flink
Issue Type:
Timo Walther created FLINK-19275:
Summary: Allow to read and write metadata in Kafka table
source/sink
Key: FLINK-19275
URL: https://issues.apache.org/jira/browse/FLINK-19275
Project: Flink
Timo Walther created FLINK-19274:
Summary: Support FLIP-107 interfaces in planner
Key: FLINK-19274
URL: https://issues.apache.org/jira/browse/FLINK-19274
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19273:
Summary: Update parser module for FLIP-107
Key: FLINK-19273
URL: https://issues.apache.org/jira/browse/FLINK-19273
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19272:
Summary: Add interfaces for FLIP-107
Key: FLINK-19272
URL: https://issues.apache.org/jira/browse/FLINK-19272
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19204:
Summary: Improve warning during a Table.execute()
Key: FLINK-19204
URL: https://issues.apache.org/jira/browse/FLINK-19204
Project: Flink
Issue Type:
Timo Walther created FLINK-19188:
Summary: Add a new streaming SQL examples
Key: FLINK-19188
URL: https://issues.apache.org/jira/browse/FLINK-19188
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19187:
Summary: Add a new basic Table API example
Key: FLINK-19187
URL: https://issues.apache.org/jira/browse/FLINK-19187
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19127:
Summary: Provide a replacement of
StreamExecutionEnvironment.createRemoteEnvironment for TableEnvironment
Key: FLINK-19127
URL: https://issues.apache.org/jira/browse/FLINK-19127
Timo Walther created FLINK-18936:
Summary: Update documentation about user-defined aggregate
functions
Key: FLINK-18936
URL: https://issues.apache.org/jira/browse/FLINK-18936
Project: Flink
Timo Walther created FLINK-18901:
Summary: Use new type inference for SQL DDL of aggregate functions
Key: FLINK-18901
URL: https://issues.apache.org/jira/browse/FLINK-18901
Project: Flink
Timo Walther created FLINK-18890:
Summary: Update AsyncTableFunctions to the new type system
Key: FLINK-18890
URL: https://issues.apache.org/jira/browse/FLINK-18890
Project: Flink
Issue
Timo Walther created FLINK-18877:
Summary: Faulty BinarySection.equals()
Key: FLINK-18877
URL: https://issues.apache.org/jira/browse/FLINK-18877
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-18840:
Summary: Support StatementSet with DataStream API
Key: FLINK-18840
URL: https://issues.apache.org/jira/browse/FLINK-18840
Project: Flink
Issue Type: New
Timo Walther created FLINK-18809:
Summary: Update internal aggregate functions to new type system
Key: FLINK-18809
URL: https://issues.apache.org/jira/browse/FLINK-18809
Project: Flink
Issue
Timo Walther created FLINK-18703:
Summary: Use new data structure converters when legacy types are
not present
Key: FLINK-18703
URL: https://issues.apache.org/jira/browse/FLINK-18703
Project: Flink
Timo Walther created FLINK-18699:
Summary: Allow variables for column names in Scala Table API
Key: FLINK-18699
URL: https://issues.apache.org/jira/browse/FLINK-18699
Project: Flink
Issue
Timo Walther created FLINK-18628:
Summary: Invalid error message for overloaded methods with same
parameter name
Key: FLINK-18628
URL: https://issues.apache.org/jira/browse/FLINK-18628
Project: Flink
Timo Walther created FLINK-18586:
Summary: Simplify the creation of explicit structured types
Key: FLINK-18586
URL: https://issues.apache.org/jira/browse/FLINK-18586
Project: Flink
Issue
Timo Walther created FLINK-18553:
Summary: Update Table API set operations to the new type system
Key: FLINK-18553
URL: https://issues.apache.org/jira/browse/FLINK-18553
Project: Flink
Issue
Timo Walther created FLINK-18537:
Summary: Remove RowDataTypeInfo
Key: FLINK-18537
URL: https://issues.apache.org/jira/browse/FLINK-18537
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-18528:
Summary: Update UNNEST to new type system
Key: FLINK-18528
URL: https://issues.apache.org/jira/browse/FLINK-18528
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-18524:
Summary: Scala varargs cause exception for new inference
Key: FLINK-18524
URL: https://issues.apache.org/jira/browse/FLINK-18524
Project: Flink
Issue Type:
Timo Walther created FLINK-18425:
Summary: GenericArrayData cannot convert object arrays to
primitive arrays
Key: FLINK-18425
URL: https://issues.apache.org/jira/browse/FLINK-18425
Project: Flink
Timo Walther created FLINK-18417:
Summary: Support List as a conversion class for ARRAY
Key: FLINK-18417
URL: https://issues.apache.org/jira/browse/FLINK-18417
Project: Flink
Issue Type:
Timo Walther created FLINK-18380:
Summary: Add a table source example
Key: FLINK-18380
URL: https://issues.apache.org/jira/browse/FLINK-18380
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-18363:
Summary: Add user classloader to context in DeSerializationSchema
Key: FLINK-18363
URL: https://issues.apache.org/jira/browse/FLINK-18363
Project: Flink
Timo Walther created FLINK-18324:
Summary: Translate updated data type and function page into Chinese
Key: FLINK-18324
URL: https://issues.apache.org/jira/browse/FLINK-18324
Project: Flink
Timo Walther created FLINK-18273:
Summary: Test and document remote cluster submission in SQL Client
Key: FLINK-18273
URL: https://issues.apache.org/jira/browse/FLINK-18273
Project: Flink
Timo Walther created FLINK-18248:
Summary: Update data type documentation for 1.11
Key: FLINK-18248
URL: https://issues.apache.org/jira/browse/FLINK-18248
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-18090:
Summary: Support RowKind in Row.toString
Key: FLINK-18090
URL: https://issues.apache.org/jira/browse/FLINK-18090
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-18066:
Summary: Add documentation for how to develop a new table
source/sink
Key: FLINK-18066
URL: https://issues.apache.org/jira/browse/FLINK-18066
Project: Flink
Timo Walther created FLINK-18065:
Summary: Add documentation for new scalar/table functions
Key: FLINK-18065
URL: https://issues.apache.org/jira/browse/FLINK-18065
Project: Flink
Issue Type:
Timo Walther created FLINK-18005:
Summary: Implement type inference for CAST
Key: FLINK-18005
URL: https://issues.apache.org/jira/browse/FLINK-18005
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-18001:
Summary: Add a new test base for evaluating expressions
Key: FLINK-18001
URL: https://issues.apache.org/jira/browse/FLINK-18001
Project: Flink
Issue Type:
Timo Walther created FLINK-17936:
Summary: Implement type inference for AS
Key: FLINK-17936
URL: https://issues.apache.org/jira/browse/FLINK-17936
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-17882:
Summary: Don't allow self referencing structured type
Key: FLINK-17882
URL: https://issues.apache.org/jira/browse/FLINK-17882
Project: Flink
Issue Type:
Timo Walther created FLINK-17880:
Summary: Use new type inference for SQL table and scalar functions
Key: FLINK-17880
URL: https://issues.apache.org/jira/browse/FLINK-17880
Project: Flink
Timo Walther created FLINK-17879:
Summary: Update Python row serializer
Key: FLINK-17879
URL: https://issues.apache.org/jira/browse/FLINK-17879
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-17793:
Summary: Replace TableSchema with dedicated CatalogSchema
Key: FLINK-17793
URL: https://issues.apache.org/jira/browse/FLINK-17793
Project: Flink
Issue Type:
Timo Walther created FLINK-17716:
Summary: Remove deprecated RowData.get and similar methods
Key: FLINK-17716
URL: https://issues.apache.org/jira/browse/FLINK-17716
Project: Flink
Issue
Timo Walther created FLINK-17698:
Summary: Support for comparing instance of all types
Key: FLINK-17698
URL: https://issues.apache.org/jira/browse/FLINK-17698
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-17668:
Summary: Fix shortcomings in new data structures
Key: FLINK-17668
URL: https://issues.apache.org/jira/browse/FLINK-17668
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-17660:
Summary: DataTypeExtractor does not check for default constructor
Key: FLINK-17660
URL: https://issues.apache.org/jira/browse/FLINK-17660
Project: Flink
Timo Walther created FLINK-17541:
Summary: Support inline structured types
Key: FLINK-17541
URL: https://issues.apache.org/jira/browse/FLINK-17541
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-17532:
Summary: Update tests to use BatchTestBase#checkTableResult
Key: FLINK-17532
URL: https://issues.apache.org/jira/browse/FLINK-17532
Project: Flink
Issue
Timo Walther created FLINK-17521:
Summary: Remove `com.ibm.icu` dependency from table-common
Key: FLINK-17521
URL: https://issues.apache.org/jira/browse/FLINK-17521
Project: Flink
Issue
Timo Walther created FLINK-17489:
Summary: Support any kind of array in
StringUtils.arrayAwareToString()
Key: FLINK-17489
URL: https://issues.apache.org/jira/browse/FLINK-17489
Project: Flink
Timo Walther created FLINK-17484:
Summary: Enable type coercion
Key: FLINK-17484
URL: https://issues.apache.org/jira/browse/FLINK-17484
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-17373:
Summary: Support the NULL type for function calls
Key: FLINK-17373
URL: https://issues.apache.org/jira/browse/FLINK-17373
Project: Flink
Issue Type:
Timo Walther created FLINK-17370:
Summary: Ensure deterministic type inference extraction
Key: FLINK-17370
URL: https://issues.apache.org/jira/browse/FLINK-17370
Project: Flink
Issue Type:
Timo Walther created FLINK-17190:
Summary: SQL client does not support views that reference a table
from DDL
Key: FLINK-17190
URL: https://issues.apache.org/jira/browse/FLINK-17190
Project: Flink
Timo Walther created FLINK-17158:
Summary: Watermark strategy property cannot be expressed in YAML
Key: FLINK-17158
URL: https://issues.apache.org/jira/browse/FLINK-17158
Project: Flink
Timo Walther created FLINK-17030:
Summary: Add primary key syntax to DDL
Key: FLINK-17030
URL: https://issues.apache.org/jira/browse/FLINK-17030
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-17000:
Summary: Type information in sources should cover all data
structures
Key: FLINK-17000
URL: https://issues.apache.org/jira/browse/FLINK-17000
Project: Flink
Timo Walther created FLINK-16999:
Summary: Data structure should cover all conversions declared in
logical types
Key: FLINK-16999
URL: https://issues.apache.org/jira/browse/FLINK-16999
Project: Flink
Timo Walther created FLINK-16998:
Summary: Add a changeflag to Row type
Key: FLINK-16998
URL: https://issues.apache.org/jira/browse/FLINK-16998
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-16997:
Summary: Add new factory interfaces and utilities
Key: FLINK-16997
URL: https://issues.apache.org/jira/browse/FLINK-16997
Project: Flink
Issue Type:
Timo Walther created FLINK-16996:
Summary: Refactor planner and connectors to use new data structures
Key: FLINK-16996
URL: https://issues.apache.org/jira/browse/FLINK-16996
Project: Flink
Timo Walther created FLINK-16995:
Summary: Add new data structure interfaces in table-common
Key: FLINK-16995
URL: https://issues.apache.org/jira/browse/FLINK-16995
Project: Flink
Issue
Timo Walther created FLINK-16994:
Summary: Support SupportsWatermarkPushDown in planner
Key: FLINK-16994
URL: https://issues.apache.org/jira/browse/FLINK-16994
Project: Flink
Issue Type:
Timo Walther created FLINK-16993:
Summary: Support SupportsComputedColumnPushDown in planner
Key: FLINK-16993
URL: https://issues.apache.org/jira/browse/FLINK-16993
Project: Flink
Issue
Timo Walther created FLINK-16992:
Summary: Add ability interfaces for table source/sink
Key: FLINK-16992
URL: https://issues.apache.org/jira/browse/FLINK-16992
Project: Flink
Issue Type:
Timo Walther created FLINK-16991:
Summary: Support DynamicTableSink in planner
Key: FLINK-16991
URL: https://issues.apache.org/jira/browse/FLINK-16991
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-16990:
Summary: Support LookupTableSource in planner
Key: FLINK-16990
URL: https://issues.apache.org/jira/browse/FLINK-16990
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-16989:
Summary: Support ScanTableSource in planner
Key: FLINK-16989
URL: https://issues.apache.org/jira/browse/FLINK-16989
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-16988:
Summary: Add core table source/sink interfaces
Key: FLINK-16988
URL: https://issues.apache.org/jira/browse/FLINK-16988
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-16987:
Summary: Add new table source and sink interfaces
Key: FLINK-16987
URL: https://issues.apache.org/jira/browse/FLINK-16987
Project: Flink
Issue Type: New
Timo Walther created FLINK-16835:
Summary: Replace TableConfig with Configuration
Key: FLINK-16835
URL: https://issues.apache.org/jira/browse/FLINK-16835
Project: Flink
Issue Type:
Timo Walther created FLINK-16779:
Summary: Support RAW types through the stack
Key: FLINK-16779
URL: https://issues.apache.org/jira/browse/FLINK-16779
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-16679:
Summary: Investigate more efficient outer join plans
Key: FLINK-16679
URL: https://issues.apache.org/jira/browse/FLINK-16679
Project: Flink
Issue Type:
Timo Walther created FLINK-16344:
Summary: Preserve nullability for nested types
Key: FLINK-16344
URL: https://issues.apache.org/jira/browse/FLINK-16344
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-16336:
Summary: Support new type inference for temporal table functions
Key: FLINK-16336
URL: https://issues.apache.org/jira/browse/FLINK-16336
Project: Flink
Timo Walther created FLINK-16314:
Summary: Revisit FlinkTypeFactory
Key: FLINK-16314
URL: https://issues.apache.org/jira/browse/FLINK-16314
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-16261:
Summary: Avoid unnecessary casting in TypeInferenceOperandChecker
Key: FLINK-16261
URL: https://issues.apache.org/jira/browse/FLINK-16261
Project: Flink
Timo Walther created FLINK-16258:
Summary: Update test utilities to FLIP-65
Key: FLINK-16258
URL: https://issues.apache.org/jira/browse/FLINK-16258
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-16047:
Summary: Blink planner produces wrong aggregate results with state
clean up
Key: FLINK-16047
URL: https://issues.apache.org/jira/browse/FLINK-16047
Project: Flink
Timo Walther created FLINK-16021:
Summary: DescriptorProperties.putTableSchema does not include
constraints
Key: FLINK-16021
URL: https://issues.apache.org/jira/browse/FLINK-16021
Project: Flink
Timo Walther created FLINK-15958:
Summary: Fully support RAW types in the API
Key: FLINK-15958
URL: https://issues.apache.org/jira/browse/FLINK-15958
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-15915:
Summary: Bump Jackson to 2.10.1 in flink-table-planner
Key: FLINK-15915
URL: https://issues.apache.org/jira/browse/FLINK-15915
Project: Flink
Issue Type:
Timo Walther created FLINK-15804:
Summary: Support the new type inference in Scala Table API
functions
Key: FLINK-15804
URL: https://issues.apache.org/jira/browse/FLINK-15804
Project: Flink
Timo Walther created FLINK-15803:
Summary: Expose the new type inference for aggregate functions
Key: FLINK-15803
URL: https://issues.apache.org/jira/browse/FLINK-15803
Project: Flink
Issue
Timo Walther created FLINK-15802:
Summary: Expose the new type inference for table functions
Key: FLINK-15802
URL: https://issues.apache.org/jira/browse/FLINK-15802
Project: Flink
Issue
Timo Walther created FLINK-15635:
Summary: Allow passing a ClassLoader to EnvironmentSettings
Key: FLINK-15635
URL: https://issues.apache.org/jira/browse/FLINK-15635
Project: Flink
Issue
201 - 300 of 668 matches
Mail list logo
