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

Enable wiping of destroyed object names in CP Subsystem [HZ-3007] #25385

Closed
wants to merge 12 commits into from

Conversation

gbarnett-hz
Copy link
Contributor

@gbarnett-hz gbarnett-hz commented Sep 6, 2023

API that permits the wiping of the names that we track for CP objects that have been destroyed. This wiping enables subsequent objects within the same CP group to use names of previously destroyed CP objects. The wiping is applicable for the following:

  • LockService
  • SemaphoreService
  • CountdownLatchService
  • AtomicRefService
  • AtomicLongService
  • CPMapService with additional PR in EE

Example.

// wipes destroyed objects names for each CP group, per-each CP member of the CP group
instance.getCPSubsystem().getCPSubsystemManagementService().wipeDestroyedObjects();

Notes:
With this new functionality, if a CP object is re-created, its linearizable history can be broken. Not all users of the CP object may be aware that the object has been destroyed and they can observe an inconsistent state of it.
For example:

atomicLong.set(2);
atomicLong.destroy();
instance.getCPSubsystem().getCPSubsystemManagementService().wipeDestroyedObjects();
assertEquals(0, atomicLong.get());

Such behaviour description #17498 (comment)

Fixes #25384

Checklist:

  • Labels (Team:, Type:, Source:, Module:) and Milestone set
  • Label Add to Release Notes or Not Release Notes content set
  • Request reviewers if possible
  • Send backports/forwardports if fix needs to be applied to past/future releases
  • New public APIs have @Nonnull/@Nullable annotations
  • New public APIs have @since tags in Javadoc

@gbarnett-hz gbarnett-hz self-assigned this Sep 6, 2023
@gbarnett-hz gbarnett-hz added this to the 5.4.0 milestone Sep 6, 2023
@gbarnett-hz gbarnett-hz marked this pull request as draft September 6, 2023 16:25
@hz-devops-test
Copy link

The job Hazelcast-pr-compiler of your PR failed. (Hazelcast internal details: build log, artifacts).
Through arcane magic we have determined that the following fragments from the build log may contain information about the problem.

Click to expand the log file
---------ERRORS-----------
--------------------------
[ERROR] /home/jenkins/jenkins_slave/workspace/Hazelcast-pr-compiler/hazelcast/src/test/java/com/hazelcast/cp/internal/WipeDestroyedObjectsTest.java:1: Line does not match expected header line of '/*'. [Header]
--------------------------
[ERROR] Failed to execute goal org.apache.maven.plugins:maven-checkstyle-plugin:3.3.0:checkstyle (default) on project hazelcast: An error has occurred in Checkstyle report generation. Failed during checkstyle execution: There is 1 error reported by Checkstyle 9.3 with /home/jenkins/jenkins_slave/workspace/Hazelcast-pr-compiler/checkstyle/checkstyle.xml ruleset. -> [Help 1]
--------------------------
[ERROR] 
--------------------------
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
--------------------------
[ERROR] 
--------------------------
[ERROR] For more information about the errors and possible solutions, please read the following articles:
--------------------------
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException
--------------------------
[ERROR] 
--------------------------
[ERROR] After correcting the problems, you can resume the build with the command
--------------------------
[ERROR]   mvn  -rf :hazelcast
--------------------------

@hz-devops-test
Copy link

The job Hazelcast-pr-builder of your PR failed. (Hazelcast internal details: build log, artifacts).
Through arcane magic we have determined that the following fragments from the build log may contain information about the problem.

