Timo Walther created FLINK-9852:
---
Summary: Expose descriptor-based sink creation in table
environments
Key: FLINK-9852
URL: https://issues.apache.org/jira/browse/FLINK-9852
Project: Flink
Timo Walther created FLINK-9886:
---
Summary: Build SQL jars with every build
Key: FLINK-9886
URL: https://issues.apache.org/jira/browse/FLINK-9886
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-9854:
---
Summary: Allow passing multi-line input to SQL Client CLI
Key: FLINK-9854
URL: https://issues.apache.org/jira/browse/FLINK-9854
Project: Flink
Issue Type: Sub
Timo Walther created FLINK-9855:
---
Summary: KeyedStream.IntervalJoined#process does not work for
lambdas
Key: FLINK-9855
URL: https://issues.apache.org/jira/browse/FLINK-9855
Project: Flink
Timo Walther created FLINK-9851:
---
Summary: Add documentation for unified table sources/sinks
Key: FLINK-9851
URL: https://issues.apache.org/jira/browse/FLINK-9851
Project: Flink
Issue Type
Timo Walther created FLINK-9870:
---
Summary: Support field mapping and time attributes for table sinks
Key: FLINK-9870
URL: https://issues.apache.org/jira/browse/FLINK-9870
Project: Flink
Issue
Timo Walther created FLINK-9863:
---
Summary: Add a built-in ingestion time TS extractor
Key: FLINK-9863
URL: https://issues.apache.org/jira/browse/FLINK-9863
Project: Flink
Issue Type: New
Timo Walther created FLINK-9864:
---
Summary: Make timestamp extraction more flexible in SQL Client
Key: FLINK-9864
URL: https://issues.apache.org/jira/browse/FLINK-9864
Project: Flink
Issue Type
Timo Walther created FLINK-9948:
---
Summary: JSON format does not convert timestamps correctly
Key: FLINK-9948
URL: https://issues.apache.org/jira/browse/FLINK-9948
Project: Flink
Issue Type
Timo Walther created FLINK-9947:
---
Summary: Document unified table sources/sinks/formats
Key: FLINK-9947
URL: https://issues.apache.org/jira/browse/FLINK-9947
Project: Flink
Issue Type
Timo Walther created FLINK-9934:
---
Summary: Kafka table source factory produces invalid field mapping
Key: FLINK-9934
URL: https://issues.apache.org/jira/browse/FLINK-9934
Project: Flink
Issue
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
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
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
Timo Walther created FLINK-9765:
---
Summary: Improve CLI responsiveness when cluster is not reachable
Key: FLINK-9765
URL: https://issues.apache.org/jira/browse/FLINK-9765
Project: Flink
Issue
Timo Walther created FLINK-9740:
---
Summary: Support group windows over intervals of months
Key: FLINK-9740
URL: https://issues.apache.org/jira/browse/FLINK-9740
Project: Flink
Issue Type: New
Timo Walther created FLINK-9774:
---
Summary: Allow to pass a string-based cluster identifier to
command line
Key: FLINK-9774
URL: https://issues.apache.org/jira/browse/FLINK-9774
Project: Flink
Timo Walther created FLINK-9775:
---
Summary: BucketingSink E2E test fails in certain environments
Key: FLINK-9775
URL: https://issues.apache.org/jira/browse/FLINK-9775
Project: Flink
Issue Type
Timo Walther created FLINK-9790:
---
Summary: Add documentation for UDF in SQL Client
Key: FLINK-9790
URL: https://issues.apache.org/jira/browse/FLINK-9790
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-9846:
---
Summary: Add a Kafka table sink factory
Key: FLINK-9846
URL: https://issues.apache.org/jira/browse/FLINK-9846
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-9833:
---
Summary: Add a SQL Client end-to-end test
Key: FLINK-9833
URL: https://issues.apache.org/jira/browse/FLINK-9833
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-8920:
---
Summary: Split code generated input unboxing code
Key: FLINK-8920
URL: https://issues.apache.org/jira/browse/FLINK-8920
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-8921:
---
Summary: Split code generated call expression
Key: FLINK-8921
URL: https://issues.apache.org/jira/browse/FLINK-8921
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-8953:
---
Summary: Resolve unresolved field references in FieldComputer
expressions
Key: FLINK-8953
URL: https://issues.apache.org/jira/browse/FLINK-8953
Project: Flink
Timo Walther created FLINK-8954:
---
Summary: Escape control characters when outputting on SQL Client
CLI
Key: FLINK-8954
URL: https://issues.apache.org/jira/browse/FLINK-8954
Project: Flink
Timo Walther created FLINK-9134:
---
Summary: Update Calcite dependency to 1.17
Key: FLINK-9134
URL: https://issues.apache.org/jira/browse/FLINK-9134
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-9229:
---
Summary: Fix literal handling in code generation
Key: FLINK-9229
URL: https://issues.apache.org/jira/browse/FLINK-9229
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-9219:
---
Summary: Add support for OpenGIS features in Table & SQL API
Key: FLINK-9219
URL: https://issues.apache.org/jira/browse/FLINK-9219
Project: Flink
Issue
Timo Walther created FLINK-9248:
---
Summary: Create a SQL Client Avro format fat-jar
Key: FLINK-9248
URL: https://issues.apache.org/jira/browse/FLINK-9248
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-9247:
---
Summary: Allow creating table sources/sinks from an Avro schema
Key: FLINK-9247
URL: https://issues.apache.org/jira/browse/FLINK-9247
Project: Flink
Issue
Timo Walther created FLINK-9181:
---
Summary: Add SQL Client documentation page
Key: FLINK-9181
URL: https://issues.apache.org/jira/browse/FLINK-9181
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-9113:
---
Summary: Data loss in BucketingSink when writing to local
filesystem
Key: FLINK-9113
URL: https://issues.apache.org/jira/browse/FLINK-9113
Project: Flink
Timo Walther created FLINK-9081:
---
Summary: ResourceManagerTaskExecutorTest is unstable
Key: FLINK-9081
URL: https://issues.apache.org/jira/browse/FLINK-9081
Project: Flink
Issue Type: Test
Timo Walther created FLINK-9082:
---
Summary: Submission with higher parallelism than task slots fails
with TimeoutException
Key: FLINK-9082
URL: https://issues.apache.org/jira/browse/FLINK-9082
Project
Timo Walther created FLINK-8863:
---
Summary: Add user-defined function support in SQL Client
Key: FLINK-8863
URL: https://issues.apache.org/jira/browse/FLINK-8863
Project: Flink
Issue Type: Sub
Timo Walther created FLINK-8864:
---
Summary: Add CLI query history
Key: FLINK-8864
URL: https://issues.apache.org/jira/browse/FLINK-8864
Project: Flink
Issue Type: Sub-task
Components
Timo Walther created FLINK-8865:
---
Summary: Add CLI query code completion in SQL Client
Key: FLINK-8865
URL: https://issues.apache.org/jira/browse/FLINK-8865
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-8861:
---
Summary: Add support for batch queries in SQL Client
Key: FLINK-8861
URL: https://issues.apache.org/jira/browse/FLINK-8861
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-8866:
---
Summary: Create unified interfaces to configure and instatiate
TableSinks
Key: FLINK-8866
URL: https://issues.apache.org/jira/browse/FLINK-8866
Project: Flink
Timo Walther created FLINK-8831:
---
Summary: Create SQL Client dependencies
Key: FLINK-8831
URL: https://issues.apache.org/jira/browse/FLINK-8831
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-8833:
---
Summary: Create SQL Client JSON format fat-jar
Key: FLINK-8833
URL: https://issues.apache.org/jira/browse/FLINK-8833
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-8839:
---
Summary: Table source factory discovery is broken in SQL Client
Key: FLINK-8839
URL: https://issues.apache.org/jira/browse/FLINK-8839
Project: Flink
Issue
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
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-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-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
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
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-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-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
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
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-10845:
Summary: Support DISTINCT aggregates for batch
Key: FLINK-10845
URL: https://issues.apache.org/jira/browse/FLINK-10845
Project: Flink
Issue Type: New
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
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-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-11184:
Summary: Rework TableSource and TableSink interfaces
Key: FLINK-11184
URL: https://issues.apache.org/jira/browse/FLINK-11184
Project: Flink
Issue Type: New
Timo Walther created FLINK-11063:
Summary: Make flink-table Scala-free
Key: FLINK-11063
URL: https://issues.apache.org/jira/browse/FLINK-11063
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-11065:
Summary: Migrate flink-table runtime classes
Key: FLINK-11065
URL: https://issues.apache.org/jira/browse/FLINK-11065
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11067:
Summary: Port TableEnvironments to Java
Key: FLINK-11067
URL: https://issues.apache.org/jira/browse/FLINK-11067
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11066:
Summary: Migrate main Table API classes to flink-table-api-base
Key: FLINK-11066
URL: https://issues.apache.org/jira/browse/FLINK-11066
Project: Flink
Issue
Timo Walther created FLINK-11068:
Summary: Port Table class to Java
Key: FLINK-11068
URL: https://issues.apache.org/jira/browse/FLINK-11068
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-11064:
Summary: Setup a new flink-table module structure
Key: FLINK-11064
URL: https://issues.apache.org/jira/browse/FLINK-11064
Project: Flink
Issue Type: Sub
Timo Walther created FLINK-11036:
Summary: Streaming classloader end-to-end test does not work on
source releases
Key: FLINK-11036
URL: https://issues.apache.org/jira/browse/FLINK-11036
Project
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
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
Timo Walther created FLINK-11273:
Summary: Queryable state (rocksdb) end-to-end test fails
Key: FLINK-11273
URL: https://issues.apache.org/jira/browse/FLINK-11273
Project: Flink
Issue Type
Timo Walther created FLINK-11200:
Summary: Port DataView classes to flink-table-common
Key: FLINK-11200
URL: https://issues.apache.org/jira/browse/FLINK-11200
Project: Flink
Issue Type: Sub
Timo Walther created FLINK-11439:
Summary: INSERT INTO flink_sql SELECT * FROM blink_sql
Key: FLINK-11439
URL: https://issues.apache.org/jira/browse/FLINK-11439
Project: Flink
Issue Type
Timo Walther created FLINK-11785:
Summary: Replace case class Null(type) in Table API
Key: FLINK-11785
URL: https://issues.apache.org/jira/browse/FLINK-11785
Project: Flink
Issue Type
Timo Walther created FLINK-11844:
Summary: Simplify OVER window Table API classes
Key: FLINK-11844
URL: https://issues.apache.org/jira/browse/FLINK-11844
Project: Flink
Issue Type
Timo Walther created FLINK-11728:
Summary: Deprecate CalciteConfig temporarily
Key: FLINK-11728
URL: https://issues.apache.org/jira/browse/FLINK-11728
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-11727:
Summary: JSON row format is not serializable
Key: FLINK-11727
URL: https://issues.apache.org/jira/browse/FLINK-11727
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-11921:
Summary: Upgrade Calcite dependency to 1.19
Key: FLINK-11921
URL: https://issues.apache.org/jira/browse/FLINK-11921
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-11901:
Summary: Update the year in NOTICE files
Key: FLINK-11901
URL: https://issues.apache.org/jira/browse/FLINK-11901
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-11890:
Summary: Replace Table API string-based expressions by a Java DSL
Key: FLINK-11890
URL: https://issues.apache.org/jira/browse/FLINK-11890
Project: Flink
Timo Walther created FLINK-11543:
Summary: Type mismatch AssertionError in FilterJoinRule
Key: FLINK-11543
URL: https://issues.apache.org/jira/browse/FLINK-11543
Project: Flink
Issue Type
Timo Walther created FLINK-11679:
Summary: Create Blink SQL planner and runtime modules
Key: FLINK-11679
URL: https://issues.apache.org/jira/browse/FLINK-11679
Project: Flink
Issue Type: New
Timo Walther created FLINK-11488:
Summary: Merge a basic Blink planner framework
Key: FLINK-11488
URL: https://issues.apache.org/jira/browse/FLINK-11488
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11493:
Summary: Finalize the Blink SQL merging efforts
Key: FLINK-11493
URL: https://issues.apache.org/jira/browse/FLINK-11493
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11489:
Summary: Add an initial Blink streaming runtime
Key: FLINK-11489
URL: https://issues.apache.org/jira/browse/FLINK-11489
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11491:
Summary: Support all TPC-DS queries
Key: FLINK-11491
URL: https://issues.apache.org/jira/browse/FLINK-11491
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11490:
Summary: Add an initial batch runtime
Key: FLINK-11490
URL: https://issues.apache.org/jira/browse/FLINK-11490
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11492:
Summary: Support the full Blink SQL runtime
Key: FLINK-11492
URL: https://issues.apache.org/jira/browse/FLINK-11492
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11535:
Summary: SQL Client jar does not contain table-api-java
Key: FLINK-11535
URL: https://issues.apache.org/jira/browse/FLINK-11535
Project: Flink
Issue Type
Timo Walther created FLINK-11444:
Summary: Deprecate methods for uncoupling table API and table core
Key: FLINK-11444
URL: https://issues.apache.org/jira/browse/FLINK-11444
Project: Flink
Timo Walther created FLINK-11448:
Summary: Clean-up and prepare Table API to be uncoupled from table
core
Key: FLINK-11448
URL: https://issues.apache.org/jira/browse/FLINK-11448
Project: Flink
Timo Walther created FLINK-11447:
Summary: Deprecate "new Table(TableEnvironment, String)"
Key: FLINK-11447
URL: https://issues.apache.org/jira/browse/FLINK-11447
Project: Flink
Timo Walther created FLINK-11449:
Summary: Uncouple the Expression class from RexNodes
Key: FLINK-11449
URL: https://issues.apache.org/jira/browse/FLINK-11449
Project: Flink
Issue Type: New
Timo Walther created FLINK-11450:
Summary: Port and move TableSource and TableSink to
flink-table-common
Key: FLINK-11450
URL: https://issues.apache.org/jira/browse/FLINK-11450
Project: Flink
Timo Walther created FLINK-11445:
Summary: Deprecate static methods in TableEnvironments
Key: FLINK-11445
URL: https://issues.apache.org/jira/browse/FLINK-11445
Project: Flink
Issue Type
Timo Walther created FLINK-11451:
Summary: Move *QueryConfig and TableDescriptor to
flink-table-api-java
Key: FLINK-11451
URL: https://issues.apache.org/jira/browse/FLINK-11451
Project: Flink
Timo Walther created FLINK-11452:
Summary: Make the table planner pluggable
Key: FLINK-11452
URL: https://issues.apache.org/jira/browse/FLINK-11452
Project: Flink
Issue Type: Sub-task
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
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
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
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
901 - 1000 of 1344 matches
Mail list logo