Hi all, Currently experiencing a strange problem with a new Samza system I am writing to connect and read from databases via JDBC. I have based it off another system I have written to read from files (which works), and at the moment there are not a lot of differences apart from opening a database Connection rather than opening a Reader on a file.
The issue does not seem to be related to my code, going by the logs and how my code is directly based off another working system, although I could be wrong. If anyone has encountered a similar problem, or knows the reason behind this, I would love to hear your thoughts. Searching around, I am yet to find any solutions or explanations that fit with the problem which I am encountering. Here is the AM log: https://gist.github.com/poltak/8858874 If needed, my SystemFactory and SystemConsumer implementations can be found here: https://github.com/poltak/hello-samza/tree/database-reader/samza-wikipedia/src/main/java/samza/examples/databasereader/system Along with the config file I am using when the error occurs: https://github.com/poltak/hello-samza/blob/database-reader/samza-job-package/src/main/config/database-reader-feed.properties Let me know if any further information is needed, and will update this if I find any solution/explanation. Thanks for your time, Jonathan
