Package azkaban.jobcontrol.impl.jobs.locks

Examples of azkaban.jobcontrol.impl.jobs.locks.NamedPermitManager

118
119
120
121
122
123
124
125
126
127
128
        if (defaultTimezoneID != null) {
          DateTimeZone.setDefault(DateTimeZone.forID(defaultTimezoneID));
          TimeZone.setDefault(TimeZone.getTimeZone(defaultTimezoneID));
        }
       
        NamedPermitManager permitManager = getNamedPermitManager(defaultProps);
        JobWrappingFactory factory = new JobWrappingFactory(
                permitManager,
                new ReadWriteLockManager(),
                _logsDir.getAbsolutePath(),
                "java",
View Full Code Here
301
302
303
304
305
306
307
308
309
310
    }

    private NamedPermitManager getNamedPermitManager(Props props) throws MalformedURLException
    {
        int workPermits = props.getInt("total.job.permits", Integer.MAX_VALUE);
        NamedPermitManager permitManager = new NamedPermitManager();
        permitManager.createNamedPermit("default", workPermits);

        return permitManager;
    }
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
108
                Utils.croak("Invalid property override: '" + override
                            + "', properties must be in the form key=value", 1);
            overrideProps.put(pieces[0], pieces[1]);
        }

        NamedPermitManager permitManager = new NamedPermitManager();
        permitManager.createNamedPermit("default", cl.getNumWorkPermits());

        JobWrappingFactory factory = new JobWrappingFactory(permitManager,
                                                            new ReadWriteLockManager(),
                                                            cl.getLogDir().getAbsolutePath(),
                                                            "java",
View Full Code Here
TOP

Related Classes of azkaban.jobcontrol.impl.jobs.locks.NamedPermitManager

  • azkaban.app.AzkabanApplication
  • azkaban.jobs.CommandLineJobRunner
  • java.util.concurrent.Semaphore
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.