starrocks: AirByte Connector: JSONException for TLS enabled SR instances

Source: parquet file from NYC taxi - https://d37ci6vzurychx.cloudfront.net/trip-data/yellow_tripdata_2023-01.parquet. Target: StarRocks.

Screenshot 2023-05-25 at 9 51 42 AM Screenshot 2023-05-25 at 9 51 33 AM

2023-05-25 16:43:59 INFO i.a.a.c.AirbyteApiClient(retryWithJitterThrows):222 - Attempt 0 to get state
2023-05-25 16:43:59 INFO i.a.w.h.DockerImageNameHelper(extractImageVersion):62 - Could not create semantic version from version latest, message: Invalid version string: latest
2023-05-25 16:43:59 INFO i.a.w.h.NormalizationInDestinationHelper(shouldNormalizeInDestination):52 - Requires Normalization: false Normalization Supported: false, Feature Flag Enabled: false
2023-05-25 16:43:59 INFO i.a.a.c.AirbyteApiClient(retryWithJitterThrows):222 - Attempt 0 to set attempt sync config
2023-05-25 16:43:59 INFO i.a.c.t.s.DefaultTaskQueueMapper(getTaskQueue):31 - Called DefaultTaskQueueMapper getTaskQueue for geography auto
2023-05-25 16:43:59 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/2/0/logs.log
2023-05-25 16:43:59 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.44.5
2023-05-25 16:43:59 INFO i.a.a.c.AirbyteApiClient(retryWithJitterThrows):222 - Attempt 0 to save workflow id for cancellation
2023-05-25 16:43:59 INFO i.a.a.c.AirbyteApiClient(retryWithJitterThrows):222 - Attempt 0 to get the source for heartbeat
2023-05-25 16:43:59 INFO i.a.a.c.AirbyteApiClient(retryWithJitterThrows):222 - Attempt 0 to get the source definition
2023-05-25 16:43:59 INFO i.a.w.g.ReplicationWorkerFactory(create):96 - Setting up source...
2023-05-25 16:43:59 INFO i.a.w.g.ReplicationWorkerFactory(create):100 - Setting up destination...
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable METRIC_CLIENT: ''
2023-05-25 16:43:59 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2023-05-25 16:43:59 INFO i.a.w.g.ReplicationWorkerFactory(create):109 - Setting up replication worker...
2023-05-25 16:43:59 INFO i.a.w.g.DefaultReplicationWorker(run):147 - start sync worker. job id: 2 attempt id: 0
2023-05-25 16:43:59 INFO i.a.w.g.DefaultReplicationWorker(run):149 - Committing states from replication activity
2023-05-25 16:43:59 INFO i.a.w.g.DefaultReplicationWorker(run):152 - Committing stats from replication activity
2023-05-25 16:43:59 INFO i.a.c.i.LineGobbler(voidCall):149 - 
2023-05-25 16:43:59 INFO i.a.w.g.DefaultReplicationWorker(run):168 - configured sync modes: {null.nyctaxi=full_refresh - overwrite}
2023-05-25 16:43:59 INFO i.a.w.i.DefaultAirbyteDestination(start):92 - Running destination...
2023-05-25 16:43:59 INFO i.a.c.i.LineGobbler(voidCall):149 - ----- START REPLICATION -----
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SIDECAR_KUBE_CPU_LIMIT: '2.0'
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SOCAT_KUBE_CPU_LIMIT: '2.0'
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SIDECAR_KUBE_CPU_REQUEST: '0.1'
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SOCAT_KUBE_CPU_REQUEST: '0.1'
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable LAUNCHDARKLY_KEY: ''
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable FEATURE_FLAG_CLIENT: ''
2023-05-25 16:43:59 INFO i.a.c.i.LineGobbler(voidCall):149 - 
2023-05-25 16:43:59 INFO i.a.c.i.LineGobbler(voidCall):149 - Checking if atwong/destination-starrocks:latest exists...
2023-05-25 16:43:59 INFO i.a.c.i.LineGobbler(voidCall):149 - atwong/destination-starrocks:latest was found locally.
2023-05-25 16:43:59 INFO i.a.w.p.DockerProcessFactory(create):139 - Creating docker container = destination-starrocks-write-2-0-noyxv with resources io.airbyte.config.ResourceRequirements@7df546c1[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=,additionalProperties={}] and allowedHosts null
2023-05-25 16:43:59 INFO i.a.w.p.DockerProcessFactory(create):192 - Preparing command: docker run --rm --init -i -w /data/2/0 --log-driver none --name destination-starrocks-write-2-0-noyxv --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_CONNECTOR_IMAGE=atwong/destination-starrocks:latest -e AUTO_DETECT_SCHEMA=true -e LAUNCHDARKLY_KEY= -e SOCAT_KUBE_CPU_REQUEST=0.1 -e SOCAT_KUBE_CPU_LIMIT=2.0 -e USE_STREAM_CAPABLE_STATE=true -e FIELD_SELECTION_WORKSPACES= -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e APPLY_FIELD_SELECTION=false -e WORKER_JOB_ATTEMPT=0 -e OTEL_COLLECTOR_ENDPOINT=http://host.docker.internal:4317 -e FEATURE_FLAG_CLIENT= -e AIRBYTE_VERSION=0.44.5 -e WORKER_JOB_ID=2 atwong/destination-starrocks:latest write --config destination_config.json --catalog destination_catalog.json
2023-05-25 16:43:59 INFO i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):41 - Writing messages to protocol version 0.2.0
2023-05-25 16:43:59 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):181 - Reading messages from protocol version 0.2.0
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SIDECAR_KUBE_CPU_LIMIT: '2.0'
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SOCAT_KUBE_CPU_LIMIT: '2.0'
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SIDECAR_KUBE_CPU_REQUEST: '0.1'
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SOCAT_KUBE_CPU_REQUEST: '0.1'
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable LAUNCHDARKLY_KEY: ''
2023-05-25 16:43:59 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable FEATURE_FLAG_CLIENT: ''
2023-05-25 16:43:59 INFO i.a.c.i.LineGobbler(voidCall):149 - Checking if airbyte/source-file:0.3.4 exists...
2023-05-25 16:43:59 INFO i.a.c.i.LineGobbler(voidCall):149 - airbyte/source-file:0.3.4 was found locally.
2023-05-25 16:43:59 INFO i.a.w.p.DockerProcessFactory(create):139 - Creating docker container = source-file-read-2-0-mxdho with resources io.airbyte.config.ResourceRequirements@4301a45e[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=,additionalProperties={}] and allowedHosts io.airbyte.config.AllowedHosts@5547b945[hosts=[*, *.datadoghq.com, *.datadoghq.eu, *.sentry.io],additionalProperties={}]
2023-05-25 16:43:59 INFO i.a.w.p.DockerProcessFactory(create):192 - Preparing command: docker run --rm --init -i -w /data/2/0 --log-driver none --name source-file-read-2-0-mxdho --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_CONNECTOR_IMAGE=airbyte/source-file:0.3.4 -e AUTO_DETECT_SCHEMA=true -e LAUNCHDARKLY_KEY= -e SOCAT_KUBE_CPU_REQUEST=0.1 -e SOCAT_KUBE_CPU_LIMIT=2.0 -e USE_STREAM_CAPABLE_STATE=true -e FIELD_SELECTION_WORKSPACES= -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e APPLY_FIELD_SELECTION=false -e WORKER_JOB_ATTEMPT=0 -e OTEL_COLLECTOR_ENDPOINT=http://host.docker.internal:4317 -e FEATURE_FLAG_CLIENT= -e AIRBYTE_VERSION=0.44.5 -e WORKER_JOB_ID=2 airbyte/source-file:0.3.4 read --config source_config.json --catalog source_catalog.json
2023-05-25 16:43:59 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):181 - Reading messages from protocol version 0.2.0
2023-05-25 16:43:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):289 - Destination output thread started.
2023-05-25 16:43:59 INFO i.a.w.i.HeartbeatTimeoutChaperone(runWithHeartbeatThread):94 - Starting source heartbeat check. Will check every 1 minutes.
2023-05-25 16:43:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$5):334 - Replication thread started.
2023-05-25 16:44:00 destination > INFO i.a.i.b.IntegrationCliParser(parseOptions):126 integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2023-05-25 16:44:00 destination > INFO i.a.i.b.IntegrationRunner(runInternal):108 Running integration: io.airbyte.integrations.destination.starrocks.StarRocksDestination
2023-05-25 16:44:00 destination > INFO i.a.i.b.IntegrationRunner(runInternal):109 Command: WRITE
2023-05-25 16:44:00 destination > INFO i.a.i.b.IntegrationRunner(runInternal):110 Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2023-05-25 16:44:00 destination > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-25 16:44:00 destination > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-25 16:44:00 destination > INFO i.a.i.d.s.StarRocksDestination(getConsumer):61 JsonNode config: 
{
  "fe_host" : "6dihxzedg.cloud-app.celerdata.com",
  "database" : "testparquet",
  "password":"**********",
  "username" : "admin",
  "http_port" : 8030,
  "query_port" : 9030
}
2023-05-25 16:44:00 source > Reading nyctaxi (https://d37ci6vzurychx.cloudfront.net/trip-data/yellow_tripdata_2023-01.parquet)...
2023-05-25 16:44:00 source > TransportParams: None
2023-05-25 16:44:00 destination > INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):144 class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2023-05-25 16:44:00 destination > INFO i.a.i.d.s.StarRocksBufferedConsumerFactory(lambda$onStartFunction$0):69 Preparing tmp tables in destination started for 1 streams
2023-05-25 16:44:00 destination > INFO i.a.i.d.s.StarRocksBufferedConsumerFactory(lambda$onStartFunction$0):75 Preparing tmp table in destination started for stream nyctaxi. tmp table name: _airbyte_tmp_hym_nyctaxi
2023-05-25 16:44:00 destination > INFO i.a.i.d.s.StarRocksBufferedConsumerFactory(lambda$onStartFunction$0):82 Preparing tmp tables in destination completed.
2023-05-25 16:44:34 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 5000 (1 MB)
2023-05-25 16:44:34 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 10000 (3 MB)
2023-05-25 16:44:35 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 15000 (5 MB)
2023-05-25 16:44:35 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 20000 (7 MB)
2023-05-25 16:44:35 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 25000 (9 MB)
2023-05-25 16:44:36 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 30000 (11 MB)
2023-05-25 16:44:36 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 35000 (13 MB)
2023-05-25 16:44:36 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 40000 (15 MB)
2023-05-25 16:44:37 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 45000 (17 MB)
2023-05-25 16:44:37 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 50000 (19 MB)
2023-05-25 16:44:38 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 55000 (21 MB)
2023-05-25 16:44:38 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 60000 (23 MB)
2023-05-25 16:44:39 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 65000 (25 MB)
2023-05-25 16:44:39 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 70000 (27 MB)
2023-05-25 16:44:39 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 75000 (29 MB)
2023-05-25 16:44:40 INFO i.a.w.g.ReplicationWorkerHelper(processMessageFromSource):87 - Records read: 80000 (31 MB)
2023-05-25 16:44:40 destination > INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(flushAllBuffers):85 Flushing nyctaxi: 80047 records (127 MB)
2023-05-25 16:44:45 destination > WARN i.a.i.d.s.DefaultStreamLoader(testHttpConnection):182 Failed to connect to address:6dihxzedg.cloud-app.celerdata.com java.net.SocketTimeoutException: Connect timed out
	at sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:546) ~[?:?]
	at sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597) ~[?:?]
	at java.net.Socket.connect(Socket.java:633) ~[?:?]
	at sun.net.NetworkClient.doConnect(NetworkClient.java:178) ~[?:?]
	at sun.net.www.http.HttpClient.openServer(HttpClient.java:532) ~[?:?]
	at sun.net.www.http.HttpClient.openServer(HttpClient.java:637) ~[?:?]
	at sun.net.www.http.HttpClient.<init>(HttpClient.java:280) ~[?:?]
	at sun.net.www.http.HttpClient.New(HttpClient.java:385) ~[?:?]
	at sun.net.www.http.HttpClient.New(HttpClient.java:407) ~[?:?]
	at sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1309) ~[?:?]
	at sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1242) ~[?:?]
	at sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1128) ~[?:?]
	at sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1057) ~[?:?]
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.testHttpConnection(DefaultStreamLoader.java:178) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.getAvailableHost(DefaultStreamLoader.java:163) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.send(DefaultStreamLoader.java:91) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]
	at io.airbyte.integrations.destination.starrocks.StarRocksBufferedConsumerFactory.lambda$recordWriterFunction$2(StarRocksBufferedConsumerFactory.java:100) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]
	at io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy.flushAllBuffers(InMemoryRecordBufferingStrategy.java:87) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy.addRecord(InMemoryRecordBufferingStrategy.java:64) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:172) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:65) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:294) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:206) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:212) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:241) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:211) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:151) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:101) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.destination.starrocks.StarRocksDestination.main(StarRocksDestination.java:42) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]

