Skip to content
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

Backport includeEndStreamAction in DeltasharingService to branch-0.7 #595

Merged
merged 8 commits into from
Oct 13, 2024

Conversation

linzhou-db
Copy link
Collaborator

Backport includeEndStreamAction in DeltasharingService to branch-0.7

@chakankardb
Copy link
Collaborator

Question @linzhou-db : Should we soak it for some time before we backport?

@@ -103,14 +114,16 @@ private[spark] class DeltaSharingRestClient(
numRetries: Int = 10,
maxRetryDuration: Long = Long.MaxValue,
sslTrustAll: Boolean = false,
forStreaming: Boolean = false
forStreaming: Boolean = false,
endStreamActionEnabled: Boolean = false
Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@chakankardb this is changed to false.

@@ -30,6 +30,9 @@ object ConfUtils {
val MAX_RETRY_DURATION_CONF = "spark.delta.sharing.network.maxRetryDuration"
val MAX_RETRY_DURATION_DEFAULT_MILLIS = 10L * 60L* 1000L /* 10 mins */

val INCLUDE_END_STREAM_ACTION_CONF = "spark.delta.sharing.query.includeEndStreamAction"
val INCLUDE_END_STREAM_ACTION_DEFAULT = "false"
Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@chakankardb this is changed to false.

@linzhou-db
Copy link
Collaborator Author

local tests passed, merging

@linzhou-db linzhou-db merged commit cc6b1a7 into branch-0.7 Oct 13, 2024
7 of 8 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants