beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "wang hongmin (JIRA)" <>
Subject [jira] [Created] (BEAM-2256) mongodb sdk MongoDbIO.BoundedMongoDbSource.splitKeysToFilters incorrect
Date Thu, 11 May 2017 07:54:04 GMT
wang hongmin created BEAM-2256:

             Summary: mongodb sdk MongoDbIO.BoundedMongoDbSource.splitKeysToFilters incorrect
                 Key: BEAM-2256
             Project: Beam
          Issue Type: Bug
          Components: sdk-java-extensions
    Affects Versions: 0.6.0, 0.5.0, 0.4.0, Not applicable
            Reporter: wang hongmin
            Assignee: Davor Bonaci

When use beam-sdks-java-io-mongodb to count a large collection in MongoDB, I always get a
smaller number than actual size of the collection. It seems a puzzle, until I dived into source
code and trace the execution. The fault exists in method MongoDbIO.BoundedMongoDbSource.splitKeysToFilters(),
which should return one more FILTER than size of input argument splitKeys. 
I check all version of this file, it seems none was correct.
Additionally, it seems no suitable [Component]. I choose a similar tag.:)

This message was sent by Atlassian JIRA

View raw message