[31/50] [abbrv] flink git commit: [FLINK-5911] [gelly] Command-line parameters

[FLINK-5911] [gelly] Command-line parameters Create interface for parsing command-line parameters using ParameterTool and generic implementations for boolean, long, double, string, choice. This closes #3433 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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

[FLINK-6197] [cep] Add support for iterative conditions. So far, the where clause only supported simple FilterFunction conditions. With this, we add support for conditions where an event is accepted not only based on its own properties, e.g. name, as it was before, but also based on some

[47/50] [abbrv] flink git commit: [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL.

[FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. This closes #3629. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d4665a00 Tree:

[32/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/test/java/org/apache/flink/cep/pattern/PatternTest.java -- diff --git

[40/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Clean up exception signature of ExecutionGraph

[hotfix] [dist. coordination] Clean up exception signature of ExecutionGraph Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/231bec8d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/231bec8d Diff:

[46/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Remove redundant method 'ExecutionVertex.getSimpleName()'

[hotfix] [dist. coordination] Remove redundant method 'ExecutionVertex.getSimpleName()' Replace the method via identical method 'getTaskNameWithSubtaskIndex'. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ca681101 Tree:

[42/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Add safety check for execution graph state transitions

[hotfix] [dist. coordination] Add safety check for execution graph state transitions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/60895a3c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/60895a3c Diff:

[45/50] [abbrv] flink git commit: [FLINK-5340] [metrics] Add an uptime and downtime metric to the Execution Graph.

[FLINK-5340] [metrics] Add an uptime and downtime metric to the Execution Graph. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/719d0cf1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/719d0cf1 Diff:

[14/50] [abbrv] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types

http://git-wip-us.apache.org/repos/asf/flink/blob/09164cf2/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java -- diff --git

[01/50] [abbrv] flink git commit: [FLINK-6139] [build] Add "mapr" build profile

Repository: flink Updated Branches: refs/heads/table-retraction d160b5e56 -> ee033c903 [FLINK-6139] [build] Add "mapr" build profile This build profile is for building Flink to be compatible with MapR. It additionally excludes dependency clashes between MapR's Hadoop / Zookeeper distributions

[43/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Fix waiting for execution termination

[hotfix] [dist. coordination] Fix waiting for execution termination Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85f75a59 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85f75a59 Diff:

[03/50] [abbrv] flink git commit: [FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics

[FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics This closes #3597. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d0695c05 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d0695c05 Diff:

[28/50] [abbrv] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction

[FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fad201bf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fad201bf Diff:

[15/50] [abbrv] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types

[FLINK-6018] Add tests for KryoSerializer restore with registered types This commit also renames isCompatibleWith() to canRestoreFrom() to make the method asymetric because in the case of KryoSerializer we can restore from state that was stored using no registed types/serializers while the other

[08/50] [abbrv] flink git commit: [FLINK-4354] [heartbeat] Implement heartbeat logic between TaskManager and ResourceManager

[FLINK-4354] [heartbeat] Implement heartbeat logic between TaskManager and ResourceManager This closes #3591. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd90672f Tree:

[07/50] [abbrv] flink git commit: [FLINK-4354] [heartbeat] Add heartbeats between the ResourceManager and TaskExecutor

[FLINK-4354] [heartbeat] Add heartbeats between the ResourceManager and TaskExecutor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/83b99f8a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/83b99f8a Diff:

[30/50] [abbrv] flink git commit: [hotfix] [docs] Fix broken links

[hotfix] [docs] Fix broken links This closes #3618. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/037b5cbd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/037b5cbd Diff:

[25/50] [abbrv] flink git commit: [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window.

[hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cac9fa02 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cac9fa02 Diff:

[12/50] [abbrv] flink git commit: [hotfix] Add EvictingWindowOperatorContractTest

[hotfix] Add EvictingWindowOperatorContractTest The existing WindowOperatorContractTest is turned into a test base while RegularWindowOperatorContract test tests WindowOperator and EvictingWindowOperatorTest tests EvictingWindowOperator. For this to work, the base tests now always use List

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

[FLINK-3318] Add support for quantifiers to CEP's pattern API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9001c4ef Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9001c4ef Diff:

[13/50] [abbrv] flink git commit: [FLINK-5972] Don't allow shrinking merging windows

[FLINK-5972] Don't allow shrinking merging windows This closes #3587. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/68289b1a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/68289b1a Diff:

[19/50] [abbrv] flink git commit: [FLINK-6128] [tests] Optimize JVM options to improve test performance

[FLINK-6128] [tests] Optimize JVM options to improve test performance Decrease the time to run TravisCI builds and reduce OOM by - increasing the heap size - switching to Java's serial garbage collector - removing the UseGCOverheadLimit option This closes #3571 Project:

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

Repository: flink Updated Branches: refs/heads/master aa3c395b9 -> ee033c903 [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:

[2/2] 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:

flink git commit: [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL.

Repository: flink Updated Branches: refs/heads/master ca681101f -> d4665a00a [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. This closes #3629. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface.

Repository: flink Updated Branches: refs/heads/master cac9fa028 -> 5c37e55c8 [FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface. This closes #3269. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window.

Repository: flink Updated Branches: refs/heads/master fe2c61a28 -> cac9fa028 [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cac9fa02 Tree:

[3/5] 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:

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

Repository: flink Updated Branches: refs/heads/master 976e03c1e -> fe2c61a28 [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:

[5/5] 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:

[2/5] 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:

[4/5] flink git commit: [FLINK-5990] [table] Add event-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL.

[FLINK-5990] [table] Add event-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. This closes #3585. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a9d39fe Tree:

[flink] Git Push Summary

Repository: flink Updated Branches: refs/heads/table-retraction [created] d160b5e56

flink git commit: [FLINK-5954] [table] Always assign names to the windows in SQL queries on streams.

Repository: flink Updated Branches: refs/heads/master f15a7d2d9 -> 7ef068ccc [FLINK-5954] [table] Always assign names to the windows in SQL queries on streams. This closes #3461. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5804] [table] Add support for procTime non-partitioned OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL.

Repository: flink Updated Branches: refs/heads/master 3fcc4e37c -> 7456d78d2 [FLINK-5804] [table] Add support for procTime non-partitioned OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL. This closes #3491. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-5803] [table] Add support for procTime partitioned OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL.

[FLINK-5803] [table] Add support for procTime partitioned OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL. This closes #3397. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/53fb8f3b Tree:

[1/2] flink git commit: [FLINK-5956] [table] Add retract method for AggregateFunction.

Repository: flink Updated Branches: refs/heads/master 821da81fe -> 53fb8f3b5 [FLINK-5956] [table] Add retract method for AggregateFunction. This closes #3470. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd801aa5

[3/3] flink git commit: [hotfix] [table] Fix initialization of accumulators for MIN and MAX aggregates.

[hotfix] [table] Fix initialization of accumulators for MIN and MAX aggregates. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2d1721bb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2d1721bb Diff:

[2/3] flink git commit: [FLINK-5955] [table] Fix aggregations with ObjectReuse enabled by pairwise merging of accumulators.

[FLINK-5955] [table] Fix aggregations with ObjectReuse enabled by pairwise merging of accumulators. This closes #3465. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/14fab4c4 Tree:

[1/3] flink git commit: [FLINK-5927] [table] Remove old Aggregate interface, built-in functions, and tests.

Repository: flink Updated Branches: refs/heads/master 050f9a416 -> c31f95cab [FLINK-5927] [table] Remove old Aggregate interface, built-in functions, and tests. This closes #3465. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-5768] [table] Refactor DataSet and DataStream aggregations to use UDAGG interface.

[FLINK-5768] [table] Refactor DataSet and DataStream aggregations to use UDAGG interface. - DataStream aggregates use new WindowedStream.aggregate() operator. This closes #3423. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/3] flink git commit: [FLINK-5768] [table] Refactor DataSet and DataStream aggregations to use UDAGG interface.

Repository: flink Updated Branches: refs/heads/master 7fe0eb477 -> 438276de8 http://git-wip-us.apache.org/repos/asf/flink/blob/438276de/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/functions/aggfunctions/AggFunctionTestBase.scala

[2/3] flink git commit: [FLINK-5768] [table] Refactor DataSet and DataStream aggregations to use UDAGG interface.

http://git-wip-us.apache.org/repos/asf/flink/blob/438276de/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala -- diff --git

flink git commit: [FLINK-5921] [table] Add custom data types for rowtime and proctime.

Repository: flink Updated Branches: refs/heads/master 3086af534 -> 2a1a9c1e3 [FLINK-5921] [table] Add custom data types for rowtime and proctime. - proctime() and rowtime() are translated to constont zero timestamp. This closes #3425. Project:

flink git commit: [FLINK-5907] [java] Fix handling of trailing empty fields in CsvInputFormat.

Repository: flink Updated Branches: refs/heads/release-1.2 19fe04758 -> 5168b9f62 [FLINK-5907] [java] Fix handling of trailing empty fields in CsvInputFormat. This closes #3417. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-3475] [table] Add support for DISTINCT aggregates in SQL queries.

Repository: flink Updated Branches: refs/heads/master 8bcb2ae3c -> 1a062b796 [FLINK-3475] [table] Add support for DISTINCT aggregates in SQL queries. This closes #3111. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-5907] [java] Fix handling of trailing empty fields in CsvInputFormat.

[FLINK-5907] [java] Fix handling of trailing empty fields in CsvInputFormat. This closes #3417. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1a062b79 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1a062b79 Diff:

[3/3] flink git commit: [hotfix] [core] Changing PublicEvolving anntoation of Archiveable to Internal.

[hotfix] [core] Changing PublicEvolving anntoation of Archiveable to Internal. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c78abab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8c78abab Diff:

[1/3] flink git commit: [FLINK-5899] [table] Fix translation of batch event-time tumbling windows with non-partial aggregation functions.

Repository: flink Updated Branches: refs/heads/master 2437da6e5 -> 0a97cd29a [FLINK-5899] [table] Fix translation of batch event-time tumbling windows with non-partial aggregation functions. This closes #3405. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink git commit: [FLINK-5710] [table] Add proctime() function to indicate processing time in Stream SQL.

[FLINK-5710] [table] Add proctime() function to indicate processing time in Stream SQL. This closes #3370. This closes #3302. // duplicate of #3370 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a755de27 Tree:

flink git commit: [FLINK-5767] [table] Add interface for user-defined aggregate functions and built-in aggregate functions.

Repository: flink Updated Branches: refs/heads/master 417597fbf -> dd8ef550c [FLINK-5767] [table] Add interface for user-defined aggregate functions and built-in aggregate functions. This closes #3354. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5624] [table] Add SQL support for tumbling windows on streaming tables.

Repository: flink Updated Branches: refs/heads/master f24514339 -> 8304f3e15 [FLINK-5624] [table] Add SQL support for tumbling windows on streaming tables. This closes #3252. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5771] [core] Fix multi-char delimiter detection in DelimitedInputFormat.

Repository: flink Updated Branches: refs/heads/release-1.1 3cd7c8ee3 -> 44f48b34e [FLINK-5771] [core] Fix multi-char delimiter detection in DelimitedInputFormat. - Add a test case to validate correct delimiter detection. - Remove a couple of try-catch blocks from existing tests. This closes

flink git commit: [FLINK-5771] [core] Fix multi-char delimiter detection in DelimitedInputFormat.

Repository: flink Updated Branches: refs/heads/release-1.2 1037ace42 -> 3b4f6cf8c [FLINK-5771] [core] Fix multi-char delimiter detection in DelimitedInputFormat. - Add a test case to validate correct delimiter detection. - Remove a couple of try-catch blocks from existing tests. This closes

[1/2] flink git commit: [FLINK-5771] [core] Fix multi-char delimiter detection in DelimitedInputFormat.

Repository: flink Updated Branches: refs/heads/master 5fb267de6 -> ae0fbff76 [FLINK-5771] [core] Fix multi-char delimiter detection in DelimitedInputFormat. - Add a test case to validate correct delimiter detection. - Remove a couple of try-catch blocks from existing tests. This closes

[2/2] flink git commit: [FLINK-2168] Refactor HBaseTableSource and extend tests.

[FLINK-2168] Refactor HBaseTableSource and extend tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/87d09342 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/87d09342 Diff:

[1/2] flink git commit: [FLINK-2168] Add HBaseTableSource for batch tables.

Repository: flink Updated Branches: refs/heads/master d88c938cf -> 87d09342b [FLINK-2168] Add HBaseTableSource for batch tables. This closes #3149. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/58d4513a Tree:

flink git commit: [FLINK-5566] [table] Add containers for table and column statistics.

Repository: flink Updated Branches: refs/heads/master d32281444 -> 663c1e3f7 [FLINK-5566] [table] Add containers for table and column statistics. This closes #3196. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] [docs] Fix error in docs for zipping elements.

Repository: flink Updated Branches: refs/heads/release-1.2 bcace0654 -> 206dde5f7 [hotfix] [docs] Fix error in docs for zipping elements. This closes #3280. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/206dde5f Tree:

[1/2] flink git commit: [FLINK-5727] [table] Unify API of batch and stream TableEnvironments.

Repository: flink Updated Branches: refs/heads/master cba85db64 -> e24a866bf [FLINK-5727] [table] Unify API of batch and stream TableEnvironments. This closes #3281. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [hotfix] [docs] Fix error in docs for zipping elements.

[hotfix] [docs] Fix error in docs for zipping elements. This closes #3280. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e24a866b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e24a866b Diff:

flink git commit: [FLINK-5455] [docs] Add documentation for upgrading applications.

Repository: flink Updated Branches: refs/heads/release-1.2 3e59d838f -> e789933b5 [FLINK-5455] [docs] Add documentation for upgrading applications. This closes #3217. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5455] [docs] Add documentation for upgrading applications.

Repository: flink Updated Branches: refs/heads/master f3930510c -> 5ca243752 [FLINK-5455] [docs] Add documentation for upgrading applications. This closes #3217. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5ca24375

flink git commit: [FLINK-2662] [optimizer] Fix translation of broadcasted unions.

Repository: flink Updated Branches: refs/heads/release-1.1 f6f1c244c -> 6566b63aa [FLINK-2662] [optimizer] Fix translation of broadcasted unions. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6566b63a Tree:

flink git commit: [FLINK-2662] [optimizer] Fix translation of broadcasted unions.

Repository: flink Updated Branches: refs/heads/release-1.2 03a1f25fa -> 8c5edb2fc [FLINK-2662] [optimizer] Fix translation of broadcasted unions. This closes #3083. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2662] [optimizer] Fix translation of broadcasted unions.

Repository: flink Updated Branches: refs/heads/master 8d6426320 -> 6dffe282b [FLINK-2662] [optimizer] Fix translation of broadcasted unions. This closes #3083. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6dffe282

flink git commit: [FLINK-5386] [table] Refactor window clause.

Repository: flink Updated Branches: refs/heads/release-1.2 0a24611a8 -> be09143cd [FLINK-5386] [table] Refactor window clause. - move window() before groupBy() - make window alias mandatory - groupBy() must include window alias Project: http://git-wip-us.apache.org/repos/asf/flink/repo

flink git commit: [FLINK-5386] [table] Refactor window clause.

Repository: flink Updated Branches: refs/heads/master 8ccedd103 -> 6bf556e60 [FLINK-5386] [table] Refactor window clause. - move window() before groupBy() - make window alias mandatory - groupBy() must include window alias This closes #3046. Project:

[3/3] flink git commit: [hotfix] [docs] Add closing parentheses on "DataStream API Programming Guide".

[hotfix] [docs] Add closing parentheses on "DataStream API Programming Guide". This closes #3153. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db230a97 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db230a97

[2/3] flink git commit: [FLINK-5452] [table] Fix SortITCase which fails under cluster mode.

[FLINK-5452] [table] Fix SortITCase which fails under cluster mode. This closes #3095. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7f769261 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7f769261 Diff:

[1/3] flink git commit: [FLINK-5520] [table] Disable outer joins with non-equality predicates.

Repository: flink Updated Branches: refs/heads/release-1.2 080617d28 -> 9073c53f9 [FLINK-5520] [table] Disable outer joins with non-equality predicates. This closes #3141. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [hotfix] [docs] Add closing parentheses on "DataStream API Programming Guide".

[hotfix] [docs] Add closing parentheses on "DataStream API Programming Guide". This closes #3153. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0c6e0ee9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0c6e0ee9

[2/3] flink git commit: [FLINK-5452] [table] Fix SortITCase which fails under cluster mode.

[FLINK-5452] [table] Fix SortITCase which fails under cluster mode. This closes #3095. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ea996a6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0ea996a6 Diff:

[1/3] flink git commit: [FLINK-5520] [table] Disable outer joins with non-equality predicates.

Repository: flink Updated Branches: refs/heads/master 4833e74e7 -> d1301c82b [FLINK-5520] [table] Disable outer joins with non-equality predicates. This closes #3141. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] [docs] Several fixes on "Basic API Concepts".

Repository: flink Updated Branches: refs/heads/release-1.2 aad8d253c -> 5f81d20ba [hotfix] [docs] Several fixes on "Basic API Concepts". - Fix a wrong function name `groupBy()` to `keyBy()`. - Add closing parentheses. - Fix an invalid return type of sample code. - Remove a duplicate "their".

flink git commit: [hotfix] [docs] Several fixes on "Basic API Concepts".

Repository: flink Updated Branches: refs/heads/master cb2820675 -> 6fb6967b9 [hotfix] [docs] Several fixes on "Basic API Concepts". - Fix a wrong function name `groupBy()` to `keyBy()`. - Add closing parentheses. - Fix an invalid return type of sample code. - Remove a duplicate "their". This

flink git commit: [FLINK-5518] [hadoopCompat] Add null check to HadoopInputFormatBase.close().

Repository: flink Updated Branches: refs/heads/release-1.1 4ea52d69d -> 214c188d7 [FLINK-5518] [hadoopCompat] Add null check to HadoopInputFormatBase.close(). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/214c188d Tree:

flink git commit: [FLINK-5518] [hadoopCompat] Add null check to HadoopInputFormatBase.close().

Repository: flink Updated Branches: refs/heads/release-1.2 61ac3605f -> aad8d253c [FLINK-5518] [hadoopCompat] Add null check to HadoopInputFormatBase.close(). This closes #3133 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] [docs] Improved Table API docs.

Repository: flink Updated Branches: refs/heads/release-1.2 8b7331409 -> d8d9d7603 [hotfix] [docs] Improved Table API docs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8d9d760 Tree:

flink git commit: [hotfix] [docs] Improved Table API docs.

Repository: flink Updated Branches: refs/heads/master 2bda5e457 -> 59b3be0ec [hotfix] [docs] Improved Table API docs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59b3be0e Tree:

flink git commit: [FLINK-5280] [table] Refactor TableSource interface.

Repository: flink Updated Branches: refs/heads/release-1.2 be3784f55 -> a504abe46 [FLINK-5280] [table] Refactor TableSource interface. This closes #3039. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a504abe4 Tree:

[1/2] flink git commit: [FLINK-5280] [table] Refactor TableSource interface.

Repository: flink Updated Branches: refs/heads/master d4d7cc326 -> 2af939a10 [FLINK-5280] [table] Refactor TableSource interface. This closes #3039. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38ded2bb Tree:

[1/2] flink-web git commit: [FLINK-5308] Add missing previous releases and release dates.

Repository: flink-web Updated Branches: refs/heads/asf-site 6a622bc29 -> f03b28f85 [FLINK-5308] Add missing previous releases and release dates. This closes #41. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit:

[2/2] flink-web git commit: [blog] Add Year 2016 in Review blog post.

[blog] Add Year 2016 in Review blog post. This closes #43. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/f03b28f8 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/f03b28f8 Diff:

[27/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala -- diff --git

[01/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

Repository: flink Updated Branches: refs/heads/master 48ef46a4d -> 67c4be648 http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamCorrelateITCase.scala

[12/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

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

[10/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

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

[21/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala -- diff --git

[34/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkRel.scala -- diff --git

[04/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

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

[46/47] flink git commit: [FLINK-3848] [table] follow-up: Refactor TableSource tests.

[FLINK-3848] [table] follow-up: Refactor TableSource tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/22af6cf5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/22af6cf5 Diff:

[13/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/batch/table/JoinITCase.java -- diff --git

[43/47] flink git commit: [FLINK-5008] [docs] Update IDE setup and quickstart documentation.

[FLINK-5008] [docs] Update IDE setup and quickstart documentation. This closes #2764. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/67c4be64 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/67c4be64 Diff:

[2/7] flink git commit: [FLINK-5188] [table] [connectors] [core] Adjust imports and method calls to new Row type.

http://git-wip-us.apache.org/repos/asf/flink/blob/4d27f8f2/flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java -- diff --git

[7/7] flink git commit: [FLINK-5266] [table] Inject projection of unused fields before aggregations.

[FLINK-5266] [table] Inject projection of unused fields before aggregations. This closes #2961. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/15e7f0a8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/15e7f0a8 Diff:

[1/7] flink git commit: [FLINK-5188] [table] [connectors] [core] Adjust imports and method calls to new Row type.

Repository: flink Updated Branches: refs/heads/master 5dab9345c -> 4d27f8f2d http://git-wip-us.apache.org/repos/asf/flink/blob/4d27f8f2/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/SumAggregate.scala

[3/7] flink git commit: [FLINK-5188] [table] [connectors] [core] Adjust imports and method calls to new Row type.

[FLINK-5188] [table] [connectors] [core] Adjust imports and method calls to new Row type. - Port RowCsvInputFormat to Java and move it to flink-core. This closes #3003. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/3] flink git commit: [FLINK-5223] [doc] Add documentation of UDTF in Table API & SQL

Repository: flink Updated Branches: refs/heads/master 270140a1d -> 5baea3f2e [FLINK-5223] [doc] Add documentation of UDTF in Table API & SQL This closes #2956. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c86efbb

[2/3] flink git commit: [FLINK-5304] [table] Rename crossApply/outerApply to join/leftOuterJoin in Table API.

[FLINK-5304] [table] Rename crossApply/outerApply to join/leftOuterJoin in Table API. This closes #2978. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da4af125 Tree:

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