Repository: flink
Updated Branches:
refs/heads/master 08ef02eba -> bcb3daf03
[docs] reintroduce link from documentation to Flink website
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bcb3daf0
Tree: http://git-wip-us.apac
Repository: flink
Updated Branches:
refs/heads/master e1e03062c -> 08ef02eba
[FLINK-1625] [streaming] Refactored StreamVertex and subclasses to clean up
after invoke and properly log and propagate exceptions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us
[FLINK-1625] [streaming] [api-breaking] Added proper cancellation to
StreamInvokables + Sink- and SourceFunction interfaces extended with cancel
method
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8436e9ce
Tree: http://gi
[FLINK-1625] [streaming] Streaming cancellation minor fix and documentation
This closes #449
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/08ef02eb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/08ef02eb
Diff: http
http://git-wip-us.apache.org/repos/asf/flink/blob/e1e03062/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/JoinWithEdgesITCase.java
--
diff --git
a/flink-staging/flink-gelly/src/test/java/org/apache/
[FLINK-1522][gelly] Fixed faulty split into create/runVertexCentricIteration
This closes #429
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8961bd19
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8961bd19
Diff: htt
Repository: flink
Updated Branches:
refs/heads/master d8d642fd6 -> e1e03062c
[FLINK-1522][gelly] Added test for SSSP Example
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f329e4ed
Tree: http://git-wip-us.apache.org/repos
[FLINK-1522][FLINK-1576] Updated LabelPropagationExample and test
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e306c629
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e306c629
Diff: http://git-wip-us.apache.org/rep
http://git-wip-us.apache.org/repos/asf/flink/blob/e1e03062/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/MapVerticesITCase.java
--
diff --git
a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/t
[gelly] refactored tests; removed duplicate data from TestGraphUtils
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e1e03062
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e1e03062
Diff: http://git-wip-us.apache.org/
[FLINK-1522][FLINK-1576][gelly] Added more test cases for Label Propagation
This closes #441
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b529b62a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b529b62a
Diff: http
[tests] Simple code format in CountCollectITCase and suppresses sysout output
for test.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/55f1508a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/55f1508a
Diff: http://gi
Repository: flink
Updated Branches:
refs/heads/master 9c0d6347e -> d8d642fd6
[FLINK-1648] Add auto-parallelism to select all available task slots
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8d642fd
Tree: http://git-wi
Author: hsaputra
Date: Wed Mar 4 18:45:04 2015
New Revision: 1664108
URL: http://svn.apache.org/r1664108
Log:
Fix typo in the Team page. From "Forner" to "Former"
Modified:
flink/community.md
flink/site/blog/feed.xml
flink/site/community.html
Modified: flink/community.md
URL:
http
[FLINK-1631] [client] Overhaul of the client.
- Fix bugs with non-serializable messages
- Separate parser and action logic
- Clean up tests
- Vastly improve logging in CLI client
- Additional tests for parsing / config setup in the command line client
Project: http://git-wip-us.apache.org/r
[jobmanager] Improve error message in case task deployment times out.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9c641374
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9c641374
Diff: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/master 0333109bb -> 9c6413740
http://git-wip-us.apache.org/repos/asf/flink/blob/5385e48d/flink-clients/src/test/java/org/apache/flink/client/CliFrontendAddressConfigurationTest.java
--
Repository: flink
Updated Branches:
refs/heads/release-0.8 941712941 -> a6f9f9939
Add autoparallelism to jobs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4ff3f4c4
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree
[jobmanage] Move auto-parallelism of vertices before master initialization
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6f9f993
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a6f9f993
Diff: http://git-wip-us.apach
[tests] Add test for restart recovery
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/785f2041
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/785f2041
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/785f2041
Repository: flink
Updated Branches:
refs/heads/master 9c6413740 -> 9c0d6347e
[FLINK-1646] [runtime] Improve 'insufficient number of network buffers' error
msg
Add a hint about how to configure the number of network buffers.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 0ae0cba31 -> 0333109bb
[FLINK-1627] [runtime] Fix race between remote receive and task release
The fixed race condition could lead to an infinite loop, in which the network
I/O thread is continuously trying to request a buffer from an alrea
Author: mxm
Date: Wed Mar 4 15:17:42 2015
New Revision: 1664034
URL: http://svn.apache.org/r1664034
Log:
[FLINK-1370] add .htaccess file also to root
Added:
flink/.htaccess
Added: flink/.htaccess
URL: http://svn.apache.org/viewvc/flink/.htaccess?rev=1664034&view=auto
===
Modified: flink/site/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html
URL:
http://svn.apache.org/viewvc/flink/site/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html?rev=1664037&r1=1664036&r2=1664037&view=diff
==
Author: mxm
Date: Wed Mar 4 15:16:55 2015
New Revision: 1664033
URL: http://svn.apache.org/r1664033
Log:
[FLINK-1370] make the release-0.8 branch the current documentation
Modified:
flink/_config.yml
Modified: flink/_config.yml
URL:
http://svn.apache.org/viewvc/flink/_config.yml?rev=166403
Author: mxm
Date: Wed Mar 4 15:19:04 2015
New Revision: 1664037
URL: http://svn.apache.org/r1664037
Log:
update website
Modified:
flink/site/archive.html
flink/site/asf.html
flink/site/blog/index.html
flink/site/blog/page2/index.html
flink/site/blog/page3/index.html
flink
Author: mxm
Date: Wed Mar 4 15:18:10 2015
New Revision: 1664036
URL: http://svn.apache.org/r1664036
Log:
[FLINK-1370] make index.html obey the template variables
Modified:
flink/archive.md
flink/index.html
Modified: flink/archive.md
URL:
http://svn.apache.org/viewvc/flink/archive.md?re
Author: mxm
Date: Wed Mar 4 15:16:25 2015
New Revision: 1664032
URL: http://svn.apache.org/r1664032
Log:
add myself to the community list
Modified:
flink/community.md
Modified: flink/community.md
URL:
http://svn.apache.org/viewvc/flink/community.md?rev=1664032&r1=1664031&r2=1664032&view=di
Repository: flink
Updated Branches:
refs/heads/master 7abed950d -> 0ae0cba31
[scala-api] Corrects type cast in Scala API's DataSet.collect method and adds
test cases for that
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 94a66d570 -> 7abed950d
[flink-yarn-tests] Add check for exceptions in the flink logs.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7abed950
Tree: http://git-wip-us.a
Repository: flink
Updated Branches:
refs/heads/travis_test [created] 393612ba3
[FLINK-1637] Reduce number of files in uberjar for java 6
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/393612ba
Tree: http://git-wip-us.apac
Repository: flink
Updated Branches:
refs/heads/travis_test [deleted] 532e8767c
32 matches
Mail list logo