diff --git a/lib/MySQL_Thread.cpp b/lib/MySQL_Thread.cpp
index d773ae836..f782fa2e2 100644
--- a/lib/MySQL_Thread.cpp
+++ b/lib/MySQL_Thread.cpp
@@ -2120,7 +2120,9 @@ __run_skip_1a:
 					for (i=0; i<rc; i++) {
 						uint32_t sess_thr_id=events[i].data.u32;
 						//memcpy(&mysess2,&events[epi].data.ptr,sizeof(MySQL_Session *));
-						if (events[i].events == EPOLLIN && mysess->thread_session_id==sess_thr_id) { // found it!
+						//if (events[i].events == EPOLLIN && mysess->thread_session_id==sess_thr_id) { // found it!
+						// NOTE: not sure why, sometime events returns odd values. If set, we take it out as normal worker threads know how to handle it
+						if (events[i].events && mysess->thread_session_id==sess_thr_id) { // found it!
 							MySQL_Data_Stream *tmp_myds=mysess->client_myds;
 							int dsidx=tmp_myds->poll_fds_idx;
 							//fprintf(stderr,"Removing session %p, DS %p idx %d\n",mysess,tmp_myds,dsidx);