-
Notifications
You must be signed in to change notification settings - Fork 244
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
Fix tempView may be unresolved when applying timestamp to plan #690
Conversation
)(sqlContext) | ||
// Use SubqueryAlias so that projects and joins can correctly resolve | ||
// UnresolvedAttributes in JoinConditions, Projects, Filters, etc. | ||
SubqueryAlias(tableName, LogicalRelation(tiDBRelation)) | ||
} | ||
|
||
protected def resolveRelations(ts: TiTimestamp): PartialFunction[LogicalPlan, LogicalPlan] = { | ||
protected def resolveTiDBRelations: PartialFunction[LogicalPlan, LogicalPlan] = { | ||
case i @ InsertIntoTable(UnresolvedRelation(tableIdentifier), _, _, _, _) |
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.
move InsertIntoTable up to keep same style as ResolveRelations.apply
println(df.queryExecution.analyzed) | ||
df.queryExecution.analyzed.foreach { checkTimestamp } | ||
df.explain | ||
println(df.queryExecution.executedPlan) |
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.
StartTs will be added after Strategies are applied.
@@ -823,6 +823,7 @@ public String toString() { | |||
sb.append(", Limit: "); | |||
sb.append("[").append(limit).append("]"); | |||
} | |||
sb.append(", startTs: ").append(startTs.getVersion()); |
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.
I added a startTs information in TiDagRequest
output. Not really sure if it is useful? @zhexuany
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.
It is better to print it out.
/run-all-tests |
/run-all-tests profile=spark-2.4 |
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.
LGTM
No description provided.