no message

Pyspark_job/utils/templates.py

@@ -25,13 +25,12 @@ from utils.spark_util import SparkUtil
 from pyspark.sql import functions as F
 from kafka import KafkaConsumer, TopicPartition
 from pyspark.sql.types import *
-from utils.db_util import DbTypes, DBUtil
+from utils.db_util import DbTypes, DBUtil, get_redis_h14
 from utils.hdfs_utils import HdfsUtils
 from pyspark.sql import Window
 from utils.common_util import CommonUtil
 import subprocess
 import requests
-from db_util import get_redis_h14
 
 
 class Templates(object):