gfwleak/galaxy-tsg-olap-dos-detection-job
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:resolve dependency conflicts(GAL-437)

Browse Source
This commit is contained in:
wangchengcheng
2024-01-15 10:19:38 +08:00
parent 77ec061844
commit 62bffa9731
3 changed files with 10 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/com/zdjizhi/utils/Threshold/ParseBaselineThreshold.java
View File

@@ -3,7 +3,6 @@ package com.zdjizhi.utils.Threshold;
import cn.hutool.log.Log;
import cn.hutool.log.LogFactory;
import com.geedgenetworks.utils.DateUtils;
import com.zdjizhi.common.DosBaselineThreshold;
import com.zdjizhi.utils.connections.hbase.HbaseUtils;
import org.apache.flink.configuration.Configuration;
@@ -13,20 +12,19 @@ import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
import java.util.*;
import static com.zdjizhi.conf.DosConfigs.*;
public class ParseBaselineThreshold {
private static final Log logger = LogFactory.get();
private ArrayList<String> floodTypeList = new ArrayList<>();
private Configuration configuration;
private static Table table = null;
private static Scan scan = null;
private Table table = null;
private Scan scan = null;
public ParseBaselineThreshold(Configuration configuration) {
this.configuration = configuration;
@@ -37,9 +35,8 @@ public class ParseBaselineThreshold {
}
private void prepareHbaseEnv() throws IOException {
org.apache.hadoop.conf.Configuration config = HBaseConfiguration.create();
private void prepareHbaseEnv() throws IOException {
final org.apache.hadoop.conf.Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", configuration.get(HBASE_ZOOKEEPER_QUORUM));
config.set("hbase.client.retries.number", "3");
config.set("hbase.bulkload.retries.number", "3");