retry with SSLError

Author: giwa

lib/embulk/output/bigquery/google_client.rb

@@ -62,6 +62,28 @@ def with_network_retry(&block)
             else
               raise e
             end
+
+            # httpclient which google-api-ruby-client depends on, catches java.net.SocketException and java.net.ConnectionException and
+            # raises SSLError.
+            # https://github.com/nahi/httpclient/blob/4658227a46f7caa633ef8036f073bbd1f0a955a2/lib/httpclient/jruby_ssl_socket.rb#L124-L134
+          rescue SSLError => e
+            retry_messages = [
+              "Java::JavaNet::SocketException: Connection reset",
+              "Java::JavaNet::SocketException: Broken pipe",
+              "Java::JavaNet::ConnectException: Connection timed out",
+            ]
+            if retry_messages.include?(e.message)
+              if retries < @task['retries']
+                retries += 1
+                Embulk.logger.warn { "embulk-output-bigquery: retry \##{retries}, #{e.class} #{e.message}" }
+                retry
+              else
+                Embulk.logger.error { "embulk-output-bigquery: retry exhausted \##{retries}, #{e.class} #{e.message}" }
+                raise e
+              end
+            else
+              raise e
+            end
           end
         end
       end