Rebase

haanhvu · haanhvu · commit b56a65b9ad0a · 2024-06-23T12:06:35.000+07:00
Signed-off-by: haanhvu &lt;haanh6594@gmail.com&gt;
diff --git a/plugin/storage/clickhouse/factory.go b/plugin/storage/clickhouse/factory.go
@@ -45,11 +45,7 @@ func NewFactory(ctx context.Context, cfg Config, logger *zap.Logger) *Factory {
 }
 
 func (f *Factory) ChExportSpans(ctx context.Context, td ptrace.Traces) error {
-	if err := chSpanStore.ExportSpans(ctx, f.client, f.spansTableName, td); err != nil {
-		return err
-	}
-
-	return nil
+	return chSpanStore.ExportSpans(ctx, f.client, f.spansTableName, td)
 }
 
 func (*Factory) Initialize(_ metrics.Factory, _ *zap.Logger) error {

Original file line number	Diff line number	Diff line change
`@@ -45,11 +45,7 @@ func NewFactory(ctx context.Context, cfg Config, logger zap.Logger) Factory {`
`45`	`45`	`}`
`46`	`46`
`47`	`47`	`func (f *Factory) ChExportSpans(ctx context.Context, td ptrace.Traces) error {`
`48`		`- if err := chSpanStore.ExportSpans(ctx, f.client, f.spansTableName, td); err != nil {`
`49`		`- return err`
`50`		`- }`
`51`		`-`
`52`		`- return nil`
	`48`	`+ return chSpanStore.ExportSpans(ctx, f.client, f.spansTableName, td)`
`53`	`49`	`}`
`54`	`50`
`55`	`51`	`func (Factory) Initialize(_ metrics.Factory, _ zap.Logger) error {`