60
60
import static com .google .common .base .Throwables .getCausalChain ;
61
61
import static com .google .common .collect .ImmutableSet .toImmutableSet ;
62
62
import static com .google .common .net .HttpHeaders .ACCEPT_ENCODING ;
63
- import static com .google .common .net .HttpHeaders .USER_AGENT ;
64
63
import static io .trino .client .HttpStatusCodes .shouldRetry ;
65
64
import static io .trino .client .ProtocolHeaders .TRINO_HEADERS ;
66
65
import static io .trino .client .TrinoJsonCodec .jsonCodec ;
67
- import static io .trino .client .UserAgentBuilder .createUserAgent ;
68
66
import static java .lang .String .format ;
69
67
import static java .net .HttpURLConnection .HTTP_BAD_METHOD ;
70
68
import static java .net .HttpURLConnection .HTTP_NOT_FOUND ;
@@ -82,7 +80,6 @@ class StatementClientV1
82
80
private static final TrinoJsonCodec <QueryResults > QUERY_RESULTS_CODEC = jsonCodec (QueryResults .class );
83
81
84
82
private static final Splitter COLLECTION_HEADER_SPLITTER = Splitter .on ('=' ).limit (2 ).trimResults ();
85
- private static final String USER_AGENT_VALUE = createUserAgent (StatementClientV1 .class .getSimpleName ());
86
83
private final Call .Factory httpCallFactory ;
87
84
private final String query ;
88
85
private final AtomicReference <QueryResults > currentResults = new AtomicReference <>();
@@ -381,9 +378,7 @@ public boolean isClearTransactionId()
381
378
382
379
private Request .Builder prepareRequest (HttpUrl url )
383
380
{
384
- Request .Builder builder = new Request .Builder ()
385
- .addHeader (USER_AGENT , USER_AGENT_VALUE )
386
- .url (url );
381
+ Request .Builder builder = new Request .Builder ().url (url );
387
382
user .ifPresent (requestUser -> builder .addHeader (TRINO_HEADERS .requestUser (), requestUser ));
388
383
originalUser .ifPresent (originalUser -> builder .addHeader (TRINO_HEADERS .requestOriginalUser (), originalUser ));
389
384
if (compressionDisabled ) {
0 commit comments