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
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
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
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
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
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
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
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
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
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
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:
[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:
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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
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
[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:
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
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
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:
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
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
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
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:
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:
40 matches
Mail list logo