refactor-cores (#2308)

diff --git a/streaming/index.js b/streaming/index.js
index c7959b3069e02f7b4f5b5fada1d7b8d0fe494f8e..a688d6de4f7096bf4d58c49cdbea01a8f16840ff 100644 (file)
--- a/streaming/index.js
+++ b/streaming/index.js
@@ -19,7 +19,7 @@ dotenv.config({
 if (cluster.isMaster) {
   // cluster master
 
-  const core = +process.env.STREAMING_CLUSTER_NUM || (env === 'development' ? 1 : (os.cpus().length > 1 ? os.cpus().length - 1 : 1))
+  const core = +process.env.STREAMING_CLUSTER_NUM || (env === 'development' ? 1 : Math.max(os.cpus().length - 1, 1))
   const fork = () => {
     const worker = cluster.fork();
     worker.on('exit', (code, signal) => {