File tree Expand file tree Collapse file tree
src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot Expand file tree Collapse file tree Original file line number Diff line number Diff line change 5151 <version >${jetbrains.annotations.version} </version >
5252 </dependency >
5353
54+ <dependency >
55+ <groupId >org.apache.commons</groupId >
56+ <artifactId >commons-lang3</artifactId >
57+ <version >${commons.lang3.version} </version >
58+ </dependency >
59+
5460 <dependency >
5561 <groupId >${project.groupId} </groupId >
5662 <artifactId >ignite-tools</artifactId >
211217 <scope >test</scope >
212218 </dependency >
213219
214- <dependency >
215- <groupId >org.apache.commons</groupId >
216- <artifactId >commons-lang3</artifactId >
217- <version >${commons.lang3.version} </version >
218- <scope >test</scope >
219- </dependency >
220-
221220 <dependency >
222221 <groupId >org.hamcrest</groupId >
223222 <artifactId >hamcrest</artifactId >
Original file line number Diff line number Diff line change 3232import java .util .function .Function ;
3333import java .util .function .Supplier ;
3434import java .util .stream .Collectors ;
35+ import org .apache .commons .lang3 .builder .MultilineRecursiveToStringStyle ;
36+ import org .apache .commons .lang3 .builder .ToStringBuilder ;
3537import org .apache .ignite .IgniteCheckedException ;
3638import org .apache .ignite .IgniteException ;
3739import org .apache .ignite .IgniteLogger ;
@@ -270,11 +272,25 @@ else if (txRec.state() == TransactionState.ROLLED_BACK) {
270272 ", walSegments=" + procSegCnt .get () + ']' );
271273 }
272274
273- return new IncrementalSnapshotVerifyResult (
275+ IncrementalSnapshotVerifyResult r = new IncrementalSnapshotVerifyResult (
274276 txHashRes ,
275277 partHashRes ,
276278 partiallyCommittedTxs ,
277279 exceptions );
280+
281+ log .warning ("--> s1=" + ToStringBuilder .reflectionToString (r , new MultilineRecursiveToStringStyle ()));
282+
283+ try {
284+ r .txHashResBytes (r .txHashResBytes ());
285+ r .partHashResBytes (r .partHashResBytes ());
286+
287+ return r ;
288+ }
289+ catch (Throwable e ) {
290+ log .warning ("--> s=" + ToStringBuilder .reflectionToString (r ));
291+ log .error ("--> Failed to verify incremental snapshot procedure" , e );
292+ throw new IgniteException (e );
293+ }
278294 }
279295 catch (IgniteCheckedException | IOException e ) {
280296 throw new IgniteException (e );
You can’t perform that action at this time.
0 commit comments