-
Notifications
You must be signed in to change notification settings - Fork 1.2k
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
Add physicalWrittenBytes to PlanNodeStats #8213
Conversation
✅ Deploy Preview for meta-velox canceled.
|
@mbasmanova @rui-mo Can you help to review? Thanks. |
velox/exec/tests/TableWriteTest.cpp
Outdated
|
||
auto planStats = exec::toPlanStats(task->taskStats()); | ||
auto& stats = planStats.at(tableWriteNodeId_); | ||
for (const auto& entry : stats.operatorStats) { |
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.
This loop and if check inside are not needed. You should be able to access stats.physicalWrittenBytes directly.
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.
@mbasmanova Updated.
Pass spark 3.4 unit test when enabling native parquet write (#466)
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.
@JkSelf LGTM after addressing comments from @mbasmanova. Thanks!
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.
Thanks.
@mbasmanova has imported this pull request. If you are a Meta employee, you can view this diff on Phabricator. |
@kgpai @majetideepak @assignUser There is a CI failure. Would you know how to resolve it?
|
@majetideepak we should build minio as part of the docker script , should be as simple as moving this :
in setup-adapters.sh I will create a PR for that.. |
Actually I realize that we use the same docker image for the adapter jobs, moving it to setup-adapters might not really help and we need to create a new docker image for this case. |
Pass spark 3.4 unit test when enabling native parquet write (#466)
Pass spark 3.4 unit test when enabling native parquet write (#466)
@mbasmanova merged this pull request in e5355f3. |
Conbench analyzed the 1 benchmark run on commit There were no benchmark performance regressions. 🎉 The full Conbench report has more details. |
The physicalWrittenBytes metric is available in the OperatorStats class, but not
in the PlanNodeStats. When accessing metrics from Task::taskStats(), we are
unable to retrieve the physicalWrittenBytes' value.
Ad physicalWrittenBytes metric to PlanNodeStats.