这篇文章主要围绕HadoopMapper由于“ApplicationMaster杀死容器”而失败展开,旨在为您提供一份详细的参考资料。我们将全面介绍HadoopMapper由于“Application
这篇文章主要围绕Hadoop Mapper由于“ApplicationMaster杀死容器”而失败展开,旨在为您提供一份详细的参考资料。我们将全面介绍Hadoop Mapper由于“ApplicationMaster杀死容器”而失败,同时也会为您带来2.2.0-ApplicationMaster总是连接0.0.0.0:8030问题的解决、Application application_1512618719369_147804 failed 2 times due to ApplicationMaster for attempt app、ApplicationListener ApplicationContextAware ApplicationEvent使用、com.intellij.openapi.application.ApplicationActivationListener的实例源码的实用方法。
本文目录一览:- Hadoop Mapper由于“ApplicationMaster杀死容器”而失败
- 2.2.0-ApplicationMaster总是连接0.0.0.0:8030问题的解决
- Application application_1512618719369_147804 failed 2 times due to ApplicationMaster for attempt app
- ApplicationListener ApplicationContextAware ApplicationEvent使用
- com.intellij.openapi.application.ApplicationActivationListener的实例源码
Hadoop Mapper由于“ApplicationMaster杀死容器”而失败
我正试图在Hadoop上执行一个map reduce程序。
当我将作业提交给hadoop单节点群集时。 这项工作正在创build,但失败的消息
“由ApplicationMaster杀死的容器”
使用的input大小为10 MB。
什么是Kerberos?
在Hadoop环境中configurationEclipse(在Windows上)(在具有SUSE Linux Enterprise Server 11的VM上)
MapReduce输出ArrayWritable
在Windows上安装和运行hadoop 2.2的文档
创build外部表格configuration单元,位置包含多个文件
当我使用input文件400 KB的相同的脚本,它成功了。 但是对于大小为10 MB的input文件失败。
在我的terminal中显示的完整日志如下。
15/05/29 09:52:16 WARN util.NativeCodeLoader: Unable to `load native- hadoop library for your platform... using builtin-java classes where applicable Submitting job on the cluster... 15/05/29 09:52:17 INFO client.RMProxy: Connecting to ResourceManager at /0.0.0.0:8032 15/05/29 09:52:18 INFO input.FileInputFormat: Total input paths to process : 1 15/05/29 09:52:18 INFO mapreduce.JobSubmitter: number of splits:1 15/05/29 09:52:19 INFO mapreduce.JobSubmitter: Submitting tokens for job: job_1432910768528_0001 15/05/29 09:52:19 INFO impl.YarnClientImpl: Submitted application application_1432910768528_0001 15/05/29 09:52:19 INFO mapreduce.Job: The url to track the job: http://localhost:8088/proxy/application_1432910768528_0001/ 15/05/29 09:52:19 INFO mapreduce.Job: Running job: job_1432910768528_0001 15/05/29 09:52:29 INFO mapreduce.Job: Job job_1432910768528_0001 running in uber mode : false 15/05/29 09:52:29 INFO mapreduce.Job: map 0% reduce 0% 15/05/29 09:52:41 INFO mapreduce.Job: map 100% reduce 0% 15/05/29 10:03:01 INFO mapreduce.Job: map 0% reduce 0% 15/05/29 10:03:01 INFO mapreduce.Job: Task Id : attempt_1432910768528_0001_m_000000_0,Status : Failed AttemptID:attempt_1432910768528_0001_m_000000_0 Timed out after 600 secs Container killed by the ApplicationMaster. Container killed on request. Exit code is 143 Container exited with a non-zero exit code 143
我的映射器在这里触发另一个程序,它将在这里处理我的input文件。 被映射器触发的程序通常会消耗大量的内存。
所以请在这方面帮助我。
程序的hadoop启动错误:PriviledgedActionException
在Windows上的Nutch:错误crawlInjector
启动hbase时未findJAVA_HOME。 有什么build议么?
为什么hdfs在Hadoop集群中引发LeaseExpiredException(AWS EMR)
是否有必要在/ usr / local中安装hadoop?
在yarn-site.xml包含以下属性并重新启动VM ,
<property> <name>yarn.nodemanager.vmem-check-enabled</name> <value>false</value> <description>Whether virtual memory limits will be enforced for containers</description> </property> <property> <name>yarn.nodemanager.vmem-pmem-ratio</name> <value>4</value> <description>Ratio between virtual memory to physical memory when setting memory limits for containers</description> </property>
一个容器是一个JVM进程。 在Mapreduce中,应用程序主服务,mapper和reducer任务都是在纱线框架内部执行的容器。
你可以通过增加reducer的数量(比如说mapreduce.job.reduces=10 )或者增加reduce堆的大小来解决这个问题( mapreduce.reduce.java.opts=-Xmx2014m )
如果你想在运行时有固定数量的reducer,你可以在命令行传递Map / Reduce作业。 使用-D mapreduce.job.reduces=10与所需的数字将在运行时产生许多reducer。
在代码中,可以配置JobConf变量来设置映射器和简化器的数量。 可以说我们有JobConf变量作为工作。
Configuration conf = new Configuration(); Job job = new Job(conf); job.setNumReduceTasks(10); // 10 reducers
您也可以将文件分割成更小的大小以避免内存问题。
如果您仍然有问题,请检查纱线日志并发布日志。
总结
以上是小编为你收集整理的Hadoop Mapper由于“ApplicationMaster杀死容器”而失败全部内容。
如果觉得小编网站内容还不错,欢迎将小编网站推荐给好友。
2.2.0-ApplicationMaster总是连接0.0.0.0:8030问题的解决
查看调用栈如下:
[1] org.apache.hadoop.ipc.Client$Connection.handleConnectionFailure (Client.java:819)
[2] org.apache.hadoop.ipc.Client$Connection.setupConnection (Client.java:623)
[3] org.apache.hadoop.ipc.Client$Connection.setupIOstreams (Client.java:699)
[4] org.apache.hadoop.ipc.Client$Connection.access$2800 (Client.java:367)
[5] org.apache.hadoop.ipc.Client.getConnection (Client.java:1,462)
[6] org.apache.hadoop.ipc.Client.call (Client.java:1,381)
[7] org.apache.hadoop.ipc.Client.call (Client.java:1,363)
[8] org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke (ProtobufRpcEngine.java:206)
[9] com.sun.proxy.$Proxy14.registerApplicationMaster (null)
[10] org.apache.hadoop.yarn.api.impl.pb.client.ApplicationMasterProtocolPBClientImpl.registerApplicationMaster (ApplicationMasterProtocolPBClientImpl.java:106)
[11] sun.reflect.NativeMethodAccessorImpl.invoke0 (native method)
[12] sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
[13] sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
[14] java.lang.reflect.Method.invoke (Method.java:498)
[15] org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod (RetryInvocationHandler.java:190)
[16] org.apache.hadoop.io.retry.RetryInvocationHandler.invoke (RetryInvocationHandler.java:103)
[17] com.sun.proxy.$Proxy15.registerApplicationMaster (null)
[18] org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl.registerApplicationMaster (AMRMClientImpl.java:196)
[19] org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl.registerApplicationMaster (AMRMClientAsyncImpl.java:138)
[20] org.apache.flink.yarn.YarnFlinkResourceManager.initialize (YarnFlinkResourceManager.java:255)
[21] org.apache.flink.runtime.clusterframework.FlinkResourceManager.preStart (FlinkResourceManager.java:186)
[22] akka.actor.Actor$class.aroundPreStart (Actor.scala:510)
[23] akka.actor.UntypedActor.aroundPreStart (UntypedActor.scala:95)
[24] akka.actor.ActorCell.create (ActorCell.scala:590)
[25] akka.actor.ActorCell.invokeAll$1 (ActorCell.scala:461)
[26] akka.actor.ActorCell.systemInvoke (ActorCell.scala:483)
[27] akka.dispatch.Mailbox.processAllSystemMessages (Mailbox.scala:282)
[28] akka.dispatch.Mailbox.run (Mailbox.scala:223)
[29] akka.dispatch.Mailbox.exec (Mailbox.scala:234)
[30] scala.concurrent.forkjoin.ForkJoinTask.doExec (ForkJoinTask.java:260)
[31] scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask (ForkJoinPool.java:1,339)
[32] scala.concurrent.forkjoin.ForkJoinPool.runWorker (ForkJoinPool.java:1,979)
[33] scala.concurrent.forkjoin.ForkJoinWorkerThread.run (ForkJoinWorkerThread.java:107)
之前也出现过这个问题,现在来分析一下
首先,在正确的地方打上断点
stop in org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl.serviceStart
然后观察-最后发现本地yarn-site.xml没有读取,那hadoop底层读取了啥?
找到调用栈
[1] org.apache.hadoop.conf.Configuration.reloadConfiguration (Configuration.java:791)
[2] org.apache.hadoop.conf.Configuration.addDefaultResource (Configuration.java:690)
[3] org.apache.hadoop.mapreduce.util.ConfigUtil.loadResources (ConfigUtil.java:43)
[4] org.apache.hadoop.mapred.JobConf.<clinit> (JobConf.java:118)
[5] java.lang.Class.forName0 (native method)
[6] java.lang.Class.forName (Class.java:348)
[7] org.apache.hadoop.conf.Configuration.getClassByNameOrNull (Configuration.java:1,834)
[8] org.apache.hadoop.util.ReflectionUtils.setJobConf (ReflectionUtils.java:91)
[9] org.apache.hadoop.util.ReflectionUtils.setConf (ReflectionUtils.java:75)
[10] org.apache.hadoop.util.ReflectionUtils.newInstance (ReflectionUtils.java:133)
[11] org.apache.hadoop.security.Groups.<init> (Groups.java:64)
[12] org.apache.hadoop.security.Groups.getUserToGroupsMappingService (Groups.java:240)
[13] org.apache.hadoop.security.UserGroupInformation.initialize (UserGroupInformation.java:255)
[14] org.apache.hadoop.security.UserGroupInformation.ensureInitialized (UserGroupInformation.java:232)
[15] org.apache.hadoop.security.UserGroupInformation.loginUserFromSubject (UserGroupInformation.java:718)
[16] org.apache.hadoop.security.UserGroupInformation.getLoginUser (UserGroupInformation.java:703)
[17] org.apache.hadoop.security.UserGroupInformation.getCurrentUser (UserGroupInformation.java:605)
[18] sun.reflect.NativeMethodAccessorImpl.invoke0 (native method)
[19] sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
[20] sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
[21] java.lang.reflect.Method.invoke (Method.java:498)
[22] org.apache.flink.runtime.util.EnvironmentInformation.getHadoopUser (EnvironmentInformation.java:96)
[23] org.apache.flink.runtime.util.EnvironmentInformation.logEnvironmentInfo (EnvironmentInformation.java:285)
[24] org.apache.flink.yarn.YarnApplicationMasterRunner.main (YarnApplicationMasterRunner.java:117)
使用的时候其实是下面这个地方
[1] org.apache.hadoop.yarn.client.ClientRMProxy.getRMAddress (ClientRMProxy.java:103)
[2] org.apache.hadoop.yarn.client.RMProxy.createRMProxy (RMProxy.java:91)
[3] org.apache.hadoop.yarn.client.ClientRMProxy.createRMProxy (ClientRMProxy.java:70)
[4] org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl.serviceStart (AMRMClientImpl.java:168)
[5] org.apache.hadoop.service.AbstractService.start (AbstractService.java:193)
[6] org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl.serviceStart (AMRMClientAsyncImpl.java:96)
[7] org.apache.hadoop.service.AbstractService.start (AbstractService.java:193)
[8] org.apache.flink.yarn.YarnFlinkResourceManager.initialize (YarnFlinkResourceManager.java:242)
[9] org.apache.flink.runtime.clusterframework.FlinkResourceManager.preStart (FlinkResourceManager.java:186)
[10] akka.actor.Actor$class.aroundPreStart (Actor.scala:510)
[11] akka.actor.UntypedActor.aroundPreStart (UntypedActor.scala:95)
[12] akka.actor.ActorCell.create (ActorCell.scala:590)
[13] akka.actor.ActorCell.invokeAll$1 (ActorCell.scala:461)
[14] akka.actor.ActorCell.systemInvoke (ActorCell.scala:483)
[15] akka.dispatch.Mailbox.processAllSystemMessages (Mailbox.scala:282)
[16] akka.dispatch.Mailbox.run (Mailbox.scala:223)
[17] akka.dispatch.Mailbox.exec (Mailbox.scala:234)
[18] scala.concurrent.forkjoin.ForkJoinTask.doExec (ForkJoinTask.java:260)
[19] scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask (ForkJoinPool.java:1,339)
[20] scala.concurrent.forkjoin.ForkJoinPool.runWorker (ForkJoinPool.java:1,979)
[21] scala.concurrent.forkjoin.ForkJoinWorkerThread.run (ForkJoinWorkerThread.java:107)
大致的代码如下
private static InetSocketAddress getRMAddress(Configuration conf,
Class<?> protocol) throws IOException {
if (protocol == ApplicationClientProtocol.class) {
return conf.getSocketAddr(YarnConfiguration.RM_ADDRESS,
YarnConfiguration.DEFAULT_RM_ADDRESS,
YarnConfiguration.DEFAULT_RM_PORT);
} else if (protocol == ResourceManagerAdministrationProtocol.class) {
return conf.getSocketAddr(
YarnConfiguration.RM_ADMIN_ADDRESS,
YarnConfiguration.DEFAULT_RM_ADMIN_ADDRESS,
YarnConfiguration.DEFAULT_RM_ADMIN_PORT);
} else if (protocol == ApplicationMasterProtocol.class) {
InetSocketAddress serviceAddr =
conf.getSocketAddr(YarnConfiguration.RM_SCHEDULER_ADDRESS,
YarnConfiguration.DEFAULT_RM_SCHEDULER_ADDRESS,
YarnConfiguration.DEFAULT_RM_SCHEDULER_PORT);
setupTokens(serviceAddr);
return serviceAddr;
} else {
String message = "Unsupported protocol found when creating the proxy " +
"connection to ResourceManager: " +
((protocol != null) ? protocol.getClass().getName() : "null");
LOG.error(message);
throw new IllegalStateException(message);
}
}
}
发现寻找yarn-site.xml的时候,没找到配置文件,原来是
虽然我定义了export HADOOP_CONF_DIR="/root/yarn_study/hadoop-2.2.0/etc/hadoop"
但是CLASSPATH里并没有这个,原因找到就好办了!
------------------------------------------------------------------------------------------直接上方法
打断点
stop at org.apache.hadoop.conf.Configuration:2037
然后执行到
stop at org.apache.hadoop.conf.Configuration:2232 时
打印url,就可以看到文件具体从哪读的!
下面是实际打印的结果
main[1] print url
url = "jar:file:/tmp/hadoop-root/nm-local-dir/usercache/ww/appcache/application_1535972793929_0001/filecache/10/flink-shaded-hadoop2-uber-1.5.0.jar!/yarn-default.xml"
Application application_1512618719369_147804 failed 2 times due to ApplicationMaster for attempt app
今天遇到一个特别怪的问题,之前etl中的hive任务一直报错,持续一上午,也没有查出原因,错误的任务的日志也找到,原本可以找到原因,但是打开日志,心里面一凉,什么报错也没有,不知所错。最后观察报错的节点,最终集中到两台机器,那就看看是不是这两台机器的hadoop的程序引起的吗?看看他们的程序都在,但是查看nodemanager的日志一直报错,并且查看cpu,nodemanager进程占用的cpu达1000%多,马上眼前一亮,知道cpu占用太多,导致ap不能联系,导致任务失败,最后把这两台机器的nodemanager重启一下,观察了一下,任务不在报错。继续努力.............
ApplicationListener ApplicationContextAware ApplicationEvent使用
AppCacheContext.JAVA
方法一:implements ApplicationListener
@SuppressWarnings("rawtypes")
public class AppCacheContext implements ApplicationListener{
Logger logger = LoggerFactory.getLogger(AppCacheContext.class);
@Autowired
private static AppCacheContextDao cacheDao;
public void onApplicationEvent(ApplicationEvent event) {
Class<? extends ApplicationEvent> clazz = event.getClass();
System.out.println(clazz.getName());
if(event instanceof ContextRefreshedEvent){
ApplicationContext appcontext = ((ApplicationContextEvent) event).getApplicationContext().getParent();
if(appcontext != null){
try {
// 数据字典初始化
initDicDetailCache();
logger.info("----------------数据字典初始化完成----------------------");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
方法二:ApplicationListener<ContextRefreshedEvent>
@SuppressWarnings("rawtypes")
public class AppCacheContext implements ApplicationListener<ContextRefreshedEvent>{
Logger logger = LoggerFactory.getLogger(AppCacheContext.class);
@Autowired
private static AppCacheContextDao cacheDao;
@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
ApplicationContext appcontext = event.getApplicationContext().getParent();
if(appcontext != null){
try {
// 数据字典初始化
initDicDetailCache();
logger.info("----------------数据字典初始化完成----------------------");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
在ApplicationListener<ContextRefreshedEvent>使用时,会存在一个问题,在web 项目中(spring mvc),系统会存在两个容器,一个是root application context (过程中) ,另一个就是我们自己的 projectName-servlet context(作为root application context的子容器,初始完成之后)。这种情况下,就会造成onApplicationEvent方法被执行两次。根据自己的需求使用。
上述例子是初始化缓存,在完成之后执行。
解决办法可参考:https://my.oschina.net/u/2369810/blog/682899?nocache=1501657886165
com.intellij.openapi.application.ApplicationActivationListener的实例源码
public PlaybackRunner(String script,StatusCallback callback,final boolean useDirectActionCall,boolean stopOnAppDeactivation,boolean useTypingTargets) { myScript = script; myCallback = callback; myUseDirectActionCall = useDirectActionCall; myUseTypingTargets = useTypingTargets; myStopOnAppDeactivation = stopOnAppDeactivation; myAppListener = new ApplicationActivationListener.Adapter() { @Override public void applicationDeactivated(IdeFrame ideFrame) { if (myStopOnAppDeactivation) { myCallback.message(null,"App lost focus,stopping...",StatusCallback.Type.message); stop(); } } }; }
private boolean isAppActive() { Application app = ApplicationManager.getApplication(); if (app != null && myAppListener == null) { myAppListener = new ApplicationActivationListener.Adapter() { @Override public void applicationActivated(IdeFrame ideFrame) { hideProgress(ideFrame.getProject(),myCurrentProcessId); _setokBadge(ideFrame,false); _setTextBadge(ideFrame,null); } }; app.getMessageBus().connect().subscribe(ApplicationActivationListener.TOPIC,myAppListener); } return app != null && app.isActive(); }
public void addRequest(@Nonnull final Runnable request,final int delay,boolean runWithActiveFrameOnly) { if (runWithActiveFrameOnly && !ApplicationManager.getApplication().isActive()) { final MessageBus bus = ApplicationManager.getApplication().getMessageBus(); final MessageBusConnection connection = bus.connect(this); connection.subscribe(ApplicationActivationListener.TOPIC,new ApplicationActivationListener() { @Override public void applicationActivated(IdeFrame ideFrame) { connection.disconnect(); addRequest(request,delay); } }); } else { addRequest(request,delay); } }
public PlaybackRunner(String script,StatusCallback.Type.message); stop(); } } }; }
private void updateConnection() { final ApplicationEx app = ApplicationManagerEx.getApplicationEx(); boolean value = PropertiesComponent.getInstance().getBoolean(KEY); if(value) { myConnection = app.getMessageBus().connect(); myConnection.subscribe(ApplicationActivationListener.TOPIC,myListener); } else { if(myConnection != null) { myConnection.disconnect(); } } }
public void afterValueChanged(RegistryValue value) { if (value.asBoolean()) { ourConnection = app.getMessageBus().connect(); ourConnection.subscribe(ApplicationActivationListener.TOPIC,LISTENER); } else { ourConnection.disconnect(); } }
public void addRequest(@NotNull final Runnable request,new ApplicationActivationListener.Adapter() { @Override public void applicationActivated(IdeFrame ideFrame) { connection.disconnect(); addRequest(request,delay); } }); } else { addRequest(request,delay); } }
public void show(final Component component,int x,int y) { if (!component.isShowing()) { //noinspection HardCodedStringLiteral throw new IllegalArgumentException("component must be shown on the screen"); } removeAll(); // Fill menu. Only after filling menu has non zero size. int x2 = Math.max(0,Math.min(x,component.getWidth() - 1)); // fit x into [0,width-1] int y2 = Math.max(0,Math.min(y,component.getHeight() - 1)); // fit y into [0,height-1] myContext = myDataContextProvider != null ? myDataContextProvider.get() : DataManager.getInstance().getDataContext(component,x2,y2); Utils.fillMenu(myGroup,this,true,myPresentationFactory,myContext,myPlace,false,false); if (getComponentCount() == 0) { return; } if (myApp != null) { if (myApp.isActive()) { Component frame = UIUtil.findUltimateParent(component); if (frame instanceof IdeFrame) { myFrame = (IdeFrame)frame; } myConnection = myApp.getMessageBus().connect(); myConnection.subscribe(ApplicationActivationListener.TOPIC,ActionPopupMenuImpl.this); } } super.show(component,x,y); }
private MountainLionNotifications() { final MessageBusConnection connection = ApplicationManager.getApplication().getMessageBus().connect(); connection.subscribe(ApplicationActivationListener.TOPIC,new ApplicationActivationListener.Adapter() { @Override public void applicationActivated(IdeFrame ideFrame) { cleanupDeliverednotifications(); } }); connection.subscribe(AppLifecycleListener.TOPIC,new AppLifecycleListener.Adapter() { @Override public void appClosing() { cleanupDeliverednotifications(); } }); }
private static boolean setActive(Application application,Window window) { IdeFrame ideFrame = getIdeFrameFromWindow(window); state = State.ACTIVE; LOG.debug("The app is in the active state"); if (ideFrame != null) { application.getMessageBus().syncpublisher(ApplicationActivationListener.TOPIC).applicationActivated(ideFrame); return true; } return false; }
/** * Adds IntelliJ listeners including already opened windows and * registers shutdown and debugger listeners. */ public void attachListeners() { WatchDogEventType.START_IDE.process(this); connection.subscribe(ApplicationActivationListener.TOPIC,new IntelliJActivationListener()); activityListener = new GeneralActivityListener(project.getName()); EditorFactory.getInstance().addEditorFactoryListener(editorWindowListener,parent); attachDebuggerListeners(); }
public void afterValueChanged(RegistryValue value) { if (value.asBoolean()) { ourConnection = app.getMessageBus().connect(); ourConnection.subscribe(ApplicationActivationListener.TOPIC,LISTENER); } else { ourConnection.disconnect(); } }
@Override public void show(final Component component,LaterInvocator.isInModalContext()); if (getComponentCount() == 0) { return; } if (myApp != null) { if (myApp.isActive()) { Component frame = UIUtil.findUltimateParent(component); if (frame instanceof IdeFrame) { myFrame = (IdeFrame)frame; } myConnection = myApp.getMessageBus().connect(); myConnection.subscribe(ApplicationActivationListener.TOPIC,ActionPopupMenuImpl.this); } } super.show(component,y); }
private MountainLionNotifications() { final MessageBusConnection connection = ApplicationManager.getApplication().getMessageBus().connect(); connection.subscribe(ApplicationActivationListener.TOPIC,new AppLifecycleListener() { @Override public void appClosing() { cleanupDeliverednotifications(); } }); }
private static boolean setActive(Application application,Window window) { IdeFrame ideFrame = getIdeFrameFromWindow(window); state = State.ACTIVE; LOG.debug("The app is in the active state"); if (ideFrame != null) { application.getMessageBus().syncpublisher(ApplicationActivationListener.TOPIC).applicationActivated(ideFrame); return true; } return false; }
@SuppressWarnings("UnusedParameters") // the dependencies are needed to ensure correct loading order public FocusManagerImpl(ServiceManagerImpl serviceManager,WindowManager wm,UiActivityMonitor monitor) { myApp = ApplicationManager.getApplication(); myQueue = IdeEventQueue.getInstance(); myActivityMonitor = monitor; myFocusedComponentAlarm = new EdtAlarm(); myForcedFocusRequestsAlarm = new EdtAlarm(); myIdleAlarm = new EdtAlarm(); final AppListener myAppListener = new AppListener(); myApp.getMessageBus().connect().subscribe(ApplicationActivationListener.TOPIC,myAppListener); IdeEventQueue.getInstance().adddispatcher(new IdeEventQueue.Eventdispatcher() { @Override public boolean dispatch(AWTEvent e) { if (e instanceof FocusEvent) { final FocusEvent fe = (FocusEvent)e; final Component c = fe.getComponent(); if (c instanceof Window || c == null) return false; Component parent = UIUtil.findUltimateParent(c); if (parent instanceof IdeFrame) { myLastFocused.put((IdeFrame)parent,c); } } else if (e instanceof WindowEvent) { Window wnd = ((WindowEvent)e).getwindow(); if (e.getID() == WindowEvent.WINDOW_CLOSED) { if (wnd instanceof IdeFrame) { myLastFocused.remove(wnd); myLastFocusedAtDeactivation.remove(wnd); } } } return false; } },this); KeyboardFocusManager.getCurrentKeyboardFocusManager().addPropertychangelistener("focusedWindow",new Propertychangelistener() { @Override public void propertyChange(PropertyChangeEvent evt) { if (evt.getNewValue() instanceof IdeFrame) { myLastFocusedFrame = (IdeFrame)evt.getNewValue(); } } }); }
public ActionCallback run() { myStopRequested = false; myRegistryValues.clear(); final UiActivityMonitor activityMonitor = UiActivityMonitor.getInstance(); activityMonitor.clear(); activityMonitor.setActive(true); myCurrentStageDepth.clear(); myPassedStages.clear(); myContextTimestamp++; ApplicationManager.getApplication().getMessageBus().connect(ApplicationManager.getApplication()).subscribe(ApplicationActivationListener.TOPIC,myAppListener); try { myActionCallback = new ActionCallback(); myActionCallback.doWhenProcessed(new Runnable() { @Override public void run() { stop(); SwingUtilities.invokelater(new Runnable() { @Override public void run() { activityMonitor.setActive(false); restoreRegistryValues(); } }); } }); myRobot = new Robot(); parse(); new Thread("playback runner") { @Override public void run() { if (myUseDirectActionCall) { executeFrom(0,getScriptDir()); } else { IdeEventQueue.getInstance().doWhenReady(new Runnable() { public void run() { executeFrom(0,getScriptDir()); } }); } } }.start(); } catch (AWTException e) { LOG.error(e); } return myActionCallback; }
protected JComponent createCenterPanel() { JPanel panel = new MyPanel(); myUiUpdater = new MergingUpdateQueue("FileChooserUpdater",200,panel); disposer.register(mydisposable,myUiUpdater); new UiNotifyConnector(panel,myUiUpdater); panel.setBorder(JBUI.Borders.empty()); createTree(); final DefaultActionGroup group = createActionGroup(); ActionToolbar toolBar = ActionManager.getInstance().createActionToolbar(ActionPlaces.UNKNowN,group,true); toolBar.setTargetComponent(panel); final JPanel toolbarPanel = new JPanel(new BorderLayout()); toolbarPanel.add(toolBar.getComponent(),BorderLayout.CENTER); myTextFieldAction = new TextFieldAction() { public void linkSelected(final LinkLabel aSource,final Object aLinkData) { toggleshowtextField(); } }; toolbarPanel.add(myTextFieldAction,BorderLayout.EAST); JPanel extraToolbarPanel = createExtraToolbarPanel(); if(extraToolbarPanel != null){ toolbarPanel.add(extraToolbarPanel,BorderLayout.soUTH); } myPathTextFieldWrapper = new JPanel(new BorderLayout()); myPathTextFieldWrapper.setBorder(JBUI.Borders.emptyBottom(2)); myPathTextField = new FileTextFieldImpl.Vfs( FileChooserFactoryImpl.getMacroMap(),getdisposable(),new LocalFsFinder.FileChooserFilter(myChooserDescriptor,myFileSystemTree)) { protected void onTextChanged(final String newValue) { myUiUpdater.cancelAllUpdates(); updateTreeFromPath(newValue); } }; disposer.register(mydisposable,myPathTextField); myPathTextFieldWrapper.add(myPathTextField.getField(),BorderLayout.CENTER); if (getRecentFiles().length > 0) { myPathTextFieldWrapper.add(createHistoryButton(),BorderLayout.EAST); } mynorthPanel = new JPanel(new BorderLayout()); mynorthPanel.add(toolbarPanel,BorderLayout.norTH); updateTextFieldShowing(); panel.add(mynorthPanel,BorderLayout.norTH); registerMouseListener(group); JScrollPane scrollPane = ScrollPaneFactory.createScrollPane(myFileSystemTree.getTree()); //scrollPane.setBorder(BorderFactory.createLineBorder(new Color(148,154,156))); panel.add(scrollPane,BorderLayout.CENTER); panel.setPreferredSize(JBUI.size(400)); panel.add(new JLabel(DRAG_N_DROP_HINT,SwingConstants.CENTER),BorderLayout.soUTH); ApplicationManager.getApplication().getMessageBus().connect(getdisposable()) .subscribe(ApplicationActivationListener.TOPIC,new ApplicationActivationListener.Adapter() { @Override public void applicationActivated(IdeFrame ideFrame) { DumbService.allowStartingDumbModeInside(DumbModePermission.MAY_START_MODAL,new Runnable() { @Override public void run() { ((SaveAndSyncHandlerImpl)SaveAndSyncHandler.getInstance()).maybeRefresh(ModalityState.current()); } }); } }); return panel; }
@SuppressWarnings("UnusedParameters") // the dependencies are needed to ensure correct loading order public FocusManagerImpl(ServiceManagerImpl serviceManager,UiActivityMonitor monitor) { myApp = ApplicationManager.getApplication(); myQueue = IdeEventQueue.getInstance(); myActivityMonitor = monitor; myFocusedComponentAlaram = new EdtAlarm(); myForcedFocusRequestsAlarm = new EdtAlarm(); myIdleAlarm = new EdtAlarm(); final AppListener myAppListener = new AppListener(); myApp.getMessageBus().connect().subscribe(ApplicationActivationListener.TOPIC,myAppListener); IdeEventQueue.getInstance().adddispatcher(new IdeEventQueue.Eventdispatcher() { public boolean dispatch(AWTEvent e) { if (e instanceof FocusEvent) { final FocusEvent fe = (FocusEvent)e; final Component c = fe.getComponent(); if (c instanceof Window || c == null) return false; Component parent = SwingUtilities.getwindowAncestor(c); if (parent instanceof IdeFrame) { myLastFocused.put((IdeFrame)parent,new WeakReference<Component>(c)); } } else if (e instanceof WindowEvent) { Window wnd = ((WindowEvent)e).getwindow(); if (e.getID() == WindowEvent.WINDOW_CLOSED) { if (wnd instanceof IdeFrame) { myLastFocused.remove((IdeFrame)wnd); myLastFocusedAtDeactivation.remove((IdeFrame)wnd); } } } return false; } },new Propertychangelistener() { @Override public void propertyChange(PropertyChangeEvent evt) { if (evt.getNewValue() instanceof IdeFrame) { myLastFocusedFrame = (IdeFrame)evt.getNewValue(); } } }); }
public ActionCallback run() { myStopRequested = false; myRegistryValues.clear(); final UiActivityMonitor activityMonitor = UiActivityMonitor.getInstance(); activityMonitor.clear(); activityMonitor.setActive(true); myCurrentStageDepth.clear(); myPassedStages.clear(); myContextTimestamp++; ApplicationManager.getApplication().getMessageBus().connect(myOnStop).subscribe(ApplicationActivationListener.TOPIC,myAppListener); try { myActionCallback = new ActionCallback(); myActionCallback.doWhenProcessed(new Runnable() { @Override public void run() { stop(); SwingUtilities.invokelater(new Runnable() { @Override public void run() { activityMonitor.setActive(false); restoreRegistryValues(); } }); } }); myRobot = new Robot(); parse(); new Thread() { @Override public void run() { if (myUseDirectActionCall) { executeFrom(0,getScriptDir()); } }); } } }.start(); } catch (AWTException e) { LOG.error(e); } return myActionCallback; }
@SuppressWarnings("UnusedParameters") // the dependencies are needed to ensure correct loading order public FocusManagerImpl(ServiceManagerImpl serviceManager,UiActivityMonitor monitor) { myApp = ApplicationManager.getApplication(); myQueue = IdeEventQueue.getInstance(); myActivityMonitor = monitor; myFocusedComponentAlarm = new EdtAlarm(); myForcedFocusRequestsAlarm = new EdtAlarm(); final AppListener myAppListener = new AppListener(); myApp.getMessageBus().connect().subscribe(ApplicationActivationListener.TOPIC,myAppListener); IdeEventQueue.getInstance().adddispatcher(e -> { if (e instanceof FocusEvent) { final FocusEvent fe = (FocusEvent)e; final Component c = fe.getComponent(); if (c instanceof Window || c == null) return false; Component parent = UIUtil.findUltimateParent(c); if (parent instanceof IdeFrame) { myLastFocused.put((IdeFrame)parent,c); } } else if (e instanceof WindowEvent) { Window wnd = ((WindowEvent)e).getwindow(); if (e.getID() == WindowEvent.WINDOW_CLOSED) { if (wnd instanceof IdeFrame) { myLastFocused.remove(wnd); myLastFocusedAtDeactivation.remove(wnd); } } } return false; },new Propertychangelistener() { @Override public void propertyChange(PropertyChangeEvent evt) { if (evt.getNewValue() instanceof IdeFrame) { myLastFocusedFrame = (IdeFrame)evt.getNewValue(); } } }); }
public ActionCallback run() { myStopRequested = false; myRegistryValues.clear(); final UiActivityMonitor activityMonitor = UiActivityMonitor.getInstance(); activityMonitor.clear(); activityMonitor.setActive(true); myCurrentStageDepth.clear(); myPassedStages.clear(); myContextTimestamp++; ApplicationManager.getApplication().getMessageBus().connect(myOnStop).subscribe(ApplicationActivationListener.TOPIC,getScriptDir()); } }); } } }.start(); } catch (AWTException e) { LOG.error(e); } return myActionCallback; }
public FocusDrawer() { super("focus debugger"); Application app = ApplicationManager.getApplication(); app.getMessageBus().connect().subscribe(ApplicationActivationListener.TOPIC,this); }
protected JComponent createCenterPanel() { JPanel panel = new MyPanel(); myUiUpdater = new MergingUpdateQueue("FileChooserUpdater",BorderLayout.EAST); JPanel extraToolbarPanel = createExtraToolbarPanel(); if (extraToolbarPanel != null) { toolbarPanel.add(extraToolbarPanel,BorderLayout.soUTH); } myPathTextFieldWrapper = new JPanel(new BorderLayout()); myPathTextFieldWrapper.setBorder(JBUI.Borders.emptyBottom(2)); myPathTextField = new FileTextFieldImpl.Vfs(FileChooserFactoryImpl.getMacroMap(),BorderLayout.CENTER); panel.setPreferredSize(JBUI.size(400)); JLabel hintLabel = new JLabel(DRAG_N_DROP_HINT,SwingConstants.CENTER); hintLabel.setForeground(JBColor.gray); hintLabel.setFont(JBUI.Fonts.smallFont()); panel.add(hintLabel,BorderLayout.soUTH); ApplicationManager.getApplication().getMessageBus().connect(getdisposable()) .subscribe(ApplicationActivationListener.TOPIC,new ApplicationActivationListener() { @Override public void applicationActivated(IdeFrame ideFrame) { ((SaveAndSyncHandlerImpl)SaveAndSyncHandler.getInstance()).maybeRefresh(ModalityState.current()); } }); return panel; }
今天的关于Hadoop Mapper由于“ApplicationMaster杀死容器”而失败的分享已经结束,谢谢您的关注,如果想了解更多关于2.2.0-ApplicationMaster总是连接0.0.0.0:8030问题的解决、Application application_1512618719369_147804 failed 2 times due to ApplicationMaster for attempt app、ApplicationListener ApplicationContextAware ApplicationEvent使用、com.intellij.openapi.application.ApplicationActivationListener的实例源码的相关知识,请在本站进行查询。
本文标签: