update codes

921af55b · 赵建伟 · 2b317922 · 921af55b
Commit 921af55b authored Apr 11, 2020 by 赵建伟
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 11 deletions

CtrEstimatePfrMysqlSink.java .../java/com/gmei/data/ctr/sink/CtrEstimatePfrMysqlSink.java +1 -11

No files found.
--- a/src/main/java/com/gmei/data/ctr/sink/CtrEstimatePfrMysqlSink.java
+++ b/src/main/java/com/gmei/data/ctr/sink/CtrEstimatePfrMysqlSink.java
@@ -117,19 +117,9 @@ public class CtrEstimatePfrMysqlSink extends RichSinkFunction<DeviceCurrentEstim
                            DateUtils.getSevenDaysAgoTimeStr(date)
                    )
            );
+            JDBCUtils.close(null,statement,null);
        }catch (Exception e){
            e.printStackTrace();
-        }finally {
-            try{
-                if (statement != null) {
-                    statement.close();
-                }
-                if (connection != null) {
-                    connection.close();
-                }
-            }catch (Exception e){
-                e.printStackTrace();
-            }
        }
    }
 }