GVKun编程网logo

Hadoop Mapper由于“ApplicationMaster杀死容器”而失败

15

这篇文章主要围绕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杀死容器”而失败

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问题的解决

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

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使用

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的实例源码

com.intellij.openapi.application.ApplicationActivationListener的实例源码

项目:intellij-ce-playground    文件:PlaybackRunner.java   
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();
      }
    }
  };
}
项目:intellij-ce-playground    文件:AppIcon.java   
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();
}
项目:consulo    文件:Alarm.java   
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);
  }
}
项目:consulo    文件:PlaybackRunner.java   
public PlaybackRunner(String script,StatusCallback.Type.message);
        stop();
      }
    }
  };
}
项目:consulo-java    文件:UnscrambleManager.java   
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();
        }
    }
}
项目:intellij-ce-playground    文件:UnscrambleAction.java   
public void afterValueChanged(RegistryValue value) {
  if (value.asBoolean()) {
    ourConnection = app.getMessageBus().connect();
    ourConnection.subscribe(ApplicationActivationListener.TOPIC,LISTENER);
  } else {
    ourConnection.disconnect();
  }
}
项目:intellij-ce-playground    文件:Alarm.java   
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);
  }
}
项目:intellij-ce-playground    文件:ActionPopupMenuImpl.java   
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);
}
项目:intellij-ce-playground    文件:MountainLionNotifications.java   
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();
    }
  });
}
项目:intellij-ce-playground    文件:ApplicationActivationStateManager.java   
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;
}
项目:watchdog    文件:IntelliJListener.java   
/**
 * 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();
}
项目:tools-idea    文件:UnscrambleAction.java   
public void afterValueChanged(RegistryValue value) {
  if (value.asBoolean()) {
    ourConnection = app.getMessageBus().connect();
    ourConnection.subscribe(ApplicationActivationListener.TOPIC,LISTENER);
  } else {
    ourConnection.disconnect();
  }
}
项目:consulo    文件:ActionPopupMenuImpl.java   
@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);
}
项目:consulo    文件:MountainLionNotifications.java   
private MountainLionNotifications() {
  final MessageBusConnection connection = ApplicationManager.getApplication().getMessageBus().connect();
  connection.subscribe(ApplicationActivationListener.TOPIC,new AppLifecycleListener() {
    @Override
    public void appClosing() {
      cleanupDeliverednotifications();
    }
  });
}
项目:consulo    文件:ApplicationActivationStateManager.java   
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;
}
项目:intellij-ce-playground    文件:FocusManagerImpl.java   
@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();
      }
    }
  });
}
项目:intellij-ce-playground    文件:PlaybackRunner.java   
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;
}
项目:intellij-ce-playground    文件:FileChooserDialogImpl.java   
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;
}
项目:tools-idea    文件:FocusManagerImpl.java   
@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();
      }
    }
  });
}
项目:tools-idea    文件:PlaybackRunner.java   
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;
}
项目:consulo    文件:FocusManagerImpl.java   
@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();
      }
    }
  });
}
项目:consulo    文件:PlaybackRunner.java   
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;
}
项目:consulo    文件:FocusDebuggerAction.java   
public FocusDrawer() {
  super("focus debugger");
  Application app = ApplicationManager.getApplication();
  app.getMessageBus().connect().subscribe(ApplicationActivationListener.TOPIC,this);
}
项目:consulo    文件:FileChooserDialogImpl.java   
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的实例源码的相关知识,请在本站进行查询。

本文标签: