Skip to content

Commit 819ee08

Browse files
* Fix DataMapping format when mapping is not provided
1 parent 7e4d38a commit 819ee08

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

lib/logstash/outputs/kusto/ingestor.rb

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,12 +78,13 @@ def initialize(ingest_url, app_id, app_key, app_tenant, managed_identity_id, cli
7878
is_mapping_ref_provided = !(json_mapping.nil? || json_mapping.empty?)
7979
if is_mapping_ref_provided
8080
@logger.debug('Using mapping reference.', json_mapping)
81-
@ingestion_properties.setIngestionMapping(json_mapping, kusto_java.ingest.IngestionMapping::IngestionMappingKind::JSON)
8281
@ingestion_properties.setDataFormat(kusto_java.ingest.IngestionProperties::DataFormat::JSON)
8382
else
8483
@logger.debug('No mapping reference provided. Columns will be mapped by names in the logstash output')
8584
@ingestion_properties.setDataFormat(kusto_java.ingest.IngestionProperties::DataFormat::JSON)
8685
end
86+
# default mapping is JSON
87+
@ingestion_properties.setIngestionMapping(json_mapping, kusto_java.ingest.IngestionMapping::IngestionMappingKind::JSON)
8788
@delete_local = delete_local
8889
@logger.debug('Kusto resources are ready.')
8990
end

version

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
2.0.7
1+
2.0.8

0 commit comments

Comments
 (0)