This is an automated email from the ASF dual-hosted git repository. mmiller pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/master by this push: new bdb59cd Formatting bdb59cd is described below commit bdb59cdb2c9cac44a7ca19a5848217dfc88d4bbc Author: Mike Miller <mmil...@apache.org> AuthorDate: Wed Dec 19 14:57:34 2018 -0500 Formatting --- .../main/java/org/apache/accumulo/tserver/log/DfsLogger.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java index d7cd7eb..776639e 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java @@ -48,7 +48,6 @@ import org.apache.accumulo.core.crypto.CryptoUtils; import org.apache.accumulo.core.crypto.streams.NoFlushOutputStream; import org.apache.accumulo.core.cryptoImpl.CryptoEnvironmentImpl; import org.apache.accumulo.core.cryptoImpl.NoCryptoService; -import org.apache.accumulo.core.cryptoImpl.NoFileEncrypter; import org.apache.accumulo.core.data.Mutation; import org.apache.accumulo.core.dataImpl.KeyExtent; import org.apache.accumulo.core.spi.crypto.CryptoEnvironment; @@ -436,13 +435,14 @@ public class DfsLogger implements Comparable<DfsLogger> { byte[] cryptoParams = encrypter.getDecryptionParameters(); CryptoUtils.writeParams(cryptoParams, logFile); - /** Always wrap the WAL in a NoFlushOutputStream to prevent extra flushing to HDFS. - * The {@link #write(LogFileKey, LogFileValue)} method will flush crypto data or do nothing - * when crypto is not enabled. + /** + * Always wrap the WAL in a NoFlushOutputStream to prevent extra flushing to HDFS. The + * {@link #write(LogFileKey, LogFileValue)} method will flush crypto data or do nothing when + * crypto is not enabled. **/ OutputStream encryptedStream = encrypter.encryptStream(new NoFlushOutputStream(logFile)); if (encryptedStream instanceof NoFlushOutputStream) { - encryptingLogFile = (NoFlushOutputStream)encryptedStream; + encryptingLogFile = (NoFlushOutputStream) encryptedStream; } else { encryptingLogFile = new DataOutputStream(encryptedStream); }