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

Merge pull request #1500 from metamx/fix-1466 

emit alert on errors when polling segments
This commit is contained in:
Xavier Léauté 2015-07-07 14:50:29 -07:00
parent 448d245a44 fe36f7f852
commit 31d05e33a1
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.LifecycleStop;
import com.metamx.common.logger.Logger;
import com.metamx.emitter.EmittingLogger;
import io.druid.client.DruidDataSource;
import io.druid.concurrent.Execs;
import io.druid.guice.ManageLifecycle;
@ -66,7 +67,8 @@ import java.util.concurrent.atomic.AtomicReference;
@ManageLifecycle
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();
@ -119,7 +121,8 @@ public class SQLMetadataSegmentManager implements MetadataSegmentManager
poll();
}
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) {
log.error(e, "Problem polling DB.");
log.makeAlert(e, "Problem polling DB.").emit();
}
}