Skip to content

Commit 5226d04

Browse files
stdpainstdpain
committed
fix up
Signed-off-by: stdpain <[email protected]>
1 parent 169cab5 commit 5226d04

25 files changed

+121
-42
lines changed

‎be/src/exec/cross_join_node.cpp

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -609,8 +609,10 @@ std::vector<std::shared_ptr<pipeline::OperatorFactory>> CrossJoinNode::_decompos
609609
std::move(_conjunct_ctxs), std::move(cross_join_context), _join_op);
610610
// Initialize OperatorFactory's fields involving runtime filters.
611611
this->init_runtime_filter_for_operator(left_factory.get(), context, rc_rf_probe_collector);
612-
left_ops = context->maybe_interpolate_local_adpative_passthrough_exchange(runtime_state(), id(), left_ops,
613-
context->degree_of_parallelism());
612+
if (context->is_colocate_group()) {
613+
left_ops = context->maybe_interpolate_local_adpative_passthrough_exchange(runtime_state(), id(), left_ops,
614+
context->degree_of_parallelism());
615+
}
614616
left_ops.emplace_back(std::move(left_factory));
615617

616618
if (limit() != -1) {

‎be/src/exec/hash_join_node.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -546,7 +546,8 @@ pipeline::OpFactories HashJoinNode::_decompose_to_pipeline(pipeline::PipelineBui
546546
lhs_operators.emplace_back(std::make_shared<LimitOperatorFactory>(context->next_operator_id(), id(), limit()));
547547
}
548548

549-
if (_hash_join_node.__isset.interpolate_passthrough && _hash_join_node.interpolate_passthrough) {
549+
if (_hash_join_node.__isset.interpolate_passthrough && _hash_join_node.interpolate_passthrough &&
550+
!context->is_colocate_group()) {
550551
lhs_operators = context->maybe_interpolate_local_passthrough_exchange(runtime_state(), id(), lhs_operators,
551552
context->degree_of_parallelism(), true);
552553
}

‎be/src/exec/pipeline/fragment_context.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,13 +63,11 @@ void FragmentContext::set_data_sink(std::unique_ptr<DataSink> data_sink) {
6363
void FragmentContext::count_down_execution_group(size_t val) {
6464
// Note that _pipelines may be destructed after fetch_add
6565
// memory_order_seq_cst semantics ensure that previous code does not reorder after fetch_add
66-
LOG(WARNING) << "TRACE count down exec group:" << _num_finished_execution_groups << ":" << _execution_groups.size();
6766
size_t total_execution_groups = _execution_groups.size();
6867
bool all_groups_finished = _num_finished_execution_groups.fetch_add(val) + val == total_execution_groups;
6968
if (!all_groups_finished) {
7069
return;
7170
}
72-
LOG(WARNING) << "TRACE count down fragment" << this;
7371

7472
// dump profile if necessary
7573
auto* state = runtime_state();

‎be/src/exec/pipeline/group_execution/execution_group.cpp

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,17 @@
1+
// Copyright 2021-present StarRocks, Inc. All rights reserved.
2+
//
3+
// Licensed under the Apache License, Version 2.0 (the "License");
4+
// you may not use this file except in compliance with the License.
5+
// You may obtain a copy of the License at
6+
//
7+
// https://www.apache.org/licenses/LICENSE-2.0
8+
//
9+
// Unless required by applicable law or agreed to in writing, software
10+
// distributed under the License is distributed on an "AS IS" BASIS,
11+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
// See the License for the specific language governing permissions and
13+
// limitations under the License.
14+
115
#include "exec/pipeline/group_execution/execution_group.h"
216

317
#include "common/logging.h"

‎be/src/exec/pipeline/group_execution/execution_group.h

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,17 @@
1+
// Copyright 2021-present StarRocks, Inc. All rights reserved.
2+
//
3+
// Licensed under the Apache License, Version 2.0 (the "License");
4+
// you may not use this file except in compliance with the License.
5+
// You may obtain a copy of the License at
6+
//
7+
// https://www.apache.org/licenses/LICENSE-2.0
8+
//
9+
// Unless required by applicable law or agreed to in writing, software
10+
// distributed under the License is distributed on an "AS IS" BASIS,
11+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
// See the License for the specific language governing permissions and
13+
// limitations under the License.
14+
115
#pragma once
216

317
#include <atomic>
@@ -51,7 +65,6 @@ class ExecutionGroup {
5165
void attach_driver_executor(DriverExecutor* executor) { _executor = executor; }
5266

5367
void count_down_pipeline(RuntimeState* state) {
54-
LOG(WARNING) << "TRACE count pipeline:" << _num_finished_pipelines << ":" << _num_pipelines;
5568
if (++_num_finished_pipelines == _num_pipelines) {
5669
state->fragment_ctx()->count_down_execution_group();
5770
}

‎be/src/exec/pipeline/group_execution/execution_group_builder.cpp

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,17 @@
1+
// Copyright 2021-present StarRocks, Inc. All rights reserved.
2+
//
3+
// Licensed under the Apache License, Version 2.0 (the "License");
4+
// you may not use this file except in compliance with the License.
5+
// You may obtain a copy of the License at
6+
//
7+
// https://www.apache.org/licenses/LICENSE-2.0
8+
//
9+
// Unless required by applicable law or agreed to in writing, software
10+
// distributed under the License is distributed on an "AS IS" BASIS,
11+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
// See the License for the specific language governing permissions and
13+
// limitations under the License.
14+
115
#include "exec/pipeline/group_execution/execution_group_builder.h"
216

317
#include "common/logging.h"

‎be/src/exec/pipeline/group_execution/execution_group_builder.h

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,17 @@
1+
// Copyright 2021-present StarRocks, Inc. All rights reserved.
2+
//
3+
// Licensed under the Apache License, Version 2.0 (the "License");
4+
// you may not use this file except in compliance with the License.
5+
// You may obtain a copy of the License at
6+
//
7+
// https://www.apache.org/licenses/LICENSE-2.0
8+
//
9+
// Unless required by applicable law or agreed to in writing, software
10+
// distributed under the License is distributed on an "AS IS" BASIS,
11+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
// See the License for the specific language governing permissions and
13+
// limitations under the License.
14+
115
#pragma once
216

317
#include <cstddef>

‎be/src/exec/pipeline/group_execution/execution_group_fwd.h

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,17 @@
1+
// Copyright 2021-present StarRocks, Inc. All rights reserved.
2+
//
3+
// Licensed under the Apache License, Version 2.0 (the "License");
4+
// you may not use this file except in compliance with the License.
5+
// You may obtain a copy of the License at
6+
//
7+
// https://www.apache.org/licenses/LICENSE-2.0
8+
//
9+
// Unless required by applicable law or agreed to in writing, software
10+
// distributed under the License is distributed on an "AS IS" BASIS,
11+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
// See the License for the specific language governing permissions and
13+
// limitations under the License.
14+
115
#pragma once
216
#include <memory>
317
#include <vector>

‎be/src/exec/pipeline/group_execution/group_operator.cpp

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,24 @@
1+
// Copyright 2021-present StarRocks, Inc. All rights reserved.
2+
//
3+
// Licensed under the Apache License, Version 2.0 (the "License");
4+
// you may not use this file except in compliance with the License.
5+
// You may obtain a copy of the License at
6+
//
7+
// https://www.apache.org/licenses/LICENSE-2.0
8+
//
9+
// Unless required by applicable law or agreed to in writing, software
10+
// distributed under the License is distributed on an "AS IS" BASIS,
11+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
// See the License for the specific language governing permissions and
13+
// limitations under the License.
14+
115
#include "exec/pipeline/group_execution/group_operator.h"
216

317
#include "exec/pipeline/group_execution/execution_group.h"
418
#include "exec/pipeline/operator.h"
519
#include "gutil/casts.h"
620

721
namespace starrocks::pipeline {
8-
void GroupContext::submit(RuntimeState* state) {}
9-
1022
Status GroupedExecutionSinkOperator::prepare(RuntimeState* state) {
1123
RETURN_IF_ERROR(Operator::prepare(state));
1224
_exchanger->incr_sinker();

‎be/src/exec/pipeline/group_execution/group_operator.h

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,17 @@
1+
// Copyright 2021-present StarRocks, Inc. All rights reserved.
2+
//
3+
// Licensed under the Apache License, Version 2.0 (the "License");
4+
// you may not use this file except in compliance with the License.
5+
// You may obtain a copy of the License at
6+
//
7+
// https://www.apache.org/licenses/LICENSE-2.0
8+
//
9+
// Unless required by applicable law or agreed to in writing, software
10+
// distributed under the License is distributed on an "AS IS" BASIS,
11+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
// See the License for the specific language governing permissions and
13+
// limitations under the License.
14+
115
#pragma once
216

317
#include <utility>
@@ -11,13 +25,6 @@
1125
#include "runtime/runtime_state.h"
1226

1327
namespace starrocks::pipeline {
14-
class GroupContext {
15-
public:
16-
void submit(RuntimeState* state);
17-
18-
private:
19-
ExecutionGroup* _groups;
20-
};
2128
// P1: SourceOp->ProjectOp->JoinProbeOp->ProjectOp->ExchangeSink
2229
// =>
2330
// P1: SourceOp->ProjectOp->JoinProbeOp->ProjectOp->GroupedSinkOp

‎be/src/exec/pipeline/pipeline_builder.cpp

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,8 @@ OpFactories PipelineBuilderContext::_maybe_interpolate_local_passthrough_exchang
121121
return pred_operators;
122122
}
123123

124+
pred_operators = maybe_interpolate_grouped_exchange(plan_node_id, pred_operators);
125+
124126
int max_input_dop = std::max(num_receivers, static_cast<int>(source_op->degree_of_parallelism()));
125127
auto mem_mgr = std::make_shared<ChunkBufferMemoryManager>(max_input_dop,
126128
config::local_exchange_buffer_mem_limit_per_driver);
@@ -502,7 +504,7 @@ void PipelineBuilderContext::pop_dependent_pipeline() {
502504

503505
void PipelineBuilderContext::_subscribe_pipeline_event(Pipeline* pipeline) {
504506
bool enable_wait_event = _fragment_context->runtime_state()->enable_wait_dependent_event();
505-
enable_wait_event &= _current_execution_group->is_colocate_exec_group();
507+
enable_wait_event &= !_current_execution_group->is_colocate_exec_group();
506508
if (enable_wait_event && !_dependent_pipelines.empty()) {
507509
pipeline->pipeline_event()->set_need_wait_dependencies_finished(true);
508510
pipeline->pipeline_event()->add_dependency(_dependent_pipelines.back()->pipeline_event());

‎be/src/exec/pipeline/query_context.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,8 +74,6 @@ QueryContext::~QueryContext() noexcept {
7474
if (_connector_scan_mem_tracker != nullptr) {
7575
_connector_scan_mem_tracker->release_without_root();
7676
}
77-
78-
LOG(WARNING) << "TRACE query ctx";
7977
}
8078

8179
void QueryContext::count_down_fragments() {

‎be/src/exec/pipeline/runtime_filter_types.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,6 @@ class RuntimeFilterHolder {
123123
private:
124124
RuntimeFilterCollectorPtr _collector_ownership;
125125
std::atomic<RuntimeFilterCollector*> _collector;
126-
std::mutex _mutex;
127126
};
128127

129128
// RuntimeFilterHub is a mediator that used to gather all runtime filters generated by RuntimeFilterBuild instances.
@@ -166,7 +165,7 @@ class RuntimeFilterHub {
166165
bool is_colocate_runtime_filters(TPlanNodeId plan_node_id) const {
167166
auto it = _holders.find(plan_node_id);
168167
DCHECK(it != _holders.end());
169-
return it->second.size() > 1;
168+
return it->second.find(-1) == it->second.end();
170169
}
171170

172171
// if strict is false, return instance level holder if not found pipeline level holder

‎be/src/exprs/runtime_filter_bank.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -396,8 +396,6 @@ void RuntimeFilterProbeCollector::do_evaluate(Chunk* chunk, RuntimeBloomFilterEv
396396

397397
for (auto& kv : seletivity_map) {
398398
RuntimeFilterProbeDescriptor* rf_desc = kv.second;
399-
// eval_context.driver_sequence;
400-
// get_runtime_filter
401399
const JoinRuntimeFilter* filter = rf_desc->runtime_filter(eval_context.driver_sequence);
402400
if (filter == nullptr || filter->always_true()) {
403401
continue;

‎be/src/exprs/runtime_filter_bank.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -176,15 +176,14 @@ class RuntimeFilterProbeDescriptor : public WithLayoutMixin {
176176
int8_t join_mode() const { return _join_mode; };
177177
const std::vector<ExprContext*>* partition_by_expr_contexts() const { return &_partition_by_exprs_contexts; }
178178

179-
// const JoinRuntimeFilter* runtime_filter() const { return _runtime_filter.load(); }
180179
const JoinRuntimeFilter* runtime_filter(int32_t driver_sequence) const {
181180
auto runtime_filter = _runtime_filter.load();
182181
if (runtime_filter != nullptr && runtime_filter->is_colocate_filter()) {
183182
DCHECK_GE(driver_sequence, 0);
184183
DCHECK_LT(driver_sequence, runtime_filter->colocate_filter().size());
185184
return runtime_filter->colocate_filter()[driver_sequence];
186185
}
187-
return nullptr;
186+
return runtime_filter;
188187
}
189188
void set_runtime_filter(const JoinRuntimeFilter* rf);
190189
void set_shared_runtime_filter(const std::shared_ptr<const JoinRuntimeFilter>& rf);

‎be/test/exec/pipeline/pipeline_file_scan_node_test.cpp

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,10 @@ void PipeLineFileScanNodeTest::execute_pipeline() {
250250
_fragment_ctx->iterate_drivers(
251251
[state = _fragment_ctx->runtime_state()](const DriverPtr& driver) { return driver->prepare(state); });
252252

253-
CHECK_OK(_fragment_ctx->submit_active_drivers(_exec_env->wg_driver_executor()));
253+
_fragment_ctx->iterate_drivers([exec_env = _exec_env](const DriverPtr& driver) {
254+
LOG(WARNING) << driver->to_readable_string();
255+
exec_env->wg_driver_executor()->submit(driver.get());
256+
});
254257
}
255258

256259
void PipeLineFileScanNodeTest::generate_morse_queue(const std::vector<starrocks::ConnectorScanNode*>& scan_nodes,
@@ -404,7 +407,6 @@ TEST_F(PipeLineFileScanNodeTest, CSVBasic) {
404407
starrocks::pipeline::CounterPtr sinkCounter = std::make_shared<starrocks::pipeline::FileScanCounter>();
405408

406409
exec_group = ExecutionGroupBuilder::create_normal_exec_group();
407-
_fragment_ctx->set_exec_groups({exec_group});
408410

409411
OpFactories op_factories = file_scan_node->decompose_to_pipeline(_context);
410412

@@ -414,6 +416,7 @@ TEST_F(PipeLineFileScanNodeTest, CSVBasic) {
414416
_pipelines.push_back(
415417
std::make_shared<starrocks::pipeline::Pipeline>(_context->next_pipe_id(), op_factories, exec_group.get()));
416418
exec_group->add_pipeline(_pipelines.back());
419+
_fragment_ctx->set_exec_groups({exec_group});
417420

418421
prepare_pipeline();
419422

‎fe/fe-core/src/main/java/com/starrocks/planner/ExchangeNode.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@
3939
import com.google.common.base.Preconditions;
4040
import com.google.common.collect.Lists;
4141
import com.starrocks.analysis.Analyzer;
42-
import com.starrocks.analysis.DescriptorTable;
4342
import com.starrocks.analysis.Expr;
4443
import com.starrocks.analysis.SlotRef;
4544
import com.starrocks.analysis.SortInfo;

‎fe/fe-core/src/main/java/com/starrocks/planner/ExecGroupSets.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public ExecGroup getExecGroup(int nodeId) {
4545
return execGroup;
4646
}
4747
}
48-
Preconditions.checkState(false, "not found exec group node:" + nodeId);
48+
Preconditions.checkState(false, "not found exec group node: %d", nodeId);
4949
return null;
5050
}
5151
}

‎fe/fe-core/src/main/java/com/starrocks/planner/PlanFragment.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,6 @@
5858
import com.starrocks.thrift.TResultSinkType;
5959
import org.apache.commons.collections.CollectionUtils;
6060
import org.apache.commons.collections4.MapUtils;
61-
import org.apache.parquet.Strings;
6261

6362
import java.nio.ByteBuffer;
6463
import java.util.ArrayList;

‎fe/fe-core/src/main/java/com/starrocks/planner/PlanNode.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -898,8 +898,6 @@ private boolean tryPushdownRuntimeFilterToChild(RuntimeFilterPushDownContext con
898898
Optional<List<Expr>> optProbeExprCandidates,
899899
Optional<List<List<Expr>>> optPartitionByExprsCandidates,
900900
int childIdx) {
901-
RuntimeFilterDescription description = context.getDescription();
902-
DescriptorTable descTbl = context.getDescTbl();
903901
if (!optProbeExprCandidates.isPresent() || !optPartitionByExprsCandidates.isPresent()) {
904902
return false;
905903
}

‎fe/fe-core/src/main/java/com/starrocks/planner/RuntimeFilterDescription.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -344,13 +344,9 @@ public int getNumDriversPerInstance() {
344344
return numDriversPerInstance;
345345
}
346346

347-
public void setIsBuildFromColocateGroup(boolean buildFromColocateGroup) {
348-
this.isBuildFromColocateGroup = buildFromColocateGroup;
349-
}
350-
351347
public void setExecGroupInfo(boolean buildFromColocateGroup, int buildExecGroupId) {
352348
this.isBuildFromColocateGroup = buildFromColocateGroup;
353-
this.execGroupId = execGroupId;
349+
this.execGroupId = buildExecGroupId;
354350
}
355351

356352
public boolean canPushAcrossExchangeNode() {

‎fe/fe-core/src/main/java/com/starrocks/planner/RuntimeFilterPushDownContext.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ public class RuntimeFilterPushDownContext {
2727
this.execGroups = execGroupSets;
2828
// set description
2929
ExecGroup execGroup = this.execGroups.getExecGroup(description.getBuildPlanNodeId());
30-
this.description.setIsBuildFromColocateGroup(execGroup.isColocateExecGroup());
30+
this.description.setExecGroupInfo(execGroup.isColocateExecGroup(), execGroup.getGroupId().asInt());
3131
}
3232

3333
public DescriptorTable getDescTbl() {

‎fe/fe-core/src/main/java/com/starrocks/planner/SetOperationNode.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,6 @@
4040
import com.google.common.collect.Maps;
4141
import com.google.common.collect.Sets;
4242
import com.starrocks.analysis.Analyzer;
43-
import com.starrocks.analysis.DescriptorTable;
4443
import com.starrocks.analysis.Expr;
4544
import com.starrocks.analysis.SlotDescriptor;
4645
import com.starrocks.analysis.SlotId;

‎fe/fe-core/src/main/java/com/starrocks/sql/plan/PlanFragmentBuilder.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2318,8 +2318,8 @@ private boolean shouldBuildGlobalRuntimeFilter() {
23182318

23192319
@Override
23202320
public PlanFragment visitPhysicalHashJoin(OptExpression optExpr, ExecPlan context) {
2321-
ExecGroup leftExecGroup = this.currentExecGroup;
23222321
PlanFragment leftFragment = visit(optExpr.inputAt(0), context);
2322+
ExecGroup leftExecGroup = this.currentExecGroup;
23232323
this.currentExecGroup = execGroups.newExecGroup();
23242324
PlanFragment rightFragment = visit(optExpr.inputAt(1), context);
23252325
return visitPhysicalJoin(leftFragment, rightFragment, leftExecGroup, currentExecGroup, optExpr, context);
@@ -2355,8 +2355,8 @@ private void setNullableForJoin(JoinOperator joinOperator,
23552355
@Override
23562356
public PlanFragment visitPhysicalNestLoopJoin(OptExpression optExpr, ExecPlan context) {
23572357
PhysicalJoinOperator node = (PhysicalJoinOperator) optExpr.getOp();
2358-
ExecGroup leftExecGroup = this.currentExecGroup;
23592358
PlanFragment leftFragment = visit(optExpr.inputAt(0), context);
2359+
ExecGroup leftExecGroup = this.currentExecGroup;
23602360
this.currentExecGroup = execGroups.newExecGroup();
23612361
PlanFragment rightFragment = visit(optExpr.inputAt(1), context);
23622362
this.currentExecGroup = leftExecGroup;
@@ -2413,8 +2413,8 @@ public PlanFragment visitPhysicalNestLoopJoin(OptExpression optExpr, ExecPlan co
24132413

24142414
@Override
24152415
public PlanFragment visitPhysicalMergeJoin(OptExpression optExpr, ExecPlan context) {
2416-
ExecGroup leftExecGroup = this.currentExecGroup;
24172416
PlanFragment leftFragment = visit(optExpr.inputAt(0), context);
2417+
ExecGroup leftExecGroup = this.currentExecGroup;
24182418
this.currentExecGroup = execGroups.newExecGroup();
24192419
PlanFragment rightFragment = visit(optExpr.inputAt(1), context);
24202420
PlanNode leftPlanRoot = leftFragment.getPlanRoot();

‎java-extensions/odps-reader/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@
4949
<dependency>
5050
<groupId>com.starrocks</groupId>
5151
<artifactId>jni-connector</artifactId>
52-
<!-- <version>1.0.0</version>-->
52+
<version>1.0.0</version>
5353
</dependency>
5454
<dependency>
5555
<groupId>org.slf4j</groupId>

0 commit comments

Comments
 (0)