File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
lib/embulk/output/bigquery Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -50,7 +50,9 @@ def with_network_retry(&block)
50
50
begin
51
51
yield
52
52
rescue ::Java ::Java . net . SocketException , ::Java ::Java . net . ConnectException => e
53
- if [ 'Broken pipe' , 'Connection reset' , 'Connection timed out' ] . include? ( e . message )
53
+ if [ 'Broken pipe' , 'Connection reset' , 'Connection timed out' ] . select! { |x | e . message . include? ( x ) } . empty?
54
+ raise e
55
+ else
54
56
if retries < @task [ 'retries' ]
55
57
retries += 1
56
58
Embulk . logger . warn { "embulk-output-bigquery: retry \# #{ retries } , #{ e . class } #{ e . message } " }
@@ -59,8 +61,6 @@ def with_network_retry(&block)
59
61
Embulk . logger . error { "embulk-output-bigquery: retry exhausted \# #{ retries } , #{ e . class } #{ e . message } " }
60
62
raise e
61
63
end
62
- else
63
- raise e
64
64
end
65
65
end
66
66
end
You can’t perform that action at this time.
0 commit comments