flink git commit: [FLINK-6564] [build] Fix copying of license files.

Repository: flink Updated Branches: refs/heads/master b50ef4b8d -> c9ffa9d2b [FLINK-6564] [build] Fix copying of license files. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9ffa9d2 Tree:

[1/5] flink git commit: [FLINK-6491] [table] Add QueryConfig and state clean up for over-windowed aggregates.

Repository: flink Updated Branches: refs/heads/release-1.3 f3ce0885f -> 609d5a32f http://git-wip-us.apache.org/repos/asf/flink/blob/6b61d153/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala

[5/5] flink git commit: [FLINK-6483] [table] Add materialization of time indicators.

[FLINK-6483] [table] Add materialization of time indicators. This closes #3862. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/609d5a32 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/609d5a32 Diff:

[3/5] flink git commit: [FLINK-6491] [table] Add QueryConfig and state clean up for non-windowed aggregates.

[FLINK-6491] [table] Add QueryConfig and state clean up for non-windowed aggregates. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/003f81a7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/003f81a7 Diff:

[4/5] flink git commit: [FLINK-6483] [table] Add materialization of time indicators.

http://git-wip-us.apache.org/repos/asf/flink/blob/609d5a32/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverterTest.scala -- diff --git

[2/5] flink git commit: [FLINK-6491] [table] Add QueryConfig and state clean up for over-windowed aggregates.

[FLINK-6491] [table] Add QueryConfig and state clean up for over-windowed aggregates. This closes #3863. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b61d153 Tree:

[4/5] flink git commit: [FLINK-6483] [table] Add materialization of time indicators.

http://git-wip-us.apache.org/repos/asf/flink/blob/b50ef4b8/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverterTest.scala -- diff --git

[2/5] flink git commit: [FLINK-6491] [table] Add QueryConfig and state clean up for over-windowed aggregates.

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

[1/5] flink git commit: [FLINK-6491] [table] Add QueryConfig and state clean up for non-windowed aggregates.

Repository: flink Updated Branches: refs/heads/master 704098725 -> b50ef4b8d [FLINK-6491] [table] Add QueryConfig and state clean up for non-windowed aggregates. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d16339db

[5/5] flink git commit: [FLINK-6483] [table] Add materialization of time indicators.

[FLINK-6483] [table] Add materialization of time indicators. This closes #3862. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b50ef4b8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b50ef4b8 Diff:

[4/4] flink git commit: [FLINK-6476] [table] Add support to convert DataSet[Row] and DataStream[Row] to Table.

[FLINK-6476] [table] Add support to convert DataSet[Row] and DataStream[Row] to Table. This closes #3849. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28a89d1c Tree:

[3/4] flink git commit: [FLINK-6486] [table] Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo.

[FLINK-6486] [table] Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo. This closes #3850. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dd799c74 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dd799c74

[1/4] flink git commit: [FLINK-6479] [table] Fix IOOBE in DataStreamGroupWindowAggregate.

Repository: flink Updated Branches: refs/heads/release-1.3 fd910f2c9 -> 28a89d1ca [FLINK-6479] [table] Fix IOOBE in DataStreamGroupWindowAggregate. This closes #3841. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/4] flink git commit: [FLINK-6436] [table] Fix code-gen bug when using a scalar UDF in a UDTF join condition.

[FLINK-6436] [table] Fix code-gen bug when using a scalar UDF in a UDTF join condition. This closes #3815. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/34cff356 Tree:

[4/4] flink git commit: [FLINK-6479] [table] Fix IOOBE in DataStreamGroupWindowAggregate.

[FLINK-6479] [table] Fix IOOBE in DataStreamGroupWindowAggregate. This closes #3841. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f26a9116 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f26a9116 Diff:

[3/4] flink git commit: [FLINK-6486] [table] Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo.

[FLINK-6486] [table] Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo. This closes #3850. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b5ddbe5c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5ddbe5c

[2/4] flink git commit: [FLINK-6436] [table] Fix code-gen bug when using a scalar UDF in a UDTF join condition.

[FLINK-6436] [table] Fix code-gen bug when using a scalar UDF in a UDTF join condition. This closes #3815. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e2cb2215 Tree:

