Aditya created SAMZA-1661: ----------------------------- Summary: Window high level API: During shutdown of RocksDb store while shutting down Samza job, RocksDb runs into an assertion Key: SAMZA-1661 URL: https://issues.apache.org/jira/browse/SAMZA-1661 Project: Samza Issue Type: Bug Reporter: Aditya
This could be consistently reproduced with Samza-sql testEndToEndGroupBy test in TestSamzaSqlEndToEnd. Please note that this issue does not happen with Stream Table join which also uses RocksDb. [p-1-container-thread-0] CoordinatorRequests [INFO] Shutdown requested. [p-1-container-thread-0] SamzaContainer [INFO] Shutting down. [p-1-container-thread-0] SamzaContainer [INFO] Shutting down consumer multiplexer. [p-1-container-thread-0] SamzaContainer [INFO] Shutting down task instance stream tasks. [p-1-container-thread-0] SamzaContainer [INFO] Shutting down timer executor [p-1-container-thread-0] SamzaContainer [INFO] Committing offsets for all task instances [p-1-container-thread-0] SamzaContainer [INFO] Shutting down task instance table manager. [p-1-container-thread-0] SamzaContainer [INFO] Shutting down task instance stores. Assertion failed: (dummy_versions_->TEST_Next() == dummy_versions_), function ~ColumnFamilyData, file db/column_family.cc, line 483. -- This message was sent by Atlassian JIRA (v7.6.3#76005)