flink git commit: [FLINK-3082] Fixed confusing error about an interface that no longer exists

2015-11-27 Thread sewen
Repository: flink Updated Branches: refs/heads/master 55fd5f32d -> d359a974a [FLINK-3082] Fixed confusing error about an interface that no longer exists This closes #1411 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/7] flink git commit: [FLINK-3056] [web-dashboard] Represent bytes in more readable form.

2015-11-30 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/80512229/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index

[6/7] flink git commit: [FLINK-2904] [web-dashboard] Fix truncation of task counts when the number is large.

2015-11-30 Thread sewen
[FLINK-2904] [web-dashboard] Fix truncation of task counts when the number is large. This closes #1321 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b80ecfdc Tree:

[7/7] flink git commit: [FLINK-2950] [ml] [docs] Fix markdown rendering problem in SVM documentation

2015-11-30 Thread sewen
[FLINK-2950] [ml] [docs] Fix markdown rendering problem in SVM documentation - Remove unnecessary indentation of table - Fix wrong `strong` end tag - Simplify lambda expression in map operation This closes #1312 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/7] flink git commit: [FLINK-3056] [web-dashboard] Represent bytes in more readable form.

2015-11-30 Thread sewen
[FLINK-3056] [web-dashboard] Represent bytes in more readable form. Bytes are now displayed in the following fashion: 1. For [0, 1000) units, display three significant digits. 2. For [1000,1024) units, display 2 decimal points for the next higher unit. For example, 1010 KB is displayed as

[4/7] flink git commit: [FLINK-2351] [core] Remove IOFormat ConfigBuilders

2015-11-30 Thread sewen
[FLINK-2351] [core] Remove IOFormat ConfigBuilders This closes #1420 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6bac9214 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6bac9214 Diff:

[5/7] flink git commit: [FLINK-3083] [docs] Add docs on how to configure streaming fault tolerance.

2015-11-30 Thread sewen
[FLINK-3083] [docs] Add docs on how to configure streaming fault tolerance. This closes #1413 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf913476 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf913476 Diff:

[1/7] flink git commit: [FLINK-3056] [web-dashboard] Represent bytes in more readable form.

2015-11-30 Thread sewen
Repository: flink Updated Branches: refs/heads/master 2b358cde0 -> d5a6b13ab http://git-wip-us.apache.org/repos/asf/flink/blob/80512229/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node-list.overview.html -- diff

flink git commit: [FLINK-3084] [streaming] FsStateBackend backs up very small state directly with the metadata.

2015-12-01 Thread sewen
Repository: flink Updated Branches: refs/heads/master cd899f3be -> d1ea365ef [FLINK-3084] [streaming] FsStateBackend backs up very small state directly with the metadata. This closes #1423 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-3051] [streaming] Add mechanisms to control the maximum number of concurrent checkpoints

2015-11-26 Thread sewen
[FLINK-3051] [streaming] Add mechanisms to control the maximum number of concurrent checkpoints This closes #1408 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/55fd5f32 Tree:

[1/2] flink git commit: [hotfix] Java-7-ify the ExecutionConfig class

2015-11-26 Thread sewen
Repository: flink Updated Branches: refs/heads/master dcce6def9 -> 55fd5f32d [hotfix] Java-7-ify the ExecutionConfig class Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4097666e Tree:

[2/2] flink git commit: [hotfix] [streaming] Fix instantiation of state backends from state backend factory.

2015-11-19 Thread sewen
[hotfix] [streaming] Fix instantiation of state backends from state backend factory. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c5f363d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3c5f363d Diff:

[1/2] flink git commit: [FLINK-3040] [docs] Add docs for State Backends

2015-11-19 Thread sewen
Repository: flink Updated Branches: refs/heads/master 8325bc6a6 -> 8b086eb91 [FLINK-3040] [docs] Add docs for State Backends Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b086eb9 Tree:

[1/2] flink git commit: [FLINK-3040] [docs] Add docs for State Backends

2015-11-19 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 a7e799b9f -> db456a761 [FLINK-3040] [docs] Add docs for State Backends Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db456a76 Tree:

