arun-rama

/** 
* This is a snippet to reproduce datadog traces being broken when you use kotlin coroutines.
* 
* Three things need to happen. 
* A. There is a child coroutine scope
* B. There is a coroutine with its own span
* C. Coroutine gets suspended and resumes in another thread
* 
* The bug here is that when the coroutine resumes, then it has incorrect span (it ends up with the parent span)
*

arun-rama

 Installation completed successfully. (Current Step) Last Refreshed: Dec 3, 2012 5:32:51 PM PST
/tmp/scm_prepare_node.hWj0UEIf 
using SSH_CLIENT to get the SCM hostname: 50.196.173.126 48099 22 
opening logging file descriptor 
Starting installation script...
Acquiring installation lock...
BEGIN flock 4 
END (0) 
Detecting root privileges...

arun-rama

role :datanodes, "node1", "node2

checkout =  "svn -q --non-interactive --no-auth-cache co https://inc.jira.com/svn/DATBUM/trunk /opt/inc/DATBUM --username svnreadonly --password ***"
update =  "svn -q --non-interactive --no-auth-cache up /opt/inc/DATBUM --username svnreadonly --password ***"


desc "Initil setup : makes the Datbum Repo locally available on all the datanodes "
task :setup_datbum, :roles => :datanodes do
  run "sudo apt-get -y install subversion"
  run "sudo mkdir -p -m 777 /opt/inc"

arun-rama

	<build>

		<!-- sourceDirectory>src/main/java</sourceDirectory -->
		<!-- testSourceDirectory>src/test/java</testSourceDirectory> -->

		<pluginManagement>
			<plugins>
				<plugin>
					<groupId>net.alchim31.maven</groupId>
					<artifactId>scala-maven-plugin</artifactId>

arun-rama

import java.io.File;
import java.io.IOException;
import java.lang.InterruptedException;
import java.util.StringTokenizer;

import org.apache.commons.io.FileUtils;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;

arun-rama

//App.scala 

object App { 
 def fromString(s:String) : Option[Int] =  if( s == "0" ) Some(0) else None
}


//Test.java
public class Test {
	public static void main(String[] args){

arun-rama

//This compiles fine 

object AppBuilder extends App {
 
    def app( blockw: Int => String ) : List[String] = List( blockw(6) )

    def app( block: => String ) : List[String] = app( _ => block )
}

arun-rama

/Users/arun/workspace/DARKMATTER/Higgs>mvn dependency:tree
[INFO] Scanning for projects...
[INFO]                                                                         
[INFO] ------------------------------------------------------------------------
[INFO] Building Higgs 0.0.1-SNAPSHOT
[INFO] ------------------------------------------------------------------------
[INFO] 
[INFO] --- maven-dependency-plugin:2.1:tree (default-cli) @ Higgs ---
[INFO] com.incentica:Higgs:jar:0.0.1-SNAPSHOT
[INFO] +- org.slf4j:jcl-over-slf4j:jar:1.5.11:compile

arun-rama

[INFO] Scanning for projects...
[WARNING] 
[WARNING] Some problems were encountered while building the effective model for ch.qos.logback:logback-demo:war:1.0
[WARNING] 'build.plugins.plugin.version' for org.apache.maven.plugins:maven-compiler-plugin is missing. @ line 116, column 15
[WARNING] 
[WARNING] It is highly recommended to fix these problems because they threaten the stability of your build.
[WARNING] 
[WARNING] For this reason, future Maven versions might no longer support building such malformed projects.
[WARNING] 
[INFO]                                                                         

arun-rama

import akka.actor.{ Actor, OneForOneStrategy, ActorLogging, Props, ActorSystem }
import akka.routing.RoundRobinRouter


  class TAct extends Actor with ActorLogging {
    var cnt = 0
    def receive = {
      case s:String =>
        cnt+=1
        log.info("requested count {} req {}", cnt, s );