diff options
| author | chrislu <chris.lu@gmail.com> | 2022-10-11 21:58:17 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-10-11 21:58:17 -0700 |
| commit | 0d817bc347188c2dd994245f992472690395c85d (patch) | |
| tree | 01c091cd4129b2a49578b0bbb770f7c3067257d9 | |
| parent | f6c8720ded2158eeb2ae103b41e029ace092af55 (diff) | |
| download | seaweedfs-0d817bc347188c2dd994245f992472690395c85d.tar.xz seaweedfs-0d817bc347188c2dd994245f992472690395c85d.zip | |
fix invalid memory address or nil pointer dereference on filer.sync
fix https://github.com/seaweedfs/seaweedfs/issues/3826
| -rw-r--r-- | weed/replication/sink/filersink/filer_sink.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/sink/filersink/filer_sink.go b/weed/replication/sink/filersink/filer_sink.go index 3af5a4a80..b922be568 100644 --- a/weed/replication/sink/filersink/filer_sink.go +++ b/weed/replication/sink/filersink/filer_sink.go @@ -54,7 +54,6 @@ func (fs *FilerSink) IsIncremental() bool { func (fs *FilerSink) Initialize(configuration util.Configuration, prefix string) error { fs.isIncremental = configuration.GetBool(prefix + "is_incremental") fs.dataCenter = configuration.GetString(prefix + "dataCenter") - fs.executor = util.NewLimitedConcurrentExecutor(32) return fs.DoInitialize( "", configuration.GetString(prefix+"grpcAddress"), @@ -85,6 +84,7 @@ func (fs *FilerSink) DoInitialize(address, grpcAddress string, dir string, fs.diskType = diskType fs.grpcDialOption = grpcDialOption fs.writeChunkByFiler = writeChunkByFiler + fs.executor = util.NewLimitedConcurrentExecutor(32) return nil } |