carp84 commented on code in PR #22788:
URL: https://github.com/apache/flink/pull/22788#discussion_r1231969461
##########
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateDownloaderTest.java:
##########
@@ -165,4 +192,48 @@ public long getStateSize() {
return 0;
}
}
+
+ private byte[][][] createContents(int numRemoteHandles, int numSubHandles)
{
+ Random random = new Random();
+ byte[][][] contents = new byte[numRemoteHandles][numSubHandles][];
+ for (int i = 0; i < numRemoteHandles; ++i)
+ for (int j = 0; j < numSubHandles; ++j) {
+ contents[i][j] = new byte[random.nextInt(100000) + 1];
+ random.nextBytes(contents[i][j]);
+ }
Review Comment:
```suggestion
for (int i = 0; i < numRemoteHandles; ++i) {
for (int j = 0; j < numSubHandles; ++j) {
contents[i][j] = new byte[random.nextInt(100000) + 1];
random.nextBytes(contents[i][j]);
}
}
```
Necessary change to pass checkstyle.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
