Skip to content

Commit

Permalink
remove AINodeService in datanode which is not used anymore.
Browse files Browse the repository at this point in the history
  • Loading branch information
ycycse committed Sep 23, 2024
1 parent 98f8701 commit a4f2437
Show file tree
Hide file tree
Showing 9 changed files with 1 addition and 442 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -439,9 +439,6 @@ public class IoTDBConfig {
/** Compact the unsequence files into the overlapped sequence files */
private volatile boolean enableCrossSpaceCompaction = true;

/** Enable the service for AINode */
private boolean enableAINodeService = false;

/** The buffer for sort operation */
private long sortBufferSize = 1024 * 1024L;

Expand Down Expand Up @@ -920,9 +917,6 @@ public class IoTDBConfig {
/** Internal port for coordinator */
private int internalPort = 10730;

/** Port for AINode */
private int aiNodePort = 10780;

/** Internal port for dataRegion consensus protocol */
private int dataRegionConsensusPort = 10760;

Expand Down Expand Up @@ -2871,14 +2865,6 @@ public void setEnableCrossSpaceCompaction(boolean enableCrossSpaceCompaction) {
this.enableCrossSpaceCompaction = enableCrossSpaceCompaction;
}

public boolean isEnableAINodeService() {
return enableAINodeService;
}

public void setEnableAINodeService(boolean enableAINodeService) {
this.enableAINodeService = enableAINodeService;
}

public InnerSequenceCompactionSelector getInnerSequenceCompactionSelector() {
return innerSequenceCompactionSelector;
}
Expand Down Expand Up @@ -3157,14 +3143,6 @@ public void setInternalPort(int internalPort) {
this.internalPort = internalPort;
}

public int getAINodePort() {
return aiNodePort;
}

public void setAINodePort(int aiNodePort) {
this.aiNodePort = aiNodePort;
}

public int getDataRegionConsensusPort() {
return dataRegionConsensusPort;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -287,19 +287,6 @@ public void loadProperties(Properties properties) throws BadNodeUrlException, IO
.getProperty(IoTDBConstant.DN_RPC_PORT, Integer.toString(conf.getRpcPort()))
.trim()));

conf.setEnableAINodeService(
Boolean.parseBoolean(
properties
.getProperty(
"enable_ainode_rpc_service", Boolean.toString(conf.isEnableAINodeService()))
.trim()));

conf.setAINodePort(
Integer.parseInt(
properties
.getProperty("ainode_rpc_port", Integer.toString(conf.getAINodePort()))
.trim()));

conf.setBufferedArraysMemoryProportion(
Double.parseDouble(
properties
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit a4f2437

Please sign in to comment.