Stack Trace: java.net.SocketTimeoutException: Connect timed out
	at java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:546)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597)
	at java.base/java.net.Socket.connect(Socket.java:633)
	at java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:178)
	at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:532)
	at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:637)
	at java.base/sun.net.www.http.HttpClient.<init>(HttpClient.java:280)
	at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:385)
	at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:407)
	at java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1309)
	at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1242)
	at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1128)
	at java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1057)
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.testHttpConnection(DefaultStreamLoader.java:178)
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.getAvailableHost(DefaultStreamLoader.java:163)
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.send(DefaultStreamLoader.java:91)
	at io.airbyte.integrations.destination.starrocks.StarRocksBufferedConsumerFactory.lambda$recordWriterFunction$2(StarRocksBufferedConsumerFactory.java:100)
	at io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy.flushAllBuffers(InMemoryRecordBufferingStrategy.java:87)
	at io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy.addRecord(InMemoryRecordBufferingStrategy.java:64)
	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:172)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:65)
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:294)
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:206)
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:212)
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:241)
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:211)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:151)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:101)
	at io.airbyte.integrations.destination.starrocks.StarRocksDestination.main(StarRocksDestination.java:42)

2023-05-25 16:44:50 destination > WARN i.a.i.d.s.DefaultStreamLoader(testHttpConnection):182 Failed to connect to address:6dihxzedg.cloud-app.celerdata.com java.net.SocketTimeoutException: Connect timed out
	at sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:546) ~[?:?]
	at sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597) ~[?:?]
	at java.net.Socket.connect(Socket.java:633) ~[?:?]
	at sun.net.NetworkClient.doConnect(NetworkClient.java:178) ~[?:?]
	at sun.net.www.http.HttpClient.openServer(HttpClient.java:532) ~[?:?]
	at sun.net.www.http.HttpClient.openServer(HttpClient.java:637) ~[?:?]
	at sun.net.www.http.HttpClient.<init>(HttpClient.java:280) ~[?:?]
	at sun.net.www.http.HttpClient.New(HttpClient.java:385) ~[?:?]
	at sun.net.www.http.HttpClient.New(HttpClient.java:407) ~[?:?]
	at sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1309) ~[?:?]
	at sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1242) ~[?:?]
	at sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1128) ~[?:?]
	at sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1057) ~[?:?]
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.testHttpConnection(DefaultStreamLoader.java:178) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.getAvailableHost(DefaultStreamLoader.java:163) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.send(DefaultStreamLoader.java:91) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]
	at io.airbyte.integrations.destination.starrocks.StarRocksBufferedConsumerFactory.lambda$recordWriterFunction$2(StarRocksBufferedConsumerFactory.java:100) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]
	at io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy.flushAllBuffers(InMemoryRecordBufferingStrategy.java:87) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy.addRecord(InMemoryRecordBufferingStrategy.java:64) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:172) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:65) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:294) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:206) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:212) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:241) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:211) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:151) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:101) ~[io.airbyte.airbyte-integrations.bases-base-java-0.44.4.jar:?]
	at io.airbyte.integrations.destination.starrocks.StarRocksDestination.main(StarRocksDestination.java:42) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.44.4.jar:?]

