|
@@ -69,7 +69,7 @@ public class SimpleNode<KEYIN, VALUEIN, KEYOUT, VALUEOUT>
|
|
|
*/
|
|
|
@Override
|
|
|
public void start() {
|
|
|
- this.startNodeExecuters();
|
|
|
+ this.startNodeExecuter();
|
|
|
|
|
|
this.startLogThread();
|
|
|
}
|
|
@@ -79,7 +79,7 @@ public class SimpleNode<KEYIN, VALUEIN, KEYOUT, VALUEOUT>
|
|
|
*
|
|
|
* @author WANGWEI
|
|
|
*/
|
|
|
- private void startNodeExecuters() {
|
|
|
+ private void startNodeExecuter() {
|
|
|
new Thread(() -> {
|
|
|
|
|
|
while (true) {
|