From 5d8c815f4a9ba9a7b982347744190c3837eac558 Mon Sep 17 00:00:00 2001 From: Chia-Ping Tsai Date: Wed, 10 Jul 2024 21:45:53 +0800 Subject: [PATCH] [COMMON] rename skiptests to opensource4you --- .github/workflows/ci.yml | 2 +- README.md | 6 +++--- .../astraea/app/performance/Performance.java | 2 +- .../org/astraea/app/web/QuotaHandler.java | 4 ++-- .../org/astraea/app/web/RecordHandler.java | 2 +- .../org/astraea/app/web/ThrottleHandler.java | 2 +- common/build.gradle | 2 +- .../org/astraea/common/assignor/Assignor.java | 4 ++-- .../astraea/common/cost/HasBrokerCost.java | 2 +- .../org/astraea/common/cost/NetworkCost.java | 10 +++++----- .../astraea/common/metrics/JndiClient.java | 2 +- .../common/metrics/collector/MetricStore.java | 2 +- .../common/partitioner/Partitioner.java | 4 ++-- .../common/producer/RecordGenerator.java | 2 +- .../astraea/common/admin/ClusterInfoTest.java | 2 +- .../connector/ConnectorClientBuilderTest.java | 4 ++-- docker/build_deps_image.sh | 4 ++-- docker/start_app.sh | 6 +++--- docker/start_broker.sh | 6 +++--- docker/start_controller.sh | 6 +++--- docker/start_hadoop.sh | 4 ++-- docker/start_worker.sh | 8 ++++---- docker/start_zookeeper.sh | 2 +- docs/balancer/experiment_1.md | 18 ++++++++--------- docs/balancer/experiment_2.md | 20 +++++++++---------- docs/build_project.md | 2 +- docs/gui/env/README.md | 2 +- docs/gui/replica/README.md | 2 +- docs/gui/setting/README.md | 6 +++--- docs/kafka_Q&A.md | 4 ++-- docs/partitioner/README.md | 10 +++++----- .../experiments/StrictCostDispatcher_2.md | 2 +- .../web_api_metricSensors_chinese.md | 2 +- gui/build.gradle | 2 +- .../java/org/astraea/gui/tab/AboutNode.java | 2 +- 35 files changed, 80 insertions(+), 80 deletions(-) diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 55825610ee..6456002ec4 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -11,7 +11,7 @@ jobs: container-test-job: runs-on: ubuntu-latest container: - image: ghcr.io/skiptests/astraea/deps + image: ghcr.io/opensource4you/astraea/deps options: --cpus 2 steps: - uses: actions/checkout@v2 diff --git a/README.md b/README.md index cbe1fa3c2c..bcbc1cdbcb 100644 --- a/README.md +++ b/README.md @@ -42,12 +42,12 @@ `Astraea` 鼓勵貢獻者參與研討會做技術發表，各年度的發表請見下列連結： -[2022 年度](https://github.com/skiptests/astraea/issues/238) +[2022 年度](https://github.com/opensource4you/astraea/issues/238) -上述報告和測試所使用的硬體詳細資訊：[Astraea 測試用硬體](https://github.com/skiptests/astraea/issues/130) +上述報告和測試所使用的硬體詳細資訊：[Astraea 測試用硬體](https://github.com/opensource4you/astraea/issues/130) # 社群活動 `Astraea` 定時舉辦線下活動，各年度活動請見下方連結 -[2022 聖誕節](https://github.com/skiptests/astraea/issues/830) \ No newline at end of file +[2022 聖誕節](https://github.com/opensource4you/astraea/issues/830) \ No newline at end of file diff --git a/app/src/main/java/org/astraea/app/performance/Performance.java b/app/src/main/java/org/astraea/app/performance/Performance.java index e7bda51daa..9b3334ab31 100644 --- a/app/src/main/java/org/astraea/app/performance/Performance.java +++ b/app/src/main/java/org/astraea/app/performance/Performance.java @@ -451,7 +451,7 @@ else if (specifiedByBroker) { } } - // replace DataSize by DataRate (see https://github.com/skiptests/astraea/issues/488) + // replace DataSize by DataRate (see https://github.com/opensource4you/astraea/issues/488) @Parameter( names = {"--throughput"}, description = diff --git a/app/src/main/java/org/astraea/app/web/QuotaHandler.java b/app/src/main/java/org/astraea/app/web/QuotaHandler.java index 828dda20d0..8c49028d71 100644 --- a/app/src/main/java/org/astraea/app/web/QuotaHandler.java +++ b/app/src/main/java/org/astraea/app/web/QuotaHandler.java @@ -73,8 +73,8 @@ public CompletionStage post(Channel channel) { .thenApply(Quotas::new)); } - // TODO: use DataRate#Field (traced https://github.com/skiptests/astraea/issues/488) - // see https://github.com/skiptests/astraea/issues/490 + // TODO: use DataRate#Field (traced https://github.com/opensource4you/astraea/issues/488) + // see https://github.com/opensource4you/astraea/issues/490 if (postRequest.producer.isPresent()) { var producerQuota = postRequest.producer.get(); return admin diff --git a/app/src/main/java/org/astraea/app/web/RecordHandler.java b/app/src/main/java/org/astraea/app/web/RecordHandler.java index 77f5431b64..1bb014e4e9 100644 --- a/app/src/main/java/org/astraea/app/web/RecordHandler.java +++ b/app/src/main/java/org/astraea/app/web/RecordHandler.java @@ -331,7 +331,7 @@ private static org.astraea.common.producer.Record createRecord( var builder = org.astraea.common.producer.Record.builder().topic(topic); // TODO: Support headers - // (https://github.com/skiptests/astraea/issues/422) + // (https://github.com/opensource4you/astraea/issues/422) var keySerializer = SerDe.ofAlias(postRecord.keySerializer).serializer; var valueSerializer = SerDe.ofAlias(postRecord.valueSerializer).serializer; postRecord.key.ifPresent( diff --git a/app/src/main/java/org/astraea/app/web/ThrottleHandler.java b/app/src/main/java/org/astraea/app/web/ThrottleHandler.java index 67cc5843de..63421e4b71 100644 --- a/app/src/main/java/org/astraea/app/web/ThrottleHandler.java +++ b/app/src/main/java/org/astraea/app/web/ThrottleHandler.java @@ -306,7 +306,7 @@ private Set toReplicaSet(String topic, String throttledRe if (throttledReplicas.isEmpty()) return Set.of(); // TODO: support for wildcard throttle might be implemented in the future, see - // https://github.com/skiptests/astraea/issues/625 + // https://github.com/opensource4you/astraea/issues/625 if (throttledReplicas.equals("*")) throw new UnsupportedOperationException("This API doesn't support wildcard throttle"); diff --git a/common/build.gradle b/common/build.gradle index 5a715e9070..ace61d71bd 100644 --- a/common/build.gradle +++ b/common/build.gradle @@ -92,7 +92,7 @@ publishing { } repositories { maven { - url = "https://maven.pkg.github.com/skiptests/astraea" + url = "https://maven.pkg.github.com/opensource4you/astraea" credentials { username = System.getenv("GITHUB_ACTOR") password = System.getenv("GITHUB_TOKEN") diff --git a/common/src/main/java/org/astraea/common/assignor/Assignor.java b/common/src/main/java/org/astraea/common/assignor/Assignor.java index 482122cfba..2835000b6a 100644 --- a/common/src/main/java/org/astraea/common/assignor/Assignor.java +++ b/common/src/main/java/org/astraea/common/assignor/Assignor.java @@ -56,7 +56,7 @@ public abstract class Assignor implements ConsumerPartitionAssignor, Configurabl HasPartitionCost costFunction = HasPartitionCost.EMPTY; // TODO: metric collector may be configured by user in the future. // TODO: need to track the performance when using the assignor in large scale consumers, see - // https://github.com/skiptests/astraea/pull/1162#discussion_r1036285677 + // https://github.com/opensource4you/astraea/pull/1162#discussion_r1036285677 protected MetricStore metricStore = null; protected Admin admin = null; @@ -72,7 +72,7 @@ protected abstract Map> assign( Map subscriptions, ClusterInfo clusterInfo); // TODO: replace the topicPartitions by ClusterInfo after Assignor is able to handle Admin - // https://github.com/skiptests/astraea/issues/1409 + // https://github.com/opensource4you/astraea/issues/1409 /** * Parse config to get JMX port and cost function type. diff --git a/common/src/main/java/org/astraea/common/cost/HasBrokerCost.java b/common/src/main/java/org/astraea/common/cost/HasBrokerCost.java index 2368055bc8..9f265f8fa6 100644 --- a/common/src/main/java/org/astraea/common/cost/HasBrokerCost.java +++ b/common/src/main/java/org/astraea/common/cost/HasBrokerCost.java @@ -30,7 +30,7 @@ public interface HasBrokerCost extends CostFunction { static HasBrokerCost of(Map costAndWeight) { // the temporary exception won't affect the smooth-weighted too much. // TODO: should we propagate the exception by better way? For example: Slf4j ? - // see https://github.com/skiptests/astraea/issues/486 + // see https://github.com/opensource4you/astraea/issues/486 var sensor = MetricSensor.of(costAndWeight.keySet().stream().map(CostFunction::metricSensor).toList()); return new HasBrokerCost() { diff --git a/common/src/main/java/org/astraea/common/cost/NetworkCost.java b/common/src/main/java/org/astraea/common/cost/NetworkCost.java index e4f562d39b..b30dfe0b3e 100644 --- a/common/src/main/java/org/astraea/common/cost/NetworkCost.java +++ b/common/src/main/java/org/astraea/common/cost/NetworkCost.java @@ -64,7 +64,7 @@ * bandwidth is correct and steadily reflect the actual resource usage. This is generally true * when the broker has reach its steady state, but to reach that state might takes awhile. And * based on our observation this probably won't happen at the early broker start (see Issue #1641). We suggest use + * href="https://github.com/opensource4you/astraea/issues/1641">Issue #1641). We suggest use * this cost with metrics from the servers in steady state. * */ @@ -182,7 +182,7 @@ public ClusterCost clusterCost(ClusterInfo clusterInfo, ClusterBean clusterBean) var maxEgress = brokerEgressRate.values().stream().mapToDouble(x -> x).sum(); var maxRate = Math.max(maxIngress, maxEgress); // the score is measured as the ratio of targeting network throughput related to the maximum - // ingress or egress throughput. See https://github.com/skiptests/astraea/issues/1285 for the + // ingress or egress throughput. See https://github.com/opensource4you/astraea/issues/1285 for the // reason to do this. double score = (summary.getMax() - summary.getMin()) / (maxRate); @@ -193,7 +193,7 @@ public ClusterCost clusterCost(ClusterInfo clusterInfo, ClusterBean clusterBean) public MetricSensor metricSensor() { // TODO: We need a reliable way to access the actual current cluster info. To do that we need to // obtain the replica info, so we intentionally sample log size but never use it. - // https://github.com/skiptests/astraea/pull/1240#discussion_r1044487473 + // https://github.com/opensource4you/astraea/pull/1240#discussion_r1044487473 return (client, clusterBean) -> Stream.of( List.of(HostMetrics.jvmMemory(client)), @@ -270,7 +270,7 @@ Map estimateRate( private long ingress(CachedCalculation calculation, TopicPartition topicPartition) { var value = calculation.partitionIngressRate.get(topicPartition); if (value == null) { - // Maybe the user run into this bug: https://github.com/skiptests/astraea/issues/1388 + // Maybe the user run into this bug: https://github.com/opensource4you/astraea/issues/1388 throw new NoSufficientMetricsException( this, Duration.ofSeconds(1), @@ -285,7 +285,7 @@ private long ingress(CachedCalculation calculation, TopicPartition topicPartitio private long egress(CachedCalculation calculation, TopicPartition topicPartition) { var value = calculation.partitionEgressRate.get(topicPartition); if (value == null) { - // Maybe the user run into this bug: https://github.com/skiptests/astraea/issues/1388 + // Maybe the user run into this bug: https://github.com/opensource4you/astraea/issues/1388 throw new NoSufficientMetricsException( this, Duration.ofSeconds(1), diff --git a/common/src/main/java/org/astraea/common/metrics/JndiClient.java b/common/src/main/java/org/astraea/common/metrics/JndiClient.java index 1f74bf3d72..2944815afa 100644 --- a/common/src/main/java/org/astraea/common/metrics/JndiClient.java +++ b/common/src/main/java/org/astraea/common/metrics/JndiClient.java @@ -153,7 +153,7 @@ public Collection beans( () -> connection.queryMBeans(beanQuery.objectName(), null).stream() // Parallelize the sampling of bean objects. The underlying RMI is thread-safe. - // https://github.com/skiptests/astraea/issues/1553#issuecomment-1461143723 + // https://github.com/opensource4you/astraea/issues/1553#issuecomment-1461143723 .parallel() .map(ObjectInstance::getObjectName) .map(BeanQuery::fromObjectName) diff --git a/common/src/main/java/org/astraea/common/metrics/collector/MetricStore.java b/common/src/main/java/org/astraea/common/metrics/collector/MetricStore.java index c323a6d1a9..5891dff092 100644 --- a/common/src/main/java/org/astraea/common/metrics/collector/MetricStore.java +++ b/common/src/main/java/org/astraea/common/metrics/collector/MetricStore.java @@ -261,7 +261,7 @@ private MetricStoreImpl( try { receivers.stream() // TODO: Busy waiting on metric receiving. - // issue: https://github.com/skiptests/astraea/issues/1834 + // issue: https://github.com/opensource4you/astraea/issues/1834 // To prevent specific receiver block other receivers' job, we set receive // timeout to zero. But if all receivers return empty immediately, it may cause // this thread busy waiting on doing `receiver.receive`. diff --git a/common/src/main/java/org/astraea/common/partitioner/Partitioner.java b/common/src/main/java/org/astraea/common/partitioner/Partitioner.java index 9b533f89ac..57d8581e69 100644 --- a/common/src/main/java/org/astraea/common/partitioner/Partitioner.java +++ b/common/src/main/java/org/astraea/common/partitioner/Partitioner.java @@ -108,7 +108,7 @@ public static void beginInterdependent( * @param producer Astraea producer */ // TODO One thread supports multiple producers. - // TODO: https://github.com/skiptests/astraea/pull/721#discussion_r973677891 + // TODO: https://github.com/opensource4you/astraea/pull/721#discussion_r973677891 public static void beginInterdependent(org.astraea.common.producer.Producer producer) { beginInterdependent((Producer) Utils.member(producer, "kafkaProducer")); } @@ -127,7 +127,7 @@ public static void endInterdependent(org.apache.kafka.clients.producer.Producer< * * @param producer Kafka producer */ - // TODO: https://github.com/skiptests/astraea/pull/721#discussion_r973677891 + // TODO: https://github.com/opensource4you/astraea/pull/721#discussion_r973677891 public static void endInterdependent(org.astraea.common.producer.Producer producer) { endInterdependent((Producer) Utils.member(producer, "kafkaProducer")); } diff --git a/common/src/main/java/org/astraea/common/producer/RecordGenerator.java b/common/src/main/java/org/astraea/common/producer/RecordGenerator.java index 545276b023..33a2719401 100644 --- a/common/src/main/java/org/astraea/common/producer/RecordGenerator.java +++ b/common/src/main/java/org/astraea/common/producer/RecordGenerator.java @@ -137,7 +137,7 @@ public RecordGenerator build() { var key = recordKeyTable.get(keyDistribution.get()); // Intentionally replace key with zero length by null key. A key with zero length can // lead to ambiguous behavior in an experiment. - // See https://github.com/skiptests/astraea/pull/1521#discussion_r1121801293 for further + // See https://github.com/opensource4you/astraea/pull/1521#discussion_r1121801293 for further // details. return key != null && key.length > 0 ? key : null; }; diff --git a/common/src/test/java/org/astraea/common/admin/ClusterInfoTest.java b/common/src/test/java/org/astraea/common/admin/ClusterInfoTest.java index e50b4530ab..a83fad05d7 100644 --- a/common/src/test/java/org/astraea/common/admin/ClusterInfoTest.java +++ b/common/src/test/java/org/astraea/common/admin/ClusterInfoTest.java @@ -44,7 +44,7 @@ public class ClusterInfoTest { */ public static ClusterInfo of(List replicas) { // TODO: this method is not suitable for production use. Move it to the test scope. - // see https://github.com/skiptests/astraea/issues/1185 + // see https://github.com/opensource4you/astraea/issues/1185 return ClusterInfo.of( "fake", replicas.stream() diff --git a/common/src/test/java/org/astraea/common/connector/ConnectorClientBuilderTest.java b/common/src/test/java/org/astraea/common/connector/ConnectorClientBuilderTest.java index 0adfd1591f..c4d5055823 100644 --- a/common/src/test/java/org/astraea/common/connector/ConnectorClientBuilderTest.java +++ b/common/src/test/java/org/astraea/common/connector/ConnectorClientBuilderTest.java @@ -36,9 +36,9 @@ void testUrlShouldSet() throws MalformedURLException { Assertions.assertThrows( IllegalArgumentException.class, () -> ConnectorClient.builder().build()); - ConnectorClient.builder().url(new URL("https://github.com/skiptests/astraea/")).build(); + ConnectorClient.builder().url(new URL("https://github.com/opensource4you/astraea/")).build(); ConnectorClient.builder() - .urls(List.of(new URL("https://github.com/skiptests/astraea/"))) + .urls(List.of(new URL("https://github.com/opensource4you/astraea/"))) .build(); } diff --git a/docker/build_deps_image.sh b/docker/build_deps_image.sh index ce491971a3..14b29adba7 100755 --- a/docker/build_deps_image.sh +++ b/docker/build_deps_image.sh @@ -16,7 +16,7 @@ declare -r DOCKER_FOLDER=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &>/dev/null && pwd) source $DOCKER_FOLDER/docker_build_common.sh -declare -r REPO=${REPO:-ghcr.io/skiptests/astraea/deps} +declare -r REPO=${REPO:-ghcr.io/opensource4you/astraea/deps} declare -r VERSION="latest" declare -r IMAGE_NAME="$REPO:$VERSION" declare -r DOCKERFILE=$DOCKER_FOLDER/deps.dockerfile @@ -34,7 +34,7 @@ RUN apt-get update && apt-get install -y \ # build code and download dependencies WORKDIR /astraea -RUN git clone https://github.com/skiptests/astraea.git /astraea +RUN git clone https://github.com/opensource4you/astraea.git /astraea RUN ./gradlew clean build -x test # download test dependencies RUN ./gradlew clean build testClasses -x test --no-daemon diff --git a/docker/start_app.sh b/docker/start_app.sh index a37f9b65d1..092475483b 100755 --- a/docker/start_app.sh +++ b/docker/start_app.sh @@ -19,7 +19,7 @@ source $DOCKER_FOLDER/docker_build_common.sh # ===============================[global variables]=============================== declare -r VERSION=${REVISION:-${VERSION:-main}} -declare -r ACCOUNT=${ACCOUNT:-skiptests} +declare -r ACCOUNT=${ACCOUNT:-opensource4you} if [[ "$VERSION" == "main" ]]; then declare -r IMAGE_NAME="ghcr.io/${ACCOUNT}/astraea/app:latest" else @@ -38,14 +38,14 @@ declare -r BACKGROUND="${BACKGROUND:-"false"}" function showHelp() { echo "Usage: [ENV] start_app.sh" echo "ENV: " - echo " ACCOUNT=skiptests set the account to clone from" + echo " ACCOUNT=opensource4you set the account to clone from" echo " BUILD=false set true if you want to build image locally" echo " RUN=false set false if you want to build/pull image only" } function generateDockerfile() { echo "# this dockerfile is generated dynamically -FROM ghcr.io/skiptests/astraea/deps AS build +FROM ghcr.io/opensource4you/astraea/deps AS build # clone repo WORKDIR /tmp diff --git a/docker/start_broker.sh b/docker/start_broker.sh index 3326f31399..a3c9a35258 100755 --- a/docker/start_broker.sh +++ b/docker/start_broker.sh @@ -18,7 +18,7 @@ declare -r DOCKER_FOLDER=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &>/dev/null source $DOCKER_FOLDER/docker_build_common.sh # ===============================[global variables]=============================== -declare -r ACCOUNT=${ACCOUNT:-skiptests} +declare -r ACCOUNT=${ACCOUNT:-opensource4you} declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache} declare -r VERSION=${REVISION:-${VERSION:-3.7.0}} declare -r DOCKERFILE=$DOCKER_FOLDER/broker.dockerfile @@ -60,7 +60,7 @@ function showHelp() { echo " num.network.threads=10 set broker network threads" echo "ENV: " echo " KAFKA_ACCOUNT=apache set the github account for kafka repo" - echo " ACCOUNT=skiptests set the github account for astraea repo" + echo " ACCOUNT=opensource4you set the github account for astraea repo" echo " HEAP_OPTS=\"-Xmx2G -Xms2G\" set broker JVM memory" echo " REVISION=trunk set revision of kafka source code to build container" echo " VERSION=3.7.0 set version of kafka distribution" @@ -73,7 +73,7 @@ function showHelp() { function generateDockerfileBySource() { local kafka_repo="https://github.com/${KAFKA_ACCOUNT}/kafka" echo "# this dockerfile is generated dynamically -FROM ghcr.io/skiptests/astraea/deps AS build +FROM ghcr.io/opensource4you/astraea/deps AS build # download jmx exporter RUN mkdir /opt/jmx_exporter diff --git a/docker/start_controller.sh b/docker/start_controller.sh index 146e82ca3d..c31d16e4e7 100755 --- a/docker/start_controller.sh +++ b/docker/start_controller.sh @@ -18,7 +18,7 @@ declare -r DOCKER_FOLDER=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &>/dev/null source $DOCKER_FOLDER/docker_build_common.sh # ===============================[global variables]=============================== -declare -r ACCOUNT=${ACCOUNT:-skiptests} +declare -r ACCOUNT=${ACCOUNT:-opensource4you} declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache} declare -r VERSION=${REVISION:-${VERSION:-3.7.0}} declare -r DOCKERFILE=$DOCKER_FOLDER/controller.dockerfile @@ -71,7 +71,7 @@ function showHelp() { echo "Usage: [ENV] start_controller.sh [ ARGUMENTS ]" echo "ENV: " echo " KAFKA_ACCOUNT=apache set the github account for kafka repo" - echo " ACCOUNT=skiptests set the github account for astraea repo" + echo " ACCOUNT=opensource4you set the github account for astraea repo" echo " HEAP_OPTS=\"-Xmx2G -Xms2G\" set controller JVM memory" echo " REVISION=trunk set revision of kafka source code to build container" echo " VERSION=3.7.0 set version of kafka distribution" @@ -83,7 +83,7 @@ function showHelp() { function generateDockerfileBySource() { local kafka_repo="https://github.com/${KAFKA_ACCOUNT}/kafka" echo "# this dockerfile is generated dynamically -FROM ghcr.io/skiptests/astraea/deps AS build +FROM ghcr.io/opensource4you/astraea/deps AS build # download jmx exporter RUN mkdir /opt/jmx_exporter diff --git a/docker/start_hadoop.sh b/docker/start_hadoop.sh index 5e5c793355..580999a901 100755 --- a/docker/start_hadoop.sh +++ b/docker/start_hadoop.sh @@ -19,7 +19,7 @@ source $DOCKER_FOLDER/docker_build_common.sh # ===============================[global variables]=============================== declare -r VERSION=${VERSION:-3.3.5} -declare -r REPO=${REPO:-ghcr.io/skiptests/astraea/hadoop} +declare -r REPO=${REPO:-ghcr.io/opensource4you/astraea/hadoop} declare -r IMAGE_NAME="$REPO:$VERSION" declare -r DOCKERFILE=$DOCKER_FOLDER/hadoop.dockerfile declare -r EXPORTER_VERSION="0.16.1" @@ -78,7 +78,7 @@ RUN tar -zxvf hadoop-${VERSION}.tar.gz -C /opt/hadoop --strip-components=1 FROM ubuntu:23.10 #install tools -# TODO: upgrade to jdk 11 (https://github.com/skiptests/astraea/issues/1681) +# TODO: upgrade to jdk 11 (https://github.com/opensource4you/astraea/issues/1681) RUN apt-get update && apt-get install -y openjdk-11-jre #copy hadoop diff --git a/docker/start_worker.sh b/docker/start_worker.sh index e5828cfd82..92c7185c35 100755 --- a/docker/start_worker.sh +++ b/docker/start_worker.sh @@ -18,7 +18,7 @@ declare -r DOCKER_FOLDER=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &>/dev/null source $DOCKER_FOLDER/docker_build_common.sh # ===============================[global variables]=============================== -declare -r ACCOUNT=${ACCOUNT:-skiptests} +declare -r ACCOUNT=${ACCOUNT:-opensource4you} declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache} declare -r VERSION=${REVISION:-${VERSION:-3.7.0}} declare -r DOCKERFILE=$DOCKER_FOLDER/worker.dockerfile @@ -47,7 +47,7 @@ function showHelp() { echo " bootstrap.servers=node:22222,node:1111 set brokers connection" echo "ENV: " echo " KAFKA_ACCOUNT=apache set the github account for kafka repo" - echo " ACCOUNT=skiptests set the github account for astraea repo" + echo " ACCOUNT=opensource4you set the github account for astraea repo" echo " HEAP_OPTS=\"-Xmx2G -Xms2G\" set worker JVM memory" echo " REVISION=trunk set revision of kafka source code to build container" echo " VERSION=3.7.0 set version of kafka distribution" @@ -77,7 +77,7 @@ function generateDockerfileBySource() { local repo="https://github.com/${ACCOUNT}/astraea" echo "# this dockerfile is generated dynamically -FROM ghcr.io/skiptests/astraea/deps AS build +FROM ghcr.io/opensource4you/astraea/deps AS build # build kafka from source code RUN git clone --depth=1 ${kafka_repo} /tmp/kafka @@ -113,7 +113,7 @@ WORKDIR /opt/kafka function generateDockerfileByVersion() { local repo="https://github.com/${ACCOUNT}/astraea" echo "# this dockerfile is generated dynamically -FROM ghcr.io/skiptests/astraea/deps AS build +FROM ghcr.io/opensource4you/astraea/deps AS build # install tools RUN apt-get update && apt-get install -y wget diff --git a/docker/start_zookeeper.sh b/docker/start_zookeeper.sh index 113f9c75c3..da2d1d981f 100755 --- a/docker/start_zookeeper.sh +++ b/docker/start_zookeeper.sh @@ -19,7 +19,7 @@ source $DOCKER_FOLDER/docker_build_common.sh # ===============================[global variables]=============================== declare -r VERSION=${VERSION:-3.9.1} -declare -r REPO=${REPO:-ghcr.io/skiptests/astraea/zookeeper} +declare -r REPO=${REPO:-ghcr.io/opensource4you/astraea/zookeeper} declare -r IMAGE_NAME="$REPO:$VERSION" declare -r ZOOKEEPER_PORT=${ZOOKEEPER_PORT:-"$(getRandomPort)"} declare -r ZOOKEEPER_JMX_PORT="${ZOOKEEPER_JMX_PORT:-"$(getRandomPort)"}" diff --git a/docs/balancer/experiment_1.md b/docs/balancer/experiment_1.md index 37bed9a21c..1dab0a503d 100644 --- a/docs/balancer/experiment_1.md +++ b/docs/balancer/experiment_1.md @@ -1,6 +1,6 @@ # Astraea Balancer 測試 #1 -這個測試展示目前的 Astraea Balancer [(7596f59)](https://github.com/skiptests/astraea/tree/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4) +這個測試展示目前的 Astraea Balancer [(7596f59)](https://github.com/opensource4you/astraea/tree/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4) 能在特定的系統環境中，平衡每個節點的 leader 數。 在這次實驗中，Astraea Balancer 得到了以下結果： @@ -10,7 +10,7 @@ ## 測試情境 -我們透過專案內的 [WebAPI](https://github.com/skiptests/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/web_server/web_api_topics_chinese.md#%E5%BB%BA%E7%AB%8B-topic) +我們透過專案內的 [WebAPI](https://github.com/opensource4you/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/web_server/web_api_topics_chinese.md#%E5%BB%BA%E7%AB%8B-topic) 工具來對測試叢集產生一個 Leader 數量不平衡的情境。WebAPI 在建立 topic 時能夠透過特定參數來以 Binomial Distribution 營造 topic logs 在叢集內分佈不均的情況。這最終形成的分佈類似於對生產環境 Kafka 叢集不斷加減 topics/partitions/nodes 所導致的資料配置不均勻狀態。 @@ -71,8 +71,8 @@ ### 建立 Kafka 叢集 請依照上述的環境建立叢集，您可以使用專案內的 -[./docker/start_zookeeper.sh](https://github.com/skiptests/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_zookeeper.md) 和 -[./docker/start_broker.sh](https://github.com/skiptests/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_kafka_broker.md) 來建立叢集。 +[./docker/start_zookeeper.sh](https://github.com/opensource4you/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_zookeeper.md) 和 +[./docker/start_broker.sh](https://github.com/opensource4you/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_kafka_broker.md) 來建立叢集。 ## 效能資料攝取 @@ -81,9 +81,9 @@ 進行底層硬體效能資料的攝取。 您可以使用專案內的 -[./docker/start_node_exporter.sh](https://github.com/skiptests/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_node_exporter.md), -[./docker/start_prometheus.sh](https://github.com/skiptests/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_prometheus.md) 和 -[./docker/start_grafana.sh](https://github.com/skiptests/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_grafana.md) 來建構監控環境。 +[./docker/start_node_exporter.sh](https://github.com/opensource4you/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_node_exporter.md), +[./docker/start_prometheus.sh](https://github.com/opensource4you/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_prometheus.md) 和 +[./docker/start_grafana.sh](https://github.com/opensource4you/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/run_grafana.md) 來建構監控環境。 本次實驗所使用的 Dashboard 可以在[這裡](resources/experiment_1_grafana-1663659783116.json)找到 @@ -92,7 +92,7 @@ 首先取得 Astraea Project ```script -git clone https://github.com/skiptests/astraea.git +git clone https://github.com/opensource4you/astraea.git cd astraea git checkout 7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4 ``` @@ -117,7 +117,7 @@ curl -X POST http://localhost:8001/topics \ 接着要開始對叢集輸入資料，我們在 P1 設備上執行下面的指令以啓動 -[Astraea Performance Tool](https://github.com/skiptests/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/performance_benchmark.md) +[Astraea Performance Tool](https://github.com/opensource4you/astraea/blob/7596f590ae0f0ec370a6e257c10cc2aeb5fb5bf4/docs/performance_benchmark.md) ```shell ./gradlew run --args="performance --bootstrap.servers --topics imbalance-topic --producers 8 --consumers 16 --key.size 10KiB --run.until 3h" diff --git a/docs/balancer/experiment_2.md b/docs/balancer/experiment_2.md index 05f75d828e..a9fc741ddc 100644 --- a/docs/balancer/experiment_2.md +++ b/docs/balancer/experiment_2.md @@ -2,7 +2,7 @@ > 這個實驗的內容和 [Experiment 1](./experiment_1.md) 目標雷同，只是透過 Web API 來做負載平衡 -這個測試展示目前的 Astraea Balancer [(5883c0d)](https://github.com/skiptests/astraea/tree/5883c0d5fbfb178714a4b3ab375d264ffcf7408d) +這個測試展示目前的 Astraea Balancer [(5883c0d)](https://github.com/opensource4you/astraea/tree/5883c0d5fbfb178714a4b3ab375d264ffcf7408d) 能在特定的系統環境中，平衡每個節點的 leader 數。 在這次實驗中，Astraea Balancer 得到了以下結果： @@ -12,7 +12,7 @@ ## 測試情境 -我們透過專案內的 [WebAPI](https://github.com/skiptests/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/web_server/web_api_topics_chinese.md#%E5%BB%BA%E7%AB%8B-topic) +我們透過專案內的 [WebAPI](https://github.com/opensource4you/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/web_server/web_api_topics_chinese.md#%E5%BB%BA%E7%AB%8B-topic) 工具來對測試叢集產生一個 Leader 數量不平衡的情境。WebAPI 在建立 topic 時能夠透過特定參數來以 Binomial Distribution 營造 topic logs 在叢集內分佈不均的情況。這最終形成的分佈類似於對生產環境 Kafka 叢集不斷加減 topics/partitions/nodes 所導致的資料配置不均勻狀態。 @@ -73,8 +73,8 @@ ### 建立 Kafka 叢集 請依照上述的環境建立叢集，您可以使用專案內的 -[./docker/start_zookeeper.sh](https://github.com/skiptests/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_zookeeper.md) 和 -[./docker/start_broker.sh](https://github.com/skiptests/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_kafka_broker.md) 來建立叢集。 +[./docker/start_zookeeper.sh](https://github.com/opensource4you/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_zookeeper.md) 和 +[./docker/start_broker.sh](https://github.com/opensource4you/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_kafka_broker.md) 來建立叢集。 ## 效能資料攝取 @@ -83,9 +83,9 @@ 進行底層硬體效能資料的攝取。 您可以使用專案內的 -[./docker/start_node_exporter.sh](https://github.com/skiptests/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_node_exporter.md), -[./docker/start_prometheus.sh](https://github.com/skiptests/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_prometheus.md) 和 -[./docker/start_grafana.sh](https://github.com/skiptests/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_grafana.md) 來建構監控環境。 +[./docker/start_node_exporter.sh](https://github.com/opensource4you/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_node_exporter.md), +[./docker/start_prometheus.sh](https://github.com/opensource4you/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_prometheus.md) 和 +[./docker/start_grafana.sh](https://github.com/opensource4you/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/run_grafana.md) 來建構監控環境。 本次實驗所使用的 Dashboard 可以在[這裡](resources/experiment_1_grafana-1663659783116.json)找到 @@ -94,7 +94,7 @@ 首先取得 Astraea Project ```script -git clone https://github.com/skiptests/astraea.git +git clone https://github.com/opensource4you/astraea.git cd astraea git checkout 5883c0d5fbfb178714a4b3ab375d264ffcf7408d ``` @@ -119,7 +119,7 @@ curl -X POST http://localhost:8001/topics \ 接着要開始對叢集輸入資料，我們在 P1 設備上執行下面的指令以啓動 -[Astraea Performance Tool](https://github.com/skiptests/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/performance_benchmark.md) +[Astraea Performance Tool](https://github.com/opensource4you/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/performance_benchmark.md) ```shell ./gradlew run --args="performance --bootstrap.servers --topics imbalance-topic --producers 8 --consumers 16 --key.size 10KiB --run.until 3h" @@ -200,7 +200,7 @@ curl -X PUT http://localhost:8001/balancer \ > 如果計劃執行失敗，可以檢查 `exception` 欄位的訊息，或是查看 Web Service 是否有印出錯誤的資訊，來做進一步的診斷。 -> 詳細的 `/balancer` API 文件，可以參考[這裡](https://github.com/skiptests/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/web_server/web_api_balancer_chinese.md) +> 詳細的 `/balancer` API 文件，可以參考[這裡](https://github.com/opensource4you/astraea/blob/5883c0d5fbfb178714a4b3ab375d264ffcf7408d/docs/web_server/web_api_balancer_chinese.md) 每次執行上述步驟都會做一輪的負載平衡，每次都會給叢集帶來一定程度的進步，通常情況下您會需要重複執行多次上述的指令，直到您覺得叢集負載不平衡情況減緩爲止。 這次實驗中我們總共執行了 8 次 Balancer。以下爲各項結果圖表： diff --git a/docs/build_project.md b/docs/build_project.md index 3c5c160651..0d417a43f6 100644 --- a/docs/build_project.md +++ b/docs/build_project.md @@ -50,7 +50,7 @@ docker run --rm -ti \ -v $HOME/project/astraea:/tmp/astraea \ - ghcr.io/skiptests/astraea/deps \ + ghcr.io/opensource4you/astraea/deps \ /bin/bash 在運行的 container 中移至 `/tmp/astraea` 後，透過上方方式測試專案 \ No newline at end of file diff --git a/docs/gui/env/README.md b/docs/gui/env/README.md index ff790c3255..3ae1cf04dd 100644 --- a/docs/gui/env/README.md +++ b/docs/gui/env/README.md @@ -4,7 +4,7 @@ ![download_jre](download_jre.png) -2. 下載 `Astraea GUI` 可執行檔，進到[Astraea GUI 可執行檔頁面](https://github.com/skiptests/astraea/packages/1725262)後搜尋結尾為`-all.jar`的檔案 +2. 下載 `Astraea GUI` 可執行檔，進到[Astraea GUI 可執行檔頁面](https://github.com/opensource4you/astraea/packages/1725262)後搜尋結尾為`-all.jar`的檔案 ![download_gui](download_gui.png) diff --git a/docs/gui/replica/README.md b/docs/gui/replica/README.md index 89a4da87c3..dd58a150fc 100644 --- a/docs/gui/replica/README.md +++ b/docs/gui/replica/README.md @@ -17,7 +17,7 @@ ## 搬移 replicas 下方的`move to broker`提供您將`replica` 搬移到不同的broker上 -* 參考 [Run Kafka Broker](https://github.com/skiptests/astraea/blob/main/docs/run_kafka_broker.md) 來建立多個Brokers +* 參考 [Run Kafka Broker](https://github.com/opensource4you/astraea/blob/main/docs/run_kafka_broker.md) 來建立多個Brokers 1. 使用者可以透過搜尋欄，增加查詢條件（支援Regex),來選出要搬移的replica 2. 按enable確認後,在按ALTER進行搬移 ![offline_replicas](replica_move_success.png) diff --git a/docs/gui/setting/README.md b/docs/gui/setting/README.md index 3ad236ecd1..572ee6addb 100644 --- a/docs/gui/setting/README.md +++ b/docs/gui/setting/README.md @@ -4,11 +4,11 @@ Astraea GUI 使用 Kafka APIs 與 JMX APIs 來協助管理叢集，因此使用 ![setting](setting.png) -*`bootstrap servers(必要欄位)` : bootstrap的IP, 讓 Astraea GUI 發送 admin request,可參考[Run Kafka Broker](https://github.com/skiptests/astraea/blob/main/docs/run_kafka_broker.md) +*`bootstrap servers(必要欄位)` : bootstrap的IP, 讓 Astraea GUI 發送 admin request,可參考[Run Kafka Broker](https://github.com/opensource4you/astraea/blob/main/docs/run_kafka_broker.md) -*`jmx port(非必要欄位)`: jmx Port , 叢集如果有開啟對外的`jmx`服務，建議設定`jmx port` , Astraea GUI 可透過`jmx`提供豐富的`metrics`查詢功能。可參考 [Run Kafka Broker](https://github.com/skiptests/astraea/blob/main/docs/run_kafka_broker.md) +*`jmx port(非必要欄位)`: jmx Port , 叢集如果有開啟對外的`jmx`服務，建議設定`jmx port` , Astraea GUI 可透過`jmx`提供豐富的`metrics`查詢功能。可參考 [Run Kafka Broker](https://github.com/opensource4you/astraea/blob/main/docs/run_kafka_broker.md) -*`worker url(非必要欄位)` : worker的IP, 讓 Astraea GUI 取得 worker以及connector的相關資訊:可參考 [Run Kafka Worker](https://github.com/skiptests/astraea/blob/main/docs/run_kafka_worker.md) +*`worker url(非必要欄位)` : worker的IP, 讓 Astraea GUI 取得 worker以及connector的相關資訊:可參考 [Run Kafka Worker](https://github.com/opensource4you/astraea/blob/main/docs/run_kafka_worker.md) *`worker jmx port(非必要欄位)` : worker jmx Port diff --git a/docs/kafka_Q&A.md b/docs/kafka_Q&A.md index 94e0a92f88..ec2f2f7c7c 100644 --- a/docs/kafka_Q&A.md +++ b/docs/kafka_Q&A.md @@ -23,7 +23,7 @@ Consumer: 調整Consumer config的"receive.buffer.bytes"，建議設定為-1， ### 詳細討論 -[#1518](https://github.com/skiptests/astraea/issues/1516) +[#1518](https://github.com/opensource4you/astraea/issues/1516) @@ -50,5 +50,5 @@ Consumer 拉取資料的簡短流程： ### 詳細討論 -[#1475](https://github.com/skiptests/astraea/issues/1475) +[#1475](https://github.com/opensource4you/astraea/issues/1475) diff --git a/docs/partitioner/README.md b/docs/partitioner/README.md index db3e05e0bb..4576283312 100644 --- a/docs/partitioner/README.md +++ b/docs/partitioner/README.md @@ -7,7 +7,7 @@ Astraea Partitioner 是強大且高效率的 Kafka Partitioner 實作，提供 ```gradle repositories { maven { - url = "https://maven.pkg.github.com/skiptests/astraea" + url = "https://maven.pkg.github.com/opensource4you/astraea" credentials { username = System.getenv("GITHUB_ACTOR") password = System.getenv("GITHUB_TOKEN") @@ -109,7 +109,7 @@ Partitioner.endInterdependent(producer); experiments 資料夾中收錄不同版本的實驗紀錄，主要使用 [performance tool](../performance_benchmark.md) 測試並紀錄數據。 -* [2022 Aug28](experiments/StrictCostDispatcher_1.md), 測試 [Strict Cost Partitioner](./strict_cost_partitioner.md) (Astraea revision: [75bcc3faa39864d5ec5f5ed530346184e79fc0c9](https://github.com/skiptests/astraea/tree/75bcc3faa39864d5ec5f5ed530346184e79fc0c9)) -* [2022 Oct1](experiments/StrictCostDispatcher_2.md), 測試資源充足下 [interdependent message](#astraea-partitioner--interdependent-message--功能) 對 [Strict Cost Partitioner](./strict_cost_partitioner.md) 的影響 (Astraea revision: [08b4e32f31091a3de69775db5442eb631deca550](https://github.com/skiptests/astraea/tree/08b4e32f31091a3de69775db5442eb631deca550)) -* [2022 Oct1](experiments/StrictCostDispatcher_3.md), 測試高壓下 [interdependent message](#astraea-partitioner--interdependent-message--功能) 對 [Strict Cost Partitioner](./strict_cost_partitioner.md) 的影響 (Astraea revision: [08b4e32f31091a3de69775db5442eb631deca550](https://github.com/skiptests/astraea/tree/08b4e32f31091a3de69775db5442eb631deca550)) -* [2022 Dec17](experiments/StrictCostDispatcher_4.md), 測試多台 producer 同時發送訊息時，[Strict Cost Partitioner](./strict_cost_partitioner.md) 的表現，並比較 [Strict Cost Partitioner](./strict_cost_partitioner.md) 、 Kafka Built-In Partitioner 和 Default Partitioner 的吞吐量、發送延遲。(Astraea revision: [5003f424e9cef4d27bbc56621d6e42f19a687a61](https://github.com/skiptests/astraea/tree/5003f424e9cef4d27bbc56621d6e42f19a687a61)) \ No newline at end of file +* [2022 Aug28](experiments/StrictCostDispatcher_1.md), 測試 [Strict Cost Partitioner](./strict_cost_partitioner.md) (Astraea revision: [75bcc3faa39864d5ec5f5ed530346184e79fc0c9](https://github.com/opensource4you/astraea/tree/75bcc3faa39864d5ec5f5ed530346184e79fc0c9)) +* [2022 Oct1](experiments/StrictCostDispatcher_2.md), 測試資源充足下 [interdependent message](#astraea-partitioner--interdependent-message--功能) 對 [Strict Cost Partitioner](./strict_cost_partitioner.md) 的影響 (Astraea revision: [08b4e32f31091a3de69775db5442eb631deca550](https://github.com/opensource4you/astraea/tree/08b4e32f31091a3de69775db5442eb631deca550)) +* [2022 Oct1](experiments/StrictCostDispatcher_3.md), 測試高壓下 [interdependent message](#astraea-partitioner--interdependent-message--功能) 對 [Strict Cost Partitioner](./strict_cost_partitioner.md) 的影響 (Astraea revision: [08b4e32f31091a3de69775db5442eb631deca550](https://github.com/opensource4you/astraea/tree/08b4e32f31091a3de69775db5442eb631deca550)) +* [2022 Dec17](experiments/StrictCostDispatcher_4.md), 測試多台 producer 同時發送訊息時，[Strict Cost Partitioner](./strict_cost_partitioner.md) 的表現，並比較 [Strict Cost Partitioner](./strict_cost_partitioner.md) 、 Kafka Built-In Partitioner 和 Default Partitioner 的吞吐量、發送延遲。(Astraea revision: [5003f424e9cef4d27bbc56621d6e42f19a687a61](https://github.com/opensource4you/astraea/tree/5003f424e9cef4d27bbc56621d6e42f19a687a61)) \ No newline at end of file diff --git a/docs/partitioner/experiments/StrictCostDispatcher_2.md b/docs/partitioner/experiments/StrictCostDispatcher_2.md index e948b51ec3..b395bc0c00 100644 --- a/docs/partitioner/experiments/StrictCostDispatcher_2.md +++ b/docs/partitioner/experiments/StrictCostDispatcher_2.md @@ -112,7 +112,7 @@ REVISION=08b4e32f31091a3de69775db5442eb631deca550 docker/start_app.sh performanc 從平均延遲來看，使用 `interdependent` 的延遲會上升，預設的 `StrictCostDispatcher` 是使用延遲判斷，`interdependent` 的限制也讓平均延遲有所增加。（這裡紀錄的延遲是 "moving average" 的一種，每秒取的 "moving average" 彼此都有相依性。每一秒取的 "moving average" 都是有個別意義的。所以這裡沒有寫出一個具體的數字，直接看圖表的意義會比較準確。） -另外，比較[先前的實驗結果](StrictCostDispatcher_1.md)，會發現延遲的數據有極大的差異，[先前的實驗](StrictCostDispatcher_1.md) 延遲落在 \~200 ms ，但這次的實驗延遲落在 ~1 ms，主要原因是 [PR 711](https://github.com/skiptests/astraea/pull/711) 修改了數據的紀錄方式，原先量測的延遲是 user -> producer -> request -> server -> response -> producer -> user，現在抓取的latency則是只有統計 request -> server -> response 這一段，兩者量測的路徑有明顯的不同，所以這次實驗的延遲才會和[先前實驗](StrictCostDispatcher_1.md)的延遲有很大的差距。 +另外，比較[先前的實驗結果](StrictCostDispatcher_1.md)，會發現延遲的數據有極大的差異，[先前的實驗](StrictCostDispatcher_1.md) 延遲落在 \~200 ms ，但這次的實驗延遲落在 ~1 ms，主要原因是 [PR 711](https://github.com/opensource4you/astraea/pull/711) 修改了數據的紀錄方式，原先量測的延遲是 user -> producer -> request -> server -> response -> producer -> user，現在抓取的latency則是只有統計 request -> server -> response 這一段，兩者量測的路徑有明顯的不同，所以這次實驗的延遲才會和[先前實驗](StrictCostDispatcher_1.md)的延遲有很大的差距。 ![](../../pictures/partitioner_experiment2_1.png) diff --git a/docs/web_server/web_api_metricSensors_chinese.md b/docs/web_server/web_api_metricSensors_chinese.md index 9096dc2444..3be9dcdd5a 100644 --- a/docs/web_server/web_api_metricSensors_chinese.md +++ b/docs/web_server/web_api_metricSensors_chinese.md @@ -1,7 +1,7 @@ /metricSensors === -此api用來指定未來可能會想要使用的`Costfunction`之`MetricSensors`，主要功能如下 (相關討論請看[#1665](https://github.com/skiptests/astraea/pull/1665)) : +此api用來指定未來可能會想要使用的`Costfunction`之`MetricSensors`，主要功能如下 (相關討論請看[#1665](https://github.com/opensource4you/astraea/pull/1665)) : - [指定MetricSensors](#指定-MetricSensors): 選擇要使用的`Costfunction`之`MetricSensor` - [查詢已指定的 MetricSensors](#查詢已指定的-MetricSensors): 查看當前已指定之`MetricSensor`的`CostFunction` diff --git a/gui/build.gradle b/gui/build.gradle index 70d1f840dc..170b9a369d 100644 --- a/gui/build.gradle +++ b/gui/build.gradle @@ -64,7 +64,7 @@ publishing { } repositories { maven { - url = "https://maven.pkg.github.com/skiptests/astraea" + url = "https://maven.pkg.github.com/opensource4you/astraea" credentials { username = System.getenv("GITHUB_ACTOR") password = System.getenv("GITHUB_TOKEN") diff --git a/gui/src/main/java/org/astraea/gui/tab/AboutNode.java b/gui/src/main/java/org/astraea/gui/tab/AboutNode.java index acdcfd0fb2..418f911d6e 100644 --- a/gui/src/main/java/org/astraea/gui/tab/AboutNode.java +++ b/gui/src/main/java/org/astraea/gui/tab/AboutNode.java @@ -43,7 +43,7 @@ private enum Info { "build date", VersionUtils.DATE, "web site", - "https://github.com/skiptests/astraea"))), + "https://github.com/opensource4you/astraea"))), Author( "維護者", List.of(