Open sfc-gh-alhuang opened 1 month ago
Modify flush service to support uploading file to external volume. This PR includes following change:
MAX_CLIENT_LAG
DISABLE_CHUNK_ENCRYPTION
StreamingIngestExternalVolume.java
FlushServiceTest
StreamingIngestStage
Modify flush service to support uploading file to external volume. This PR includes following change:
MAX_CLIENT_LAG
for Iceberg modeDISABLE_CHUNK_ENCRYPTION
to disable chunk encryption in Iceberg modeStreamingIngestExternalVolume.java
FlushServiceTest
andStreamingIngestStage
, more test cases is expected