diff --git a/build.gradle b/build.gradle
index eef040ac8a..99a235ec76 100644
--- a/build.gradle
+++ b/build.gradle
@@ -1,8 +1,8 @@
 buildscript {
     ext {
         // App version
-        versionName = '7.11.0'
-        versionCode = 129
+        versionName = '7.11.1'
+        versionCode = 130
 
         applicationId = "io.novafoundation.nova"
         releaseApplicationSuffix = "market"
@@ -51,7 +51,7 @@ buildscript {
 
         web3jVersion = '4.9.5'
 
-        substrateSdkVersion = '2.0.0'
+        substrateSdkVersion = '2.0.2'
 
         gifVersion = '1.2.19'
 
diff --git a/feature-staking-impl/src/main/java/io/novafoundation/nova/feature_staking_impl/data/nominationPools/network/blockhain/updater/PooledBalanceUpdater.kt b/feature-staking-impl/src/main/java/io/novafoundation/nova/feature_staking_impl/data/nominationPools/network/blockhain/updater/PooledBalanceUpdater.kt
index 333d04ef55..1fe9dda6dd 100644
--- a/feature-staking-impl/src/main/java/io/novafoundation/nova/feature_staking_impl/data/nominationPools/network/blockhain/updater/PooledBalanceUpdater.kt
+++ b/feature-staking-impl/src/main/java/io/novafoundation/nova/feature_staking_impl/data/nominationPools/network/blockhain/updater/PooledBalanceUpdater.kt
@@ -33,17 +33,13 @@ import io.novafoundation.nova.runtime.multiNetwork.chain.model.Chain.Asset.Staki
 import io.novafoundation.nova.runtime.storage.source.StorageDataSource
 import io.novafoundation.nova.runtime.storage.source.query.api.observeNonNull
 import io.novafoundation.nova.runtime.storage.source.query.metadata
-import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.SharingStarted
 import kotlinx.coroutines.flow.combine
 import kotlinx.coroutines.flow.distinctUntilChanged
 import kotlinx.coroutines.flow.emptyFlow
 import kotlinx.coroutines.flow.flatMapLatest
 import kotlinx.coroutines.flow.flowOf
 import kotlinx.coroutines.flow.map
-import kotlinx.coroutines.flow.shareIn
-import kotlin.coroutines.coroutineContext
 
 class RealPooledBalanceUpdaterFactory(
     private val remoteStorageSource: StorageDataSource,
@@ -92,7 +88,6 @@ class PooledBalanceUpdater(
         return remoteStorageSource.subscribe(chain.id, storageSubscriptionBuilder) {
             val poolMemberFlow = metadata.nominationPools.poolMembers
                 .observe(accountId)
-                .shareIn(CoroutineScope(coroutineContext), SharingStarted.Lazily, replay = 1)
 
             val poolWithBalance = poolMemberFlow
                 .map { it?.poolId }