diff --git a/docs/.vuepress/sidebar/en.js b/docs/.vuepress/sidebar/en.js index 8cca1c5b84..05a9c2d855 100644 --- a/docs/.vuepress/sidebar/en.js +++ b/docs/.vuepress/sidebar/en.js @@ -480,8 +480,7 @@ module.exports = [ "bitand", "bitor", "bitxor", - "bitnot", - "bit_length" + "bitnot" ], }, { diff --git a/docs/.vuepress/sidebar/zh-CN.js b/docs/.vuepress/sidebar/zh-CN.js index 3fd8f69003..3053c2d2b6 100644 --- a/docs/.vuepress/sidebar/zh-CN.js +++ b/docs/.vuepress/sidebar/zh-CN.js @@ -482,8 +482,7 @@ module.exports = [ "bitand", "bitor", "bitxor", - "bitnot", - "bit_length" + "bitnot" ], }, { diff --git a/docs/en/sql-reference/sql-functions/bitwise-functions/bit_length.md b/docs/en/sql-reference/sql-functions/bitwise-functions/bit_length.md deleted file mode 100644 index 9f56a1ff04..0000000000 --- a/docs/en/sql-reference/sql-functions/bitwise-functions/bit_length.md +++ /dev/null @@ -1,55 +0,0 @@ ---- -{ -"title": "bit_length", -"language": "en" -} ---- - - - -# bit_length -## description -### Syntax - -`INT bit_length(VARCHAR str)` - -Return length of argument in bits. - -## example - -``` -MySQL> select bit_length("doris"); -+---------------------+ -| bit_length('doris') | -+---------------------+ -| 40 | -+---------------------+ - -MySQL [test]> select bit_length("hello world"); -+---------------------------+ -| bit_length('hello world') | -+---------------------------+ -| 88 | -+---------------------------+ -``` - -## keyword - - bit_length diff --git a/docs/zh-CN/sql-reference/sql-functions/bitwise-functions/bit_length.md b/docs/zh-CN/sql-reference/sql-functions/bitwise-functions/bit_length.md deleted file mode 100644 index c0005fade1..0000000000 --- a/docs/zh-CN/sql-reference/sql-functions/bitwise-functions/bit_length.md +++ /dev/null @@ -1,55 +0,0 @@ ---- -{ -"title": "bit_length", -"language": "zh-CN" -} ---- - - - -# bit_length -## description -### Syntax - -`INT bit_length(VARCHAR str)` - -返回字符串的bit位数 - -## example - -``` -MySQL> select bit_length("doris"); -+---------------------+ -| bit_length('doris') | -+---------------------+ -| 40 | -+---------------------+ - -MySQL [test]> select bit_length("hello world"); -+---------------------------+ -| bit_length('hello world') | -+---------------------------+ -| 88 | -+---------------------------+ -``` - -## keyword - - bit_length diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java index eaa52e258b..c72ee6c3d6 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java @@ -21,10 +21,14 @@ import org.apache.doris.common.Config; import org.apache.doris.common.InternalErrorCode; import org.apache.doris.system.SystemInfoService; +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; + /** * ScheduleRule: RoutineLoad PAUSED -> NEED_SCHEDULE */ public class ScheduleRule { + private static final Logger LOG = LogManager.getLogger(ScheduleRule.class); private static int deadBeCount(String clusterName) { SystemInfoService systemInfoService = Catalog.getCurrentSystemInfo(); @@ -43,17 +47,26 @@ public class ScheduleRule { return false; } if (jobRoutine.autoResumeLock) {//only manual resume for unlock + LOG.debug("routine load job {}'s autoResumeLock is true, skip", jobRoutine.id); return false; } /* * Handle all backends are down. */ + LOG.debug("try to auto reschedule routine load {}, firstResumeTimestamp: {}, autoResumeCount: {}, " + + "pause reason: {}", + jobRoutine.id, jobRoutine.firstResumeTimestamp, jobRoutine.autoResumeCount, + jobRoutine.pauseReason == null ? "null" : jobRoutine.pauseReason.getCode().name()); if (jobRoutine.pauseReason != null && jobRoutine.pauseReason.getCode() == InternalErrorCode.REPLICA_FEW_ERR) { int dead = deadBeCount(jobRoutine.clusterName); if (dead > Config.max_tolerable_backend_down_num) { + LOG.debug("dead backend num {} is larger than config {}, " + + "routine load job {} can not be auto rescheduled", + dead, Config.max_tolerable_backend_down_num, jobRoutine.id); return false; } + if (jobRoutine.firstResumeTimestamp == 0) {//the first resume jobRoutine.firstResumeTimestamp = System.currentTimeMillis(); jobRoutine.autoResumeCount = 1; diff --git a/thirdparty/download-thirdparty.sh b/thirdparty/download-thirdparty.sh index 9680703d1d..74919f3cad 100755 --- a/thirdparty/download-thirdparty.sh +++ b/thirdparty/download-thirdparty.sh @@ -280,18 +280,6 @@ fi cd - echo "Finished patching $HDFS3_SOURCE" -# aws-c-cal patch to fix compile error -# This bug has been fixed in new version of aws-c-cal -if [ $AWS_C_CAL_SOURCE == "aws-c-cal-0.4.5" ]; then - cd $TP_SOURCE_DIR/$AWS_C_CAL_SOURCE - if [ ! -f $PATCHED_MARK ]; then - patch -p1 < $TP_PATCH_DIR/aws-c-cal-0.4.5.patch - touch $PATCHED_MARK - fi - cd - -fi -echo "Finished patching $AWS_C_CAL_SOURCE" - # rocksdb patch to fix compile error if [ $ROCKSDB_SOURCE == "rocksdb-5.14.2" ]; then cd $TP_SOURCE_DIR/$ROCKSDB_SOURCE @@ -317,7 +305,8 @@ echo "Finished patching $LIBRDKAFKA_SOURCE" cd $TP_SOURCE_DIR/$AWS_SDK_SOURCE if [ ! -f $PATCHED_MARK ]; then if [ $AWS_SDK_SOURCE == "aws-sdk-cpp-1.9.211" ]; then - curl -L https://doris-thirdparty-repo.bj.bcebos.com/thirdparty/aws-crt-cpp-1.9.211.tar.gz | tar -zx + wget --no-check-certificate -q https://doris-thirdparty-repo.bj.bcebos.com/thirdparty/aws-crt-cpp-1.9.211.tar.gz + tar xzf aws-crt-cpp-1.9.211.tar.gz else bash ./prefetch_crt_dependency.sh fi