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

rptest: Basic transaction produce test #15955

Merged
merged 4 commits into from
Jan 11, 2024
Merged

Conversation

savex
Copy link
Contributor

@savex savex commented Jan 5, 2024

Basic produce tests and some fixes for consume basic tests.

Backports Required

  • none - not a bug fix
  • none - this is a backport
  • none - issue does not exist in previous branches
  • none - papercut/not impactful enough to backport
  • v23.3.x
  • v23.2.x
  • v23.1.x

Release Notes

  • none

@savex savex self-assigned this Jan 5, 2024
@savex savex requested a review from bharathv January 5, 2024 00:23
@savex
Copy link
Contributor Author

savex commented Jan 5, 2024

This will be updated once venv will be prepared to use inside task executor. Main reason is that once graph generates jobs that run python code from java - it needs pyflink packages accessible outside flink service. And we do not want to install them at system level on ducktape worker node.

@savex savex marked this pull request as ready for review January 5, 2024 00:27
@vbotbuildovich
Copy link
Collaborator

vbotbuildovich commented Jan 5, 2024

new failures in https://buildkite.com/redpanda/redpanda/builds/43456#018cd742-40ab-403e-ad86-53b6ac575fea:

"rptest.tests.cloud_storage_timing_stress_test.CloudStorageTimingStressTest.test_cloud_storage.cleanup_policy=delete"

new failures in https://buildkite.com/redpanda/redpanda/builds/43577#018cec24-3ec7-4523-b0e2-0f598c011092:

"rptest.tests.flink_basic_test.FlinkBasicTests.test_transaction_workload"

new failures in https://buildkite.com/redpanda/redpanda/builds/43624#018cf145-476c-4f56-97a6-61b2745a441f:

"rptest.tests.cluster_features_test.FeaturesMultiNodeUpgradeTest.test_upgrade"

new failures in https://buildkite.com/redpanda/redpanda/builds/43624#018cf145-4776-44ed-8be2-d32f6978bca6:

"rptest.tests.cluster_features_test.FeaturesMultiNodeUpgradeTest.test_rollback"

new failures in https://buildkite.com/redpanda/redpanda/builds/43624#018cf145-476f-4dcc-ba4d-8be5475b070b:

"rptest.tests.cluster_features_test.FeaturesSingleNodeUpgradeTest.test_upgrade"
"rptest.tests.cluster_features_test.FeaturesNodeJoinTest.test_old_node_join"

new failures in https://buildkite.com/redpanda/redpanda/builds/43624#018cf156-ed06-459f-bc34-de63574722eb:

"rptest.tests.cluster_features_test.FeaturesMultiNodeUpgradeTest.test_rollback"

new failures in https://buildkite.com/redpanda/redpanda/builds/43624#018cf156-ed09-4d7f-8676-47c3bb21a2fd:

"rptest.tests.cluster_features_test.FeaturesMultiNodeUpgradeTest.test_upgrade"

new failures in https://buildkite.com/redpanda/redpanda/builds/43624#018cf156-ed0c-4b66-9808-3e12469a9a20:

"rptest.tests.cluster_features_test.FeaturesSingleNodeUpgradeTest.test_upgrade"
"rptest.tests.cluster_features_test.FeaturesNodeJoinTest.test_old_node_join"

@savex savex requested a review from a team as a code owner January 5, 2024 22:36
@savex savex requested review from gousteris and bharathv and removed request for a team January 5, 2024 22:36
@savex
Copy link
Contributor Author

savex commented Jan 9, 2024

As of now, consumer sets latest offset to +2 comparing to last offset produced. Investigation pending on why this happens.

@savex savex force-pushed the rp-2281-flink-transaction-test branch from c6b6f1a to ba99b25 Compare January 10, 2024 00:07
@savex
Copy link
Contributor Author

savex commented Jan 10, 2024

Updated test logic so it would not wait for Consumer to finish but check for data produced instead. Also, instead of offset, index is used in validation of data.

 also, enables consume on transactions
  Additionally to produce updates, consume routine updated with
  different table structure to include indices and subindices (batches)
@savex savex force-pushed the rp-2281-flink-transaction-test branch from ba99b25 to c22447c Compare January 10, 2024 01:35
@savex savex requested a review from bharathv January 10, 2024 18:29
@savex savex merged commit c9162cb into dev Jan 11, 2024
17 checks passed
@savex savex deleted the rp-2281-flink-transaction-test branch January 11, 2024 14:10
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

3 participants