Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

emit alert for DB polling error

This commit is contained in:
Nishant 2015-07-07 19:51:36 +05:30
parent 66d105940d
commit fe36f7f852
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/src/main/java/io/druid/metadata/SQLMetadataSegmentManager.java
View File

@ -30,6 +30,7 @@ import com.metamx.common.MapUtils;
import com.metamx.common.lifecycle.LifecycleStart; import com.metamx.common.lifecycle.LifecycleStart;
import com.metamx.common.lifecycle.LifecycleStop; import com.metamx.common.lifecycle.LifecycleStop;
import com.metamx.common.logger.Logger; import com.metamx.common.logger.Logger;
import com.metamx.emitter.EmittingLogger;
import io.druid.client.DruidDataSource; import io.druid.client.DruidDataSource;
import io.druid.concurrent.Execs; import io.druid.concurrent.Execs;
import io.druid.guice.ManageLifecycle; import io.druid.guice.ManageLifecycle;
@ -66,7 +67,8 @@ import java.util.concurrent.atomic.AtomicReference;
@ManageLifecycle @ManageLifecycle
public class SQLMetadataSegmentManager implements MetadataSegmentManager public class SQLMetadataSegmentManager implements MetadataSegmentManager
{ {
private static final Logger log = new Logger(SQLMetadataSegmentManager.class); private static final EmittingLogger log = new EmittingLogger(SQLMetadataSegmentManager.class);
private final Object lock = new Object(); private final Object lock = new Object();
@ -119,7 +121,8 @@ public class SQLMetadataSegmentManager implements MetadataSegmentManager
poll(); poll();
} }
catch (Exception e) { catch (Exception e) {
log.error(e, "uncaught exception in segment manager polling thread"); log.makeAlert(e, "uncaught exception in segment manager polling thread").emit();
} }
} }
}, },
@ -494,7 +497,7 @@ public class SQLMetadataSegmentManager implements MetadataSegmentManager
} }
} }
catch (Exception e) { catch (Exception e) {
log.error(e, "Problem polling DB."); log.makeAlert(e, "Problem polling DB.").emit();
} }
} }