[1/4] flink git commit: [FLINK-6476] [table] Add support to convert DataSet[Row] and DataStream[Row] to Table.

Repository: flink Updated Branches: refs/heads/master e0ab5f524 -> 6cd98a9b6 [FLINK-6476] [table] Add support to convert DataSet[Row] and DataStream[Row] to Table. This closes #3849. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/3] flink git commit: [FLINK-6033] [table] Add support for SQL UNNEST.

Repository: flink Updated Branches: refs/heads/master e5b65a7fc -> fe4e96a72 [FLINK-6033] [table] Add support for SQL UNNEST. This closes #3793. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe4e96a7 Tree:

[3/3] flink git commit: [FLINK-6257] [table] Refactor OVER window tests.

[FLINK-6257] [table] Refactor OVER window tests. This closes #3697. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9f2293cf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9f2293cf Diff:

[2/3] flink git commit: [FLINK-6257] [table] Refactor OVER window tests.

http://git-wip-us.apache.org/repos/asf/flink/blob/9f2293cf/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/WindowAggregateTest.scala -- diff --git

[flink] Git Push Summary

Repository: flink Updated Branches: refs/heads/table-retraction [deleted] e265620d4

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

[FLINK-6090] [table] Add RetractionRules for annotating AccMode to DataStreamRel nodes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc54abc6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dc54abc6 Diff:

[11/15] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

http://git-wip-us.apache.org/repos/asf/flink/blob/27bf4cab/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowInputMapRunner.scala -- diff --git