Click to expand the log file
---------ERRORS-----------
--------------------------
[ERROR] /home/jenkins/jenkins_slave/workspace/Hazelcast-pr-builder/hazelcast/src/test/java/com/hazelcast/cp/internal/WipeDestroyedObjectsTest.java:1: Line does not match expected header line of '/*'. [Header]
--------------------------
[ERROR] Failed to execute goal org.apache.maven.plugins:maven-checkstyle-plugin:3.3.0:checkstyle (default) on project hazelcast: An error has occurred in Checkstyle report generation. Failed during checkstyle execution: There is 1 error reported by Checkstyle 9.3 with /home/jenkins/jenkins_slave/workspace/Hazelcast-pr-builder/checkstyle/checkstyle.xml ruleset. -> [Help 1]
--------------------------
[ERROR] 
--------------------------
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
--------------------------
[ERROR] 
--------------------------
[ERROR] For more information about the errors and possible solutions, please read the following articles:
--------------------------
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException
--------------------------
[ERROR] 
--------------------------
[ERROR] After correcting the problems, you can resume the build with the command
--------------------------
[ERROR]   mvn  -rf :hazelcast
--------------------------

@gbarnett-hz
Copy link
Contributor Author

Leaving in DRAFT state for now -- I think we should be careful with this until other bits are progressed.

Copy link
Contributor

@arodionov arodionov left a comment

Choose a reason for hiding this comment

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

Thanks for the PR, it looks good, but there are a couple of comments

@arodionov
Copy link
Contributor

arodionov commented Sep 7, 2023

@gbarnett-hz @vbekiaris I think it will be also Okay if, in addition to
cpSubsystemManagementService.wipeDestroyedObjects();
that wipes destroyed object names in all CP groups, we create an endpoint to wipe a particular group:
cpSubsystemManagementService.wipeDestroyedObjects(CPGroupID cpGroupID);
It also makes sense for granularity and testability reasons.
WDYT?

@gbarnett-hz
Copy link
Contributor Author

@arodionov I had a preference more for the API wipeDestroyedObjects(CPGroupId) but it seemed that on the previous communication there was a requirement for a single simple solution, hence wipeDestroyedObjects(). As the latter makes use of the former internally I don't think there's an issue exposing this unless we don't want to clutter the management API which seems to be pretty concise and focused from what I see...leading to maybe just exposing wipeDestroyedObjects().

@arodionov
Copy link
Contributor

arodionov commented Sep 7, 2023

@gbarnett-hz Yes, you are right. My previous comments were not to expose additional APIs as I thought we would not handle each CP group separately. But while we're at it, it might make sense to also expose this method via a public API.

Copy link
Contributor

@vbekiaris vbekiaris left a comment

Choose a reason for hiding this comment

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

Added a couple comments and a few thumbs-up in previous comments.
Let's keep this PR on the side and revisit once we have a solid solution for CP object reuse.
thanks @gbarnett-hz

@hz-devops-test
Copy link

The job Hazelcast-pr-builder of your PR failed. (Hazelcast internal details: build log, artifacts).
Through arcane magic we have determined that the following fragments from the build log may contain information about the problem.

Click to expand the log file
---------ERRORS-----------
--------------------------
[ERROR] Tests run: 17, Failures: 1, Errors: 0, Skipped: 1, Time elapsed: 222.6 s <<< FAILURE! -- in com.hazelcast.jet.kinesis.KinesisIntegrationTest
--------------------------
[ERROR] com.hazelcast.jet.kinesis.KinesisIntegrationTest.restart_dynamicStream_graceful -- Time elapsed: 125.7 s <<< FAILURE!
--------------------------
[ERROR] Failures: 
--------------------------
[ERROR]   KinesisIntegrationTest.restart_dynamicStream_graceful:387->restart_dynamicStream:425->assertMessages:637->AbstractKinesisTest.assertMessages:163->HazelcastTestSupport.assertTrueEventually:1269->HazelcastTestSupport.assertTrueEventually:1165->AbstractKinesisTest.lambda$assertMessages$3:180 Messages for key 247 differ!
--------------------------
[ERROR] Tests run: 26, Failures: 1, Errors: 0, Skipped: 3
--------------------------
[ERROR] There are test failures.
--------------------------
--------------------------
-------TEST FAILURE-------
--------------------------
[INFO] Results:
[INFO] 
[ERROR] Failures: 
[ERROR]   KinesisIntegrationTest.restart_dynamicStream_graceful:387->restart_dynamicStream:425->assertMessages:637->AbstractKinesisTest.assertMessages:163->HazelcastTestSupport.assertTrueEventually:1269->HazelcastTestSupport.assertTrueEventually:1165->AbstractKinesisTest.lambda$assertMessages$3:180 Messages for key 247 differ!
	expected: 10
	  actual: 1506 expected:<[247: msg 000000247, 247: msg 000000497, 247: msg 000000747, 247: msg 000000997, 247: msg 000001247, 247: msg 000001497, 247: msg 000001747, 247: msg 000001997, 247: msg 000002247, 247: msg 000002497]> but was:<[247: msg 000000247, 247: msg 000000497, 247: msg 000000747, 247: msg 000000997, 247: msg 000001247, 247: msg 000001497, 247: msg 000001747, 247: msg 000001997, 247: msg 000002247, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497, 247: msg 000002497]>
