Abacn commented on issue #23090: URL: https://github.com/apache/beam/issues/23090#issuecomment-1258451057
Could not reproduce when reading with single document by running `python apache_beam/io/mongodbio_it_test.py --num_documents=1` or `python apache_beam/io/mongodbio_it_test.py --num_documents=1 --batch_size=1` setting break point at range tracker [here](https://github.com/apache/beam/blob/3a4d57eb8976c5f503b32d478a80b1800490f66f/sdks/python/apache_beam/io/mongodbio.py#L367) get the following logging: ``` raise RuntimeError(str(start_position) + " " + str(stop_position)) 6331ef8116e9cab1252f4558 6331ef8116e9cab1252f4559 [while running 'ReadFromMongoDB/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/PairWithRestriction'] ``` As can be seen start_positin and stop_position still differ by 1 when there is single document. @diRblo Is it possible to provide a minimum working example that reproduces the issue? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
