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)
5050 begin
5151 yield
5252 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
5456 if retries < @task [ 'retries' ]
5557 retries += 1
5658 Embulk . logger . warn { "embulk-output-bigquery: retry \# #{ retries } , #{ e . class } #{ e . message } " }
@@ -59,8 +61,6 @@ def with_network_retry(&block)
5961 Embulk . logger . error { "embulk-output-bigquery: retry exhausted \# #{ retries } , #{ e . class } #{ e . message } " }
6062 raise e
6163 end
62- else
63- raise e
6464 end
6565 end
6666 end
You can’t perform that action at this time.
0 commit comments