jfarcand

<configuration debug='true'>

    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>%d{HH:mm:ss.SSS} %level [%thread] %logger{10} [%file:%line] %msg%n</pattern>
        </encoder>
    </appender>

    <logger name="org.atmosphere.interceptor.OnDisconnectInterceptor" level="TRACE"/>
    <logger name="org.atmosphere.cache.UUIDBroadcasterCache" level="TRACE"/>

jfarcand

Caused by: java.net.ConnectException: Connection timed out: /52.24.104.213:8080
	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_45]
	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_45]
	at org.jboss.netty.channel.socket.nio.NioClientBoss.connect(NioClientBoss.java:152) ~[tubes-loaddriver-all.jar:master-SNAPSHOT]
	at org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:105) ~[tubes-loaddriver-all.jar:master-SNAPSHOT]
	... 8 common frames omitted

jfarcand

            /**
             * Exception in thread "main" scala.MatchError: StringType (of class org.apache.spark.sql.types.StringType$)
             	at org.apache.spark.sql.json.InferSchema$.apply(InferSchema.scala:58)
             	at org.apache.spark.sql.json.JSONRelation$$anonfun$schema$1.apply(JSONRelation.scala:139)
             	at org.apache.spark.sql.json.JSONRelation$$anonfun$schema$1.apply(JSONRelation.scala:138)
             	at scala.Option.getOrElse(Option.scala:121)
             	at org.apache.spark.sql.json.JSONRelation.schema$lzycompute(JSONRelation.scala:137)
             	at org.apache.spark.sql.json.JSONRelation.schema(JSONRelation.scala:137)
             	at org.apache.spark.sql.sources.LogicalRelation.<init>(LogicalRelation.scala:30)
             	at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:120)

jfarcand

Producer

Setup
bin/kafka-topics.sh --zookeeper esv4-hcl197.grid.linkedin.com:2181 --create --topic test-rep-one --partitions 6 --replication-factor 1
bin/kafka-topics.sh --zookeeper esv4-hcl197.grid.linkedin.com:2181 --create --topic test --partitions 6 --replication-factor 3

Single thread, no replication

bin/kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance test7 50000000 100 -1 acks=1 bootstrap.servers=esv4-hcl198.grid.linkedin.com:9092 buffer.memory=67108864 batch.size=8196

jfarcand

--- a/modules/cpr/src/main/java/org/atmosphere/cpr/AtmosphereResourceImpl.java
+++ b/modules/cpr/src/main/java/org/atmosphere/cpr/AtmosphereResourceImpl.java
@@ -831,7 +831,9 @@ public class AtmosphereResourceImpl implements AtmosphereResource {
                 }

                 if (AtmosphereRequest.class.isAssignableFrom(req.getClass())) {
-                    AtmosphereRequest.class.cast(req).destroy();
+                    if (closeOnCancel) {
+                        AtmosphereRequest.class.cast(req).destroy();
+                    }

jfarcand

10:11:21.891 INFO [main] o.a.c.AtmosphereFramework [AtmosphereFramework.java:1082] Atmosphere is using async support: org.atmosphere.container.JSR356AsyncSupport running under container: jetty/9.2.10.v20150310 using javax.servlet/3.0 and jsr356/WebSocket API
10:11:21.892 INFO [main] o.a.c.AtmosphereFramework [AtmosphereFramework.java:1084] Atmosphere Framework 2.3.0-SNAPSHOT started.
10:11:21.892 INFO [main] o.a.c.AtmosphereFramework [AtmosphereFramework.java:1086]

	For Atmosphere Framework Commercial Support, visit
	http://www.async-io.org/ or send an email to support@async-io.org

2015-03-25 10:11:21.914:INFO:oejsh.ContextHandler:main: Started o.e.j.m.p.JettyWebAppContext@3b4a1a75{/,[file:/Users/jfarcand/workspace/atmosphere-samples/samples/chat/src/main/webapp/, file:/Users/jfarcand/workspace/atmosphere-samples/samples/chat/target/tmp/javascript-2_2_8_war1/],AVAILABLE}{file:/Users/jfarcand/workspace/atmosphere-samples/samples/chat/src/main/webapp/}
2015-03-25 10:11:21.915:WARN:oejsh.RequestLogHandler:main

jfarcand

T 127.0.0.1:62444 -> 127.0.0.1:8080 [AP]
GET /chat?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.8-javascript&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true HTTP/1.1.
Host: 127.0.0.1:8080.
Connection: Upgrade.
Pragma: no-cache.
Cache-Control: no-cache.
Upgrade: websocket.
Origin: http://127.0.0.1:8080.
Sec-WebSocket-Version: 13.
User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_10_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2272.104 Safari/537.36.

jfarcand

remfamille:primefaces_showcase jfarcand$ run
Preparing to Execute Maven in Debug Mode
Listening for transport dt_socket at address: 9009
[INFO] Scanning for projects...
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Building primefaces-showcase 5.2-SNAPSHOT
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] >>> jetty-maven-plugin:8.1.9.v20130131:run (default-cli) > test-compile @ showcase >>>

jfarcand

   protected void queueWriteIO(AtmosphereResource r, Deliver deliver, AtomicInteger count) throws InterruptedException {
        if (deliver.async) {
            // The onStateChange/onRequest may change the isResumed value, hence we need to make sure only one thread flip
            // the switch to garantee the Entry will be cached in the order it was broadcasted.
            // Without synchronizing we may end up with a out of order BroadcasterCache queue.
            if (!bc.getBroadcasterCache().getClass().equals(BroadcasterCache.DEFAULT.getClass().getName())) {
                if (r.isResumed() || r.isCancelled()) {
                    logger.trace("AtmosphereResource {} has been resumed or cancelled, unable to Broadcast message {}", r.uuid(), deliver.message);

                    /**

jfarcand

10:29:38,577 INFO  [org.jboss.as.server.deployment] (MSC service thread 1-3) JBAS015876: Starting deployment of "prime.war" (runtime-name: "prime.war")
10:29:39,375 INFO  [org.jboss.web] (ServerService Thread Pool -- 63) JBAS018210: Register web context: /prime
10:29:39,379 INFO  [org.apache.catalina.core] (ServerService Thread Pool -- 63) JBWEB001093: The listener com.sun.faces.config.ConfigureListener is already configured for this context, the duplicate definition has been ignored
10:29:39,387 INFO  [javax.enterprise.resource.webcontainer.jsf.config] (ServerService Thread Pool -- 63) Initializing Mojarra 2.1.19-jbossorg-1 20131024-0833 for context '/prime'
10:29:39,794 INFO  [org.primefaces.webapp.PostConstructApplicationEventListener] (ServerService Thread Pool -- 63) Running on PrimeFaces 5.1.9
10:29:39,808 INFO  [org.atmosphere.cpr.AtmosphereFramework] (ServerService Thread Pool -- 63) Installed AtmosphereInterceptor Atmosphere LifeCycle with priority AFTER_DEFAULT 
10:29:39,809 INFO  [org.atmosphere.cp