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

enh: dnode condition pushdown #30596

Closed
wants to merge 4 commits into from
Closed

enh: dnode condition pushdown #30596

wants to merge 4 commits into from

Conversation

facetosea
Copy link
Contributor

Description

Please briefly describe the code changes in this pull request.

Checklist

Please check the items in the checklist if applicable.

  • Is the user manual updated?
  • Are the test cases passed and automated?
  • Is there no significant decrease in test coverage?

@facetosea facetosea force-pushed the fix/TS-6244/showDnodes branch from 6c36138 to 503dbcd Compare April 2, 2025 07:33
if (pOperNode->opType == OP_TYPE_EQUAL || pOperNode->opType == OP_TYPE_NOT_EQUAL) {
SNode* pLeft = pOperNode->pLeft;
SNode* pRight = pOperNode->pRight;
if ((QUERY_NODE_COLUMN == nodeType(pLeft) && strcmp(((SColumnNode*)pLeft)->node.aliasName, "dnode_id") == 0) ||
Copy link
Contributor

Choose a reason for hiding this comment

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

这个条件严重不足,不能因为有一列叫"dnode_id"就可以做这个优化,用户的表里有个列叫"dnode_id"也可以吗

OPTIMIZE_FLAG_TEST_MASK(pScan->node.optimizedFlag, OPTIMIZE_FLAG_PUSH_DOWN_CONDE) ||
TSDB_SYSTEM_TABLE == pScan->tableType) {
OPTIMIZE_FLAG_TEST_MASK(pScan->node.optimizedFlag, OPTIMIZE_FLAG_PUSH_DOWN_CONDE)
// || TSDB_SYSTEM_TABLE == pScan->tableType
Copy link
Contributor

Choose a reason for hiding this comment

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

所有系统表扫描都做了后续的处理,确定可以吗

@@ -5021,8 +5021,9 @@ int32_t tSerializeSDnodeListRsp(void *buf, int32_t bufLen, SDnodeListRsp *pRsp)
int32_t num = taosArrayGetSize(pRsp->dnodeList);
TAOS_CHECK_EXIT(tEncodeI32(&encoder, num));
for (int32_t i = 0; i < num; ++i) {
SEpSet *pEpSet = taosArrayGet(pRsp->dnodeList, i);
TAOS_CHECK_EXIT(tEncodeSEpSet(&encoder, pEpSet));
SDNodeAddr *pAddr = taosArrayGet(pRsp->dnodeList, i);
Copy link
Contributor

Choose a reason for hiding this comment

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

这改变了消息怎么保证兼容性?怎么能向main提交?

@facetosea facetosea closed this Apr 8, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants