-
Notifications
You must be signed in to change notification settings - Fork 35
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Feature/update tag name for dups #401
base: master
Are you sure you want to change the base?
Conversation
connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala
Outdated
Show resolved
Hide resolved
blobUUID: String, | ||
kustoClient: ExtendedKustoClient, | ||
partitionsResults: CollectionAccumulator[PartitionResult], | ||
batchIdForTracing: String, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
use the batchIdForTracing as well in getDedupTagsPrefix - so that it will work on (spark) streaming as well.
parameters: KustoWriteResource, | ||
ingestionProperties: IngestionProperties, | ||
flushImmediately: Boolean = false, | ||
blobUUID: String, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
blobUUID - not used
val kustoClient = KustoClientCache.getClient( | ||
parameters.coordinates.clusterUrl, | ||
parameters.authentication, | ||
parameters.coordinates.ingestionUrl, | ||
parameters.coordinates.clusterAlias) | ||
val blobIdMap = new ConcurrentHashMap[String, Int]() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
did you mean for this to be some static cache ? if so it will need to live outside the function as a member.
currently this will always hold only the current run with the same request id in all Map entries,
Regardless - a simple integer with ncrements would do the job i think
…stoWriter.scala Co-authored-by: ohad bitton <[email protected]>
* Update POM
* Update POM
No description provided.