diff --git a/eth/backend.go b/eth/backend.go
index 2668d6c37e..dde6889a0f 100644
--- a/eth/backend.go
+++ b/eth/backend.go
@@ -219,7 +219,6 @@ func New(ctx *node.ServiceContext, config *Config) (*Ethereum, error) {
 				startBlockNumber := number - (rCheckpoint * 2) + 1
 				endBlockNumber := startBlockNumber + rCheckpoint - 1
 				signers := make(map[common.Address]*rewardLog)
-				validators := make(map[common.Address]*rewardLog)
 				totalSigner := uint64(0)
 
 				for i := startBlockNumber; i <= endBlockNumber; i++ {
@@ -239,14 +238,18 @@ func New(ctx *node.ServiceContext, config *Config) (*Ethereum, error) {
 					}
 
 					// Get validator in blockSigner smartcontract.
-					addrs, _ := blockSigner.GetSigners(opts, new(big.Int).SetUint64(i))
+					addrs, err := blockSigner.GetSigners(opts, new(big.Int).SetUint64(i))
+					if err != nil {
+						log.Error("TOMO - Fail to get signers from smartcontract.", "error", err)
+						return err
+					}
 					if len(addrs) > 0 {
 						for j := 0; j < len(addrs); j++ {
-							_, exist := validators[addrs[j]]
+							_, exist := signers[addrs[j]]
 							if exist {
-								validators[addrs[j]].Sign++
+								signers[addrs[j]].Sign++
 							} else {
-								validators[addrs[j]] = &rewardLog{1, 0}
+								signers[addrs[j]] = &rewardLog{1, 0}
 							}
 							totalSigner++
 						}
@@ -256,6 +259,7 @@ func New(ctx *node.ServiceContext, config *Config) (*Ethereum, error) {
 				chainReward := new(big.Int).SetUint64(chain.Config().Clique.Reward * params.Ether)
 				// Add reward for signer.
 				calcReward := new(big.Int)
+				// Add reward for validators.
 				for signer, rLog := range signers {
 					calcReward.Mul(chainReward, new(big.Int).SetUint64(rLog.Sign))
 					calcReward.Div(calcReward, new(big.Int).SetUint64(totalSigner))
@@ -263,26 +267,13 @@ func New(ctx *node.ServiceContext, config *Config) (*Ethereum, error) {
 
 					state.AddBalance(signer, calcReward)
 				}
-				// Add reward for validators.
-				for validator, rLog := range validators {
-					calcReward.Mul(chainReward, new(big.Int).SetUint64(rLog.Sign))
-					calcReward.Div(calcReward, new(big.Int).SetUint64(totalSigner))
-					rLog.Reward = float64(calcReward.Int64())
-
-					state.AddBalance(validator, calcReward)
-				}
 				jsonSigners, err := json.Marshal(signers)
 				if err != nil {
 					log.Error("TOMO - Fail to parse json signers", "error", err)
 					return err
 				}
-				jsonValidators, err := json.Marshal(validators)
-				if err != nil {
-					log.Error("TOMO - Fail to parse json validators", "error", err)
-					return err
-				}
 
-				log.Info("TOMO - Calculate reward at checkpoint", "startBlock", startBlockNumber, "endBlock", endBlockNumber, "signers", string(jsonSigners), "totalSigner", totalSigner, "totalReward", chainReward, "validators", string(jsonValidators))
+				log.Info("TOMO - Calculate reward at checkpoint", "startBlock", startBlockNumber, "endBlock", endBlockNumber, "signers", string(jsonSigners), "totalSigner", totalSigner, "totalReward", chainReward)
 			}
 
 			return nil
diff --git a/eth/fetcher/fetcher.go b/eth/fetcher/fetcher.go
index 13a486b149..11b9a360b8 100644
--- a/eth/fetcher/fetcher.go
+++ b/eth/fetcher/fetcher.go
@@ -25,7 +25,6 @@ import (
 	"github.com/ethereum/go-ethereum/accounts"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/consensus"
-	"github.com/ethereum/go-ethereum/consensus/clique"
 	"github.com/ethereum/go-ethereum/core"
 	"github.com/ethereum/go-ethereum/core/types"
 	"github.com/ethereum/go-ethereum/log"
@@ -743,8 +742,6 @@ func (f *Fetcher) forgetBlock(hash common.Hash) {
 // Create tx for sign to smartcontract after import block into chain.
 func (f *Fetcher) CreateTransactionSign(chainConfig *params.ChainConfig, pool *core.TxPool, manager *accounts.Manager, engine consensus.Engine) {
 	if chainConfig.Clique != nil {
-		c := engine.(*clique.Clique)
-
 		f.importedHook = func(block *types.Block) {
 			// Find active account.
 			account := accounts.Account{}
@@ -756,30 +753,20 @@ func (f *Fetcher) CreateTransactionSign(chainConfig *params.ChainConfig, pool *c
 				}
 			}
 
-			// Get block signer.
-			signer, err := c.RecoverSigner(block.Header())
+			// Create and send tx to smart contract for sign validate block.
+			blockHex := common.LeftPadBytes(block.Number().Bytes(), 32)
+			data := common.Hex2Bytes("2fb1b25f")
+			inputData := append(data, blockHex...)
+			nonce := pool.State().GetNonce(account.Address)
+			tx := types.NewTransaction(nonce, common.HexToAddress(common.BlockSigners), big.NewInt(0), 100000, big.NewInt(0), inputData)
+			txSigned, err := wallet.SignTx(account, tx, chainConfig.ChainId)
 			if err != nil {
-				log.Error("TOMO - Fail to get signer", "error", err)
+				log.Error("TOMO - Fail to create tx sign", "error", err)
 				return
 			}
 
-			// Not send tx sign when this node is current block miner.
-			if signer != account.Address {
-				// Create and send tx to smartcontract for sign validate block.
-				blockHex := common.LeftPadBytes(block.Number().Bytes(), 32)
-				data := common.Hex2Bytes("2fb1b25f")
-				inputData := append(data, blockHex...)
-				nonce := pool.State().GetNonce(account.Address)
-				tx := types.NewTransaction(nonce, common.HexToAddress(common.BlockSigners), big.NewInt(0), 100000, big.NewInt(0), inputData)
-				txSigned, err := wallet.SignTx(account, tx, chainConfig.ChainId)
-				if err != nil {
-					log.Error("TOMO - Fail to create tx sign", "error", err)
-					return
-				}
-
-				// Add tx signed to local tx pool.
-				pool.AddLocal(txSigned)
-			}
+			// Add tx signed to local tx pool.
+			pool.AddLocal(txSigned)
 		}
 	}
 }