You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@storm.apache.org by ght230 <gh...@163.com> on 2015/08/12 03:56:19 UTC

How does external module storm-jdbc implement transactional

Hello :

I had a problem during using the module storm/external/storm-jdbc, 
the class JdbcState in this module does not seem to distinguish between opaque transactional state, transactional state, and non-transactional state, how can it implement the transaction executed only once?

This function is forgotten, or any other reason?

Thanks!




iceguo

Re: How does external module storm-jdbc implement transactional

Posted by Bobby Evans <ev...@yahoo-inc.com.INVALID>.

Yes JDBC state has the same problem that I found in HDFS state recently.  It is ignoring the commits.
https://github.com/apache/storm/blob/master/external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java#L114-L122

Please file a JIRA to update JdbcState to make it transactional.  Depending on the size of the transactions we probably should just use the database's build in transactions.
 - Bobby 


     On Tuesday, August 11, 2015 8:57 PM, ght230 <gh...@163.com> wrote:
   

 Hello :

I had a problem during using the module storm/external/storm-jdbc, 
the class JdbcState in this module does not seem to distinguish between opaque transactional state, transactional state, and non-transactional state, how can it implement the transaction executed only once?

This function is forgotten, or any other reason?

Thanks!




iceguo