update codes

src/main/java/com/gmei/data/ctr/operator/CtrEstimatePfrOperator.java

@@ -111,7 +111,7 @@ public class CtrEstimatePfrOperator implements BaseOperator{
                 }
                 return false;
               }
-            });
+            }).setParallelism(parallelism);
         //filter.print();
         SingleOutputStreamOperator map = filter
                 .map(new MapFunction<JSONObject, CtrEstimatePfrEtl>() {
@@ -155,7 +155,7 @@ public class CtrEstimatePfrOperator implements BaseOperator{
                         }
                         return ctrEstimatePfrEtl;
                     }
-                });
+                }).setParallelism(parallelism);
         //map.print();
         DataStream<DeviceCurrentEstimatePfrTmp> tidbAsyncDataStream = AsyncDataStream
                 .unorderedWait(map, new TidbMysqlAsyncPfrSource(jerryJdbcUrl,jerryUsername,jerryPassword), 1, TimeUnit.MINUTES, 1000)