[04/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

http://git-wip-us.apache.org/repos/asf/flink/blob/495f104b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/fieldExpression.scala -- diff --git

[09/15] 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/8f78824b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8f78824b Diff:

[07/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL. Continued

[FLINK-5884] [table] Integrate time indicators for Table API & SQL. Continued Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24bf61ce Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24bf61ce Diff:

[02/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

http://git-wip-us.apache.org/repos/asf/flink/blob/495f104b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/validate/FunctionCatalog.scala -- diff --git

[15/15] flink git commit: [FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction.

[FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f37988c1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f37988c1

[10/15] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

http://git-wip-us.apache.org/repos/asf/flink/blob/27bf4cab/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/TableEnvironmentTest.scala -- diff --git

[14/15] flink git commit: [FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction.

http://git-wip-us.apache.org/repos/asf/flink/blob/f37988c1/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/CsvTableSink.scala -- diff --git

[05/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

[FLINK-5884] [table] Integrate time indicators for Table API & SQL This closes #3808. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/495f104b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/495f104b Diff:

[01/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

Repository: flink Updated Branches: refs/heads/master 28ab73750 -> f37988c19 http://git-wip-us.apache.org/repos/asf/flink/blob/495f104b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupWindowTest.scala

[12/15] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

[FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/27bf4cab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/27bf4cab Diff:

[13/15] flink git commit: [FLINK-6093] [table] Implement and turn on retraction for table sinks.

[FLINK-6093] [table] Implement and turn on retraction for table sinks. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bfed279f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bfed279f Diff:

[03/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

http://git-wip-us.apache.org/repos/asf/flink/blob/495f104b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala -- diff --git

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

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

[2/2] flink git commit: [FLINK-5906] [table] Add support to register UDAGGs for Table API and SQL.

[FLINK-5906] [table] Add support to register UDAGGs for Table API and SQL. This closes #3809. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/981dea41 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/981dea41 Diff:

[1/2] flink git commit: [FLINK-5906] [table] Add support to register UDAGGs for Table API and SQL.

Repository: flink Updated Branches: refs/heads/master d6435e87c -> 981dea41e http://git-wip-us.apache.org/repos/asf/flink/blob/981dea41/flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/utils/UserDefinedAggFunctions.java

[39/50] [abbrv] flink git commit: [hotfix] [runtime] SerializedThrowable copy constructor preserves cause

[hotfix] [runtime] SerializedThrowable copy constructor preserves cause Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/03721cff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/03721cff Diff:

[16/50] [abbrv] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java -- diff --git

[29/50] [abbrv] flink git commit: [FLINK-6337][network] Remove the buffer provider from PartitionRequestServerHandler

[FLINK-6337][network] Remove the buffer provider from PartitionRequestServerHandler The buffer provider is not needed and most likely a left over from prior refactorings. This closes #3785. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[35/50] [abbrv] flink git commit: [hotfix] [build] Remove unneeded logback-test.xml files

[hotfix] [build] Remove unneeded logback-test.xml files Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bad7e0b9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bad7e0b9 Diff:

[45/50] [abbrv] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

http://git-wip-us.apache.org/repos/asf/flink/blob/856485be/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/TableEnvironmentITCase.scala -- diff --git

[22/50] [abbrv] flink git commit: [FLINK-6406] [table] Remove unused imports

[FLINK-6406] [table] Remove unused imports This closes #3795 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ea54962e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ea54962e Diff:

[50/50] [abbrv] flink git commit: [FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction.

[FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e265620d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e265620d

[15/50] [abbrv] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java -- diff --git

[46/50] [abbrv] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

http://git-wip-us.apache.org/repos/asf/flink/blob/856485be/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowWrappingCollector.scala -- diff --git

[41/50] [abbrv] flink git commit: [FLINK-2067] [runtime] Unwrap the ExceptionInChainedOperatorException exceptions to clean up stack traces

[FLINK-2067] [runtime] Unwrap the ExceptionInChainedOperatorException exceptions to clean up stack traces Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6181302f Tree:

[31/50] [abbrv] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

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

[05/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTest.java -- diff --git

[38/50] [abbrv] flink git commit: [hotfix] [runtime] Minor improvement to logging in CheckpointCoordinator

[hotfix] [runtime] Minor improvement to logging in CheckpointCoordinator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/91b2d6f3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/91b2d6f3 Diff:

[10/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Make slot registration static

[FLINK-5810] [flip-6] Make slot registration static Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d16a5a29 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d16a5a29 Diff:

[34/50] [abbrv] flink git commit: [FLINK-6415] [build] Make sure core Flink artifacts have no specific logger dependency

[FLINK-6415] [build] Make sure core Flink artifacts have no specific logger dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e0ba2687 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e0ba2687 Diff:

[07/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

[FLINK-5810] [flip-6] Introduce a hardened slot manager Harden the slot manager so that it better deals with lost and out of order messages from the TaskManager. The basic idea is that the TaskManager are considered the ground truth and the SlotManager tries to maintain a consistent view of

[04/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java -- diff --git

[18/50] [abbrv] flink git commit: [Flink-5892] Restore state on operator level

[Flink-5892] Restore state on operator level Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7980a7e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7980a7e Diff:

[26/50] [abbrv] flink git commit: [FLINK-6377] [table] Support map types in the Table / SQL API

[FLINK-6377] [table] Support map types in the Table / SQL API This closes #3767. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b6e71ce Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5b6e71ce Diff:

[25/50] [abbrv] flink git commit: [FLINK-6377] [table] Add additional map tests

[FLINK-6377] [table] Add additional map tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d49efbd2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d49efbd2 Diff:

[19/50] [abbrv] flink git commit: [FLINK-5892] Add tests for topology modifications

[FLINK-5892] Add tests for topology modifications This closes #3770. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c68085f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2c68085f Diff:

[02/50] [abbrv] flink git commit: [FLINK-6208] [cep] Implement skip till next match strategy

[FLINK-6208] [cep] Implement skip till next match strategy Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c35dc0e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7c35dc0e Diff:

[30/50] [abbrv] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

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

[21/50] [abbrv] flink git commit: [FLINK-6395] [tests] Mark test bases as abstract

[FLINK-6395] [tests] Mark test bases as abstract This closes #3790 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d27d3dda Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d27d3dda Diff:

[11/50] [abbrv] flink git commit: [FLINK-6411] [flip-6] Remove job removal from RunningJobsRegistry in YarnFlinkApplicationMasterRunner.shutdown

[FLINK-6411] [flip-6] Remove job removal from RunningJobsRegistry in YarnFlinkApplicationMasterRunner.shutdown The YarnFlinkApplicationMasterRunner should not be concerned with removing jobs from the RunningJobsRegistry. This is the responsibility of the JobManagerRunner. This PR removes the

[06/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java -- diff --git

[49/50] [abbrv] flink git commit: [FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction.

http://git-wip-us.apache.org/repos/asf/flink/blob/e265620d/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/RetractStreamTableSink.scala -- diff --git

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

[FLINK-6090] [table] Add RetractionRules for annotating AccMode to DataStreamRel nodes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/455a3c58 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/455a3c58 Diff:

[40/50] [abbrv] flink git commit: [hotfix] [client] Unwrap SerializedThrowable in client log statements when possible

[hotfix] [client] Unwrap SerializedThrowable in client log statements when possible Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9623be2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c9623be2 Diff:

[14/50] [abbrv] flink git commit: [FLINK-5892] Add new StateAssignmentOperationV2

[FLINK-5892] Add new StateAssignmentOperationV2 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8045faba Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8045faba Diff:

[48/50] [abbrv] flink git commit: [FLINK-6093] [table] Implement and turn on retraction for table sinks.

[FLINK-6093] [table] Implement and turn on retraction for table sinks. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/917f7249 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/917f7249 Diff:

[03/50] [abbrv] flink git commit: [FLINK-6293] [tests] Harden JobManagerITCase

[FLINK-6293] [tests] Harden JobManagerITCase One of the unit tests in JobManagerITCase starts a MiniCluster and sends a LeaderSessionMessage to the JobManager without waiting until the JobManager has gained leadership. This can lead to a dropped TriggerSavepoint message which will cause the test

[23/50] [abbrv] flink git commit: [FLINK-6112] [table] Support Calcite 1.12's new numerical functions

[FLINK-6112] [table] Support Calcite 1.12's new numerical functions This closes #3718. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a06b3222 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a06b3222 Diff:

[44/50] [abbrv] 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/24fa1a1c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24fa1a1c Diff:

[33/50] [abbrv] flink git commit: [FLINK-6337] [network] Fix instability in SuccessAfterNetworkBuffersFailureITCase

[FLINK-6337] [network] Fix instability in SuccessAfterNetworkBuffersFailureITCase The reduced number of network buffers as part of this issue was too low and lead to instable tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[32/50] [abbrv] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

[FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly This closes #3799. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2d33c0be Tree:

[28/50] [abbrv] flink git commit: [FLINK-6382] [gelly] Support additional types for generated graphs in Gelly examples

[FLINK-6382] [gelly] Support additional types for generated graphs in Gelly examples The Gelly examples current support IntValue, LongValue, and StringValue for RMatGraph. Allow transformations and tests for all generated graphs for ByteValue, Byte, ShortValue, Short, CharValue, Character,

[08/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Multiple small cleanups across Resource Manager related code

[FLINK-5810] [flip-6] Multiple small cleanups across Resource Manager related code Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/759f46ea Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/759f46ea Diff:

[20/50] [abbrv] flink git commit: [FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table.

[FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table. This closes #3546. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c8eb55f1 Tree:

[13/50] [abbrv] flink git commit: [FLINK-6341] [jm] Add test case to guard against RM registration loop

[FLINK-6341] [jm] Add test case to guard against RM registration loop Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/591841f3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/591841f3 Diff:

[27/50] [abbrv] flink git commit: [FLINK-6382] [gelly] Support additional types for generated graphs in Gelly examples

http://git-wip-us.apache.org/repos/asf/flink/blob/33695781/flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/GraphMetricsITCase.java -- diff --git

[01/50] [abbrv] flink git commit: [FLINK-6208] [cep] Implement skip till next match strategy [Forced Update!]

Repository: flink Updated Branches: refs/heads/table-retraction b237a3ef0 -> e265620d4 (forced update) http://git-wip-us.apache.org/repos/asf/flink/blob/7c35dc0e/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java

[36/50] [abbrv] flink git commit: [hotfix] [tests] Fix test log level in flink-runtime

[hotfix] [tests] Fix test log level in flink-runtime Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9cb76213 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9cb76213 Diff:

[24/50] [abbrv] flink git commit: [FLINK-6112] [table] Improve documentation, consistency, and fix bugs

[FLINK-6112] [table] Improve documentation, consistency, and fix bugs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a334312 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0a334312 Diff:

[17/50] [abbrv] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperationV2.java -- diff --git

[12/50] [abbrv] flink git commit: [FLINK-6341] [jm] Don't let JM fall into infinite loop

[FLINK-6341] [jm] Don't let JM fall into infinite loop This closes #3745. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/23838392 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/23838392 Diff:

flink git commit: [FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table.

Repository: flink Updated Branches: refs/heads/release-1.2 c0fb70f1c -> fdb3f65f2 [FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-6247] [table] Put flink-table.jar with all dependencies into ./opt folder.

Repository: flink Updated Branches: refs/heads/master fff04bfbe -> bb972b85a [FLINK-6247] [table] Put flink-table.jar with all dependencies into ./opt folder. This closes #3666. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-6392] [table] Improve group window API to make alias mandatory.

[FLINK-6392] [table] Improve group window API to make alias mandatory. This closes #3786. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb972b85 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bb972b85 Diff:

[1/3] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

Repository: flink Updated Branches: refs/heads/table-retraction 5ba0f02a6 -> b237a3ef0 http://git-wip-us.apache.org/repos/asf/flink/blob/b237a3ef/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/TableEnvironmentITCase.scala

[3/3] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

[FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b237a3ef Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b237a3ef Diff:

[2/2] flink git commit: [FLINK-6361] [table] Refactor the AggregateFunction interface and built-in aggregates.

[FLINK-6361] [table] Refactor the AggregateFunction interface and built-in aggregates. This closes #3762. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bc6409d6 Tree:

[1/2] flink git commit: [FLINK-6361] [table] Refactor the AggregateFunction interface and built-in aggregates.

Repository: flink Updated Branches: refs/heads/master fe018921e -> bc6409d62 http://git-wip-us.apache.org/repos/asf/flink/blob/bc6409d6/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/functions/aggfunctions/AvgFunctionTest.scala

[1/2] flink git commit: [FLINK-6228] [table] Add support for OVER windows to streaming Table API.

Repository: flink Updated Branches: refs/heads/master 166444767 -> fe018921e http://git-wip-us.apache.org/repos/asf/flink/blob/fe018921/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/stringexpr/OverWindowStringExpressionTest.scala

[2/2] flink git commit: [FLINK-6228] [table] Add support for OVER windows to streaming Table API.

[FLINK-6228] [table] Add support for OVER windows to streaming Table API. This closes #3743. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe018921 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fe018921 Diff:

[2/5] flink git commit: [FLINK-6326] [table] Add ProjectMergeRule to logical optimization rule set.

[FLINK-6326] [table] Add ProjectMergeRule to logical optimization rule set. This closes #3739. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4024afff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4024afff Diff:

[3/5] flink git commit: [FLINK-6242] [table] Add code generation for DataSet Aggregates

http://git-wip-us.apache.org/repos/asf/flink/blob/3b4542b8/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSlideWindowAggReduceCombineFunction.scala -- diff --git

[1/5] flink git commit: [FLINK-4562] [table] Move table examples into a dedicated module in flink-examples.

Repository: flink Updated Branches: refs/heads/master 83061ad0f -> db31ca3f8 [FLINK-4562] [table] Move table examples into a dedicated module in flink-examples. This closes #2460. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/5] flink git commit: [FLINK-6242] [table] Add code generation for DataSet Aggregates

[FLINK-6242] [table] Add code generation for DataSet Aggregates This closes #3735. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3b4542b8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3b4542b8 Diff:

[5/5] flink git commit: [hotfix] [table] Add missing semicolons to Table API Java examples.

[hotfix] [table] Add missing semicolons to Table API Java examples. This closes #3754. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db31ca3f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db31ca3f Diff:

flink git commit: [FLINK-6240] [table] Add code generation for DataStream group window aggregations.

Repository: flink Updated Branches: refs/heads/master 283f5efd5 -> 9be5cc42c [FLINK-6240] [table] Add code generation for DataStream group window aggregations. This closes #3694. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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