Skip to content
This repository was archived by the owner on Dec 26, 2024. It is now read-only.

Commit 69bca78

Browse files
bednarbednar
committed
fix: formatting
1 parent 0e21eaf commit 69bca78

3 files changed

Lines changed: 27 additions & 30 deletions

File tree

‎nifi-influx-database-processors/src/main/java/org/influxdata/nifi/processors/PutInfluxDatabaseRecord_2.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -181,10 +181,10 @@ public void onTrigger(final ProcessContext context, final ProcessSession session
181181
if (Arrays.asList(429, 503).contains(ie.status()) || ie.getCause() instanceof SocketTimeoutException) {
182182
getLogger().error("Failed to insert into influxDB due {} to {} and retrying",
183183
new Object[]{ie.status(), ie.getLocalizedMessage()}, ie);
184-
String retryAfterHeader = getRetryAfterHeader(ie);
185-
if (StringUtils.isNoneBlank(retryAfterHeader)) {
186-
flowFile = session.putAttribute(flowFile, INFLUX_DB_RETRY_AFTER, retryAfterHeader);
187-
}
184+
String retryAfterHeader = getRetryAfterHeader(ie);
185+
if (StringUtils.isNoneBlank(retryAfterHeader)) {
186+
flowFile = session.putAttribute(flowFile, INFLUX_DB_RETRY_AFTER, retryAfterHeader);
187+
}
188188
session.penalize(flowFile);
189189
session.transfer(flowFile, REL_RETRY);
190190
} else {

‎nifi-influx-database-processors/src/main/java/org/influxdata/nifi/processors/PutInfluxDatabase_2.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -170,11 +170,11 @@ public void onTrigger(final ProcessContext context, final ProcessSession session
170170
if (Arrays.asList(429, 503).contains(ie.status()) || ie.getCause() instanceof SocketTimeoutException) {
171171
getLogger().error("Failed to insert into influxDB due {} to {} and retrying",
172172
new Object[]{ie.status(), ie.getLocalizedMessage()}, ie);
173-
String retryAfterHeader = getRetryAfterHeader(ie);
174-
if (StringUtils.isNoneBlank(retryAfterHeader)) {
175-
flowFile = session.putAttribute(flowFile, INFLUX_DB_RETRY_AFTER, retryAfterHeader);
176-
}
177-
session.transfer(flowFile, REL_RETRY);
173+
String retryAfterHeader = getRetryAfterHeader(ie);
174+
if (StringUtils.isNoneBlank(retryAfterHeader)) {
175+
flowFile = session.putAttribute(flowFile, INFLUX_DB_RETRY_AFTER, retryAfterHeader);
176+
}
177+
session.transfer(flowFile, REL_RETRY);
178178
} else {
179179
getLogger().error(INFLUX_DB_FAIL_TO_INSERT, new Object[]{ie.getLocalizedMessage()}, ie);
180180
session.transfer(flowFile, REL_FAILURE);

‎nifi-influx-database-processors/src/main/java/org/influxdata/nifi/processors/internal/AbstractInfluxDatabaseProcessor_2.java‎

Lines changed: 18 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -200,29 +200,26 @@ public synchronized InfluxDBClient getInfluxDBClient(final ProcessContext contex
200200
return influxDBClient.get();
201201
}
202202

203-
@Nullable
204-
protected String getRetryAfterHeader(InfluxException ie) {
205-
try
206-
{
203+
@Nullable
204+
protected String getRetryAfterHeader(InfluxException ie) {
205+
try {
207206
//
208-
// Temporally solution before release https://github.com/influxdata/influxdb-client-java/pull/317
207+
// Temporally solution before release https://github.com/influxdata/influxdb-client-java/pull/317
209208
//
210-
Field responseField = InfluxException.class.getDeclaredField("response");
211-
responseField.setAccessible(true);
212-
Response response = (Response) responseField.get(ie);
213-
if (response != null) {
214-
return response.headers().get("Retry-After");
215-
}
216-
}
217-
catch (Exception e)
218-
{
219-
return null;
220-
}
221-
222-
return null;
223-
}
224-
225-
/**
209+
Field responseField = InfluxException.class.getDeclaredField("response");
210+
responseField.setAccessible(true);
211+
Response response = (Response) responseField.get(ie);
212+
if (response != null) {
213+
return response.headers().get("Retry-After");
214+
}
215+
} catch (Exception e) {
216+
return null;
217+
}
218+
219+
return null;
220+
}
221+
222+
/**
226223
* Configure LogLevel and GZIP.
227224
*/
228225
private void configure(@NonNull final InfluxDBClient influxDBClient, @NonNull final ProcessContext context) {

0 commit comments

Comments
 (0)