diff options
| author | chrislu <chris.lu@gmail.com> | 2024-06-17 10:59:41 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-06-17 10:59:41 -0700 |
| commit | a829f36d17cedfe12a1c4a58e58ee464a958cd4e (patch) | |
| tree | cd92e5ce263704b4b2e7664834f1f56dcf497085 /weed/command | |
| parent | e9cee59c8c1e9efabb114911d1f37bad12c57be9 (diff) | |
| download | seaweedfs-a829f36d17cedfe12a1c4a58e58ee464a958cd4e.tar.xz seaweedfs-a829f36d17cedfe12a1c4a58e58ee464a958cd4e.zip | |
adjust error handling
fix https://github.com/seaweedfs/seaweedfs/issues/5677
Diffstat (limited to 'weed/command')
| -rw-r--r-- | weed/command/filer_backup.go | 2 | ||||
| -rw-r--r-- | weed/command/filer_meta_backup.go | 2 | ||||
| -rw-r--r-- | weed/command/filer_remote_gateway_buckets.go | 2 | ||||
| -rw-r--r-- | weed/command/filer_remote_sync_dir.go | 2 |
4 files changed, 4 insertions, 4 deletions
diff --git a/weed/command/filer_backup.go b/weed/command/filer_backup.go index 4aeab60f2..43b7c6256 100644 --- a/weed/command/filer_backup.go +++ b/weed/command/filer_backup.go @@ -158,7 +158,7 @@ func doFilerBackup(grpcDialOption grpc.DialOption, backupOption *FilerBackupOpti DirectoriesToWatch: nil, StartTsNs: startFrom.UnixNano(), StopTsNs: 0, - EventErrorType: pb.TrivialOnError, + EventErrorType: pb.RetryForeverOnError, } return pb.FollowMetadata(sourceFiler, grpcDialOption, metadataFollowOption, processEventFnWithOffset) diff --git a/weed/command/filer_meta_backup.go b/weed/command/filer_meta_backup.go index ff4a61e41..87623cf4e 100644 --- a/weed/command/filer_meta_backup.go +++ b/weed/command/filer_meta_backup.go @@ -207,7 +207,7 @@ func (metaBackup *FilerMetaBackupOptions) streamMetadataBackup() error { DirectoriesToWatch: nil, StartTsNs: startTime.UnixNano(), StopTsNs: 0, - EventErrorType: pb.TrivialOnError, + EventErrorType: pb.RetryForeverOnError, } return pb.FollowMetadata(pb.ServerAddress(*metaBackup.filerAddress), metaBackup.grpcDialOption, metadataFollowOption, processEventFnWithOffset) diff --git a/weed/command/filer_remote_gateway_buckets.go b/weed/command/filer_remote_gateway_buckets.go index 9bb59dabb..8ca109282 100644 --- a/weed/command/filer_remote_gateway_buckets.go +++ b/weed/command/filer_remote_gateway_buckets.go @@ -60,7 +60,7 @@ func (option *RemoteGatewayOptions) followBucketUpdatesAndUploadToRemote(filerSo DirectoriesToWatch: nil, StartTsNs: lastOffsetTs.UnixNano(), StopTsNs: 0, - EventErrorType: pb.TrivialOnError, + EventErrorType: pb.RetryForeverOnError, } return pb.FollowMetadata(pb.ServerAddress(*option.filerAddress), option.grpcDialOption, metadataFollowOption, processEventFnWithOffset) diff --git a/weed/command/filer_remote_sync_dir.go b/weed/command/filer_remote_sync_dir.go index 76f7e46d5..42dc9ff28 100644 --- a/weed/command/filer_remote_sync_dir.go +++ b/weed/command/filer_remote_sync_dir.go @@ -74,7 +74,7 @@ func followUpdatesAndUploadToRemote(option *RemoteSyncOptions, filerSource *sour DirectoriesToWatch: nil, StartTsNs: lastOffsetTs.UnixNano(), StopTsNs: 0, - EventErrorType: pb.TrivialOnError, + EventErrorType: pb.RetryForeverOnError, } return pb.FollowMetadata(pb.ServerAddress(*option.filerAddress), option.grpcDialOption, metadataFollowOption, processEventFnWithOffset) |