I have done some changes to cdap persists API to try out something and now I am getting following transaction related errors.
[warn 2015/08/10 22:50:53.299 IST <DatasetTypeManager STARTING> tid=0x24] Transaction 1439227213486000000 is not in progress.
co.cask.tephra.TransactionNotInProgressException: canCommit() is called for transaction 1439227213486000000 that is not in progress (it is known to be invalid)
at co.cask.tephra.TransactionManager.commit(TransactionManager.java:842)
at co.cask.tephra.inmemory.InMemoryTxSystemClient.commit(InMemoryTxSystemClient.java:73)
at co.cask.tephra.TransactionContext.commit(TransactionContext.java:265)
at co.cask.tephra.TransactionContext.finish(TransactionContext.java:98)
at co.cask.tephra.DefaultTransactionExecutor.executeOnce(DefaultTransactionExecutor.java:142)
at co.cask.tephra.DefaultTransactionExecutor.executeWithRetry(DefaultTransactionExecutor.java:115)
at co.cask.tephra.DefaultTransactionExecutor.execute(DefaultTransactionExecutor.java:72)
at co.cask.tephra.DefaultTransactionExecutor.execute(DefaultTransactionExecutor.java:90)
at co.cask.cdap.data2.dataset2.tx.TransactionalDatasetRegistry.execute(TransactionalDatasetRegistry.java:64)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.deleteSystemModules(DatasetTypeManager.java:397)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.startUp(DatasetTypeManager.java:88)
at com.google.common.util.concurrent.AbstractIdleService$1$1.run(AbstractIdleService.java:43)
at java.lang.Thread.run(Thread.java:745)
[info 2015/08/10 22:50:53.306 IST <DatasetTypeManager STARTING> tid=0x24] Tx invalid list: removed aborted tx 1439227213486000000
Exception in thread "DatasetTypeManager STARTING" Exception in thread "DatasetService" com.google.common.util.concurrent.UncheckedExecutionException: java.lang.RuntimeException: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at com.google.common.util.concurrent.Futures.wrapAndThrowUnchecked(Futures.java:1015)
at com.google.common.util.concurrent.Futures.getUnchecked(Futures.java:1001)
at com.google.common.util.concurrent.AbstractService.startAndWait(AbstractService.java:220)
at com.google.common.util.concurrent.AbstractIdleService.startAndWait(AbstractIdleService.java:106)
at co.cask.cdap.data2.datafabric.dataset.service.DatasetService.startUp(DatasetService.java:123)
at com.google.common.util.concurrent.AbstractExecutionThreadService$1$1.run(AbstractExecutionThreadService.java:47)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.RuntimeException: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.deleteSystemModules(DatasetTypeManager.java:412)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.startUp(DatasetTypeManager.java:88)
at com.google.common.util.concurrent.AbstractIdleService$1$1.run(AbstractIdleService.java:43)
... 1 more
Caused by: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at co.cask.tephra.TransactionContext.commit(TransactionContext.java:269)
at co.cask.tephra.TransactionContext.finish(TransactionContext.java:98)
at co.cask.tephra.DefaultTransactionExecutor.executeOnce(DefaultTransactionExecutor.java:142)
at co.cask.tephra.DefaultTransactionExecutor.executeWithRetry(DefaultTransactionExecutor.java:115)
at co.cask.tephra.DefaultTransactionExecutor.execute(DefaultTransactionExecutor.java:72)
at co.cask.tephra.DefaultTransactionExecutor.execute(DefaultTransactionExecutor.java:90)
at co.cask.cdap.data2.dataset2.tx.TransactionalDatasetRegistry.execute(TransactionalDatasetRegistry.java:64)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.deleteSystemModules(DatasetTypeManager.java:397)
... 3 more
Caused by: co.cask.tephra.TransactionNotInProgressException: canCommit() is called for transaction 1439227213486000000 that is not in progress (it is known to be invalid)
at co.cask.tephra.TransactionManager.commit(TransactionManager.java:842)
at co.cask.tephra.inmemory.InMemoryTxSystemClient.commit(InMemoryTxSystemClient.java:73)
at co.cask.tephra.TransactionContext.commit(TransactionContext.java:265)
... 10 more
java.lang.RuntimeException: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.deleteSystemModules(DatasetTypeManager.java:412)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.startUp(DatasetTypeManager.java:88)
at com.google.common.util.concurrent.AbstractIdleService$1$1.run(AbstractIdleService.java:43)
at java.lang.Thread.run(Thread.java:745)
Caused by: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at co.cask.tephra.TransactionContext.commit(TransactionContext.java:269)
at co.cask.tephra.TransactionContext.finish(TransactionContext.java:98)
at co.cask.tephra.DefaultTransactionExecutor.executeOnce(DefaultTransactionExecutor.java:142)
at co.cask.tephra.DefaultTransactionExecutor.executeWithRetry(DefaultTransactionExecutor.java:115)
at co.cask.tephra.DefaultTransactionExecutor.execute(DefaultTransactionExecutor.java:72)
at co.cask.tephra.DefaultTransactionExecutor.execute(DefaultTransactionExecutor.java:90)
at co.cask.cdap.data2.dataset2.tx.TransactionalDatasetRegistry.execute(TransactionalDatasetRegistry.java:64)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.deleteSystemModules(DatasetTypeManager.java:397)
... 3 more
Caused by: co.cask.tephra.TransactionNotInProgressException: canCommit() is called for transaction 1439227213486000000 that is not in progress (it is known to be invalid)
at co.cask.tephra.TransactionManager.commit(TransactionManager.java:842)
com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.util.concurrent.UncheckedExecutionException: java.lang.RuntimeException: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at com.google.common.util.concurrent.Futures.wrapAndThrowUnchecked(Futures.java:1015)
at com.google.common.util.concurrent.Futures.getUnchecked(Futures.java:1001)
at com.google.common.util.concurrent.AbstractService.startAndWait(AbstractService.java:220)
at com.google.common.util.concurrent.AbstractExecutionThreadService.startAndWait(AbstractExecutionThreadService.java:154)
at co.cask.cdap.test.ConfigurableTestBase.initialize(ConfigurableTestBase.java:263)
at co.cask.cdap.test.ConfigurableTestBase.initTestBase(ConfigurableTestBase.java:183)
at co.cask.cdap.test.TestBase.init(TestBase.java:36)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:78)
at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:212)
at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:68)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)
Caused by: com.google.common.util.concurrent.UncheckedExecutionException: java.lang.RuntimeException: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at com.google.common.util.concurrent.Futures.wrapAndThrowUnchecked(Futures.java:1015)
at com.google.common.util.concurrent.Futures.getUnchecked(Futures.java:1001)
at com.google.common.util.concurrent.AbstractService.startAndWait(AbstractService.java:220)
at com.google.common.util.concurrent.AbstractIdleService.startAndWait(AbstractIdleService.java:106)
at co.cask.cdap.data2.datafabric.dataset.service.DatasetService.startUp(DatasetService.java:123)
at com.google.common.util.concurrent.AbstractExecutionThreadService$1$1.run(AbstractExecutionThreadService.java:47)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.RuntimeException: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.deleteSystemModules(DatasetTypeManager.java:412)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.startUp(DatasetTypeManager.java:88)
at com.google.common.util.concurrent.AbstractIdleService$1$1.run(AbstractIdleService.java:43)
... 1 more
Caused by: co.cask.tephra.TransactionFailureException: Transaction 1439227213486000000 is not in progress.
at co.cask.tephra.TransactionContext.commit(TransactionContext.java:269)
at co.cask.tephra.TransactionContext.finish(TransactionContext.java:98)
at co.cask.tephra.DefaultTransactionExecutor.executeOnce(DefaultTransactionExecutor.java:142)
at co.cask.tephra.DefaultTransactionExecutor.executeWithRetry(DefaultTransactionExecutor.java:115)
at co.cask.tephra.DefaultTransactionExecutor.execute(DefaultTransactionExecutor.java:72)
at co.cask.tephra.DefaultTransactionExecutor.execute(DefaultTransactionExecutor.java:90)
at co.cask.cdap.data2.dataset2.tx.TransactionalDatasetRegistry.execute(TransactionalDatasetRegistry.java:64)
at co.cask.cdap.data2.datafabric.dataset.type.DatasetTypeManager.deleteSystemModules(DatasetTypeManager.java:397)
... 3 more
Caused by: co.cask.tephra.TransactionNotInProgressException: canCommit() is called for transaction 1439227213486000000 that is not in progress (it is known to be invalid)
at co.cask.tephra.TransactionManager.commit(TransactionManager.java:842)
at co.cask.tephra.inmemory.InMemoryTxSystemClient.commit(InMemoryTxSystemClient.java:73)
at co.cask.tephra.TransactionContext.commit(TransactionContext.java:265)
... 10 more
at co.cask.tephra.inmemory.InMemoryTxSystemClient.commit(InMemoryTxSystemClient.java:73)
at co.cask.tephra.TransactionContext.commit(TransactionContext.java:265)
... 10 more
java.lang.NullPointerException
at co.cask.cdap.test.ConfigurableTestBase.finish(ConfigurableTestBase.java:355)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:33)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:78)
at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:212)
at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:68)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)
java.lang.NullPointerException
at co.cask.cdap.test.ConfigurableTestBase.finish(ConfigurableTestBase.java:355)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:33)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:78)
at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:212)
at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:68)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)