[INFO] 
[ERROR] Tests run: 26, Failures: 1, Errors: 0, Skipped: 3
[INFO] 

[ERROR] There are test failures.

@arodionov
Copy link
Contributor

run-lab-run

@hz-devops-test
Copy link

The job Hazelcast-pr-builder of your PR failed. (Hazelcast internal details: build log, artifacts).
Through arcane magic we have determined that the following fragments from the build log may contain information about the problem.

Click to expand the log file
---------ERRORS-----------
--------------------------
[ERROR] Tests run: 28, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 224.4 s <<< FAILURE! -- in com.hazelcast.jet.kafka.impl.StreamKafkaPTest
--------------------------
[ERROR] com.hazelcast.jet.kafka.impl.StreamKafkaPTest.when_processingGuaranteeNoneWithConsumerGroup_then_continueFromLastReadMessageAfterJobRestart -- Time elapsed: 123.6 s <<< FAILURE!
--------------------------
[ERROR] Failures: 
--------------------------
[ERROR]   StreamKafkaPTest.when_processingGuaranteeNoneWithConsumerGroup_then_continueFromLastReadMessageAfterJobRestart:266->testWithJobRestart:345->HazelcastTestSupport.assertTrueEventually:1269->HazelcastTestSupport.assertTrueEventually:1165->lambda$testWithJobRestart$4:345 expected:<200> but was:<198>
--------------------------
[ERROR] Tests run: 51, Failures: 1, Errors: 0, Skipped: 0
--------------------------
[ERROR] There are test failures.
--------------------------
--------------------------
-------TEST FAILURE-------
--------------------------
[INFO] Results:
[INFO] 
[ERROR] Failures: 
[ERROR]   StreamKafkaPTest.when_processingGuaranteeNoneWithConsumerGroup_then_continueFromLastReadMessageAfterJobRestart:266->testWithJobRestart:345->HazelcastTestSupport.assertTrueEventually:1269->HazelcastTestSupport.assertTrueEventually:1165->lambda$testWithJobRestart$4:345 expected:<200> but was:<198>
[INFO] 
[ERROR] Tests run: 51, Failures: 1, Errors: 0, Skipped: 0
[INFO] 

[ERROR] There are test failures.

@gbarnett-hz
Copy link
Contributor Author

run-lab-run

@arodionov
Copy link
Contributor

@gbarnett-hz @vbekiaris I've refactored a current PR to be able to support the CPMap.
Please take a look

@gbarnett-hz gbarnett-hz changed the title Enable wiping of destroyed object names in CP Subsystem Enable wiping of destroyed object names in CP Subsystem [HZ-3007] Nov 10, 2023
@gbarnett-hz
Copy link
Contributor Author

@arodionov LGTM

@devOpsHazelcast
Copy link
Collaborator

PR closed by Hazelcast automation as no activity (>3 months). Please reopen with comments, if necessary. Thank you for using Hazelcast and your valuable contributions

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.

Wiping of destroyed object names in CP Subsystem
5 participants