Skip to content

Commit

Permalink
T ronmoneta/compression auto detect fix (#222)
Browse files Browse the repository at this point in the history
* Changed just sstream to false. the rest was fine

* Switched rows
  • Loading branch information
t-ronmoneta committed Feb 11, 2024
1 parent 5203460 commit b584ce2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions kusto/ingest/streaming.go
Original file line number Diff line number Diff line change
Expand Up @@ -93,13 +93,13 @@ func prepFileAndProps(fPath string, props *properties.All, options []FileOption,

props.Source.OriginalSource = fPath
compression := utils.CompressionDiscovery(fPath)
props.Source.DontCompress = !queued.ShouldCompress(props, compression)

err = queued.CompleteFormatFromFileName(props, fPath)
if err != nil {
return nil, err, true
}

props.Source.DontCompress = !queued.ShouldCompress(props, compression)

file, err := os.Open(fPath)
if err != nil {
return nil, err, true
Expand Down

0 comments on commit b584ce2

Please sign in to comment.