- 27 8月, 2015 8 次提交
-
-
由 Stephan Ewen 提交于
[streaming] Cleanup de-/serialization schema, add TypeInformationSerializationSchema prominent, add tests.
-
由 Robert Metzger 提交于
This closes #996
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 HuangWHWHW 提交于
This closes #991.
-
由 Ufuk Celebi 提交于
This closes #1063.
-
由 Stephan Ewen 提交于
- check for memory availability before probing - correctly compute memory required for recursive build fast path - remove all temp files properly
-
由 Stephan Ewen 提交于
-
- 26 8月, 2015 10 次提交
-
-
由 Maximilian Michels 提交于
- also adapt config.sh to use the same cross-platform compatible mechanism This closes #1049.
-
由 Robert Metzger 提交于
This is needed because the Hadoop IF/OF's are using Hadoop's FileSystem stack, which is using the security credentials passed in the JobConf / Job class in the getSplits() method. Note that access to secured Hadoop 1.x using Hadoop IF/OF's is not possible with this change. This limitation is due to missing methods in the old APIs. - Add some comments & change dependency scope to test
-
由 Fabian Hueske 提交于
This closes #1056.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Till Rohrmann 提交于
-
由 Ufuk Celebi 提交于
- Address PR comments This closes #1051.
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
- Address PR comments This closes #1050.
-
- 25 8月, 2015 5 次提交
-
-
由 Stephan Ewen 提交于
-
由 chengxiang li 提交于
- Expand the verification boundary for random sampler test - Increase the number of times we sample This closes #1047
-
由 vasia 提交于
[FLINK-2563] [gelly] extended the run() method of GraphAlgorithm interface to return an arbitrary type This closes #1042
-
由 Aljoscha Krettek 提交于
-
由 Stephan Ewen 提交于
-
- 24 8月, 2015 1 次提交
-
-
由 mjsax 提交于
- disabled avro-maven-plugin within Eclipse via <pluginManagement> ... <lifecyleMappingMetaData> This closes #1041
-
- 23 8月, 2015 4 次提交
-
-
由 vasia 提交于
[gelly] made the number of vertices an optional parameter of PageRank; added the edge weight initialization to the library methods
-
由 vasia 提交于
[FLINK-2451] [gelly] re-organized tests; compare with collect() instead of temp files where possible This closes #1000
-
由 vasia 提交于
-
由 vasia 提交于
[FLINK-2451] [gelly] removed redundant examples; added comments describing which gelly method each example illustrates.
-
- 22 8月, 2015 2 次提交
-
-
由 mjsax 提交于
- enabled .declareStream() and connect via stream name - enabled multiplt output streams - added .split() / .select() / strip pattern - added helpers in new package utils - adapted and extended JUnit tests - adapted examples some minor improvements (FlinkClient, integration of Tuple0) This closes #1011
-
由 Stephan Ewen 提交于
-
- 21 8月, 2015 3 次提交
-
-
由 chengxiang li 提交于
[FLINK-1901] [core] enable sample with fixed size on the whole dataset. [FLINK-1901] [core] add more comments for RandomSamplerTest. [FLINK-1901] [core] refactor PoissonSampler output Iterator. [FLINK-1901] [core] move sample/sampleWithSize operator to DataSetUtils. Adds notes for commons-math3 to LICENSE and NOTICE file This closes #949.
-
由 Ufuk Celebi 提交于
The DataExchangeMode of union nodes was not respected when translating an OptimizedPlan to a JobGraph. This could result in deadlocks, when a branched data flow was closed. Union nodes with a batch exchange will propagate their exchange mode to all inputs of their inputs when the JobGraph is generated. This closes #1036
-
由 Stephan Ewen 提交于
-
- 19 8月, 2015 2 次提交
-
-
由 Aljoscha Krettek 提交于
This decouples the building of the StreamGraph from the API methods. Before the methods would build the StreamGraph as they go. Now the API methods build a hierachy of StreamTransformation nodes. From these a StreamGraph is generated upon execution. This also introduces some API breaking changes: - The result of methods that create sinks is now DataStreamSink instead of DataStream - Iterations cannot have feedback edges with differing parallelism - "Preserve partitioning" is not the default for feedback edges. The previous option for this is removed. - You can close an iteration several times, no need for a union. - Strict checking of whether partitioning and parallelism work together. I.e. if upstream and downstream parallelism don't match it is not legal to have Forward partitioning anymore. This was not very transparent: When you went from low parallelism to high dop some downstream operators would never get any input. When you went from high parallelism to low dop you would get skew in the downstream operators because all elements that would be forwarded to an operator that is not "there" go to another operator. This requires insertion of global() or rebalance() in some places. For example with most sources which have parallelism one. This also makes StreamExecutionEnvironment.execute() behave consistently across different execution environments (local, remote ...): The list of operators to be executed are cleared after execute is called.
-
由 Till Rohrmann 提交于
[tests] Replaces Scala mixins for the Job/TaskManager with classes which extend the respective classes. Adds proper logger registration for sub-classes of FlinkUntypedActor.
-
- 18 8月, 2015 5 次提交
-
-
由 Stephan Ewen 提交于
-
由 HuangWHWHW 提交于
This closes #1022
-
由 Pieter-Jan Van Aeken 提交于
This closes #1004
-
由 HuangWHWHW 提交于
This closes #977
-
由 Stephan Ewen 提交于
-