frsyuki

included!
paramter: {{ env.EDITOR }}

frsyuki

コンパイラで例外が発生しました(1.8.0_20)。Bug Paradeで重複がないかをご確認のうえ、Java Developer Connection (http://java.sun.com/webapps/bugreport)でbugの登録をお願いいたします。レポートには、そのプログラムと下記の診断内容を含めてください。ご協力ありがとうございます。
java.lang.NullPointerException
        at com.sun.tools.javac.comp.Attr.visitVarDef(Attr.java:1066)
        at com.sun.tools.javac.tree.JCTree$JCVariableDecl.accept(JCTree.java:852)
        at com.sun.tools.javac.comp.Attr.attribTree(Attr.java:607)
        at com.sun.tools.javac.comp.Attr.attribStat(Attr.java:676)
        at com.sun.tools.javac.comp.Attr.attribStats(Attr.java:692)
        at com.sun.tools.javac.comp.Attr.visitLambda(Attr.java:2379)
        at com.sun.tools.javac.tree.JCTree$JCLambda.accept(JCTree.java:1624)
        at com.sun.tools.javac.comp.Attr.attribTree(Attr.java:607)

frsyuki

diff -urp hadoop-2.4.0.2.1.5.0-695-src-orig/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AppSchedulable.java hadoop-2.4.0.2.1.5.0-695-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AppSchedulable.java
--- hadoop-2.4.0.2.1.5.0-695-src-orig/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AppSchedulable.java	2014-08-27 20:05:43.000000000 -0700
+++ hadoop-2.4.0.2.1.5.0-695-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AppSchedulable.java	2015-08-12 18:17:22.000000000 -0700
@@ -82,14 +82,18 @@ public class AppSchedulable extends Sche
     Resources.addTo(de

frsyuki

diff -urp hadoop-2.4.0.2.1.5.0-695-src-orig/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AppSchedulable.java hadoop-2.4.0.2.1.5.0-695-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AppSchedulable.java
--- hadoop-2.4.0.2.1.5.0-695-src-orig/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AppSchedulable.java	2014-08-27 20:05:43.000000000 -0700
+++ hadoop-2.4.0.2.1.5.0-695-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AppSchedulable.java	2015-08-06 15:46:40.000000000 -0700
@@ -92,6 +92,20 @@ public class AppSchedulable extends Sche
     }
   }
 
+  public 

frsyuki

variables:  # declare variables in a config file
  myval: 1
plugin_variables:  # run an input plugin, and use tha last (or first) row as variables
  type: postgresql
  query: select max(id) as max_id from access
  database: production
  host: pg_analyze
in:
  type: mysql
  query: select id, host, ip from access_source where ${max_id} < id

frsyuki

Problem:

HistoryFileManager.addIfAbsent produces large amount of logs if number of
cached entries whose age is less than mapreduce.jobhistory.max-age-ms becomes
larger than mapreduce.jobhistory.joblist.cache.size by far.

Example:

For example, if the cache contains 50000 entries in total and 10,000 entries
newer than mapreduce.jobhistory.max-age-ms where

frsyuki

@MessagePackPolimorhpicType("type")
public abstract class PlanNode
{
    ...

    public static final Deserializer type = new PolymorphicDeserializer()
            .add("error", ErrorNode.class)
            .add("engine", EngineNode.class);
}

frsyuki

@MessagePackDeserializer(PlanNodeDeserializer.class)
public abstract class PlanNode
{
    ...
}

public class PlanNodeDeserializer extends Deserializer<PlanNode>
{
    public PlanNode deserialize(Unpacker unpacker)
    {

frsyuki

@MessagePackDeserialzeTypeSwitches({
        @MessagePackTypeSwitches.ifEquals(key = "type", value = "output", then = OutputNode.class),
        @MessagePackTypeSwitches.ifEquals(key = "type", value = "project", then = ProjectNode.class),
        @MessagePackTypeSwitches.ifEquals(key = "type", value = "tablescan", then = TableScanNode.class),
        @MessagePackTypeSwitches.ifExists(key = "error", then = ErrorNode.class)
        @MessagePackTypeSwitches.ifExists(key = "engine", then = EngineNode.class)
})
public abstract class PlanNode
{
    ...

frsyuki

import com.fasterxml.jackson.annotation.JsonValue;
import com.fasterxml.jackson.annotation.JsonCreator;

@MessagePackPolymorphicTypeStorage("csharp_types")
public class DictWithPersistentTypeInfo
{
    private final Map<String, Object> dict;
    
    @JsonCreator
    public MyDictWithPersistentTypeInfo(Map<String, Object> dict)