Codewut Because Software Matters

#replace eth1:0 with your NIC / alias
bind_ip=$(/sbin/ifconfig eth1:0 | grep 'inet addr:' | cut -d: -f2 | awk '{print $1}')
 
export BIND_OPTS="-Dlocal.bind.address=${bind_ip}"
 
# Command specific options appended to HADOOP_OPTS when specified
export HADOOP_NAMENODE_OPTS="-Dcom.sun.management.jmxremote $HADOOP_NAMENODE_OPTS $BIND_OPTS"
export HADOOP_SECONDARYNAMENODE_OPTS="-Dcom.sun.management.jmxremote $HADOOP_SECONDARYNAMENODE_OPTS $BIND_OPTS"
export HADOOP_DATANODE_OPTS="-Dcom.sun.management.jmxremote $HADOOP_DATANODE_OPTS $BIND_OPTS"
export HADOOP_BALANCER_OPTS="-Dcom.sun.management.jmxremote $HADOOP_BALANCER_OPTS $BIND_OPTS" 
export HADOOP_JOBTRACKER_OPTS="-Dcom.sun.management.jmxremote $HADOOP_JOBTRACKER_OPTS $BIND_OPTS"

<property>
  <name>dfs.secondary.http.address</name>
  <value>${local.bind.address}:50090</value>
  <description>
    The secondary namenode http server address and port.
    If the port is 0 then the server will start on a free port.
  </description>
</property>
 
<property>
  <name>dfs.datanode.address</name>
  <value>${local.bind.address}:50010</value>
</property>
 
<property>
  <name>dfs.datanode.http.address</name>
  <value>${local.bind.address}:50075</value>
</property>
 
<property>
  <name>dfs.datanode.ipc.address</name>
  <value>${local.bind.address}:50020</value>
</property>
 
<property>
  <name>dfs.http.address</name>
  <value>${local.bind.address}:50070</value>
</property>
 
<property>
  <name>dfs.datanode.https.address</name>
  <value>${local.bind.address}:50475</value>
</property>
 
<property>
  <name>dfs.https.address</name>
  <value>${local.bind.address}:50470</value>
</property>

public class TestThreadPool extends TestCase
{
 private static Log log = LogFactory.getLog(TestThreadPool.class);
 
 public void testLoadTracker() throws InterruptedException
 {
  int maxRunningThreads = 128;
  int maxLoad = 500;
 
  LoadTracker load = new LoadTracker(maxLoad);
  ExecutorService pool = Executors.newFixedThreadPool(maxRunningThreads);
 
  for (int i = 0; i < 500; i++)
  {
   // here you would create your real job and *predict* its impact on the load factor.
   // we choose the load to be random.
   int predictedJobLoad = (int) Math.round(Math.random() * 10l);
   MyJob aJob = new MyJob(load, predictedJobLoad,"job-"+i,this);
 
   while (!load.canHandle(predictedJobLoad))
   {
    log.debug(String.format("WAIT: current load %d and new job is about to be %d", load.get(), predictedJobLoad));
    synchronized (this) { this.wait(1000); }
   }
 
   log.debug(String.format("QUEUE: current load is %d and new job is about to be %d", load.get(), predictedJobLoad));
   pool.execute(aJob);
  }
  pool.shutdown();
  pool.awaitTermination(42,TimeUnit.DAYS);
  assertEquals(0, load.get());
 }
 
 private  class MyJob implements Runnable
 {
  private LoadTracker loadTracker;
  private int load;
  private String jobId;
  private Object monitor;
 
  public MyJob(LoadTracker loadTracker, int load, String jobId, Object monitor)
  {
   this.jobId = jobId;
   this.loadTracker = loadTracker;
   this.load = load;
   this.monitor = monitor;
   loadTracker.add(load);
  }
 
  @Override
  public void run()
  {
   log.debug(String.format("RUN: %s with a load of %d", jobId, load));
   try
   {
    Thread.sleep((int) Math.round(Math.random() * 5000l));
   }
   catch (InterruptedException e)
   {
    e.printStackTrace();
   }
   log.debug(String.format("FIN: %s with a load of %d", jobId, load));
   loadTracker.remove(load);
   if (monitor != null) synchronized (monitor) { monitor.notify(); }
  }
 }
 
 private class LoadTracker
 {
  private int currentLoad = 0;
  private int maxLoad = 0;
 
  public LoadTracker(int maxLoad)
  {
   this.maxLoad = maxLoad;
  }
 
  private synchronized void add(int load)
  {
   this.currentLoad += load;
  }
 
  private synchronized void remove(int load)
  {
   this.currentLoad -= load;
  }
 
  public synchronized int get()
  {
   return currentLoad;
  }
 
  public synchronized boolean canHandle(int additionalLoad)
  {
   return ((this.get() + additionalLoad) < maxLoad);
  }
 }
}

Connection connection = dataSource.getConnection();
Statement st = connection.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
st.setFetchSize(Integer.MIN_VALUE); // Inter.MIN_VALUE <- and ONLY this value, 1,5 or 100 won't fix your problem.
ResultSet rs = st.executeQuery("select * from someREALLYHugeTable");

#!/bin/sh
 
########################################################################
## Scans all jar files within a directory (recursively) for a class 
## name
## Usage: findClass /tmp/ MyFunnyClass
########################################################################
 
black='\E[30;47m'
red='\E[31;40m\033[1m'
green='\E[32;47m'
yellow='\E[33;40m'
blue='\E[34;40m\033[1m'
magenta='\E[35;47m'
cyan='\E[36;47m'
white='\E[37;47m'
alias Reset="tput sgr0"      
 
cecho () 
{
  local default_msg=" "
  message=${1:-$default_msg}   # Defaults to default message.
  color=${2:-$black}           # Defaults to black, if not specified.
  echo -e -n "$color"
  echo -n "$message"
  Reset                      # Reset to normal.
  return
} 
 
clsln()
{
	fillLine " ";
} 
 
fillLine()
{
        let tw=$(tput cols)-1;
        for (( c=0 ; c < $tw; c++))
        do
                echo -n "$1";
        done
        echo -e -n '\r'
}
 
echo 
echo -n Scanning Folder: 
cecho "$1" $yellow
echo -n for Class: 
cecho "$2" $yellow
echo
 
fillLine "."
echo
for i in $(find $1 -name '*jar');
do
	clsln;
        echo -n -e "Scanning :";
	cecho $i $blue
	echo -n -e '\r';
 
        out=$(jar vft $i | egrep $2);
 
        if [ "$out" ]
        then
		clsln;
		fillLine "*"
		echo
		echo -n -e 'Possble hit in file:'
		cecho $i $blue
		echo
                echo "$out" $red
		echo
		fillLine "*"
		echo
		echo
        fi
done;
clsln;
echo;

<Context>
  <Valve
    className="org.apache.catalina.valves.AccessLogValve"
    prefix="access_log"
    pattern="%{X-Forwarded-For}i %l %u %t &quot;%r&quot; %s %b &quot;%{Referer}i&quot; &quot;%{User-Agent}i&quot;"
    rotatable="false"/>
</Context>

/home/tomcat/logs/*_log
{
  weekly
  rotate 48
  create 640 tomcat www-data
  sharedscripts
  postrotate /etc/init.d/tomcat restart
  endscript
  compress
}