Repository: flink
Updated Branches:
refs/heads/master af1e03e13 -> b489c3673
[FLINK-2825] FlinkClient.killTopology fails due to missing leader session ID
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b489c367
Tree: http:
Repository: flink
Updated Branches:
refs/heads/master 48791c347 -> af1e03e13
Create a deep-copy of the record when changing timestamps.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af1e03e1
Tree: http://git-wip-us.apach
Repository: flink
Updated Branches:
refs/heads/master b08669abf -> 48791c347
Revert "[FLINK-2203] handling null values for RowSerializer"
This reverts commit f8e12b20d925c3f6f24769327d1da5d98affa679.
The commit had to be reverted because the RowSerializer is not in sync
with other comperators
Revert "[FLINK-2210] Table API support for aggregation on columns with null
values"
This reverts commit b59c81bc41f0fc4ade5359dfdf42549a76d412fa.
The commit had to be reverted because the RowSerializer is not in sync
with other comparators and serializers. See FLINK-2236.
Project: http://git-w
[FLINK-2283] [streaming] Test for checkpointing in internal operators
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a76d9638
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a76d9638
Diff: http://git-wip-us.apache.org
[FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no
longer valid reference
Remove Pact word from class and file names in Apache Flink.
Pact was the name used in Stratosphere time to refer to concept of distributed
datasets (similar to Flink Dataset). It was used when Pac
http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java
Repository: flink
Updated Branches:
refs/heads/master e494c2795 -> b08669abf
http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/TaskContext.java
--
diff --g
http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceCombineDriver.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators
http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadPactTask.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/iterati
[FLINK-2812] [streaming] KeySelectorUtil interacts well with type extraction
The interaction is tested in the AggregationFunctionTest and the scala
DataStreamTest amongst others.
Closes #1155
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/
[streaming] Removed unused StreamReduce
Refactored corresponding tests, some minor cleanups.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/906bd6dc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/906bd6dc
Diff: http
Repository: flink
Updated Branches:
refs/heads/master 4938ff09f -> e494c2795
[FLINK-2283] [streaming] Proper serialization of state in StreamGroupedFold and
Reduce
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c414ea98
[FLINK-2283] [streaming] grouped reduce and fold operators checkpoint state
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/225704bc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/225704bc
Diff: http://git-wip-us.apac
Repository: flink
Updated Branches:
refs/heads/master 4c5d43b6f -> 4938ff09f
[FLINK-2642] [table] Scala Table API crashes when executing word count example
This closes #1209.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commi
Repository: flink
Updated Branches:
refs/heads/master 4cb967089 -> 4c5d43b6f
[FLINK-2822] [streaming] Remove scala.Serializable imports
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4c5d43b6
Tree: http://git-wip-us.apach
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/AbstractTest.java
--
diff --git
a/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/A
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/stormoperators/WordCountDataPojos.java
--
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/test/java/org/apache/flink/stormcompatibility/wrappers/StormBoltWrapperTest.java
--
diff --git
a
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/SplitStreamTypeKeySelector.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/7a67a60f/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/test/java/org/apache/flink/stormcompatibility/util/FiniteTestSpout.java
--
diff --git
a/flink-co
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountLocalByName.java
--
diff --git
a/flink-contrib/flink-storm-examples/src/main/jav
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/excamation/ExclamationLocal.java
--
diff --git
a/flink-contrib/flink-storm-examples/src/main/java/o
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/util/FiniteStormInMemorySpout.java
--
diff --gi
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalITCase.java
--
diff --git
a/flink-contrib/flink-storm-examples/src/test/jav
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormSpoutWrapper.java
--
diff --git
a/fl
Repository: flink
Updated Branches:
refs/heads/master 39115abe4 -> 4cb967089
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
---
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/pom.xml
--
diff --git
a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-exampl
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/AbstractStormCollector.java
--
diff --git
a/flink-contrib/flink-storm/src/main/java/org/apache/flin
[FLINK-2566] FlinkTopologyContext not populated completely
- extended FlinkTopologyContext to be populted with all supportable attributes
- added JUnit test
- updated README.md
additionally: module restructuring to get cleaner package structure
This closes #1135
Project: http://git-wip-us.
[Storm Compatibility] Maven module restucturing and cleanup
- removed storm-parent; renamed storm-core and storm-examples
- updated internal Java package structure
* renamed package "stormcompatibility" to "storm"
* unified *SpoutWrapper* to single SpoutWrapper.java class
* moved cl
Repository: flink
Updated Branches:
refs/heads/master 2b81b17d5 -> 39115abe4
http://git-wip-us.apache.org/repos/asf/flink/blob/39115abe/flink-staging/flink-spargel/src/main/java/org/apache/flink/spargel/java/VertexUpdateFunction.java
-
[FLINK-2786] Remove Spargel code and docs; Port Spargel tests to Gelly; Remove
Beta badge from Gelly
This closes #1229
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/39115abe
Tree: http://git-wip-us.apache.org/repos/asf/fli
Repository: flink
Updated Branches:
refs/heads/master de14a8015 -> 2b81b17d5
[FLINK-2741] Use single log statement in TestLogger
This closes #1221
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b81b17d
Tree: http://git-
[FLINK-2811] [web-dashboard] Add job manager configuration overview
This closes #1219
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/de14a801
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/de14a801
Diff: http://git-
http://git-wip-us.apache.org/repos/asf/flink/blob/de14a801/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 8d8
Repository: flink
Updated Branches:
refs/heads/master 19076b2df -> de14a8015
http://git-wip-us.apache.org/repos/asf/flink/blob/de14a801/flink-runtime-web/web-dashboard/web/partials/jobmanager/config.html
--
diff --git
a/flink-
Repository: flink
Updated Branches:
refs/heads/release-0.9 2b6a837a2 -> cf6f87b5e
[FLINK-1610] fix building of java doc for Java 8
This closes #1225.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf6f87b5
Tree: http://g
[FLINK-1610] fix building of java doc for Java 8
This closes #1225.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/352b041b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/352b041b
Diff: http://git-wip-us.apache.org/
Repository: flink
Updated Branches:
refs/heads/master 9513f0e33 -> 19076b2df
[FLINK-2810] Warn user if bc not installed
This closes #1228.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/19076b2d
Tree: http://git-wip-us.a
[FLINK-2813] document parameter for off-heap memory
This closes #1226.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f8fa3377
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f8fa3377
Diff: http://git-wip-us.apache.o
41 matches
Mail list logo