Skip to content

Commit 91d69cb

Browse files
CRZbulabulaCRZbulabula
committed
spotless
1 parent d3f549c commit 91d69cb

File tree

2 files changed

+119
-3
lines changed

2 files changed

+119
-3
lines changed

‎iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java‎

Lines changed: 117 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,123 @@
136136
import org.apache.iotdb.confignode.persistence.schema.ClusterSchemaInfo;
137137
import org.apache.iotdb.confignode.persistence.subscription.SubscriptionInfo;
138138
import org.apache.iotdb.confignode.procedure.impl.schema.SchemaUtils;
139-
import org.apache.iotdb.confignode.rpc.thrift.*;
139+
import org.apache.iotdb.confignode.rpc.thrift.TAINodeInfo;
140+
import org.apache.iotdb.confignode.rpc.thrift.TAINodeRegisterReq;
141+
import org.apache.iotdb.confignode.rpc.thrift.TAINodeRestartReq;
142+
import org.apache.iotdb.confignode.rpc.thrift.TAINodeRestartResp;
143+
import org.apache.iotdb.confignode.rpc.thrift.TAlterLogicalViewReq;
144+
import org.apache.iotdb.confignode.rpc.thrift.TAlterOrDropTableReq;
145+
import org.apache.iotdb.confignode.rpc.thrift.TAlterPipeReq;
146+
import org.apache.iotdb.confignode.rpc.thrift.TAlterSchemaTemplateReq;
147+
import org.apache.iotdb.confignode.rpc.thrift.TAuthizedPatternTreeResp;
148+
import org.apache.iotdb.confignode.rpc.thrift.TCloseConsumerReq;
149+
import org.apache.iotdb.confignode.rpc.thrift.TClusterParameters;
150+
import org.apache.iotdb.confignode.rpc.thrift.TConfigNodeRegisterReq;
151+
import org.apache.iotdb.confignode.rpc.thrift.TConfigNodeRegisterResp;
152+
import org.apache.iotdb.confignode.rpc.thrift.TCountTimeSlotListReq;
153+
import org.apache.iotdb.confignode.rpc.thrift.TCountTimeSlotListResp;
154+
import org.apache.iotdb.confignode.rpc.thrift.TCreateCQReq;
155+
import org.apache.iotdb.confignode.rpc.thrift.TCreateConsumerReq;
156+
import org.apache.iotdb.confignode.rpc.thrift.TCreateFunctionReq;
157+
import org.apache.iotdb.confignode.rpc.thrift.TCreateModelReq;
158+
import org.apache.iotdb.confignode.rpc.thrift.TCreatePipePluginReq;
159+
import org.apache.iotdb.confignode.rpc.thrift.TCreatePipeReq;
160+
import org.apache.iotdb.confignode.rpc.thrift.TCreateSchemaTemplateReq;
161+
import org.apache.iotdb.confignode.rpc.thrift.TCreateTableViewReq;
162+
import org.apache.iotdb.confignode.rpc.thrift.TCreateTopicReq;
163+
import org.apache.iotdb.confignode.rpc.thrift.TCreateTrainingReq;
164+
import org.apache.iotdb.confignode.rpc.thrift.TCreateTriggerReq;
165+
import org.apache.iotdb.confignode.rpc.thrift.TDataNodeRegisterReq;
166+
import org.apache.iotdb.confignode.rpc.thrift.TDataNodeRestartReq;
167+
import org.apache.iotdb.confignode.rpc.thrift.TDataNodeRestartResp;
168+
import org.apache.iotdb.confignode.rpc.thrift.TDataPartitionTableResp;
169+
import org.apache.iotdb.confignode.rpc.thrift.TDataSchemaForTable;
170+
import org.apache.iotdb.confignode.rpc.thrift.TDatabaseSchema;
171+
import org.apache.iotdb.confignode.rpc.thrift.TDeactivateSchemaTemplateReq;
172+
import org.apache.iotdb.confignode.rpc.thrift.TDeleteDatabasesReq;
173+
import org.apache.iotdb.confignode.rpc.thrift.TDeleteLogicalViewReq;
174+
import org.apache.iotdb.confignode.rpc.thrift.TDeleteTableDeviceReq;
175+
import org.apache.iotdb.confignode.rpc.thrift.TDeleteTableDeviceResp;
176+
import org.apache.iotdb.confignode.rpc.thrift.TDeleteTimeSeriesReq;
177+
import org.apache.iotdb.confignode.rpc.thrift.TDescTable4InformationSchemaResp;
178+
import org.apache.iotdb.confignode.rpc.thrift.TDescTableResp;
179+
import org.apache.iotdb.confignode.rpc.thrift.TDropCQReq;
180+
import org.apache.iotdb.confignode.rpc.thrift.TDropFunctionReq;
181+
import org.apache.iotdb.confignode.rpc.thrift.TDropModelReq;
182+
import org.apache.iotdb.confignode.rpc.thrift.TDropPipePluginReq;
183+
import org.apache.iotdb.confignode.rpc.thrift.TDropPipeReq;
184+
import org.apache.iotdb.confignode.rpc.thrift.TDropSubscriptionReq;
185+
import org.apache.iotdb.confignode.rpc.thrift.TDropTopicReq;
186+
import org.apache.iotdb.confignode.rpc.thrift.TDropTriggerReq;
187+
import org.apache.iotdb.confignode.rpc.thrift.TExtendRegionReq;
188+
import org.apache.iotdb.confignode.rpc.thrift.TFetchTableResp;
189+
import org.apache.iotdb.confignode.rpc.thrift.TGetAllPipeInfoResp;
190+
import org.apache.iotdb.confignode.rpc.thrift.TGetAllSubscriptionInfoResp;
191+
import org.apache.iotdb.confignode.rpc.thrift.TGetAllTemplatesResp;
192+
import org.apache.iotdb.confignode.rpc.thrift.TGetAllTopicInfoResp;
193+
import org.apache.iotdb.confignode.rpc.thrift.TGetDataNodeLocationsResp;
194+
import org.apache.iotdb.confignode.rpc.thrift.TGetDatabaseReq;
195+
import org.apache.iotdb.confignode.rpc.thrift.TGetJarInListReq;
196+
import org.apache.iotdb.confignode.rpc.thrift.TGetJarInListResp;
197+
import org.apache.iotdb.confignode.rpc.thrift.TGetLocationForTriggerResp;
198+
import org.apache.iotdb.confignode.rpc.thrift.TGetModelInfoReq;
199+
import org.apache.iotdb.confignode.rpc.thrift.TGetModelInfoResp;
200+
import org.apache.iotdb.confignode.rpc.thrift.TGetPathsSetTemplatesReq;
201+
import org.apache.iotdb.confignode.rpc.thrift.TGetPathsSetTemplatesResp;
202+
import org.apache.iotdb.confignode.rpc.thrift.TGetPipePluginTableResp;
203+
import org.apache.iotdb.confignode.rpc.thrift.TGetRegionIdReq;
204+
import org.apache.iotdb.confignode.rpc.thrift.TGetRegionIdResp;
205+
import org.apache.iotdb.confignode.rpc.thrift.TGetSeriesSlotListReq;
206+
import org.apache.iotdb.confignode.rpc.thrift.TGetSeriesSlotListResp;
207+
import org.apache.iotdb.confignode.rpc.thrift.TGetTemplateResp;
208+
import org.apache.iotdb.confignode.rpc.thrift.TGetTimeSlotListReq;
209+
import org.apache.iotdb.confignode.rpc.thrift.TGetTimeSlotListResp;
210+
import org.apache.iotdb.confignode.rpc.thrift.TGetTriggerTableResp;
211+
import org.apache.iotdb.confignode.rpc.thrift.TGetUDFTableResp;
212+
import org.apache.iotdb.confignode.rpc.thrift.TGetUdfTableReq;
213+
import org.apache.iotdb.confignode.rpc.thrift.TMigrateRegionReq;
214+
import org.apache.iotdb.confignode.rpc.thrift.TNodeVersionInfo;
215+
import org.apache.iotdb.confignode.rpc.thrift.TPermissionInfoResp;
216+
import org.apache.iotdb.confignode.rpc.thrift.TPipeConfigTransferReq;
217+
import org.apache.iotdb.confignode.rpc.thrift.TPipeConfigTransferResp;
218+
import org.apache.iotdb.confignode.rpc.thrift.TReconstructRegionReq;
219+
import org.apache.iotdb.confignode.rpc.thrift.TRegionRouteMapResp;
220+
import org.apache.iotdb.confignode.rpc.thrift.TRemoveRegionReq;
221+
import org.apache.iotdb.confignode.rpc.thrift.TSchemaNodeManagementResp;
222+
import org.apache.iotdb.confignode.rpc.thrift.TSchemaPartitionTableResp;
223+
import org.apache.iotdb.confignode.rpc.thrift.TSetDataNodeStatusReq;
224+
import org.apache.iotdb.confignode.rpc.thrift.TSetSchemaTemplateReq;
225+
import org.apache.iotdb.confignode.rpc.thrift.TShowAINodesResp;
226+
import org.apache.iotdb.confignode.rpc.thrift.TShowCQResp;
227+
import org.apache.iotdb.confignode.rpc.thrift.TShowClusterResp;
228+
import org.apache.iotdb.confignode.rpc.thrift.TShowConfigNodes4InformationSchemaResp;
229+
import org.apache.iotdb.confignode.rpc.thrift.TShowConfigNodesResp;
230+
import org.apache.iotdb.confignode.rpc.thrift.TShowDataNodes4InformationSchemaResp;
231+
import org.apache.iotdb.confignode.rpc.thrift.TShowDataNodesResp;
232+
import org.apache.iotdb.confignode.rpc.thrift.TShowDatabaseResp;
233+
import org.apache.iotdb.confignode.rpc.thrift.TShowModelReq;
234+
import org.apache.iotdb.confignode.rpc.thrift.TShowModelResp;
235+
import org.apache.iotdb.confignode.rpc.thrift.TShowPipePluginReq;
236+
import org.apache.iotdb.confignode.rpc.thrift.TShowPipeReq;
237+
import org.apache.iotdb.confignode.rpc.thrift.TShowPipeResp;
238+
import org.apache.iotdb.confignode.rpc.thrift.TShowSubscriptionReq;
239+
import org.apache.iotdb.confignode.rpc.thrift.TShowSubscriptionResp;
240+
import org.apache.iotdb.confignode.rpc.thrift.TShowTable4InformationSchemaResp;
241+
import org.apache.iotdb.confignode.rpc.thrift.TShowTableResp;
242+
import org.apache.iotdb.confignode.rpc.thrift.TShowThrottleReq;
243+
import org.apache.iotdb.confignode.rpc.thrift.TShowTopicReq;
244+
import org.apache.iotdb.confignode.rpc.thrift.TShowTopicResp;
245+
import org.apache.iotdb.confignode.rpc.thrift.TShowVariablesResp;
246+
import org.apache.iotdb.confignode.rpc.thrift.TSpaceQuotaResp;
247+
import org.apache.iotdb.confignode.rpc.thrift.TStartPipeReq;
248+
import org.apache.iotdb.confignode.rpc.thrift.TStopPipeReq;
249+
import org.apache.iotdb.confignode.rpc.thrift.TSubscribeReq;
250+
import org.apache.iotdb.confignode.rpc.thrift.TTableInfo;
251+
import org.apache.iotdb.confignode.rpc.thrift.TThrottleQuotaResp;
252+
import org.apache.iotdb.confignode.rpc.thrift.TTimeSlotList;
253+
import org.apache.iotdb.confignode.rpc.thrift.TUnsetSchemaTemplateReq;
254+
import org.apache.iotdb.confignode.rpc.thrift.TUnsubscribeReq;
255+
import org.apache.iotdb.confignode.rpc.thrift.TUpdateModelInfoReq;
140256
import org.apache.iotdb.consensus.common.DataSet;
141257
import org.apache.iotdb.consensus.exception.ConsensusException;
142258
import org.apache.iotdb.db.schemaengine.template.Template;

‎iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClient.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ public TForecastResp forecast(
199199
TSStatus tsStatus = new TSStatus(CAN_NOT_CONNECT_AINODE.getStatusCode());
200200
tsStatus.setMessage(
201201
String.format(
202-
"Failed to connect to AINode from DataNode when executing %s: %s",
202+
"Failed to connect to AINode when executing %s: %s",
203203
Thread.currentThread().getStackTrace()[1].getMethodName(), e.getMessage()));
204204
return new TForecastResp(tsStatus, ByteBuffer.allocate(0));
205205
}
@@ -210,7 +210,7 @@ public TSStatus createTrainingTask(TTrainingReq req) throws TException {
210210
return client.createTrainingTask(req);
211211
} catch (TException e) {
212212
logger.warn(
213-
"Failed to connect to AINode from DataNode when executing {}: {}",
213+
"Failed to connect to AINode when executing {}: {}",
214214
Thread.currentThread().getStackTrace()[1].getMethodName(),
215215
e.getMessage());
216216
throw new TException(MSG_CONNECTION_FAIL);

0 commit comments

Comments
 (0)