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
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-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
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:
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-7990:
Summary: Strange behavior when configuring Logback for logging
Key: FLINK-7990
URL: https://issues.apache.org/jira/browse/FLINK-7990
Project: Flink
Issue
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:
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:
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-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
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-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-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:
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
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-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-7656:
Summary: Switch to user ClassLoader when invoking
initializeOnMaster finalizeOnMaster
Key: FLINK-7656
URL: https://issues.apache.org/jira/browse/FLINK-7656
Project:
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
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
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
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:
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-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
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
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-7193:
Summary: Update all OVER window ProcessFunction implementations to
use SortedQueueState
Key: FLINK-7193
URL: https://issues.apache.org/jira/browse/FLINK-7193
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
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
Fabian Hueske created FLINK-6969:
Summary: Add support for deferred computation for group window
aggregates
Key: FLINK-6969
URL: https://issues.apache.org/jira/browse/FLINK-6969
Project: Flink
Fabian Hueske created FLINK-6968:
Summary: Store streaming, updating tables with unique key in
queryable state
Key: FLINK-6968
URL: https://issues.apache.org/jira/browse/FLINK-6968
Project: Flink
Fabian Hueske created FLINK-6930:
Summary: Selecting window start / end on row-based Tumble/Slide
window causes NPE
Key: FLINK-6930
URL: https://issues.apache.org/jira/browse/FLINK-6930
Project:
Fabian Hueske created FLINK-6929:
Summary: Add documentation for Table API OVER windows
Key: FLINK-6929
URL: https://issues.apache.org/jira/browse/FLINK-6929
Project: Flink
Issue Type:
Fabian Hueske created FLINK-6859:
Summary: StateCleaningCountTrigger should not delete timer
Key: FLINK-6859
URL: https://issues.apache.org/jira/browse/FLINK-6859
Project: Flink
Issue Type:
Fabian Hueske created FLINK-6858:
Summary: Unbounded event time Over Window emits incorrect
timestamps
Key: FLINK-6858
URL: https://issues.apache.org/jira/browse/FLINK-6858
Project: Flink
Fabian Hueske created FLINK-6751:
Summary: Table API / SQL Docs: UDFs Page
Key: FLINK-6751
URL: https://issues.apache.org/jira/browse/FLINK-6751
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6750:
Summary: Table API / SQL Docs: Table Sources & Sinks Page
Key: FLINK-6750
URL: https://issues.apache.org/jira/browse/FLINK-6750
Project: Flink
Issue Type:
Fabian Hueske created FLINK-6747:
Summary: Table API / SQL Docs: Streaming Page
Key: FLINK-6747
URL: https://issues.apache.org/jira/browse/FLINK-6747
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6749:
Summary: Table API / SQL Docs: SQL Page
Key: FLINK-6749
URL: https://issues.apache.org/jira/browse/FLINK-6749
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6748:
Summary: Table API / SQL Docs: Table API Page
Key: FLINK-6748
URL: https://issues.apache.org/jira/browse/FLINK-6748
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6745:
Summary: Table API / SQL Docs: Overview Page
Key: FLINK-6745
URL: https://issues.apache.org/jira/browse/FLINK-6745
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6746:
Summary: Table API / SQL Docs: Common Page
Key: FLINK-6746
URL: https://issues.apache.org/jira/browse/FLINK-6746
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-6614:
Summary: Applying function on window auxiliary function fails
Key: FLINK-6614
URL: https://issues.apache.org/jira/browse/FLINK-6614
Project: Flink
Issue
Fabian Hueske created FLINK-6589:
Summary: ListSerializer should deserialize as ArrayList with size
+ 1
Key: FLINK-6589
URL: https://issues.apache.org/jira/browse/FLINK-6589
Project: Flink
Fabian Hueske created FLINK-6564:
Summary: Build fails on file systems that do not distinguish
between upper and lower case
Key: FLINK-6564
URL: https://issues.apache.org/jira/browse/FLINK-6564
Fabian Hueske created FLINK-6508:
Summary: Include license files of packaged dependencies
Key: FLINK-6508
URL: https://issues.apache.org/jira/browse/FLINK-6508
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-6491:
Summary: Add QueryConfig to specify state retention time for
streaming queries
Key: FLINK-6491
URL: https://issues.apache.org/jira/browse/FLINK-6491
Project: Flink
Fabian Hueske created FLINK-6473:
Summary: Add OVER window support for batch tables
Key: FLINK-6473
URL: https://issues.apache.org/jira/browse/FLINK-6473
Project: Flink
Issue Type: New
Fabian Hueske created FLINK-6261:
Summary: Add support for TUMBLE, HOP, SESSION to batch SQL
Key: FLINK-6261
URL: https://issues.apache.org/jira/browse/FLINK-6261
Project: Flink
Issue Type:
Fabian Hueske created FLINK-6257:
Summary: Post-pass OVER windows
Key: FLINK-6257
URL: https://issues.apache.org/jira/browse/FLINK-6257
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-6247:
Summary: Build a jar-with-dependencies for flink-table and put it
into ./opt
Key: FLINK-6247
URL: https://issues.apache.org/jira/browse/FLINK-6247
Project: Flink
Fabian Hueske created FLINK-6100:
Summary: Add documentation for Projectable and Filterable
TableSource
Key: FLINK-6100
URL: https://issues.apache.org/jira/browse/FLINK-6100
Project: Flink
Fabian Hueske created FLINK-6059:
Summary: Reject DataSet and DataStream without
RowTypeInformation
Key: FLINK-6059
URL: https://issues.apache.org/jira/browse/FLINK-6059
Project: Flink
Fabian Hueske created FLINK-5963:
Summary: Remove preparation mapper of DataSetAggregate
Key: FLINK-5963
URL: https://issues.apache.org/jira/browse/FLINK-5963
Project: Flink
Issue Type:
Fabian Hueske created FLINK-5922:
Summary: Remove FlinkAggregateJoinTransposeRule when upgrading to
Calcite 1.12
Key: FLINK-5922
URL: https://issues.apache.org/jira/browse/FLINK-5922
Project: Flink
Fabian Hueske created FLINK-5921:
Summary: Adapt time mode indicator functions return custom data
types
Key: FLINK-5921
URL: https://issues.apache.org/jira/browse/FLINK-5921
Project: Flink
Fabian Hueske created FLINK-5906:
Summary: Add support to register UDAGGs in TableEnvironment
Key: FLINK-5906
URL: https://issues.apache.org/jira/browse/FLINK-5906
Project: Flink
Issue Type:
Fabian Hueske created FLINK-5905:
Summary: Add user-defined aggregation functions to documentation.
Key: FLINK-5905
URL: https://issues.apache.org/jira/browse/FLINK-5905
Project: Flink
Issue
Fabian Hueske created FLINK-5722:
Summary: Implement DISTINCT as dedicated operator
Key: FLINK-5722
URL: https://issues.apache.org/jira/browse/FLINK-5722
Project: Flink
Issue Type:
Fabian Hueske created FLINK-5658:
Summary: Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING
aggregation to SQL
Key: FLINK-5658
URL: https://issues.apache.org/jira/browse/FLINK-5658
Project:
Fabian Hueske created FLINK-5657:
Summary: Add processing time OVER RANGE BETWEEN UNBOUNDED
PRECEDING aggregation to SQL
Key: FLINK-5657
URL: https://issues.apache.org/jira/browse/FLINK-5657
Project:
Fabian Hueske created FLINK-5656:
Summary: Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING
aggregation to SQL
Key: FLINK-5656
URL: https://issues.apache.org/jira/browse/FLINK-5656
Project:
Fabian Hueske created FLINK-5655:
Summary: Add event time OVER RANGE BETWEEN x PRECEDING aggregation
to SQL
Key: FLINK-5655
URL: https://issues.apache.org/jira/browse/FLINK-5655
Project: Flink
Fabian Hueske created FLINK-5654:
Summary: Add processing time OVER RANGE BETWEEN x PRECEDING
aggregation to SQL
Key: FLINK-5654
URL: https://issues.apache.org/jira/browse/FLINK-5654
Project: Flink
Fabian Hueske created FLINK-5653:
Summary: Add processing time OVER ROWS BETWEEN x PRECEDING
aggregation to SQL
Key: FLINK-5653
URL: https://issues.apache.org/jira/browse/FLINK-5653
Project: Flink
Fabian Hueske created FLINK-5548:
Summary: Move
Key: FLINK-5548
URL: https://issues.apache.org/jira/browse/FLINK-5548
Project: Flink
Issue Type: Improvement
Components: Table API &
Fabian Hueske created FLINK-5547:
Summary: Move checks for DataSetRel validity into constructor
Key: FLINK-5547
URL: https://issues.apache.org/jira/browse/FLINK-5547
Project: Flink
Issue
Fabian Hueske created FLINK-5524:
Summary: Support early out for code generated conjunctive
conditions
Key: FLINK-5524
URL: https://issues.apache.org/jira/browse/FLINK-5524
Project: Flink
Fabian Hueske created FLINK-5523:
Summary: Improve access of fields in code generated functions with
filters
Key: FLINK-5523
URL: https://issues.apache.org/jira/browse/FLINK-5523
Project: Flink
Fabian Hueske created FLINK-5520:
Summary: Disable outer joins with non-equality predicates
Key: FLINK-5520
URL: https://issues.apache.org/jira/browse/FLINK-5520
Project: Flink
Issue Type:
Fabian Hueske created FLINK-5375:
Summary: Fix watermark documentation
Key: FLINK-5375
URL: https://issues.apache.org/jira/browse/FLINK-5375
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-5281:
Summary: Extend KafkaJsonTableSources to support nested data
Key: FLINK-5281
URL: https://issues.apache.org/jira/browse/FLINK-5281
Project: Flink
Issue
Fabian Hueske created FLINK-5280:
Summary: Extend TableSource to support nested data
Key: FLINK-5280
URL: https://issues.apache.org/jira/browse/FLINK-5280
Project: Flink
Issue Type:
Fabian Hueske created FLINK-5271:
Summary: Refactor the batch SQL tests
Key: FLINK-5271
URL: https://issues.apache.org/jira/browse/FLINK-5271
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-5270:
Summary: Refactor the batch Scala-expression Table API tests
Key: FLINK-5270
URL: https://issues.apache.org/jira/browse/FLINK-5270
Project: Flink
Issue
Fabian Hueske created FLINK-5269:
Summary: Convert string-based Table API tests into unit tests
Key: FLINK-5269
URL: https://issues.apache.org/jira/browse/FLINK-5269
Project: Flink
Issue
Fabian Hueske created FLINK-5268:
Summary: Split TableProgramsTestBase into
TableProgramsCollectionTestBase and TableProgramsClusterTestBase
Key: FLINK-5268
URL: https://issues.apache.org/jira/browse/FLINK-5268
Fabian Hueske created FLINK-5256:
Summary: Extend DataSetSingleRowJoin to support Left and Right
joins
Key: FLINK-5256
URL: https://issues.apache.org/jira/browse/FLINK-5256
Project: Flink
Fabian Hueske created FLINK-5255:
Summary: Improve single row check in DataSetSingleRowJoinRule
Key: FLINK-5255
URL: https://issues.apache.org/jira/browse/FLINK-5255
Project: Flink
Issue
Fabian Hueske created FLINK-5227:
Summary: Add warning to include flink-table in job fat jars
Key: FLINK-5227
URL: https://issues.apache.org/jira/browse/FLINK-5227
Project: Flink
Issue Type:
Fabian Hueske created FLINK-5226:
Summary: Eagerly project unused attributes
Key: FLINK-5226
URL: https://issues.apache.org/jira/browse/FLINK-5226
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-5191:
Summary: ConnectedComponentsWithDeferredUpdateITCase failed
Key: FLINK-5191
URL: https://issues.apache.org/jira/browse/FLINK-5191
Project: Flink
Issue Type:
Fabian Hueske created FLINK-5094:
Summary: Support RichReduceFunction and RichFoldFunction as
incremental window aggregation functions
Key: FLINK-5094
URL: https://issues.apache.org/jira/browse/FLINK-5094
Fabian Hueske created FLINK-5084:
Summary: Replace Java Table API integration tests by unit tests
Key: FLINK-5084
URL: https://issues.apache.org/jira/browse/FLINK-5084
Project: Flink
Issue
Fabian Hueske created FLINK-4937:
Summary: Add incremental group window aggregation for streaming
Table API
Key: FLINK-4937
URL: https://issues.apache.org/jira/browse/FLINK-4937
Project: Flink
Fabian Hueske created FLINK-4864:
Summary: Shade Calcite dependency in flink-table
Key: FLINK-4864
URL: https://issues.apache.org/jira/browse/FLINK-4864
Project: Flink
Issue Type:
Fabian Hueske created FLINK-4688:
Summary: Optimizer hangs for hours when optimizing complex plans
Key: FLINK-4688
URL: https://issues.apache.org/jira/browse/FLINK-4688
Project: Flink
Issue
Fabian Hueske created FLINK-4678:
Summary: Add SessionRow row-windows for streaming tables (FLIP-11)
Key: FLINK-4678
URL: https://issues.apache.org/jira/browse/FLINK-4678
Project: Flink
Fabian Hueske created FLINK-4683:
Summary: Add SlideRow row-windows for batch tables
Key: FLINK-4683
URL: https://issues.apache.org/jira/browse/FLINK-4683
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-4682:
Summary: Add TumbleRow row-windows for batch tables.
Key: FLINK-4682
URL: https://issues.apache.org/jira/browse/FLINK-4682
Project: Flink
Issue Type:
Fabian Hueske created FLINK-4681:
Summary: Add SessionRow row-windows for batch tables.
Key: FLINK-4681
URL: https://issues.apache.org/jira/browse/FLINK-4681
Project: Flink
Issue Type:
Fabian Hueske created FLINK-4680:
Summary: Add SlidingRow row-windows for streaming tables
Key: FLINK-4680
URL: https://issues.apache.org/jira/browse/FLINK-4680
Project: Flink
Issue Type:
Fabian Hueske created FLINK-4679:
Summary: Add TumbleRow row-windows for streaming tables
Key: FLINK-4679
URL: https://issues.apache.org/jira/browse/FLINK-4679
Project: Flink
Issue Type:
Fabian Hueske created FLINK-4676:
Summary: Merge flink-batch-con
Key: FLINK-4676
URL: https://issues.apache.org/jira/browse/FLINK-4676
Project: Flink
Issue Type: Task
Reporter:
Fabian Hueske created FLINK-4640:
Summary: Serialization of the initialValue of a Fold on
WindowedStream fails
Key: FLINK-4640
URL: https://issues.apache.org/jira/browse/FLINK-4640
Project: Flink
Fabian Hueske created FLINK-4636:
Summary: AbstractCEPPatternOperator fails to restore state
Key: FLINK-4636
URL: https://issues.apache.org/jira/browse/FLINK-4636
Project: Flink
Issue Type:
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
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-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
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:
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:
101 - 200 of 313 matches
Mail list logo
