We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
Hi,
We are using azure-cosmosdb-spark to read data from cosmosdb changefeed.
Today, we got nothing from cosmosdb changefeed eventhough there are data inserted into cosmosdb.
Here is our configuration `readConfig = { "Endpoint": cosmos_host, "Masterkey": cosmos_key, "Database": "TicketMaster", "Collection": "Tickets", "ReadChangeFeed": "true", "ChangeFeedQueryName": "Tickets-ChangeFeed", "ChangeFeedStartFromTheBeginning": "false", "InferStreamSchema": "false", "ChangeFeedCheckpointLocation": checkpoint_cosmosdb_dir }
changeFeed = (spark.readStream.format("com.microsoft.azure.cosmosdb.spark.streaming.CosmosDBSourceProvider").options(**readConfig).load())`
Is there anyway, we can reset the checkpoint value to reload missing data from previous checkpoint?
Thanks and regards, Di Truong
The text was updated successfully, but these errors were encountered:
No branches or pull requests
Hi,
We are using azure-cosmosdb-spark to read data from cosmosdb changefeed.
Today, we got nothing from cosmosdb changefeed eventhough there are data inserted into cosmosdb.
Here is our configuration
`readConfig = {
"Endpoint": cosmos_host,
"Masterkey": cosmos_key,
"Database": "TicketMaster",
"Collection": "Tickets",
"ReadChangeFeed": "true",
"ChangeFeedQueryName": "Tickets-ChangeFeed",
"ChangeFeedStartFromTheBeginning": "false",
"InferStreamSchema": "false",
"ChangeFeedCheckpointLocation": checkpoint_cosmosdb_dir
}
changeFeed = (spark.readStream.format("com.microsoft.azure.cosmosdb.spark.streaming.CosmosDBSourceProvider").options(**readConfig).load())`
Is there anyway, we can reset the checkpoint value to reload missing data from previous checkpoint?
Thanks and regards,
Di Truong
The text was updated successfully, but these errors were encountered: