- 06 5月, 2015 4 次提交
-
-
由 mbalassi 提交于
-
由 mbalassi 提交于
This improves tracking of jobs. Closes #654
-
由 Fabian Hueske 提交于
This closes #627
-
由 Fabian Hueske 提交于
This closes #641
-
- 05 5月, 2015 6 次提交
-
-
由 vasia 提交于
moved the migration guide section to the end of Gelly guide; made a few corrections in the migration guide text This closes #600
-
由 andralungu 提交于
-
由 joey001 提交于
This closes #650
-
由 andralungu 提交于
This closes #626
-
由 Till Rohrmann 提交于
-
由 mbalassi 提交于
-
- 04 5月, 2015 4 次提交
-
-
由 Chiwan Park 提交于
[FLINK-1855] [streaming] Add WordCount class into WindowWordCount and SocketTextStreamWordCount example jars Closes #644
-
由 mbalassi 提交于
Moved corresponding test to flink-contrib Removed unnecessary print Closes #581
-
由 Gabor Gevay 提交于
Streams back the results from the job to the client via a TCP socket
-
由 mbalassi 提交于
-
- 02 5月, 2015 1 次提交
-
-
由 andralungu 提交于
This is a squash of the following commits: [FLINK-1883][gelly] Added Min Vertex Id Propagation library and example [FLINK-1883][gelly] Renamed algorithm to Connected Components [FLINK-1883][gelly] Made the CC library method match Spargel [FLINK-1883][gelly] Polished the CC with Randomised Edges test Closes #596
-
- 01 5月, 2015 1 次提交
-
-
由 Maximilian Michels 提交于
-
- 30 4月, 2015 2 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Maximilian Michels 提交于
The previously introduced SoftReferences to store archived ExecutionGraphs cleared old graphs in a non-transparent order. This closes #639.
-
- 29 4月, 2015 14 次提交
-
-
由 elbehery 提交于
This closes #621 This closes #442
-
由 mbalassi 提交于
Closes #630
-
由 szape 提交于
-
由 Gyula Fora 提交于
Closes #634
-
由 Stephan Ewen 提交于
- Checkpoints can be configured to have different sets of tasks that triggering the checkpoint barriers, that acknowledging the checkpoint, and that require checkpoint confirmations. - A configurable number of successful chckpoints can be retained - Checkpoints time out after a certain time, if not acknowledged (prevent resource leaks) - Checkpoints are robust to lost messages and out of order acknowledging.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[streaming] Change 'getParallelism()' signature to return a primitive to avoid failed equality checks.
-
由 Stephan Ewen 提交于
-
由 Till Rohrmann 提交于
1. TDD reception with eager acknowledgement and 2. TDD instantiation with a subsequent state update message. This closes #622
-
由 Till Rohrmann 提交于
[FLINK-1923] [runtime] Replaces asynchronous logging with synchronous logging using grizzled-slf4j wrapper for Scala. This closes #628
-
由 Till Rohrmann 提交于
This closes #631
-
由 Till Rohrmann 提交于
[yarn] [python] Adds -Xms start option for yarn, fixes python test case to overwrite files, fixes python docs Fixes failing yarn test cases
-
由 Till Rohrmann 提交于
-
- 28 4月, 2015 6 次提交
-
-
由 Robert Metzger 提交于
This closes #637
-
由 Till Rohrmann 提交于
-
由 mingliang 提交于
This closes #35
-
由 mingliang 提交于
-
由 fpompermaier 提交于
This closes #632 This closes #571
-
由 hsaputra 提交于
FLINK-1693 Add DEPRECATED annotations in Spargel APIs and update the doc to refer to Gelly for Flink graph processing. Mark all user-facing from the Spargel API as deprecated and add a comment in the docs and point people to Gelly. This should help migration to Gelly in the next release. Author: hsaputra <hsaputra@apache.org> Closes #618 from hsaputra/FLINK-1693_deprecate_spargel_apis and squashes the following commits: 4652805 [hsaputra] FLINK-1693 Add DEPRECATED annotations in Spargel APIs and update the doc to refer to Gelly for Flink graph processing.
-
- 27 4月, 2015 2 次提交
-
-
由 zentol 提交于
- code formatting - simpler python process initialization - renaming of the python connection following the switch to TCP This closes #616.
-
由 Ufuk Celebi 提交于
This closes #617.
-