Fabian Hueske created FLINK-3939:
Summary: Prevent distinct aggregates and grouping sets from being
translated
Key: FLINK-3939
URL: https://issues.apache.org/jira/browse/FLINK-3939
Project: Flink
Fabian Hueske created FLINK-3940:
Summary: Add support for ORDER BY OFFSET FETCH
Key: FLINK-3940
URL: https://issues.apache.org/jira/browse/FLINK-3940
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-3941:
Summary: Add support for UNION (with duplicate elimination)
Key: FLINK-3941
URL: https://issues.apache.org/jira/browse/FLINK-3941
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3942:
Summary: Add support for INTERSECT
Key: FLINK-3942
URL: https://issues.apache.org/jira/browse/FLINK-3942
Project: Flink
Issue Type: New Feature
Com
Fabian Hueske created FLINK-3943:
Summary: Add support for EXCEPT (set minus)
Key: FLINK-3943
URL: https://issues.apache.org/jira/browse/FLINK-3943
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-3944:
Summary: Add optimization rules to reorder Cartesian products and
joins
Key: FLINK-3944
URL: https://issues.apache.org/jira/browse/FLINK-3944
Project: Flink
Fabian Hueske created FLINK-3955:
Summary: Change Table.toSink() to Table.writeToSink()
Key: FLINK-3955
URL: https://issues.apache.org/jira/browse/FLINK-3955
Project: Flink
Issue Type: Improv
Fabian Hueske created FLINK-3971:
Summary: Aggregates handle null values incorrectly.
Key: FLINK-3971
URL: https://issues.apache.org/jira/browse/FLINK-3971
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-3973:
Summary: Table API documentation is "hidden" in Programming Guide
menu list
Key: FLINK-3973
URL: https://issues.apache.org/jira/browse/FLINK-3973
Project: Flink
Fabian Hueske created FLINK-4047:
Summary: Fix documentation about determinism of KeySelectors
Key: FLINK-4047
URL: https://issues.apache.org/jira/browse/FLINK-4047
Project: Flink
Issue Type:
Fabian Hueske created FLINK-4068:
Summary: Move constant computations out of code-generated
`flatMap` functions.
Key: FLINK-4068
URL: https://issues.apache.org/jira/browse/FLINK-4068
Project: Flink
Fabian Hueske created FLINK-4077:
Summary: Register Pojo DataSet/DataStream as Table requires alias
expression.
Key: FLINK-4077
URL: https://issues.apache.org/jira/browse/FLINK-4077
Project: Flink
Fabian Hueske created FLINK-4086:
Summary: Hide internal Expression methods from Table API
Key: FLINK-4086
URL: https://issues.apache.org/jira/browse/FLINK-4086
Project: Flink
Issue Type: Imp
Fabian Hueske created FLINK-4088:
Summary: Add interface to save and load TableSources
Key: FLINK-4088
URL: https://issues.apache.org/jira/browse/FLINK-4088
Project: Flink
Issue Type: Improve
Fabian Hueske created FLINK-4453:
Summary: Scala code example in Window documentation shows Java
Key: FLINK-4453
URL: https://issues.apache.org/jira/browse/FLINK-4453
Project: Flink
Issue Typ
Fabian Hueske created FLINK-4480:
Summary: Incorrect link to elastic.co in documentation
Key: FLINK-4480
URL: https://issues.apache.org/jira/browse/FLINK-4480
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-4513:
Summary: Kafka connector documentation refers to Flink 1.1-SNAPSHOT
Key: FLINK-4513
URL: https://issues.apache.org/jira/browse/FLINK-4513
Project: Flink
Issu
Fabian Hueske created FLINK-18988:
-
Summary: Continuous query with LATERAL and LIMIT produces wrong
result
Key: FLINK-18988
URL: https://issues.apache.org/jira/browse/FLINK-18988
Project: Flink
Fabian Hueske created FLINK-19321:
-
Summary: CollectSinkFunction does not define serialVersionUID
Key: FLINK-19321
URL: https://issues.apache.org/jira/browse/FLINK-19321
Project: Flink
Issue
Fabian Hueske created FLINK-19398:
-
Summary: Hive connector fails with IllegalAccessError if submitted
as usercode
Key: FLINK-19398
URL: https://issues.apache.org/jira/browse/FLINK-19398
Project: Flin
Fabian Hueske created FLINK-19790:
-
Summary: Writing MAP to Kafka with JSON format
produces incorrect data.
Key: FLINK-19790
URL: https://issues.apache.org/jira/browse/FLINK-19790
Project: Flink
Fabian Hueske created FLINK-20578:
-
Summary: Cannot create empty array using ARRAY[]
Key: FLINK-20578
URL: https://issues.apache.org/jira/browse/FLINK-20578
Project: Flink
Issue Type: Sub-tas
Fabian Hueske created FLINK-17845:
-
Summary: Can't remove a table connector property with ALTER TABLE
Key: FLINK-17845
URL: https://issues.apache.org/jira/browse/FLINK-17845
Project: Flink
Is
Fabian Hueske created FLINK-18298:
-
Summary: Rename TableResult headers of SHOW statements
Key: FLINK-18298
URL: https://issues.apache.org/jira/browse/FLINK-18298
Project: Flink
Issue Type: I
Fabian Hueske created FLINK-18378:
-
Summary: CatalogManager checks for CatalogTableImpl instead of
CatalogTable
Key: FLINK-18378
URL: https://issues.apache.org/jira/browse/FLINK-18378
Project: Flink
Fabian Hueske created FLINK-18623:
-
Summary: CREATE TEMPORARY TABLE not documented
Key: FLINK-18623
URL: https://issues.apache.org/jira/browse/FLINK-18623
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-18657:
-
Summary: Change semantics of DESCRIBE SELECT statement
Key: FLINK-18657
URL: https://issues.apache.org/jira/browse/FLINK-18657
Project: Flink
Issue Type: I
Fabian Hueske created FLINK-18672:
-
Summary: Fix Scala code examples for UDF type inference annotations
Key: FLINK-18672
URL: https://issues.apache.org/jira/browse/FLINK-18672
Project: Flink
Fabian Hueske created FLINK-18673:
-
Summary: Calling ROW() in a UDF results in
UnsupportedOperationException
Key: FLINK-18673
URL: https://issues.apache.org/jira/browse/FLINK-18673
Project: Flink
Fabian Hueske created FLINK-18683:
-
Summary: Support @DataTypeHint for TableFunction output types
Key: FLINK-18683
URL: https://issues.apache.org/jira/browse/FLINK-18683
Project: Flink
Issue
Fabian Hueske created FLINK-18704:
-
Summary: Support DECIMAL types in datagen Table source connector
Key: FLINK-18704
URL: https://issues.apache.org/jira/browse/FLINK-18704
Project: Flink
Iss
Fabian Hueske created FLINK-7128:
Summary: Timestamp types in Table API documenation not correct
Key: FLINK-7128
URL: https://issues.apache.org/jira/browse/FLINK-7128
Project: Flink
Issue Typ
Fabian Hueske created FLINK-7142:
Summary: Scala DataSet API ignores ResultTypeQueryable interface
Key: FLINK-7142
URL: https://issues.apache.org/jira/browse/FLINK-7142
Project: Flink
Issue T
Fabian Hueske created FLINK-7193:
Summary: Update all OVER window ProcessFunction implementations to
use SortedQueueState
Key: FLINK-7193
URL: https://issues.apache.org/jira/browse/FLINK-7193
Project:
Fabian Hueske created FLINK-7194:
Summary: Add getResultType and getAccumulatorType to
AggregateFunction
Key: FLINK-7194
URL: https://issues.apache.org/jira/browse/FLINK-7194
Project: Flink
Fabian Hueske created FLINK-7217:
Summary: Give hints about unsupported SQL / Table API features.
Key: FLINK-7217
URL: https://issues.apache.org/jira/browse/FLINK-7217
Project: Flink
Issue Ty
Fabian Hueske created FLINK-7239:
Summary: GroupWindow and OverWindow aggregates do not check
correctly for updating input
Key: FLINK-7239
URL: https://issues.apache.org/jira/browse/FLINK-7239
Project
Fabian Hueske created FLINK-7291:
Summary: Incorrect return value of getArity() in ListTypeInfo and
MapTypeInfo
Key: FLINK-7291
URL: https://issues.apache.org/jira/browse/FLINK-7291
Project: Flink
Fabian Hueske created FLINK-7337:
Summary: Refactor handling of time indicator attributes
Key: FLINK-7337
URL: https://issues.apache.org/jira/browse/FLINK-7337
Project: Flink
Issue Type: Impr
Fabian Hueske created FLINK-7388:
Summary: ProcessFunction.onTimer() sets processing time as
timestamp
Key: FLINK-7388
URL: https://issues.apache.org/jira/browse/FLINK-7388
Project: Flink
Is
Fabian Hueske created FLINK-7404:
Summary: Table API batch join code-gen's equi-join conditions
Key: FLINK-7404
URL: https://issues.apache.org/jira/browse/FLINK-7404
Project: Flink
Issue Type
Fabian Hueske created FLINK-7571:
Summary: Execution of TableSources with Time Indicators fails
Key: FLINK-7571
URL: https://issues.apache.org/jira/browse/FLINK-7571
Project: Flink
Issue Type
Fabian Hueske created FLINK-7656:
Summary: Switch to user ClassLoader when invoking
initializeOnMaster finalizeOnMaster
Key: FLINK-7656
URL: https://issues.apache.org/jira/browse/FLINK-7656
Project: F
Fabian Hueske created FLINK-7696:
Summary: Add projection push-down support for TableSources with
time attributes
Key: FLINK-7696
URL: https://issues.apache.org/jira/browse/FLINK-7696
Project: Flink
Fabian Hueske created FLINK-7730:
Summary: TableFunction LEFT OUTER joins with ON predicates are
broken
Key: FLINK-7730
URL: https://issues.apache.org/jira/browse/FLINK-7730
Project: Flink
I
Fabian Hueske created FLINK-7755:
Summary: Null values are not correctly handled by batch inner and
outer joins
Key: FLINK-7755
URL: https://issues.apache.org/jira/browse/FLINK-7755
Project: Flink
Fabian Hueske created FLINK-7764:
Summary: FlinkKafkaProducer010 does not accept name, uid, or
parallelism
Key: FLINK-7764
URL: https://issues.apache.org/jira/browse/FLINK-7764
Project: Flink
Fabian Hueske created FLINK-7797:
Summary: Add support for windowed outer joins for streaming tables
Key: FLINK-7797
URL: https://issues.apache.org/jira/browse/FLINK-7797
Project: Flink
Issue
Fabian Hueske created FLINK-7798:
Summary: Add support for windowed joins to Table API
Key: FLINK-7798
URL: https://issues.apache.org/jira/browse/FLINK-7798
Project: Flink
Issue Type: Sub-tas
Fabian Hueske created FLINK-7799:
Summary: Improve performance of windowed joins
Key: FLINK-7799
URL: https://issues.apache.org/jira/browse/FLINK-7799
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-7800:
Summary: Enable window joins without equi-join predicates
Key: FLINK-7800
URL: https://issues.apache.org/jira/browse/FLINK-7800
Project: Flink
Issue Type: Su
Fabian Hueske created FLINK-7814:
Summary: Add BETWEEN expression to Table API
Key: FLINK-7814
URL: https://issues.apache.org/jira/browse/FLINK-7814
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-7821:
Summary: Replace Table.limit() by Table.fetch() and Table.offset()
Key: FLINK-7821
URL: https://issues.apache.org/jira/browse/FLINK-7821
Project: Flink
Issue
Fabian Hueske created FLINK-7919:
Summary: Join with Solution Set fails with NPE if Solution Set has
no entry
Key: FLINK-7919
URL: https://issues.apache.org/jira/browse/FLINK-7919
Project: Flink
Fabian Hueske created FLINK-7932:
Summary: Best Practices docs recommend passing parameters through
open(Configuration c)
Key: FLINK-7932
URL: https://issues.apache.org/jira/browse/FLINK-7932
Project:
Fabian Hueske created FLINK-7939:
Summary: DataStream of atomic type cannot be converted to Table
with time attributes
Key: FLINK-7939
URL: https://issues.apache.org/jira/browse/FLINK-7939
Project: Fl
Fabian Hueske created FLINK-7955:
Summary: Rowtime attribute cannot be aggregated in group window of
stream Table API
Key: FLINK-7955
URL: https://issues.apache.org/jira/browse/FLINK-7955
Project: Fli
Fabian Hueske created FLINK-7990:
Summary: Strange behavior when configuring Logback for logging
Key: FLINK-7990
URL: https://issues.apache.org/jira/browse/FLINK-7990
Project: Flink
Issue Typ
Fabian Hueske created FLINK-7996:
Summary: Add support for (left.time = right.time) predicates to
window join.
Key: FLINK-7996
URL: https://issues.apache.org/jira/browse/FLINK-7996
Project: Flink
Fabian Hueske created FLINK-8002:
Summary: Incorrect join window boundaries for LESS_THAN and
GREATER_THAN predicates
Key: FLINK-8002
URL: https://issues.apache.org/jira/browse/FLINK-8002
Project: Fli
Fabian Hueske created FLINK-8012:
Summary: Table with time attribute cannot be written to
CsvTableSink
Key: FLINK-8012
URL: https://issues.apache.org/jira/browse/FLINK-8012
Project: Flink
Is
Fabian Hueske created FLINK-8013:
Summary: Check of AggregateFunction merge function signature is
too strict.
Key: FLINK-8013
URL: https://issues.apache.org/jira/browse/FLINK-8013
Project: Flink
Fabian Hueske created FLINK-8014:
Summary: Add Kafka010JsonTableSink
Key: FLINK-8014
URL: https://issues.apache.org/jira/browse/FLINK-8014
Project: Flink
Issue Type: Improvement
Com
Fabian Hueske created FLINK-8015:
Summary: Add Kafka011JsonTableSink
Key: FLINK-8015
URL: https://issues.apache.org/jira/browse/FLINK-8015
Project: Flink
Issue Type: Improvement
Com
Fabian Hueske created FLINK-8016:
Summary: Add documentation for KafkaJsonTableSink
Key: FLINK-8016
URL: https://issues.apache.org/jira/browse/FLINK-8016
Project: Flink
Issue Type: Improvemen
Fabian Hueske created FLINK-8128:
Summary: Add Latency/Throughput Section to Table API / SQL docs
Key: FLINK-8128
URL: https://issues.apache.org/jira/browse/FLINK-8128
Project: Flink
Issue Ty
Fabian Hueske created FLINK-8140:
Summary: Add AppendStreamTableSink for bucketed CSV files
Key: FLINK-8140
URL: https://issues.apache.org/jira/browse/FLINK-8140
Project: Flink
Issue Type: Ne
Fabian Hueske created FLINK-8141:
Summary: Add AppendStreamTableSink for bucketed ORC files
Key: FLINK-8141
URL: https://issues.apache.org/jira/browse/FLINK-8141
Project: Flink
Issue Type: Ne
Fabian Hueske created FLINK-8177:
Summary: Flink cannot be built for Hadoop 2.9.0
Key: FLINK-8177
URL: https://issues.apache.org/jira/browse/FLINK-8177
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-8179:
Summary: Convert CharSequence to String when registering /
converting a Table
Key: FLINK-8179
URL: https://issues.apache.org/jira/browse/FLINK-8179
Project: Flink
Fabian Hueske created FLINK-8203:
Summary: Make schema definition of DataStream/DataSet to Table
conversion more flexible
Key: FLINK-8203
URL: https://issues.apache.org/jira/browse/FLINK-8203
Project:
Fabian Hueske created FLINK-8242:
Summary: ClassCastException in OrcTableSource.toOrcPredicate
Key: FLINK-8242
URL: https://issues.apache.org/jira/browse/FLINK-8242
Project: Flink
Issue Type:
Fabian Hueske created FLINK-8243:
Summary: OrcTableSource should recursively read all files in
nested directories of the input path.
Key: FLINK-8243
URL: https://issues.apache.org/jira/browse/FLINK-8243
Fabian Hueske created FLINK-8260:
Summary: Document API of Kafka 0.11 Producer
Key: FLINK-8260
URL: https://issues.apache.org/jira/browse/FLINK-8260
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-8278:
Summary: Scala examples in Metric documentation do not compile
Key: FLINK-8278
URL: https://issues.apache.org/jira/browse/FLINK-8278
Project: Flink
Issue Typ
Fabian Hueske created FLINK-8303:
Summary: Update Savepoint Compatibility Table for 1.4
Key: FLINK-8303
URL: https://issues.apache.org/jira/browse/FLINK-8303
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-8308:
Summary: Update yajl-ruby dependency to 1.3.1 or higher
Key: FLINK-8308
URL: https://issues.apache.org/jira/browse/FLINK-8308
Project: Flink
Issue Type: Task
Fabian Hueske created FLINK-8331:
Summary: FieldParsers do not correctly set EMPT_COLUMN error state
Key: FLINK-8331
URL: https://issues.apache.org/jira/browse/FLINK-8331
Project: Flink
Issue
Fabian Hueske created FLINK-8391:
Summary: Improve dependency documentation for queryable state
Key: FLINK-8391
URL: https://issues.apache.org/jira/browse/FLINK-8391
Project: Flink
Issue Type
Fabian Hueske created FLINK-8433:
Summary: Update code example for "Managed Operator State"
documentation
Key: FLINK-8433
URL: https://issues.apache.org/jira/browse/FLINK-8433
Project: Flink
Fabian Hueske created FLINK-8457:
Summary: Documentation for Building from Source is broken
Key: FLINK-8457
URL: https://issues.apache.org/jira/browse/FLINK-8457
Project: Flink
Issue Type: Bu
Fabian Hueske created FLINK-8474:
Summary: Add documentation for HBaseTableSource
Key: FLINK-8474
URL: https://issues.apache.org/jira/browse/FLINK-8474
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-8487:
Summary: State loss after multiple restart attempts
Key: FLINK-8487
URL: https://issues.apache.org/jira/browse/FLINK-8487
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-8489:
Summary: Data is not emitted by second ElasticSearch connector
Key: FLINK-8489
URL: https://issues.apache.org/jira/browse/FLINK-8489
Project: Flink
Issue Typ
Fabian Hueske created FLINK-8566:
Summary: Replace retract/insert of same record for state retention
timer resets
Key: FLINK-8566
URL: https://issues.apache.org/jira/browse/FLINK-8566
Project: Flink
Fabian Hueske created FLINK-8651:
Summary: Add support for different event-time OVER windows in a
query
Key: FLINK-8651
URL: https://issues.apache.org/jira/browse/FLINK-8651
Project: Flink
I
Fabian Hueske created FLINK-8652:
Summary: Reduce log level of QueryableStateClient.getKvState() to
DEBUG
Key: FLINK-8652
URL: https://issues.apache.org/jira/browse/FLINK-8652
Project: Flink
Fabian Hueske created FLINK-8820:
Summary: FlinkKafkaConsumer010 reads too many bytes
Key: FLINK-8820
URL: https://issues.apache.org/jira/browse/FLINK-8820
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-8850:
Summary: SQL Client does not support Event-time
Key: FLINK-8850
URL: https://issues.apache.org/jira/browse/FLINK-8850
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-8851:
Summary: SQL Client fails if same file is used as default and env
configuration
Key: FLINK-8851
URL: https://issues.apache.org/jira/browse/FLINK-8851
Project: Flink
Fabian Hueske created FLINK-8852:
Summary: SQL Client does not work with new FLIP-6 mode
Key: FLINK-8852
URL: https://issues.apache.org/jira/browse/FLINK-8852
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-8853:
Summary: SQL Client cannot emit query results that contain a
rowtime attribute
Key: FLINK-8853
URL: https://issues.apache.org/jira/browse/FLINK-8853
Project: Flink
Fabian Hueske created FLINK-8854:
Summary: Mapping of SchemaValidator.deriveFieldMapping() is
incorrect.
Key: FLINK-8854
URL: https://issues.apache.org/jira/browse/FLINK-8854
Project: Flink
Fabian Hueske created FLINK-8855:
Summary: SQL client result serving gets stuck in result-mode=table
Key: FLINK-8855
URL: https://issues.apache.org/jira/browse/FLINK-8855
Project: Flink
Issue
Fabian Hueske created FLINK-8950:
Summary: "Materialize" Tables to avoid recomputation.
Key: FLINK-8950
URL: https://issues.apache.org/jira/browse/FLINK-8950
Project: Flink
Issue Type: New Fe
Fabian Hueske created FLINK-8951:
Summary: Support OVER windows PARTITION BY (rounded) timestamp
Key: FLINK-8951
URL: https://issues.apache.org/jira/browse/FLINK-8951
Project: Flink
Issue Typ
Fabian Hueske created FLINK-8952:
Summary: Support setting the parallelism of individual operators
of a query
Key: FLINK-8952
URL: https://issues.apache.org/jira/browse/FLINK-8952
Project: Flink
Fabian Hueske created FLINK-9031:
Summary: DataSet Job result changes when adding rebalance after
union
Key: FLINK-9031
URL: https://issues.apache.org/jira/browse/FLINK-9031
Project: Flink
I
Fabian Hueske created FLINK-9055:
Summary: WebUI shows job as Running although not enough resources
are available
Key: FLINK-9055
URL: https://issues.apache.org/jira/browse/FLINK-9055
Project: Flink
Fabian Hueske created FLINK-9056:
Summary: Job submission fails with AskTimeoutException if not
enough slots are available
Key: FLINK-9056
URL: https://issues.apache.org/jira/browse/FLINK-9056
Project
101 - 200 of 380 matches
Mail list logo
