-
Notifications
You must be signed in to change notification settings - Fork 474
[MySQL] Add replica status data stream #10344
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
[MySQL] Add replica status data stream #10344
Conversation
/test |
🚀 Benchmarks reportTo see the full report comment with |
multi: false | ||
required: true | ||
show_user: true | ||
default: "SHOW REPLICA STATUS;" |
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.
As the SHOW SLAVE STATUS
is deprecated as mentioned in the mysql document. By default we can use the SHOW REPLICA STATUS;
query and the user can change it to SLAVE
if the mysql version is prior to 8.0.22. We have to update it in the description. That way we support the replica_status metrics for users who is using the older version of mysql.
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.
Sure, we have added it in readme, we will also add description here.
|
For any new Integration/datastream, we should now follow the ecs@mappings only. |
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.
Is it feasible to display source.port
without a comma(shown in SS 3,306)?
Since ports typically don't include separators, having one might appear strange to users.
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 agree, but we are not able to show it with out coma in kibana since it is number.
…ql_replica_status Conflicts: packages/mysql/_dev/build/docs/README.md packages/mysql/changelog.yml packages/mysql/data_stream/error/_dev/test/pipeline/test-error.log-expected.json packages/mysql/data_stream/error/_dev/test/pipeline/test-mariadb-10-4-8.log-expected.json packages/mysql/data_stream/error/_dev/test/pipeline/test-mysql-darwin-brew-5-7-10.log-expected.json packages/mysql/data_stream/error/_dev/test/pipeline/test-mysql-ubuntu-5-5-53.log-expected.json packages/mysql/data_stream/error/_dev/test/pipeline/test-mysql-ubuntu-8-0-15.log-expected.json packages/mysql/docs/README.md
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!
description: "Current global transaction ID value." | ||
- name: is_auto_position | ||
type: boolean | ||
description: "true if GTID auto-positioning is in use for the channel, otherwise false." |
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.
nit:
description: "true if GTID auto-positioning is in use for the channel, otherwise false." | |
description: "True if GTID auto-positioning is in use for the channel, otherwise false." |
- name: tls_version | ||
type: keyword | ||
description: "The TLS version used on the source." | ||
- name: slave |
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.
Are these fields only for SLAVE query of the older versions?
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 have changed it to replica.
- name: delay_remaining.sec | ||
type: long | ||
metric_type: gauge | ||
description: "When Replica_SQL_Running_State is Waiting until MASTER_DELAY seconds after source executed event, this field contains the number of delay seconds remaining. At other times, this field is NULL." |
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.
description: "When Replica_SQL_Running_State is Waiting until MASTER_DELAY seconds after source executed event, this field contains the number of delay seconds remaining. At other times, this field is NULL." | |
description: "When Replica_SQL_Running_State is waiting until MASTER_DELAY seconds after source executed event, this field contains the number of delay seconds remaining. At other times, this field is NULL." |
…ql_replica_status Conflicts: packages/mysql/changelog.yml
/test |
description: "This status variable counts the occurrence of transactional event groups. This is a replica-side counter for optimistic parallel replication." | ||
- name: replicate_do_domain_ids | ||
type: keyword | ||
description: "The do_domain_id option value for change master.(The DO_DOMAIN_IDS option for CHANGE MASTER can be used to configure a replica to only apply binary log events if the transaction's GTID is in a specific gtid_domain_id value.)" |
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.
nit:
description: "The do_domain_id option value for change master.(The DO_DOMAIN_IDS option for CHANGE MASTER can be used to configure a replica to only apply binary log events if the transaction's GTID is in a specific gtid_domain_id value.)" | |
description: "The do_domain_id option value for change master.(The DO_DOMAIN_IDS option for CHANGE MASTER can be used to configure a replica to only apply binary log events if the transaction's GTID is in a specific gtid_domain_id value)." |
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 guess it is already correct. https://www.ub.edu/llibre-estil/criteri.php?id=2320#:~:text=When%20a%20passage%20within,before%20the%20closing%20bracket.
description: "The do_domain_id option value for change master.(The DO_DOMAIN_IDS option for CHANGE MASTER can be used to configure a replica to only apply binary log events if the transaction's GTID is in a specific gtid_domain_id value.)" | ||
- name: replicate_ignore_domain_ids | ||
type: keyword | ||
description: "The ignore_domain_id option value for change master.(The IGNORE_DOMAIN_IDS option for CHANGE MASTER can be used to configure a replica to ignore binary log events if the transaction's GTID is in a specific gtid_domain_id value)" |
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.
nit:
description: "The ignore_domain_id option value for change master.(The IGNORE_DOMAIN_IDS option for CHANGE MASTER can be used to configure a replica to ignore binary log events if the transaction's GTID is in a specific gtid_domain_id value)" | |
description: "The ignore_domain_id option value for change master.(The IGNORE_DOMAIN_IDS option for CHANGE MASTER can be used to configure a replica to ignore binary log events if the transaction's GTID is in a specific gtid_domain_id value)." |
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.
Change looks good to me. As @niraj-elastic confirmed the TSDB testing is done as part of E2E testing.
Yes. @aliabbas-elastic Has done complete E2E testing which includes TSDB as well. |
/test |
💚 Build Succeeded
History
|
|
* add replica status data stream * update data stream * update changelog * Address review comment * address review comments * address review comment * address review comments
* add replica status data stream * update data stream * update changelog * Address review comment * address review comments * address review comment * address review comments
What does this PR do?
Checklist
changelog.yml
file.How to test this PR locally
Screenshots
issue