Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
private class StreamingBuildJobStatusChecker implements Runnable { private int maxJobTryCnt = 5; private CubeManager cubeManager = CubeManager.getInstance(KylinConfig.getInstanceFromEnv()); private ConcurrentMap<String, ConcurrentSkipListSet<SegmentJobBuildInfo>> segmentBuildJobMap = Maps .newConcurrentMap(); private CopyOnWriteArrayList<String> pendingCubeName = Lists.newCopyOnWriteArrayList();
Attachments
Issue Links
- links to