Skip to content

Commit 5e6298a

Browse files
remove unintended changes
1 parent 07c396c commit 5e6298a

File tree

1 file changed

+6
-18
lines changed

1 file changed

+6
-18
lines changed

hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AzureIngressHandler.java

Lines changed: 6 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -89,9 +89,7 @@ public void setAbfsOutputStream(final AbfsOutputStream abfsOutputStream) {
8989
* @param data the data to buffer
9090
* @param off the start offset in the data
9191
* @param length the number of bytes to buffer
92-
*
9392
* @return the number of bytes buffered
94-
*
9593
* @throws IOException if an I/O error occurs
9694
*/
9795
protected abstract int bufferData(AbfsBlock block,
@@ -104,9 +102,7 @@ protected abstract int bufferData(AbfsBlock block,
104102
* @param uploadData the data to upload
105103
* @param reqParams the request parameters for the append operation
106104
* @param tracingContext the tracing context
107-
*
108105
* @return the result of the REST operation
109-
*
110106
* @throws IOException if an I/O error occurs
111107
*/
112108
protected abstract AbfsRestOperation remoteWrite(AbfsBlock blockToUpload,
@@ -122,9 +118,7 @@ protected abstract AbfsRestOperation remoteWrite(AbfsBlock blockToUpload,
122118
* @param isClose whether this is a close operation
123119
* @param leaseId the lease ID
124120
* @param tracingContext the tracing context
125-
*
126121
* @return the result of the REST operation
127-
*
128122
* @throws IOException if an I/O error occurs
129123
*/
130124
protected abstract AbfsRestOperation remoteFlush(long offset,
@@ -149,14 +143,12 @@ protected abstract void writeAppendBlobCurrentBufferToService()
149143
* the data to be uploaded, the block of data, and additional parameters required for
150144
* the append operation.</p>
151145
*
152-
* @param path The path of the append blob to which data is to be appended.
153-
* @param uploadData The data to be uploaded as part of the append operation.
154-
* @param block The block of data to append.
155-
* @param reqParams The additional parameters required for the append operation.
146+
* @param path The path of the append blob to which data is to be appended.
147+
* @param uploadData The data to be uploaded as part of the append operation.
148+
* @param block The block of data to append.
149+
* @param reqParams The additional parameters required for the append operation.
156150
* @param tracingContext The tracing context for the operation.
157-
*
158151
* @return An {@link AbfsRestOperation} object representing the remote write operation.
159-
*
160152
* @throws IOException If an I/O error occurs during the append operation.
161153
*/
162154
protected abstract AbfsRestOperation remoteAppendBlobWrite(String path,
@@ -169,7 +161,6 @@ protected abstract AbfsRestOperation remoteAppendBlobWrite(String path,
169161
* Determines if the ingress handler should be switched based on the given exception.
170162
*
171163
* @param ex the exception that occurred
172-
*
173164
* @return true if the ingress handler should be switched, false otherwise
174165
*/
175166
protected boolean shouldIngressHandlerBeSwitched(AbfsRestOperationException ex) {
@@ -179,10 +170,8 @@ protected boolean shouldIngressHandlerBeSwitched(AbfsRestOperationException ex)
179170
String errorCode = ex.getErrorCode().getErrorCode();
180171
if (errorCode != null) {
181172
return ex.getStatusCode() == HTTP_CONFLICT
182-
&& (Objects.equals(errorCode,
183-
AzureServiceErrorCode.BLOB_OPERATION_NOT_SUPPORTED.getErrorCode())
184-
|| Objects.equals(errorCode,
185-
AzureServiceErrorCode.INVALID_APPEND_OPERATION.getErrorCode()));
173+
&& (Objects.equals(errorCode, AzureServiceErrorCode.BLOB_OPERATION_NOT_SUPPORTED.getErrorCode())
174+
|| Objects.equals(errorCode, AzureServiceErrorCode.INVALID_APPEND_OPERATION.getErrorCode()));
186175
}
187176
return false;
188177
}
@@ -191,7 +180,6 @@ protected boolean shouldIngressHandlerBeSwitched(AbfsRestOperationException ex)
191180
* Constructs an InvalidIngressServiceException that includes the current handler class name in the exception message.
192181
*
193182
* @param e the original AbfsRestOperationException that triggered this exception.
194-
*
195183
* @return an InvalidIngressServiceException with the status code, error code, original message, and handler class name.
196184
*/
197185
protected InvalidIngressServiceException getIngressHandlerSwitchException(

0 commit comments

Comments
 (0)