I see :)
Btw: Travis is green now. Marton gave the right hint about inconsistent
module renaming while moving the layer to flink-contib. Due to an old
cache (thanks for the clearing hint, Fabian) and this bug, the funny
error message showed up. After clearing the cache I got a different
error mess
In StreamingJobGraphGenerator.connect(headOfChain, edge) is checks the
strategy. If it is FORWARD it only does a POINTWISE connection to the
low-level downstream vertex. I know, this is all very unclear... :D
On Thu, 11 Jun 2015 at 00:13 Matthias J. Sax
wrote:
> I am not sure about this... You a
I am not sure about this... You are right about the super constructor,
however, selectChannels(...) does not call super.getStrategy() what is
the only way to get back the value set in the super class (ie,
StreamPartitioner.strategy).
selectChannels() computes the return value independently from
th
It doesn't evaluate the member forward, but it calls the super constructor
with a partitioning strategy that depends on on the forward parameter.
That's how it works.
On Wed, 10 Jun 2015 at 18:51 Márton Balassi
wrote:
> Thanks for spotting the documentation issues. I'm fixing them quickly for
>
Thanks for spotting the documentation issues. I'm fixing them quickly for
the release then.
The RebalancePartitioner indeed is obfuscated, let me see what can be done
there.
On Wed, Jun 10, 2015 at 6:34 PM, Matthias J. Sax <
mj...@informatik.hu-berlin.de> wrote:
> Thanks!
>
>
> About shuffle() vs
Thanks!
About shuffle() vs rebalance(): I would suggest to explain the
difference (random vs round-robin) in the JavaDoc of DataStream.
Furthermore, I was wondering if the JavaDoc for @return is correct for
"forward()", "rebalance()", and "global()". They all state
> "@return The DataStream wit
Hey,
As the storm-compatibility-core build goes fine this is a dependency issue
with storm-compatibility-examples. As a first try replace:
org.apache.flink
flink-streaming-core
${project.version}
test
tests
with
org.apache.flink
flink-streaming-core
${project.version}
test
Travis caches Maven dependendies and sometimes fails to update them.
Try to clear you Travis cache via "Settings" (up right) -> "Caches"
Cheers, Fabian
2015-06-10 14:22 GMT+02:00 Matthias J. Sax :
> Hi,
>
> the current PR of storm compatibility layer builds successfully on my
> laptop (mvn clean
This seems like a version mismatch. For example,
DataStream.distribute() was changed to DataStream.rebalance()
recently. Maybe your build getting some outdated jars from the travis
cache.
On Wed, Jun 10, 2015 at 2:22 PM, Matthias J. Sax
wrote:
> Hi,
>
> the current PR of storm compatibility layer
Hi,
the current PR of storm compatibility layer builds successfully on my
laptop (mvn clean install). However, on travis I get strange error
messages in the IT-Cases:
https://travis-ci.org/mjsax/flink/builds/66137928
For example:
> Caused by: java.lang.AbstractMethodError:
> org.apache.flink.st
10 matches
Mail list logo
