update codes

pom.xml

@@ -207,7 +207,7 @@
                             </filters>
                             <transformers>
                                 <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
-                                    <mainClass>com.gmei.data.ctr.main.TestCtrPfrCrtMain</mainClass>
+                                    <mainClass>com.gmei.data.ctr.main.TestCtrPfrRctMain</mainClass>
                                 </transformer>
                             </transformers>
                             <createDependencyReducedPom>false</createDependencyReducedPom>

src/main/java/com/gmei/data/ctr/sink/CtrPfrRctMysqlSink.java

@@ -72,6 +72,7 @@ public class CtrPfrRctMysqlSink extends RichSinkFunction<CtrPfrRctBean> {
     }
 
     private void insertAndDel(CtrPfrRctBean ctrPfrRctBean)  {
+        if(null != ctrPfrRctBean){
             Statement statement = null;
             Date date = new Date();
             String timeStr = DateUtil.getTimeStr(date);
@@ -309,6 +310,7 @@ public class CtrPfrRctMysqlSink extends RichSinkFunction<CtrPfrRctBean> {
                 }
             }
         }
+    }
 
     private LinkedList<PfrRecentInfo> getNewQueue(LinkedList<PfrRecentInfo> oldQueue, String pfrStr, String timeStr, Integer queueSize ){
         LinkedList<PfrRecentInfo> newQueue = new LinkedList<>();