Fixing the partition id which is passed further to DataStreamReader; the partitionId from taskContext was bogus, the Partition.index should've been used instead. - Githubissues

ActianCorp / spark-vector

Repository for the Spark-Vector connector

Apache License 2.0

20 stars 9 forks source link

Fixing the partition id which is passed further to DataStreamReader; the partitionId from taskContext was bogus, the Partition.index should've been used instead. #42

Closed cbarca closed 8 years ago

cbarca commented 8 years ago

Fixes #38

and-costea commented 8 years ago

ship