Skip to content
Permalink
Browse files
optimize log, change retry log from warn to debug (#26)
  • Loading branch information
qidaye committed May 6, 2022
1 parent e388338 commit 094d76f84d2761ff18dfbbe5118539ba5f5cd142
Showing 2 changed files with 2 additions and 2 deletions.
@@ -100,7 +100,7 @@ private[sql] class DorisSourceProvider extends DataSourceRegister
catch {
case e: Exception =>
try {
logger.warn("Failed to load data on BE: {} node ", dorisStreamLoader.getLoadUrlStr)
logger.debug("Failed to load data on BE: {} node ", dorisStreamLoader.getLoadUrlStr)
//If the current BE node fails to execute Stream Load, randomly switch to other BE nodes and try again
dorisStreamLoader.setHostPort(RestService.randomBackendV2(sparkSettings, logger))
Thread.sleep(1000 * i)
@@ -83,7 +83,7 @@ private[sql] class DorisStreamLoadSink(sqlContext: SQLContext, settings: SparkSe
catch {
case e: Exception =>
try {
logger.warn("Failed to load data on BE: {} node ", dorisStreamLoader.getLoadUrlStr)
logger.debug("Failed to load data on BE: {} node ", dorisStreamLoader.getLoadUrlStr)
//If the current BE node fails to execute Stream Load, randomly switch to other BE nodes and try again
dorisStreamLoader.setHostPort(RestService.randomBackendV2(settings, logger))
Thread.sleep(1000 * i)

0 comments on commit 094d76f

Please sign in to comment.