[2/2] flink git commit: [hotfix] [streaming] Fix instantiation of state backends from state backend factory.

2015-11-19 Thread sewen
[hotfix] [streaming] Fix instantiation of state backends from state backend factory. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef709093 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ef709093 Diff:

flink git commit: [hotfix] [docs] Fix errors in streaming docs for fold()

2015-11-19 Thread sewen
Repository: flink Updated Branches: refs/heads/master 38cf0c610 -> 2f013a204 [hotfix] [docs] Fix errors in streaming docs for fold() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2f013a20 Tree:

[2/2] flink git commit: [FLINK-3048] [tests] Increase stability of DataSinkTaskTest

2015-11-19 Thread sewen
[FLINK-3048] [tests] Increase stability of DataSinkTaskTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/93622001 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/93622001 Diff:

flink git commit: [FLINK-2429] [streaming] Deprecate the "enableCheckpointing()" method with no interval argument.

2015-11-23 Thread sewen
Repository: flink Updated Branches: refs/heads/master 1600fe2c2 -> 68a69c76a [FLINK-2429] [streaming] Deprecate the "enableCheckpointing()" method with no interval argument. This closes #1382 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability

2015-11-19 Thread sewen
[FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability This closes #1381 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7441799e Tree:

[1/2] flink git commit: [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer.

2015-11-19 Thread sewen
Repository: flink Updated Branches: refs/heads/master 6b253d9f8 -> 864357bac [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer. This also adds to the deprecated classes pointers forward to the designated classes. This closes #1380 Project:

[2/2] flink git commit: [FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability

2015-11-19 Thread sewen
[FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability This closes #1381 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20612063 Tree:

[1/2] flink git commit: [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer.

2015-11-19 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 e977d8274 -> 9defe0cb2 [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer. This also adds to the deprecated classes pointers forward to the designated classes. This closes #1380 Project:

[1/6] flink git commit: [FLINK-2832] [tests] Hardens RandomSamplerTest

2016-06-08 Thread sewen
Repository: flink Updated Branches: refs/heads/master 65ee28c34 -> 297d75c2e [FLINK-2832] [tests] Hardens RandomSamplerTest Increase the level of significance from p=0.01 to p=0.001 and add retry annotations to random sampler tests. This should decrease the probability of failing random

[2/6] flink git commit: [hotfix] [nifi] Minor style cleanups in NiFi source

2016-06-08 Thread sewen
[hotfix] [nifi] Minor style cleanups in NiFi source Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b08b64ab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b08b64ab Diff:

[6/6] flink git commit: [FLINK-3405] [nifi] Extend NiFiSource with interface StoppableFunction

2016-06-08 Thread sewen
[FLINK-3405] [nifi] Extend NiFiSource with interface StoppableFunction This closes #2047 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38362c40 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/38362c40 Diff:

[3/6] flink git commit: [FLINK-4000] [RabbitMQ] Fix for checkpoint state restore at MessageAcknowledgingSourceBase

2016-06-08 Thread sewen
[FLINK-4000] [RabbitMQ] Fix for checkpoint state restore at MessageAcknowledgingSourceBase As says documentation for MessageAcknowledgingSourceBase.restoreState() This method is invoked when a function is executed as part of a recovery run. Note that restoreState() is called before open(). So

[4/6] flink git commit: [FLINK-4000] [RabbitMQ] Style cleanups in MessageAcknowledgingSourceBase

2016-06-08 Thread sewen
[FLINK-4000] [RabbitMQ] Style cleanups in MessageAcknowledgingSourceBase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6afb2b00 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6afb2b00 Diff:

[5/6] flink git commit: [FLINK-3922] [core] Fix case of infinite recursion in TypeExtractor

2016-06-08 Thread sewen
[FLINK-3922] [core] Fix case of infinite recursion in TypeExtractor This closes #2011 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e1b55f03 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e1b55f03 Diff:

flink git commit: [hotfix] [core] Make sure Dropwizard reporters do not block operator creation/teardown while reporting

2016-06-10 Thread sewen
Repository: flink Updated Branches: refs/heads/master 393bceb58 -> 2bffd7b9e [hotfix] [core] Make sure Dropwizard reporters do not block operator creation/teardown while reporting The "report()" method used to hold the same lock that was needed to create and shutdown metrics. Holding that

flink git commit: [hotfix] [core] Re-enable JMX metrics as the default.

2016-06-09 Thread sewen
Repository: flink Updated Branches: refs/heads/master ccc86e9f1 -> d760bbc96 [hotfix] [core] Re-enable JMX metrics as the default. This also does some minor code cleanups, logging fixes, and smoother concurrency handling. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-4052] [runtime] Improve test stability for ConnectionUtilsTest

2016-06-09 Thread sewen
Repository: flink Updated Branches: refs/heads/master d760bbc96 -> 8696e799f [FLINK-4052] [runtime] Improve test stability for ConnectionUtilsTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8696e799 Tree:

flink git commit: [hotfix] [core] Fix scope format keys for metrics

2016-06-05 Thread sewen
Repository: flink Updated Branches: refs/heads/master 65545c2ed -> ccc3e44cb [hotfix] [core] Fix scope format keys for metrics This closes #2068 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ccc3e44c Tree:

[3/3] flink git commit: [hotfix] Remove leftover config key constant from ExecutionConfig

2016-05-26 Thread sewen
[hotfix] Remove leftover config key constant from ExecutionConfig Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5a7f4e33 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5a7f4e33 Diff:

[1/3] flink git commit: [FLINK-3962] [core] Properly initialize I/O Metric Group

2016-05-26 Thread sewen
Repository: flink Updated Branches: refs/heads/master ef5832d8f -> 573a92fc5 [FLINK-3962] [core] Properly initialize I/O Metric Group Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/573a92fc Tree:

[2/3] flink git commit: [hotfix] Fix access to temp file directories in SpillingAdaptiveSpanningRecordDeserializer

2016-05-26 Thread sewen
[hotfix] Fix access to temp file directories in SpillingAdaptiveSpanningRecordDeserializer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bf256c7f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bf256c7f Diff:

[7/7] flink git commit: [hotfix] [yarn tests] Fix deadlock between YARN Session CLI tests and Surefire

2016-05-30 Thread sewen
[hotfix] [yarn tests] Fix deadlock between YARN Session CLI tests and Surefire The Surefire Plugin uses stdin to communicate with forked JVMs for tests. The YARN Session CLI tests also try to read the stdin stream. The tests deadlock since Surefire never releases the stdin locks during the

[5/7] flink git commit: [FLINK-1502] [core] Cleanups, robustness, and performance improvements in the metrics system

2016-05-30 Thread sewen
[FLINK-1502] [core] Cleanups, robustness, and performance improvements in the metrics system Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ad8375a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7ad8375a Diff:

[1/7] flink git commit: [hotfix] [contrib] Fix robustness of DataStreamUtils stream collecting

2016-05-30 Thread sewen
Repository: flink Updated Branches: refs/heads/master 035f62969 -> da23ee38e [hotfix] [contrib] Fix robustness of DataStreamUtils stream collecting Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3e3bd52 Tree:

[4/4] flink git commit: [FLINK-3886] [clients] Give a better error when the application Main class is not public.

2016-05-31 Thread sewen
[FLINK-3886] [clients] Give a better error when the application Main class is not public. This closes #2043 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6db9e6ae Tree:

[3/4] flink git commit: [FLINK-3979] [docs] Add import statements for last code sample in the quickstart docs.

2016-05-31 Thread sewen
[FLINK-3979] [docs] Add import statements for last code sample in the quickstart docs. This closes #2038 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ad52a5f0 Tree:

[2/4] flink git commit: [FLINK-3978] [core] Add hasBroadcastVariable method to RuntimeContext

2016-05-31 Thread sewen
[FLINK-3978] [core] Add hasBroadcastVariable method to RuntimeContext New method RuntimeContext.hasBroadcastVariable(String). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b028797 Tree:

flink git commit: [hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators

2016-01-15 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 2d7f0b1af -> dfeee2372 [hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators This closes #1511 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators

2016-01-15 Thread sewen
Repository: flink Updated Branches: refs/heads/master 2c556f74e -> cfcb5d7ba [hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators This closes #1511 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[07/12] flink git commit: [FLINK-3235] Remove Flink on Tez code

2016-01-15 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/8b8dfc16/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/dag/TezDAGGenerator.java -- diff --git

[11/12] flink git commit: [hotfix] Minor cleanup of warnings, comments, and code style in the Java API Utils

2016-01-15 Thread sewen
[hotfix] Minor cleanup of warnings, comments, and code style in the Java API Utils Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/93654413 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/93654413 Diff:

[12/12] flink git commit: [FLINK-3197] [core] Close InputStream in BinaryInputFormat#createStatistics reliably

2016-01-15 Thread sewen
[FLINK-3197] [core] Close InputStream in BinaryInputFormat#createStatistics reliably This closes #1494 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c556f74 Tree:

[02/12] flink git commit: [hotfix] Remove outdated README for the quickstart projects.

2016-01-15 Thread sewen
[hotfix] Remove outdated README for the quickstart projects. The README was describing non-existing bash scripts removed several versions ago. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16cf8b13 Tree:

[10/12] flink git commit: [FLINK-3219] [java scala] Implement DataSet.count and DataSet.collect using a single operator

2016-01-15 Thread sewen
[FLINK-3219] [java scala] Implement DataSet.count and DataSet.collect using a single operator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9a53587 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9a53587 Diff:

[06/12] flink git commit: [FLINK-3235] Remove Flink on Tez code

2016-01-15 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/8b8dfc16/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezTask.java -- diff --git

[04/12] flink git commit: [hotfix] Remove unnecessary dependencies in flink-runtime.

2016-01-15 Thread sewen
[hotfix] Remove unnecessary dependencies in flink-runtime. - Removes Apache Commons HTTP Client - Removes Apache Commons IO - Removes Jettison JSONparser and consolidates tests to use Jackson instead (which is included anyways) Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[08/12] flink git commit: [FLINK-3235] Remove Flink on Tez code

2016-01-15 Thread sewen
[FLINK-3235] Remove Flink on Tez code Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b8dfc16 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8b8dfc16 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8b8dfc16

[03/12] flink git commit: [hotfix] Remove docs for the now removed web client.

2016-01-15 Thread sewen
[hotfix] Remove docs for the now removed web client. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9915b339 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9915b339 Diff:

[05/12] flink git commit: [FLINK-3235] Remove Flink on Tez code

2016-01-15 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/8b8dfc16/flink-contrib/flink-tez/src/test/resources/log4j-test.properties -- diff --git a/flink-contrib/flink-tez/src/test/resources/log4j-test.properties

[01/12] flink git commit: [FLINK-3232] [runtime] Add option to eagerly deploy channels

2016-01-15 Thread sewen
Repository: flink Updated Branches: refs/heads/master a65cd8db1 -> 2c556f74e [FLINK-3232] [runtime] Add option to eagerly deploy channels Adds a flag to the ExecutionGraph's IntermediateResult class indicating whether the result consumers should be deployed eagerly. If true, the consumers are

[09/12] flink git commit: [FLINK-3236] [runtime] Flink user code classloader as parent classloader from Flink core classes

2016-01-15 Thread sewen
[FLINK-3236] [runtime] Flink user code classloader as parent classloader from Flink core classes Originally, the user code classloader delegates to the system classloader as parent. That works in Flink standalone settings, but not when the Flink core classes themselves are not loaded with the

[2/2] flink git commit: [FLINK-2716] [gelly] [apis] New checksum method on DataSet and Graph

2016-01-15 Thread sewen
[FLINK-2716] [gelly] [apis] New checksum method on DataSet and Graph This closes #1462 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a8be52a3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a8be52a3 Diff:

[1/2] flink git commit: [FLINK-2671] [tests] Fix unstable StreamCheckpointNotifierITCase

2016-01-15 Thread sewen
Repository: flink Updated Branches: refs/heads/master 98fad04ec -> c0fd36bac [FLINK-2671] [tests] Fix unstable StreamCheckpointNotifierITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c0fd36ba Tree:

flink git commit: [hotfix] Exclude 'flink-annotations' from fat jars in quickstart poms.

2016-01-18 Thread sewen
Repository: flink Updated Branches: refs/heads/master 7d7d8b68e -> 153a67881 [hotfix] Exclude 'flink-annotations' from fat jars in quickstart poms. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/153a6788 Tree:

[2/2] flink git commit: [hotfix] Clean up CliFrontend after removing web client

2016-01-16 Thread sewen
[hotfix] Clean up CliFrontend after removing web client Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17fa6a9b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17fa6a9b Diff:

[1/2] flink git commit: [hotfix] Fix reference to batch Java examples in flink-java8

2016-01-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master c0fd36bac -> adbeec2f9 [hotfix] Fix reference to batch Java examples in flink-java8 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/adbeec2f Tree:

flink git commit: [FLINK-3236] [runtime] Flink user code classloader as parent classloader from Flink core classes

2016-01-14 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 d09a83320 -> 2d7f0b1af [FLINK-3236] [runtime] Flink user code classloader as parent classloader from Flink core classes Originally, the user code classloader delegates to the system classloader as parent. That works in Flink

flink git commit: [FLINK-3373] [build] Shade away Hadoop's HTTP Components dependency

2016-02-10 Thread sewen
Repository: flink Updated Branches: refs/heads/master aeee6efd4 -> 8ccd7544e [FLINK-3373] [build] Shade away Hadoop's HTTP Components dependency This closes #1615 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ccd7544

flink git commit: [FLINK-3372] Setting custom YARN application name is ignored

2016-02-10 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 2cd06181f -> 11bfe6f3e [FLINK-3372] Setting custom YARN application name is ignored This closes #1607 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/11bfe6f3

[6/6] flink git commit: [FLINK-3260] [runtime] Enforce terminal state of Executions

2016-02-10 Thread sewen
[FLINK-3260] [runtime] Enforce terminal state of Executions This commit fixes the problem that Executions could leave their terminal state FINISHED to transition to FAILED. Such a transition will be propagated to the ExecutionGraph where it entails JobStatus changes. Since the Execution already

[3/6] flink git commit: [hotfix] [tests] Ignore ZooKeeper logs in process tests

2016-02-10 Thread sewen
[hotfix] [tests] Ignore ZooKeeper logs in process tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3a643c07 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3a643c07 Diff:

[1/6] flink git commit: [FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9

2016-02-10 Thread sewen
Repository: flink Updated Branches: refs/heads/master 8ccd7544e -> 6968a57a1 [FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9 This closes #1597 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/6] flink git commit: [FLINK-3350] [tests] Increase default test Akka ask and ZooKeeper timeouts

2016-02-10 Thread sewen
[FLINK-3350] [tests] Increase default test Akka ask and ZooKeeper timeouts Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8f40251 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8f40251 Diff:

[4/6] flink git commit: [hotfix] [tests] Log retry rule failures on warn level

2016-02-10 Thread sewen
[hotfix] [tests] Log retry rule failures on warn level Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/756cbaff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/756cbaff Diff:

[2/2] flink git commit: [FLINK-3384] [kafka] Add ClosableQueue for message exchanges between Kafka Threads

2016-02-10 Thread sewen
[FLINK-3384] [kafka] Add ClosableQueue for message exchanges between Kafka Threads Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd324ea7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fd324ea7 Diff:

[1/2] flink git commit: [FLINK-3371] [api-breaking] Move TriggerResult and TriggerContext to dedicated classes

2016-02-10 Thread sewen
Repository: flink Updated Branches: refs/heads/master 8df0bbacb -> fd324ea72 [FLINK-3371] [api-breaking] Move TriggerResult and TriggerContext to dedicated classes This closes #1603 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3355] [rocksdb backend] Allow passing options to the RocksDB backend.

2016-02-09 Thread sewen
Repository: flink Updated Branches: refs/heads/master 28c6254ee -> 9ee167949 [FLINK-3355] [rocksdb backend] Allow passing options to the RocksDB backend. This also cleans up the generics in the RocksDB state classes. This closes #1608 Project:

flink git commit: [FLINK-3373] [build] Bump version of transitine HTTP Components dependency to 4.4.4 (core) / 4.5.1 (client)

2016-02-09 Thread sewen
Repository: flink Updated Branches: refs/heads/master a4f0692e9 -> c57a7e910 [FLINK-3373] [build] Bump version of transitine HTTP Components dependency to 4.4.4 (core) / 4.5.1 (client) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3268] [tests] Enhance stability of ZooKeeperTestEnvironment.deleteAll()

2016-02-04 Thread sewen
Repository: flink Updated Branches: refs/heads/master 7378f014b -> f8f747f22 [FLINK-3268] [tests] Enhance stability of ZooKeeperTestEnvironment.deleteAll() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f8f747f2 Tree:

[1/2] flink git commit: [streaming] [scala] Scala wrapper for DataStreamUtils

2016-02-04 Thread sewen
Repository: flink Updated Branches: refs/heads/master 69f7f6d92 -> 4852302a1 [streaming] [scala] Scala wrapper for DataStreamUtils This closes #1574 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4852302a Tree:

[4/4] flink git commit: [hotfix] Minor code cleanups in AbstractStateBackend

2016-02-12 Thread sewen
[hotfix] Minor code cleanups in AbstractStateBackend Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d93b154d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d93b154d Diff:

[2/4] flink git commit: [FLINK-2991] Add Folding State and use in WindowOperator

2016-02-12 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/94cba899/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java -- diff --git

[1/3] flink git commit: [FLINK-3358] [FLINK-3351] [rocksdb] Add simple constructors and automatic temp path configuration

2016-02-11 Thread sewen
Repository: flink Updated Branches: refs/heads/master dcea46e89 -> edae79340 [FLINK-3358] [FLINK-3351] [rocksdb] Add simple constructors and automatic temp path configuration This adds constructors that only take a backup dir URI and use it to initialize both the RocksDB file backups and the

[3/3] flink git commit: [FLINK-3271] [build] Don't exclude jetty-util dependency from the Hadoop dependencies

2016-02-11 Thread sewen
[FLINK-3271] [build] Don't exclude jetty-util dependency from the Hadoop dependencies This closes #1543 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82c7383a Tree:

[2/3] flink git commit: [FLINK-3389] [rocksdb] Add pre-defined option profiles.

2016-02-11 Thread sewen
[FLINK-3389] [rocksdb] Add pre-defined option profiles. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/be72758d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/be72758d Diff:

flink git commit: [FLINK-3338] [kafka] Use proper classloader when cloning the deserialization schema.

2016-02-05 Thread sewen
Repository: flink Updated Branches: refs/heads/master fe0c3b539 -> 2eb2a0ef3 [FLINK-3338] [kafka] Use proper classloader when cloning the deserialization schema. This closes #1590 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[6/9] flink git commit: [hotfix] typo IllegalArgumentException

2016-02-08 Thread sewen
[hotfix] typo IllegalArgumentException This closes #1602 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c47f385 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c47f385 Diff:

[5/9] flink git commit: [FLINK-3334] [conf] Include year-month-day in the log output

2016-02-08 Thread sewen
[FLINK-3334] [conf] Include year-month-day in the log output Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d51bec15 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d51bec15 Diff:

[2/9] flink git commit: [FLINK-3363] [jobmanager] Properly shut down executor thread pool when JobManager shuts down

2016-02-08 Thread sewen
[FLINK-3363] [jobmanager] Properly shut down executor thread pool when JobManager shuts down Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a277543c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a277543c Diff:

[7/9] flink git commit: [FLINK-3357] [core] Drop AbstractID#toShortString()

2016-02-08 Thread sewen
[FLINK-3357] [core] Drop AbstractID#toShortString() This closes #1601 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28feede7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28feede7 Diff:

[4/9] flink git commit: [FLINK-3337] [runtime] mvn test fails on flink-runtime because curator classes not found

2016-02-08 Thread sewen
[FLINK-3337] [runtime] mvn test fails on flink-runtime because curator classes not found Removes curator dependency exclusions from flink-runtime. This resolves NoClassDefFoundError exceptions when running `mvn test`. This partialy reverts e31a4d8. This closes #1596 Project:

[8/9] flink git commit: [hotfix] Update comments in 'ChainingStrategy' and remove outdated 'FORCE_ALWAYS' constant

2016-02-08 Thread sewen
[hotfix] Update comments in 'ChainingStrategy' and remove outdated 'FORCE_ALWAYS' constant Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9c83ea2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9c83ea2 Diff:

[1/9] flink git commit: [FLINK-3365] [taskmanager] Properly shut down cleanup timer thread

2016-02-08 Thread sewen
Repository: flink Updated Branches: refs/heads/master 22423e23f -> 28c6254ee [FLINK-3365] [taskmanager] Properly shut down cleanup timer thread Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/457cb145 Tree:

[5/5] flink git commit: [FLINK-3265] [rabbitmq] Fix concurrency bug in RabbitMQ

2016-01-28 Thread sewen
[FLINK-3265] [rabbitmq] Fix concurrency bug in RabbitMQ This closes #1534 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b01a890 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6b01a890 Diff:

[3/5] flink git commit: [FLINK-3242] Also Set User-specified StateBackend without Checkpointing

2016-01-28 Thread sewen
[FLINK-3242] Also Set User-specified StateBackend without Checkpointing Before, the user-specified StateBackedn would not be set when generating the JobGraph if checkpointing was disabled. This closes #1516 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/5] flink git commit: [FLINK-3292]Fix for Bug in flink-jdbc. Not all JDBC drivers supported

2016-01-28 Thread sewen
[FLINK-3292]Fix for Bug in flink-jdbc. Not all JDBC drivers supported This closes #1551 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d97fcda6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d97fcda6 Diff:

[1/5] flink git commit: [FLINK-3178] Don't Emit In-Flight Windows When Closing Window Operator

2016-01-28 Thread sewen
Repository: flink Updated Branches: refs/heads/master 2e2330737 -> 6b01a8902 [FLINK-3178] Don't Emit In-Flight Windows When Closing Window Operator This closes #1542 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3242] Adjust StateBackendITCase for 0.10 signatures of state backends

2016-01-28 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 2aeb6fac3 -> bef39f881 [FLINK-3242] Adjust StateBackendITCase for 0.10 signatures of state backends Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bef39f88

flink git commit: [hotfix] Remove 'ByteArrayInputView' and replace deserialization in TypeInformationSerializationSchema with more efficient reusable buffers.

2016-02-01 Thread sewen
Repository: flink Updated Branches: refs/heads/master 67b380d61 -> 92efcd34a [hotfix] Remove 'ByteArrayInputView' and replace deserialization in TypeInformationSerializationSchema with more efficient reusable buffers. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[13/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

2016-02-02 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/TupleSerializerTestInstance.java -- diff --git

[01/38] flink git commit: [hotfix] Reduce the heavy sysout verbosity for certain tests

2016-02-02 Thread sewen
Repository: flink Updated Branches: refs/heads/master 360f02b1f -> 8fc7e7af2 [hotfix] Reduce the heavy sysout verbosity for certain tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f042e78 Tree:

[05/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

2016-02-02 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/typeutils/CompositeTypeTest.java -- diff --git

[30/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

2016-02-02 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java -- diff --git a/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java

[08/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

2016-02-02 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java -- diff --git

[23/38] flink git commit: [FLINK-3303] [core] Move Tuple classes to flink-core

2016-02-02 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple15Builder.java -- diff --git

[04/38] flink git commit: [FLINK-3303] [core] Move all type utilities to flink-core

2016-02-02 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/AvroGenericTypeComparatorTest.java -- diff --git

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