flink git commit: [FLINK-6090] [table] Add RetractionRules for annotating AccMode to DataStreamRel nodes.

Repository: flink Updated Branches: refs/heads/table-retraction 07a59ae0e -> 5ba0f02a6 [FLINK-6090] [table] Add RetractionRules for annotating AccMode to DataStreamRel nodes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-6279] [table] Fix toString() of TableSourceScan.

Repository: flink Updated Branches: refs/heads/master 0038da415 -> 697cc9610 [FLINK-6279] [table] Fix toString() of TableSourceScan. - The digest of VolcanoRuleMatch matched different table sources with same field names as the same. This closes #3699. Project:

[2/2] flink git commit: [FLINK-5545] [table] Remove FlinkAggregateExpandDistinctAggregatesRule after bumping Calcite to v1.12.

[FLINK-5545] [table] Remove FlinkAggregateExpandDistinctAggregatesRule after bumping Calcite to v1.12. This closes #3695. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0038da41 Tree:

[1/2] flink git commit: [FLINK-6012] [table] Support SQL WindowStart and WindowEnd functions.

Repository: flink Updated Branches: refs/heads/master 635394751 -> 0038da415 [FLINK-6012] [table] Support SQL WindowStart and WindowEnd functions. This closes #3693. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[05/11] flink git commit: [FLINK-5376] Fix log statement in UnorderedStreamElementQueue

[FLINK-5376] Fix log statement in UnorderedStreamElementQueue Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/153d73a6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/153d73a6 Diff:

[11/11] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams.

[FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams. This closes #3646. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/07a59ae0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/07a59ae0 Diff:

[09/11] flink git commit: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group window functions for SQL queries on batch tables.

[FLINK-6261] [table] Support TUMBLE, HOP, SESSION group window functions for SQL queries on batch tables. - Drop support for group window translation of "GROUP BY FLOOR/CEIL". This closes #3675. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[06/11] flink git commit: [FLINK-6270] port some memory and network task manager options to ConfigOption

[FLINK-6270] port some memory and network task manager options to ConfigOption This closes #3683. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e2a4f47e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e2a4f47e

[03/11] flink git commit: [FLINK-6079] [kafka] Provide meaningful error message if TopicPartitions are null

[FLINK-6079] [kafka] Provide meaningful error message if TopicPartitions are null This closes #3685. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8890a8db Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8890a8db

[04/11] flink git commit: [FLINK-6269] Make UserCodeClassLoader final

[FLINK-6269] Make UserCodeClassLoader final This closes #3682. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2cb60043 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2cb60043 Diff:

[08/11] flink git commit: [FLINK-6256] Fix outputTag variable name in Side Output docs

[FLINK-6256] Fix outputTag variable name in Side Output docs This closes #3684. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6355edd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a6355edd Diff:

[07/11] flink git commit: [FLINK-6270] extend Configuration with contains(configOption)

[FLINK-6270] extend Configuration with contains(configOption) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d1d761ed Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d1d761ed Diff:

[02/11] flink git commit: [hotfix] [jdbc] Add generic parameter to ResultTypeQueryable

[hotfix] [jdbc] Add generic parameter to ResultTypeQueryable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b3ac6932 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b3ac6932 Diff:

flink git commit: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group window functions for SQL queries on batch tables.

Repository: flink Updated Branches: refs/heads/master e2a4f47ed -> 635394751 [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group window functions for SQL queries on batch tables. - Drop support for group window translation of "GROUP BY FLOOR/CEIL". This closes #3675. Project:

[03/12] flink git commit: [hotfix] [py] Fix PythonCoGroup useByteArray check

[hotfix] [py] Fix PythonCoGroup useByteArray check Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8f78e9d7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8f78e9d7 Diff:

[09/12] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12.

http://git-wip-us.apache.org/repos/asf/flink/blob/c5173fa2/flink-libraries/flink-table/src/main/java/org/apache/flink/table/calcite/sql2rel/FlinkRelDecorrelator.java -- diff --git

[02/12] flink git commit: [FLINK-6223] [py] Rework PythonPlanBinder generics

[FLINK-6223] [py] Rework PythonPlanBinder generics Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bba49d67 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bba49d67 Diff:

[11/12] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams.

http://git-wip-us.apache.org/repos/asf/flink/blob/ff262508/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupWindowTest.scala -- diff --git

[10/12] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12.

[FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12. This closes #3689. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c5173fa2 Tree:

[06/12] flink git commit: [FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows.

http://git-wip-us.apache.org/repos/asf/flink/blob/07f1b035/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala -- diff --git

[08/12] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12.

http://git-wip-us.apache.org/repos/asf/flink/blob/c5173fa2/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/QueryDecorrelationTest.scala -- diff --git

[05/12] flink git commit: [FLINK-6229] [py] Rework configuration of PythonPlanBinder/Operators

[FLINK-6229] [py] Rework configuration of PythonPlanBinder/Operators - unify python2/python3 configuration - explicitly pass on a configuration to each operator - port all configuration options to ConfigOptions - [FLINK-5516] Make all paths explicitly configurable - [FLINK-6230] Make mmap size

[04/12] flink git commit: [FLINK-6229] [py] Rework setup of PythonPlanBinder

[FLINK-6229] [py] Rework setup of PythonPlanBinder - make file/argument split more readable - pass on Paths where applicable instead of recreating them every time - rename PPB#clearPath to more appropriate deleteIfExists - simplify PPB#copyFile - simplify PPB#startPython - use UUID#randomUUID()

[07/12] flink git commit: [FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows.

[FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows. - Add check for sort order of OVER windows. This closes #3681. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/07f1b035 Tree:

[12/12] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams.

[FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams. This closes #3646. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ff262508 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ff262508 Diff:

[4/5] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12.

http://git-wip-us.apache.org/repos/asf/flink/blob/c5173fa2/flink-libraries/flink-table/src/main/java/org/apache/flink/table/calcite/sql2rel/FlinkRelDecorrelator.java -- diff --git

[2/5] flink git commit: [FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows.

[FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows. - Add check for sort order of OVER windows. This closes #3681. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/07f1b035 Tree:

[1/5] flink git commit: [FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows.

Repository: flink Updated Branches: refs/heads/master 5ff9c99ff -> c5173fa26 http://git-wip-us.apache.org/repos/asf/flink/blob/07f1b035/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala

[3/5] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12.

http://git-wip-us.apache.org/repos/asf/flink/blob/c5173fa2/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/QueryDecorrelationTest.scala -- diff --git

[5/5] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12.

[FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12. This closes #3689. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c5173fa2 Tree:

[2/2] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams.

[FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams. This closes #3646. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/448cb333 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/448cb333 Diff:

[1/2] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams.

Repository: flink Updated Branches: refs/heads/table-retraction 89d9dec38 -> 448cb333b http://git-wip-us.apache.org/repos/asf/flink/blob/448cb333/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupWindowTest.scala

[01/37] flink git commit: [FLINK-5625] [kinesis] Configurable date format for timestamp-based start position in FlinkKinesisConsumer

Repository: flink Updated Branches: refs/heads/table-retraction ee033c903 -> 89d9dec38 [FLINK-5625] [kinesis] Configurable date format for timestamp-based start position in FlinkKinesisConsumer This closes #3651. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[20/37] flink git commit: [FLINK-6265] [cep] Fix consecutive() for times()

[FLINK-6265] [cep] Fix consecutive() for times() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ffca0e76 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ffca0e76 Diff:

[34/37] flink git commit: [FLINK-6183] [metrics] Prevent some cases of TaskMG not being closed

[FLINK-6183] [metrics] Prevent some cases of TaskMG not being closed Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dabb0bac Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dabb0bac Diff:

[10/37] flink git commit: [FLINK-5913] [gelly] Example drivers

http://git-wip-us.apache.org/repos/asf/flink/blob/a48357db/flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/TriangleListing.java -- diff --git

[11/37] flink git commit: [FLINK-5913] [gelly] Example drivers

[FLINK-5913] [gelly] Example drivers Replace existing and create new algorithm Driver implementations for each of the library methods. This closes #3635 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a48357db Tree:

[27/37] flink git commit: [FLINK-6246] Fix generic type of OutputTag in operator Output

[FLINK-6246] Fix generic type of OutputTag in operator Output This closes #3662. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9bdbe607 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9bdbe607 Diff:

[25/37] flink git commit: [FLINK-6127] [checkstyle] Add MissingDeprecation check

[FLINK-6127] [checkstyle] Add MissingDeprecation check This closes #3572. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/68605d05 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/68605d05 Diff:

[07/37] flink git commit: [FLINK-3695] [gelly] ValueArray types

http://git-wip-us.apache.org/repos/asf/flink/blob/963f46e7/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ValueArrayFactory.java -- diff --git

[18/37] flink git commit: [FLINK-6267] [table] Remove unused imports in FlinkRelBuilder.

[FLINK-6267] [table] Remove unused imports in FlinkRelBuilder. This closes #3671. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6add620 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a6add620 Diff:

[02/37] flink git commit: [FLINK-4577] [kinesis] Transparent reshard handling for FlinkKinesisConsumer

[FLINK-4577] [kinesis] Transparent reshard handling for FlinkKinesisConsumer This closes #3458. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/19322401 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/19322401 Diff:

[15/37] flink git commit: [FLINK-6124] [table] Add min/max string aggregation with retracion

[FLINK-6124] [table] Add min/max string aggregation with retracion This closes #3593. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c5282cbc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c5282cbc Diff:

[37/37] flink git commit: [FLINK-6241] [table] Add codeGen for streaming OVER aggregations.

[FLINK-6241] [table] Add codeGen for streaming OVER aggregations. This closes #3676. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/89d9dec3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/89d9dec3 Diff:

[09/37] flink git commit: [FLINK-5912] [gelly] Inputs for CSV and graph generators

[FLINK-5912] [gelly] Inputs for CSV and graph generators Create Input classes for reading graphs from CSV as well as for each of the graph generators. This closes #3626 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[32/37] flink git commit: [hotfix] Fix shading checks

[hotfix] Fix shading checks Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c44f539 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c44f539 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5c44f539 Branch:

[03/37] flink git commit: [FLINK-6205] [FLINK-6069] [cep] Correct watermark/late events in side output.

[FLINK-6205] [FLINK-6069] [cep] Correct watermark/late events in side output. With this, the CEP library assumes correctness of the watermark and considers as late, events that arrive having a timestamp smaller than that of the last seen watermark. Late events are not silently dropped, but the

[28/37] flink git commit: [FLINK-6086] [py] Clean up PythonSender/-Streamer generics

[FLINK-6086] [py] Clean up PythonSender/-Streamer generics Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a7251c56 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a7251c56 Diff:

[05/37] flink git commit: [FLINK-5903] [yarn] Respect taskmanager.numberOfTaskSlots config value in Yarn mode

[FLINK-5903] [yarn] Respect taskmanager.numberOfTaskSlots config value in Yarn mode This closes #3408. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2313a74e Tree:

[31/37] flink git commit: [hotfix] [py] Code cleanup - PythonStreamer

[hotfix] [py] Code cleanup - PythonStreamer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dd588efe Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dd588efe Diff:

[33/37] flink git commit: [FLINK-6181][Start scripts] Fix regex in start scripts

[FLINK-6181][Start scripts] Fix regex in start scripts This closes #3605. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc13500d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dc13500d Diff:

[06/37] flink git commit: [FLINK-2814] [optimizer] DualInputPlanNode cannot be cast to SingleInputPlanNode

[FLINK-2814] [optimizer] DualInputPlanNode cannot be cast to SingleInputPlanNode WorksetIterationNode#instantiate loops over all solution and work set candidates. Since the solution set reference is modified in place when the predecessor node can be used in its place, swith this variable to the

[35/37] flink git commit: [FLINK-6203] [docs] [batch] Fix scala GroupReduce example

[FLINK-6203] [docs] [batch] Fix scala GroupReduce example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf28a562 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf28a562 Diff:

[21/37] flink git commit: [FLINK-6201] [py] [dist] move python example files from resources to the examples

[FLINK-6201] [py] [dist] move python example files from resources to the examples This closes #3628. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/995422c4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/995422c4

[04/37] flink git commit: [FLINK-5915] [table] Forward the complete aggregate ArgList to aggregate runtime functions.

[FLINK-5915] [table] Forward the complete aggregate ArgList to aggregate runtime functions. This closes #3647. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/91c90c5d Tree:

[12/37] flink git commit: [FLINK-5654] [table] Add processing-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL.

[FLINK-5654] [table] Add processing-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. This closes #3641. This closes #3590. This closes #3550. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31e120a9 Tree:

[13/37] flink git commit: [FLINK-4949] [gelly] Refactor Gelly driver inputs

[FLINK-4949] [gelly] Refactor Gelly driver inputs The Gelly drivers started as simple wrappers around library algorithms but have grown to handle a matrix of input sources while often running multiple algorithms and analytics with custom parameterization. The monolithic drivers are replaced with

[16/37] flink git commit: [FLINK-6254] [cep] Same method name for late data outputs on PatternStream and WindowedStream

[FLINK-6254] [cep] Same method name for late data outputs on PatternStream and WindowedStream Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1b6baddc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1b6baddc Diff:

[36/37] flink git commit: [FLINK-4848] [ssl] Throw meaningful exception when SSL is misconfigured

[FLINK-4848] [ssl] Throw meaningful exception when SSL is misconfigured This closes #3677. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80800d8c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/80800d8c Diff:

[30/37] flink git commit: [hotfix] [py] Code cleanup - StreamPrinter

[hotfix] [py] Code cleanup - StreamPrinter - implements Runnable instead of extending Thread - use AtomicRefence instead of StringBuilder - remove redundant wrapInException argument Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[23/37] flink git commit: [FLINK-6186] Remove unused import in StreamExecutionEnvironment.scala

[FLINK-6186] Remove unused import in StreamExecutionEnvironment.scala This closes #3612. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c224047 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6c224047 Diff:

[24/37] flink git commit: [FLINK-6127] [checkstyle] Add MissingDeprecation check

http://git-wip-us.apache.org/repos/asf/flink/blob/68605d05/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AggregatingProcessingTimeWindowOperator.java -- diff --git

[29/37] flink git commit: [hotfix] [py] Code cleanup - PythonStreamer#sendBroadCastVariables()

[hotfix] [py] Code cleanup - PythonStreamer#sendBroadCastVariables() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f4324ba7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f4324ba7 Diff:

[22/37] flink git commit: [FLINK-6212] [docs] Add avro dependency reference

[FLINK-6212] [docs] Add avro dependency reference Adds the reference to the maven dependecy for flink-avro in the "Avro support in Flink" section. This closes #3638. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c8f8a41b

[14/37] flink git commit: [FLINK-5829] [table] Bump Calcite version to 1.12.

[FLINK-5829] [table] Bump Calcite version to 1.12. This closes #3613. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/05ceec0a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/05ceec0a Diff:

[19/37] flink git commit: [FLINK-6011] [table] Support TUMBLE, HOP, SESSION group window functions in SQL queries on streams.

[FLINK-6011] [table] Support TUMBLE, HOP, SESSION group window functions in SQL queries on streams. This closes #3665. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1649f352 Tree:

[26/37] flink git commit: [hotfix] Fix unchecked conversion in JobDetailsHandler

[hotfix] Fix unchecked conversion in JobDetailsHandler Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/48ce77c7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/48ce77c7 Diff:

flink git commit: [FLINK-6241] [table] Add codeGen for streaming OVER aggregations.

Repository: flink Updated Branches: refs/heads/master 80800d8ce -> 89d9dec38 [FLINK-6241] [table] Add codeGen for streaming OVER aggregations. This closes #3676. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/89d9dec3

[1/2] flink git commit: [FLINK-6267] [table] Remove unused imports in FlinkRelBuilder.

Repository: flink Updated Branches: refs/heads/master cae4976a4 -> 1649f3520 [FLINK-6267] [table] Remove unused imports in FlinkRelBuilder. This closes #3671. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6add620

[2/2] flink git commit: [FLINK-6011] [table] Support TUMBLE, HOP, SESSION group window functions in SQL queries on streams.

[FLINK-6011] [table] Support TUMBLE, HOP, SESSION group window functions in SQL queries on streams. This closes #3665. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1649f352 Tree:

[2/3] flink-web git commit: Rebuild website for 'Dynamic Tables' blog post

http://git-wip-us.apache.org/repos/asf/flink-web/blob/f6ac337f/content/news/2017/04/04/dynamic-tables.html -- diff --git a/content/news/2017/04/04/dynamic-tables.html b/content/news/2017/04/04/dynamic-tables.html new file mode

[1/3] flink-web git commit: Add blog post 'Continuous Queries on Dynamic Tables'

Repository: flink-web Updated Branches: refs/heads/asf-site 661f76489 -> f6ac337f0 Add blog post 'Continuous Queries on Dynamic Tables' Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/c0574c39 Tree:

[3/3] flink-web git commit: Rebuild website for 'Dynamic Tables' blog post

ant: The Maven artifacts published with version 1.1.0 on Maven central have a Hadoop dependency issue. It is highly recommended to use 1.1.1 or 1.1.1-hadoop1 as the Flink version. + + + + Continue reading + + + + + Stream Processing for Everyone with SQL and Apache Flin

flink git commit: [FLINK-6044] Replace all unintentional calls to InputStream#read(...) with InputStream#readFully(...)

Repository: flink Updated Branches: refs/heads/release-1.1 8a1f16bd4 -> b62808ed7 [FLINK-6044] Replace all unintentional calls to InputStream#read(...) with InputStream#readFully(...) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-6044] Replace all unintentional calls to InputStream#read(...) with InputStream#readFully(...)

Repository: flink Updated Branches: refs/heads/release-1.2 bb3e26f97 -> a359b4cfa [FLINK-6044] Replace all unintentional calls to InputStream#read(...) with InputStream#readFully(...) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5915] [table] Forward the complete aggregate ArgList to aggregate runtime functions.

Repository: flink Updated Branches: refs/heads/master 48890285d -> 91c90c5d2 [FLINK-5915] [table] Forward the complete aggregate ArgList to aggregate runtime functions. This closes #3647. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[02/50] [abbrv] flink git commit: [FLINK-5067][hotfix] Fix snapshot deployment

[FLINK-5067][hotfix] Fix snapshot deployment Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/64c7b119 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/64c7b119 Diff:

[11/50] [abbrv] flink git commit: [hotfix] Fix various small issues in WindowOperatorContractTest

[hotfix] Fix various small issues in WindowOperatorContractTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/25d52e4d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/25d52e4d Diff:

[26/50] [abbrv] flink git commit: [FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface.

[FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface. This closes #3269. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c37e55c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c37e55c Diff:

[35/50] [abbrv] flink git commit: comments

comments Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ad21a441 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ad21a441 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ad21a441 Branch:

[37/50] [abbrv] flink git commit: [FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams

http://git-wip-us.apache.org/repos/asf/flink/blob/cd552741/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OperatorSnapshotResult.java -- diff --git

[09/50] [abbrv] flink git commit: [hotfix][scripts] Fix zookeeper quorum regex

[hotfix][scripts] Fix zookeeper quorum regex Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3e860b40 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3e860b40 Diff:

[50/50] [abbrv] flink git commit: [FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL.

[FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. This closes #3653. This closes #3574. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ee033c90 Tree:

[29/50] [abbrv] flink git commit: [hotfix] Make GC test more strict in WindowOperatorContractTest

[hotfix] Make GC test more strict in WindowOperatorContractTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/662ed33d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/662ed33d Diff:

[17/50] [abbrv] flink git commit: [FLINK-6182] Fix possible NPE in SourceStreamTask

[FLINK-6182] Fix possible NPE in SourceStreamTask This closes #3606. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4b19e272 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4b19e272 Diff:

[49/50] [abbrv] flink git commit: [FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window.

[FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window. This closes #3649. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/44f9c76a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/44f9c76a Diff:

[23/50] [abbrv] flink git commit: [FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment.

[FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment. This closes #3409. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/135a57c4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/135a57c4 Diff:

[16/50] [abbrv] flink git commit: [hotfix] Remove validateRunsInMainThread from TaskExecutor to fix TaskExecutorTest

[hotfix] Remove validateRunsInMainThread from TaskExecutor to fix TaskExecutorTest Currently, the TestingSerialRpcService does not play well together with the MainThreadValidatorUtil which assumes that rpc calls are dispatched to a mailbox from where they are picked up. In order to support the

[44/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Move metrics out of the Execution Graph

[hotfix] [dist. coordination] Move metrics out of the Execution Graph ExecutionGraph-based metrics should be in their own package 'org.apache.flink.runtime.executiongraph.metrics'. They are instantiated by whoever builds the execution graph, but not by the execution graph itself. This separates

[18/50] [abbrv] flink git commit: [FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled

[FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled The initial fix for this ticket is not working on larger data sets. Reduce supports returning the left input, right input, a new object, or a locally reused object. The trouble with the initial fix was that the returned local

[41/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Small code cleanups in ExecutionGraph and related classes

[hotfix] [dist. coordination] Small code cleanups in ExecutionGraph and related classes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/874d9565 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/874d9565 Diff:

[20/50] [abbrv] flink git commit: [FLINK-5658] [table] Add event-time OVER ROWS/RANGE UNBOUNDED PRECEDING aggregation to SQL.

[FLINK-5658] [table] Add event-time OVER ROWS/RANGE UNBOUNDED PRECEDING aggregation to SQL. This closes #3386. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe2c61a2 Tree:

[48/50] [abbrv] flink git commit: [FLINK-6165] [cep] Implement internal continuity for looping states.

[FLINK-6165] [cep] Implement internal continuity for looping states. Allows looping states (oneOrMore, zeroOrMore, times) to specify if they want their elements to be consecutive or allow non-matching elements in-between. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[05/50] [abbrv] flink git commit: [FLINK-3318] Add support for quantifiers to CEP's pattern API

http://git-wip-us.apache.org/repos/asf/flink/blob/9001c4ef/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java -- diff --git

[36/50] [abbrv] flink git commit: [FLINK-6207] Duplicate TypeSerializers for async snapshots of CopyOnWriteStateTable

[FLINK-6207] Duplicate TypeSerializers for async snapshots of CopyOnWriteStateTable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/89866a5a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/89866a5a Diff:

[22/50] [abbrv] flink git commit: [hotfix] [table] Improved code documentation for external catalog.

[hotfix] [table] Improved code documentation for external catalog. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f97deaa9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f97deaa9 Diff:

[10/50] [abbrv] flink git commit: [FLINK-6129] [metrics] Stop query actor of MetricRegistry

[FLINK-6129] [metrics] Stop query actor of MetricRegistry This PR properly shuts down the query actor of the MetricRegistry upon shut down. Add locking to the MetricRegistry This closes #3573. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[33/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions.

http://git-wip-us.apache.org/repos/asf/flink/blob/7fbdc100/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/OrCondition.java -- diff --git

[38/50] [abbrv] flink git commit: [FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams

[FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd552741 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cd552741

[24/50] [abbrv] flink git commit: [FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization.

[FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization. This closes #3564. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6949c8c7 Tree:

<    3   4   5   6   7   8   9   10   11   12   >