Error Loading Data to StarRocks Destination

Summary

User encountered a StreamLoadFailException while attempting to load data into the StarRocks destination in Airbyte, indicating a null pointer exception in the stream load process.


Question

Hi,
Was working on the custom connector for starrocks in airbyte.

Tried to load some data to the starrocks destination.
But was getting the error: Additional Failure Information: io.airbyte.integrations.destination.starrocks.exception.StreamLoadFailException: Stream load failed because of unknown exception

Putting the last error logs here:

	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:186) ~[io.airbyte.airbyte-integrations.bases-base-java-0.50.13.jar:?]
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:123) ~[io.airbyte.airbyte-integrations.bases-base-java-0.50.13.jar:?]
	at io.airbyte.integrations.destination.starrocks.StarRocksDestination.main(StarRocksDestination.java:51) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.50.13.jar:?]
Caused by: java.lang.NullPointerException: Cannot invoke "io.airbyte.integrations.destination.starrocks.StreamLoadResponse$StreamLoadResponseBody.getStatus()" because "streamLoadBody" is null
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.send(DefaultStreamLoader.java:132) ~[io.airbyte.airbyte-integrations.connectors-destination-starrocks-0.50.13.jar:?]
	... 8 more
Stack Trace: io.airbyte.integrations.destination.starrocks.exception.StreamLoadFailException: Stream load failed because of unknown exception, db: src_google_sheet, table: _airbyte_tmp_ghz_suppliers, label: airbyte__airbyte_tmp_ghz_suppliers_338ca6f4-de79-4516-b6f8-8c34f6b56caa1709547045049
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.send(DefaultStreamLoader.java:166)
	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.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:291)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:82)
	at io.airbyte.integrations.base.Destination$ShimToSerializedAirbyteMessageConsumer.close(Destination.java:95)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:186)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:123)
	at io.airbyte.integrations.destination.starrocks.StarRocksDestination.main(StarRocksDestination.java:51)
Caused by: java.lang.NullPointerException: Cannot invoke "io.airbyte.integrations.destination.starrocks.StreamLoadResponse$StreamLoadResponseBody.getStatus()" because "streamLoadBody" is null
	at io.airbyte.integrations.destination.starrocks.DefaultStreamLoader.send(DefaultStreamLoader.java:132)
	...```
P.S: Found the issue being raised here: <https://github.com/StarRocks/starrocks/issues/41560>

<br>

---

This topic has been created from a Slack thread to give it more visibility.
It will be on Read-Only mode here. [Click here](https://airbytehq.slack.com/archives/C021JANJ6TY/p1709547311511259) if you want
to access the original thread.

[Join the conversation on Slack](https://slack.airbyte.com)

<sub>
['starrocks', 'streamloadfailexception', 'nullpointerexception', 'airbyte']
</sub>