jfarcand

kl()
  local key="$1"
  local namespace="${2:-production}" # Default to production if no namespace is provided
  local pod_names
  local selected_pods=()

  # Find the pod names based on the key
  pod_names=($(kubectl get pod -n "$namespace" | grep "$key" | awk '{print $1}'))

  if [[ ${#pod_names[@]} -eq 0 ]]; then

jfarcand

kl() {
  local key="$1"
  local namespace="${2:-production}" # Default to production if no namespace is provided
  local pod_names
  local selected_pod

  # Find the pod names based on the key
  pod_names=($(kubectl get pod -n "$namespace" | grep "$key" | awk '{print $1}'))

  if [[ ${#pod_names[@]} -eq 0 ]]; then

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