Stack Trace: java.net.SocketTimeoutException: Connect timed out
	at java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:546)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597)
	at java.base/java.net.Socket.connect(Socket.java:633)
	at java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:178)
	at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:532)
	at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:637)
	at java.base/sun.net.www.http.HttpClient.<init>(HttpClient.java:280)
	at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:385)
	at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:407)
	at java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1309)
	at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1242)
	at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1128)
	at java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1057)
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.testHttpConnection(DefaultStreamLoader.java:178)
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.getAvailableHost(DefaultStreamLoader.java:163)
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.send(DefaultStreamLoader.java:91)
	at io.airbyte.integrations.destination.starrocks.StarRocksBufferedConsumerFactory.lambda$recordWriterFunction$2(StarRocksBufferedConsumerFactory.java:100)
	at io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy.flushAllBuffers(InMemoryRecordBufferingStrategy.java:87)
	at io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy.addRecord(InMemoryRecordBufferingStrategy.java:64)
	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.acceptTracked(BufferedStreamConsumer.java:172)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:65)
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:294)
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:206)
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:212)
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:241)
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:211)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:151)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:101)
	at io.airbyte.integrations.destination.starrocks.StarRocksDestination.main(StarRocksDestination.java:42)

About this issue

  • Original URL
  • State: closed
  • Created a year ago
  • Comments: 18 (5 by maintainers)

Most upvoted comments

Maybe we can add config to choose http/https Protocol or set stream load URL directly

+1
liuzhongjun89 on Jun 3, 2023
Read more comments on GitHub
← cairo: Declare fail: Error: OSError: [Errno 8] Exec format error
starrocks: Attempt to free invalid pointer 0x623ff80 →