Fixed partition assignment to datastreams.

ActianCorp / spark-vector

Repository for the Spark-Vector connector

Apache License 2.0

20 stars 9 forks source link

Fixed partition assignment to datastreams. #16

Closed and-costea closed 8 years ago

and-costea commented 8 years ago

When the refactor was done to move the matching logic into a separate trait, I mixed the "numAperB" with "matchedAperB". Also, adding some more tracing so that future errors/bugs in this code are easier to debug in the future.

cbarca commented 8 years ago

ship