[02/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-streaming-examples/src/test/java/org/apache/flink/streaming/test/exampleJavaPrograms/join/WindowJoinITCase.java -- diff --git

[29/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseFlinkTestConstants.java -- diff --git

[33/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/SqlExplainITCase.scala -- diff --git

[04/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery10.scala -- diff --git

[42/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/common/ParameterMap.scala -- diff --git

[30/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopReduceFunction.java -- diff --git

[16/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/examples/TransitiveClosureNaiveStep.java -- diff --git

[25/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala -- diff --git

[11/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCountPojo.java -- diff --git

[09/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/twitter/util/TwitterStreamData.java -- diff --git

flink git commit: [FLINK-2342] [ml] Add a new fit operation for Vector with Double value to StandardScaler

2016-01-14 Thread chiwanpark
Repository: flink Updated Branches: refs/heads/master d92e422ec -> 62938c110 [FLINK-2342] [ml] Add a new fit operation for Vector with Double value to StandardScaler - Add more tests to `StandardScalerITSuite` - Refactor `StandardScalerITSuite` This closes #899. Project:

[14/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

2016-01-14 Thread rmetzger
[FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d0e1d635 Tree:

[49/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/avro/AvroExternalJarProgramITCase.java -- diff --git

[22/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaStreamingTranslator.scala -- diff --git

[37/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala -- diff --git

[35/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RenameOperator.scala -- diff --git

[31/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-avro/src/test/java/org/apache/flink/api/io/avro/AvroPojoTest.java -- diff --git

[38/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/regression/RegressionData.scala -- diff --git

[08/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-examples-streaming/src/test/java/org/apache/flink/streaming/test/exampleJavaPrograms/socket/SocketTextStreamWordCountITCase.java -- diff --git

[07/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/graph/EnumTrianglesBasic.java -- diff --git

[01/50] flink git commit: [FLINK-3195] Rework quickstart example & some cleanups on the new examples

2016-01-14 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 62938c110 -> e9bf13d86 [FLINK-3195] Rework quickstart example & some cleanups on the new examples Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b7520a53 Tree:

[28/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java -- diff --git

[44/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezTask.java -- diff --git

[40/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala -- diff --git

[26/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/Solver.scala -- diff --git

[05/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/wordcount/util/WordCountData.java -- diff --git

[48/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-batch-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopReduceCombineFunction.java -- diff --git

[27/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/Breeze.scala -- diff --git a/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/Breeze.scala

[39/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/math/DenseVectorSuite.scala -- diff --git

[34/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/JoinITCase.java -- diff --git

[36/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/SelectionAnalyzer.scala -- diff --git

[50/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
[FLINK-1712] Remove "flink-staging" module This closes #1492 This closes #1482 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9bf13d8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9bf13d8 Diff:

[23/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-scala-shell/src/main/java/org/apache/flink/api/java/JarHelper.java -- diff --git

[24/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

2016-01-14 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/math/SparseVectorSuite.scala -- diff --git

flink git commit: [FLINK-2984] [ml] Extend libSVM file format support

2016-01-14 Thread chiwanpark
Repository: flink Updated Branches: refs/heads/master be055b7a9 -> 615cf42b3 [FLINK-2984] [ml] Extend libSVM file format support This closes #1504. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/615cf42b Tree:

buildbot success in ASF Buildbot on flink-docs-master

2016-01-14 Thread buildbot
The Buildbot has detected a restored build on builder flink-docs-master while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/flink-docs-master/builds/205 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason: The

flink git commit: [FLINK-2586] Unstable Storm Compatibility Tests - added BLOCKING flag to FlinkLocalCluster - added NullTerminatingSpout and SpoutOutputCollectorObserver plus tests - reworked test ac

2016-01-14 Thread mjsax
Repository: flink Updated Branches: refs/heads/master e4d894400 -> d1c93d286 [FLINK-2586] Unstable Storm Compatibility Tests - added BLOCKING flag to FlinkLocalCluster - added NullTerminatingSpout and SpoutOutputCollectorObserver plus tests - reworked test accordingly - set BLOCKING flag

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-2962] Cluster startup script refers to unused variable

2016-01-14 Thread uce
Repository: flink Updated Branches: refs/heads/master e9bf13d86 -> e4d894400 [FLINK-2962] Cluster startup script refers to unused variable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e4d89440 Tree:

flink git commit: [FLINK-2962] Cluster startup script refers to unused variable

2016-01-14 Thread uce
Repository: flink Updated Branches: refs/heads/release-0.10 66dd32d9e -> d09a83320 [FLINK-2962] Cluster startup script refers to unused variable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d09a8332 Tree: