Branch: feature/frontend-vertical-sidebar
Transform the Pierre Admin Frontend with a vertical sidebar navigation and full alignment with BRAND.md design system.
check_setup_status() in src/auth.rs - was checking hardcoded [email protected] instead of any user with is_admin=true
| Run cargo clippy --all-targets --all-features --quiet -- -W clippy::all -W clippy::pedantic -W clippy::nursery -D warnings | |
| cargo clippy --all-targets --all-features --quiet -- -W clippy::all -W clippy::pedantic -W clippy::nursery -D warnings | |
| shell: /usr/bin/bash -e {0} | |
| env: | |
| CARGO_TERM_COLOR: always | |
| CARGO_HOME: /home/runner/.cargo | |
| CARGO_INCREMENTAL: 0 | |
| error: `to_string()` called on a `&str` | |
| --> src/providers/utils.rs:154:27 | |
| | |
| 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 |
| 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 |
| <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"/> |
| 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 |
| /** | |
| * 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) |
| 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 |
| --- 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(); | |
| + } |