New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
#3256 Provider Scaling out Interface-Add all apis #3692
#3256 Provider Scaling out Interface-Add all apis #3692
Conversation
java ${JAVA_OPTS} -classpath ${CLASS_PATH} ${MAIN_CLASS} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Moving port to configFile maybe better. You can refer Bootstrap in sharding-proxy
.
@@ -49,72 +41,36 @@ | |||
@Slf4j | |||
public class Bootstrap { | |||
|
|||
private static final int PORT = Integer.parseInt(System.getProperty("port", "8080")); | |||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Moving port to configFile maybe better. You can refer Bootstrap in sharding-proxy
.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I will submit a new issue for config related, so here will stay as it is?
"pushTimeout": 1000, | ||
"concurrency": 3 | ||
} | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please end file with blank line.
@Data | ||
public class Job { | ||
private int id; | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can you replace this class by ShardingScalingJob
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yes, it is a good idea.
|
||
private final BlockingQueue<Record> queue = new ArrayBlockingQueue<>(ScalingContext.getInstance().getServerConfiguration().getBlockQueueSize()); | ||
private final BlockingQueue<Record> queue = new ArrayBlockingQueue<>(10000); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why do you use hardcode in there?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I will submit a new issue for config related.
For #3256.
Changes proposed in this pull request: