@@ -790,7 +790,7 @@ private <T> T executeMutation(String tableName, MutationExecuteCallback<T> callb
790790 if (null != callback .getRowKey ()) {
791791 // using row key
792792 obPair = getTable (tableName , callback .getRowKey (), needRefreshTableEntry ,
793- tableEntryRefreshIntervalWait , route );
793+ tableEntryRefreshIntervalWait , needFetchAllRouteInfo , route );
794794 } else if (null != callback .getKeyRanges ()) {
795795 // using scan range
796796 obPair = getTableByRowKeyRange (tableName , new ObTableQuery (), callback .getKeyRanges ());
@@ -1698,8 +1698,8 @@ public ObPair<Long, ObTableParam> getTableByRowKeyRange(String tableName, ObTabl
16981698 * @throws Exception exception
16991699 */
17001700 public ObPair <Long , ObTableParam > getTable (String tableName , Row rowKey , boolean refresh ,
1701- boolean waitForRefresh ) throws Exception {
1702- return getTable (tableName , rowKey , refresh , waitForRefresh , getRoute (false ));
1701+ boolean waitForRefresh , boolean needFetchAll ) throws Exception {
1702+ return getTable (tableName , rowKey , refresh , waitForRefresh , needFetchAll , getRoute (false ));
17031703 }
17041704
17051705 /**
@@ -1713,9 +1713,9 @@ public ObPair<Long, ObTableParam> getTable(String tableName, Row rowKey, boolean
17131713 * @throws Exception exception
17141714 */
17151715 public ObPair <Long , ObTableParam > getTable (String tableName , Row rowKey , boolean refresh ,
1716- boolean waitForRefresh , ObServerRoute route )
1716+ boolean waitForRefresh , boolean needFetchAll , ObServerRoute route )
17171717 throws Exception {
1718- TableEntry tableEntry = getOrRefreshTableEntry (tableName , refresh , waitForRefresh , false );
1718+ TableEntry tableEntry = getOrRefreshTableEntry (tableName , refresh , waitForRefresh , needFetchAll );
17191719 long partId = getPartition (tableEntry , rowKey ); // partition id in 3.x, origin partId in 4.x, logicId
17201720
17211721 return getTableInternal (tableName , tableEntry , partId , waitForRefresh , route );
@@ -2950,7 +2950,7 @@ private Partition getSinglePartitionInternal(String tableName, Row rowKey) throw
29502950 if (odpMode ) {
29512951 obPair = getODPTableWithRowKey (tableName , rowKey , false );
29522952 } else {
2953- obPair = getTable (tableName , rowKey , false , false );
2953+ obPair = getTable (tableName , rowKey , false , false , false );
29542954 }
29552955 ObTableParam tableParam = obPair .getRight ();
29562956 return new Partition (tableParam .getPartitionId (), obPair .getLeft (),
0 commit comments