- 28 1月, 2016 2 次提交
-
-
由 zentol 提交于
-parallelism is stored Value object within the OperationInfo, so it can be passed as a reference to multiple operations (in cases where a set is internally executed as multiple operations) -setParallelism is called for every DataSet with either a user-set value or env.getParallelism -added a DataSink set, providing access to name() and setParallelism() for sinks
-
由 twalthr 提交于
This closes #1465.
-
- 27 1月, 2016 10 次提交
-
-
由 zentol 提交于
-identifier saved in java OpInfo -changed default values to prevent null exceptions -all operations use the same routine to transfer parameters -PyPlRcv can handle Tuple0 -labeled py OpInfo fields as transferred/internal -fixed broadcast OpInfo not having correct identifier -removed unused projection code
-
由 Ufuk Celebi 提交于
[FLINK-3258] [runtime, streaming-java, tests] Move registerInputOutput code to invoke and remove registerInputOutput This closes #1538
-
由 Ufuk Celebi 提交于
-
由 Aljoscha Krettek 提交于
Before, it could happen that a Task is canceled during snapshotting. Some State Backends would silently swallow exceptions resulting from this and the Task would get stuck until the cleanup logic gets to it. Now, we rethrow a CancelTaskException if isRunning is false in StreamTask after performing snapshots. This also moves the logic that swallows exceptions in case a task is not running anymore from StreamTask to the async caller in Task.
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
- add suffixes - adapt change-scala-version script This closes #1529.
-
由 chengxiang li 提交于
this commit support full outer join includes: 1. left outer join with REPARTITION_HASH_FIRST. 2. right outer join with REPARTITION_HASH_SECOND. 3. fullouter join with REPARTITION_HASH_FIRST and REPARTITION_HASH_SECOND. this close #1469
-
- 26 1月, 2016 13 次提交
-
-
由 smarthi 提交于
This closes #1539.
-
由 Stefano Baghino 提交于
This closes #1550
-
由 Kostas Kloudas 提交于
This closes #1548
-
由 Fabian Hueske 提交于
This closes #1522
-
由 Fabian Hueske 提交于
- Unify usage of expression keys: FLINK-1666 - Unify supported key expressions (incl. support for partitioning on atomic types: FLINK-3233) - Remove removal of duplicate keys: FLINK-1903 - Unify checks for sort keys - Add more tests for SelectorFunctionKeys and ExpressionKeys This closes #1520
-
由 sksamuel 提交于
This closes #1549.
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
This closes #1541
-
由 Aljoscha Krettek 提交于
Only keep Time for specifying time durations/intervals. This closes #1512
-
由 Maximilian Michels 提交于
This closes #1547
-
由 sksamuel 提交于
This closes #1531
-
由 ramkrishna 提交于
This closes #1530
-
由 Ufuk Celebi 提交于
-
- 25 1月, 2016 10 次提交
-
-
由 Paris Carbone 提交于
This closes #1526
-
由 Stephan Ewen 提交于
Before this commit, Kryo runs extra logic to track and resolve repeated references to the same object (similar as JavaSerialization) This disables reference tracking because - reference tracking is costly - it is virtually always unnecessary in the datatypes used in Flink - it is inconsistent with Flink's own serialization (which does not do reference tracking) - it may have problems if elements are read in a different order than they are written. This closes #1528
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-3246] Remove unnecessary '-parent' suffix from projects 'flink-contrib' and 'flink-streaming-connectors'. This closes #1515
-
由 Stephan Ewen 提交于
This closes #1518
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Gabor Gevay 提交于
This closes #1545
-
由 Aljoscha Krettek 提交于
Before, it could happen that a StreamingTask receives a Checkpoint Trigger message while internally not being ready. The checkpoint coordinator would then wait the specified timeout interval before continuing. Now, tasks can signal that they are not ready and the checkpoint coordinator will dicard a checkpoint for which is this the case and trigger new checkpoints if necessary. The newly triggered checkpoints will also release alignment locks in streaming tasks that are still waiting for barriers from failed checkpoints.
-
由 Ufuk Celebi 提交于
-
- 22 1月, 2016 4 次提交
-
-
由 Till Rohrmann 提交于
Only some of the LearningRateMethodTrait implementations use the decay value. Thus, it should only be part of these methods. This commit makes the learning rate methods which need additional parameters a case class which has to be instantiated with the respective parameter values. Corrects some of the learning rate formulas and the example in the documentation.
-
由 rawkintrevo 提交于
Added SGD gain calculation schemes fixed optimal SGD calculation scheme FLINK-1994: Added 4 new effective learning rates [FLINK-1994] [ml] Add different gain calculation schemes to SGD fixed long lines in GradientDescent.scala [FLINK-1994][ml]Add different gain calculation schemes to SGD [FLINK-1994][ml] Add different gain calculation schemes to SGD [FLINK-1994][ml] Add different gain calculation schemes to SGD Added SGD gain calculation schemes fixed optimal SGD calculation scheme [FLINK-1994] [ml] Add different gain calculation schemes to SGD FLINK-1994: Added 3 new effective learning rates Added SGD gain calculation schemes fixed optimal SGD calculation scheme [FLINK-1994] [ml] Add different gain calculation schemes to SGD fixed long lines in GradientDescent.scala [FLINK-1994][ml] Add different gain calculation schemes to SGD [Flink-1994][ml] Add different gain calculation schemes to SGD [FLINK-1994][ml] Updated docs, refactored optimizationMethod from Int to String [FLINK-1994][ml] Added test and example to docs [FLINK-1994][ml] Fixed Int Artifacts in LinearRegression.scala Added LearningRateMethod to IterativeSolver The learning rate method defines how the effective learning step is calculated for each iteration step of the IterativeSolver. Fixed docs, merged enumeration from Till, fixed typo in Wus method [FLINK-1994][ml] Added 4 new effective learning rate methods [FLINK-1994][ml] Add different gain calulation schemes to SGD This closes #1397.
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
-
- 21 1月, 2016 1 次提交
-
-
由 Maximilian Michels 提交于
This closes #1535.
-