Wenchen Fan
Wenchen Fan
### What changes were proposed in this pull request? This PR is a refactor of `SessionCatalog`. It centralizes the code of qualifying identifiers in one place: `SessionCatalog.qualifyIdentifier`. Then we can...
Something like ``` val g = Graph("a" ~> "b" % 3, "a" ~> "c" % 2, "b" ~> "c" % -2) println(g.get("a").shortestPathTo(g.get("c")).get.weight) ``` will print 2, which is wrong(should be...
Is there a flag to turn it on?
#### Which Delta project/connector is this regarding? - [x] Spark - [ ] Standalone - [ ] Flink - [ ] Kernel - [ ] Other (fill in here) ##...
### What changes were proposed in this pull request? We have Github Action jobs to test package building and doc generation, but the execution environment is different from what we...
#### Which Delta project/connector is this regarding? - [x] Spark - [ ] Standalone - [ ] Flink - [ ] Kernel - [ ] Other (fill in here) ##...
#### Which Delta project/connector is this regarding? - [x] Spark - [ ] Standalone - [ ] Flink - [ ] Kernel - [ ] Other (fill in here) ##...
### What changes were proposed in this pull request? This is a re-submitting of https://github.com/apache/spark/pull/43938 to fix a join correctness bug caused by https://github.com/apache/spark/pull/41398 . Credits go to @mcdull-zhang ###...