Skip to content

Unpredictable behaviour at the state management sample #211

Description

@RicardoNiepel

Environment

PS C:\Sources\dapr-java-sdk> mvn -v
  Apache Maven 3.6.3 (cecedd343002696d0abb50b32b541b8a6ba2883f)
  Maven home: C:\Program Files\apache-maven-3.6.3\bin\..
  Java version: 11.0.6, vendor: AdoptOpenJDK, runtime: C:\Users\riniepel\AppData\Local\Programs\AdoptOpenJDK
  Default locale: de_DE, platform encoding: Cp1252
  OS name: "windows 10", version: "10.0", arch: "amd64", family: "windows"
PS C:\Sources\dapr-java-sdk>dapr --version
  CLI version: 0.3.0
  Runtime version: 0.3.0

Branch: release-0.2.0-beta

Expected Behavior

The State management sample should not lead to Maven errors and warnings and each execution should bring the same successful outcome.

Actual Behavior

As you can see below, multiple Maven Errors and Warnings are coming up.

In addition, sometimes the client is unable to connect to Dapr (the second run) and thus is not predictable.

Logs / Output

First Run

dapr run --port 3006 -- mvn exec:java -D exec.mainClass=io.dapr.examples.state.StateClient -D exec.args="'my message'"
Starting Dapr with id Pigwinter-Hide. HTTP Port: 3006. gRPC Port: 55991
You're up and running! Both Dapr and your app logs will appear here.

== DAPR == time="2020-02-05T14:01:58+01:00" level=info msg="starting Dapr Runtime -- version 0.3.0 -- commit 
v0.3.0-rc.0-1-gfe6c306-dirty"
== DAPR == time="2020-02-05T14:01:58+01:00" level=info msg="log level set to: info"
== DAPR == time="2020-02-05T14:01:58+01:00" level=info msg="standalone mode configured"
== DAPR == time="2020-02-05T14:01:58+01:00" level=info msg="dapr id: Pigwinter-Hide"
== DAPR == time="2020-02-05T14:01:58+01:00" level=info msg="loaded component messagebus (pubsub.redis)" 
== DAPR == time="2020-02-05T14:01:58+01:00" level=info msg="loaded component sample123 (bindings.kafka)"
== DAPR == time="2020-02-05T14:01:58+01:00" level=info msg="loaded component statestore (state.redis)"  
== DAPR == 2020-02-05 14:01:58.786736 I | redis: connecting to localhost:6379
== DAPR == 2020-02-05 14:01:58.798735 I | redis: connected to localhost:6379 (localAddr: [::1]:55992, rem
Addr: [::1]:6379)
    == DAPR == time="2020-02-05T14:01:58+01:00" level=info msg="Initialized service discovery to standalone"
    == APP == [INFO] Scanning for projects...
    == APP == [WARNING] 
    == APP == [WARNING] Some problems were encountered while building the effective model for io.dapr:dapr-sd
k-examples:jar:0.2.0-beta-1
    == APP == [WARNING] 'build.plugins.plugin.version' for org.apache.maven.plugins:maven-deploy-plugin is mi
ssing. @ line 130, column 15
== APP == [WARNING]
== APP == [WARNING] It is highly recommended to fix these problems because they threaten the stability of
 your build.
    == APP == [WARNING] 
== APP == [WARNING] For this reason, future Maven versions might no longer support building such malforme
d projects.
== APP == [WARNING]
    == APP == [INFO] Inspecting build with total of 1 modules...
== APP == [INFO] Installing Nexus Staging features:
== APP == [INFO]   ... total of 1 executions of maven-deploy-plugin replaced with nexus-staging-maven-plu
gin
    == APP == [INFO] 
    == APP == [INFO] ---------------------< io.dapr:dapr-sdk-examples >----------------------
== APP == [INFO] Building dapr-sdk-examples 0.2.0-beta-1
== APP == [INFO] --------------------------------[ jar ]---------------------------------
    == DAPR == time="2020-02-05T14:02:08+01:00" level=warning msg="failed to init output binding bindings.kaf
ka: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)"
    == DAPR == time="2020-02-05T14:02:08+01:00" level=warning msg="failed to init input bindings: app channel
 not initialized"
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="actor runtime started. actor idle timeout: 1h
0m0s. actor scan interval: 30s"
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="actors: starting connection attempt to placem
ent service at localhost:6050"
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="http server is running on port 3006"
    == DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="gRPC server is running on port 55991"
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="local service entry announced"
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="dapr initialized. Status: Running. Init Elaps
ed 10006.8203ms"
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="actors: established connection to placement s
ervice at localhost:6050"
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="actors: placement order received: lock"      
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="actors: placement order received: update"    
    == DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="actors: placement tables updated"
== DAPR == time="2020-02-05T14:02:08+01:00" level=info msg="actors: placement order received: unlock"    
    == APP == [INFO] 
    == APP == [INFO] --- exec-maven-plugin:1.6.0:java (default-cli) @ dapr-sdk-examples ---
    == APP == 14:02:12.456 [io.dapr.examples.state.StateClient.main()] DEBUG reactor.util.Loggers$LoggerFacto
ry - Using Slf4j logging framework
    == APP == Saving class with message: my message
    == APP == Retrieved class message from state: my message
    == APP == Deleting state...
== APP == Trying to retrieve deleted state: null
    == APP == [WARNING] thread Thread[OkHttp ConnectionPool,5,io.dapr.examples.state.StateClient] was interru
pted but is still alive after waiting at least 15000msecs
    == APP == [WARNING] thread Thread[OkHttp ConnectionPool,5,io.dapr.examples.state.StateClient] will linger
 despite being asked to die via interruption
    == APP == [WARNING] thread Thread[Okio Watchdog,5,io.dapr.examples.state.StateClient] will linger despite
 being asked to die via interruption
== APP == [WARNING] NOTE: 2 thread(s) did not finish despite being asked to  via interruption. This is no
t a problem with exec:java, it is a problem with the running code. Although not serious, it should be remedied.     
    == APP == [WARNING] Couldn't destroy threadgroup org.codehaus.mojo.exec.ExecJavaMojo$IsolatedThreadGroup[
name=io.dapr.examples.state.StateClient,maxpri=10]
    == APP == java.lang.IllegalThreadStateException
== APP ==     at java.lang.ThreadGroup.destroy (ThreadGroup.java:776)
== APP ==     at org.codehaus.mojo.exec.ExecJavaMojo.execute (ExecJavaMojo.java:321)
== APP ==     at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo (DefaultBuildPluginManager
.java:137)
== APP ==     at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:210)        
== APP ==     at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:156)        
== APP ==     at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:148)        
== APP ==     at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject (LifecycleModule
Builder.java:117)
== APP ==     at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject (LifecycleModule
Builder.java:81)
== APP ==     at org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build (
SingleThreadedBuilder.java:56)
== APP ==     at org.apache.maven.lifecycle.internal.LifecycleStarter.execute (LifecycleStarter.java:128)

== APP ==     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:305)
== APP ==     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:192)
== APP ==     at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:105)
== APP ==     at org.apache.maven.cli.MavenCli.execute (MavenCli.java:957)
== APP ==     at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:289)
== APP ==     at org.apache.maven.cli.MavenCli.main (MavenCli.java:193)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) 
== APP ==     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.j
ava:43)
== APP ==     at java.lang.reflect.Method.invoke (Method.java:566)
== APP ==     at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced (Launcher.java:282)    
== APP ==     at org.codehaus.plexus.classworlds.launcher.Launcher.launch (Launcher.java:225)
== APP ==     at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode (Launcher.java:406)  
== APP ==     at org.codehaus.plexus.classworlds.launcher.Launcher.main (Launcher.java:347)
== APP == [INFO] ------------------------------------------------------------------------
== APP == [INFO] BUILD SUCCESS
== APP == [INFO] ------------------------------------------------------------------------
== APP == [INFO] Total time:  25.322 s
== APP == [INFO] Finished at: 2020-02-05T14:02:27+01:00
== APP == [INFO] ------------------------------------------------------------------------

terminated signal received: shutting down
== DAPR == time="2020-02-05T14:03:43+01:00" level=info msg="dapr shutting down. Waiting 5 seconds to finish o
utstanding operations"
== DAPR == time="2020-02-05T14:03:43+01:00" level=info msg="stop command issued. Shutting down all operat
ions"
Exited Dapr successfully
Error exiting App: TerminateProcess: Access is denied.

Second Run

PS C:\Sources\dapr-java-sdk\examples> dapr run --port 3006 -- mvn exec:java -D exec.mainClass=io.dapr.examples.state.StateClient -D exec.args="'my message'"
Starting Dapr with id Beetleshy-Buffalo. HTTP Port: 3006. gRPC Port: 56039
You're up and running! Both Dapr and your app logs will appear here.

== DAPR == time="2020-02-05T14:03:46+01:00" level=info msg="starting Dapr Runtime -- version 0.3.0 -- commit 
v0.3.0-rc.0-1-gfe6c306-dirty"
    == DAPR == time="2020-02-05T14:03:46+01:00" level=info msg="log level set to: info"
== DAPR == time="2020-02-05T14:03:46+01:00" level=info msg="standalone mode configured"
== DAPR == time="2020-02-05T14:03:46+01:00" level=info msg="dapr id: Beetleshy-Buffalo"
    == DAPR == time="2020-02-05T14:03:46+01:00" level=info msg="loaded component messagebus (pubsub.redis)"
== DAPR == time="2020-02-05T14:03:46+01:00" level=info msg="loaded component statestore (state.redis)"   
== DAPR == time="2020-02-05T14:03:46+01:00" level=info msg="loaded component sample123 (bindings.kafka)" 
== DAPR == 2020-02-05 14:03:46.928647 I | redis: connecting to localhost:6379
== DAPR == 2020-02-05 14:03:46.941648 I | redis: connected to localhost:6379 (localAddr: [::1]:56042, rem
Addr: [::1]:6379)
    == DAPR == time="2020-02-05T14:03:46+01:00" level=info msg="Initialized service discovery to standalone"
    == APP == [INFO] Scanning for projects...
    == APP == [WARNING] 
    == APP == [WARNING] Some problems were encountered while building the effective model for io.dapr:dapr-sd
k-examples:jar:0.2.0-beta-1
== APP == [WARNING] 'build.plugins.plugin.version' for org.apache.maven.plugins:maven-deploy-plugin is mi
ssing. @ line 130, column 15
    == APP == [WARNING] 
    == APP == [WARNING] It is highly recommended to fix these problems because they threaten the stability of
 your build.
    == APP == [WARNING] 
== APP == [WARNING] For this reason, future Maven versions might no longer support building such malforme
d projects.
== APP == [WARNING]
== APP == [INFO] Inspecting build with total of 1 modules...
== APP == [INFO] Installing Nexus Staging features:
== APP == [INFO]   ... total of 1 executions of maven-deploy-plugin replaced with nexus-staging-maven-plu
gin
    == APP == [INFO] 
    == APP == [INFO] ---------------------< io.dapr:dapr-sdk-examples >----------------------
== APP == [INFO] Building dapr-sdk-examples 0.2.0-beta-1
== APP == [INFO] --------------------------------[ jar ]---------------------------------
    == APP == [INFO] 
    == APP == [INFO] --- exec-maven-plugin:1.6.0:java (default-cli) @ dapr-sdk-examples ---
    == APP == 14:03:51.151 [io.dapr.examples.state.StateClient.main()] DEBUG reactor.util.Loggers$LoggerFacto
ry - Using Slf4j logging framework
    == APP == [WARNING] 
    == APP == java.lang.RuntimeException: java.net.ConnectException: Failed to connect to localhost/0:0:0:0:0
:0:0:1:3006
== APP ==     at io.dapr.client.DaprHttp.lambda$invokeApi$3 (DaprHttp.java:214)
== APP ==     at reactor.core.publisher.MonoCallable.subscribe (MonoCallable.java:56)
    == APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4105)
== APP ==     at reactor.core.publisher.MonoIgnorePublisher.subscribe (MonoIgnorePublisher.java:47)      
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4105)
== APP ==     at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap (FluxFlatMap.java:202)
    == APP ==     at reactor.core.publisher.MonoFlatMap.subscribeOrReturn (MonoFlatMap.java:53)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4090)
== APP ==     at reactor.core.publisher.Mono.block (Mono.java:1662)
== APP ==     at io.dapr.examples.state.StateClient.main (StateClient.java:39)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) 
== APP ==     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.j
ava:43)
== APP ==     at java.lang.reflect.Method.invoke (Method.java:566)
== APP ==     at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:282)
== APP ==     at java.lang.Thread.run (Thread.java:834)
== APP == Caused by: java.net.ConnectException: Failed to connect to localhost/0:0:0:0:0:0:0:1:3006      
== APP ==     at okhttp3.internal.connection.RealConnection.connectSocket (RealConnection.kt:270)        
== APP ==     at okhttp3.internal.connection.RealConnection.connect (RealConnection.kt:176)
== APP ==     at okhttp3.internal.connection.ExchangeFinder.findConnection (ExchangeFinder.kt:236)       
== APP ==     at okhttp3.internal.connection.ExchangeFinder.findHealthyConnection (ExchangeFinder.kt:109)

== APP ==     at okhttp3.internal.connection.ExchangeFinder.find (ExchangeFinder.kt:77)
== APP ==     at okhttp3.internal.connection.Transmitter.newExchange$okhttp (Transmitter.kt:162)
== APP ==     at okhttp3.internal.connection.ConnectInterceptor.intercept (ConnectInterceptor.kt:35)     
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)        
    == APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.internal.cache.CacheInterceptor.intercept (CacheInterceptor.kt:82)
    == APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.internal.http.BridgeInterceptor.intercept (BridgeInterceptor.kt:84)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)        
== APP ==     at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept (RetryAndFollowUpInterceptor
.kt:71)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)        
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.RealCall.getResponseWithInterceptorChain (RealCall.kt:184)
== APP ==     at okhttp3.RealCall.execute (RealCall.kt:66)
== APP ==     at io.dapr.client.DaprHttp.lambda$invokeApi$3 (DaprHttp.java:196)
== APP ==     at reactor.core.publisher.MonoCallable.subscribe (MonoCallable.java:56)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4105)
    == APP ==     at reactor.core.publisher.MonoIgnorePublisher.subscribe (MonoIgnorePublisher.java:47)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4105)
== APP ==     at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap (FluxFlatMap.java:202)
== APP ==     at reactor.core.publisher.MonoFlatMap.subscribeOrReturn (MonoFlatMap.java:53)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4090)
== APP ==     at reactor.core.publisher.Mono.block (Mono.java:1662)
== APP ==     at io.dapr.examples.state.StateClient.main (StateClient.java:39)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) 
== APP ==     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.j
ava:43)
== APP ==     at java.lang.reflect.Method.invoke (Method.java:566)
== APP ==     at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:282)
== APP ==     at java.lang.Thread.run (Thread.java:834)
== APP == Caused by: java.net.ConnectException: Connection refused: connect
== APP ==     at java.net.PlainSocketImpl.waitForConnect (Native Method)
    == APP ==     at java.net.PlainSocketImpl.socketConnect (PlainSocketImpl.java:107)
    == APP ==     at java.net.AbstractPlainSocketImpl.doConnect (AbstractPlainSocketImpl.java:399)
== APP ==     at java.net.AbstractPlainSocketImpl.connectToAddress (AbstractPlainSocketImpl.java:242)    
== APP ==     at java.net.AbstractPlainSocketImpl.connect (AbstractPlainSocketImpl.java:224)
== APP ==     at java.net.SocksSocketImpl.connect (SocksSocketImpl.java:403)
== APP ==     at java.net.Socket.connect (Socket.java:609)
== APP ==     at okhttp3.internal.platform.Platform.connectSocket (Platform.kt:127)
== APP ==     at okhttp3.internal.connection.RealConnection.connectSocket (RealConnection.kt:268)        
    == APP ==     at okhttp3.internal.connection.RealConnection.connect (RealConnection.kt:176)
== APP ==     at okhttp3.internal.connection.ExchangeFinder.findConnection (ExchangeFinder.kt:236)       
== APP ==     at okhttp3.internal.connection.ExchangeFinder.findHealthyConnection (ExchangeFinder.kt:109)

== APP ==     at okhttp3.internal.connection.ExchangeFinder.find (ExchangeFinder.kt:77)
== APP ==     at okhttp3.internal.connection.Transmitter.newExchange$okhttp (Transmitter.kt:162)
== APP ==     at okhttp3.internal.connection.ConnectInterceptor.intercept (ConnectInterceptor.kt:35)     
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)        
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.internal.cache.CacheInterceptor.intercept (CacheInterceptor.kt:82)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)        
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.internal.http.BridgeInterceptor.intercept (BridgeInterceptor.kt:84)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)        
== APP ==     at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept (RetryAndFollowUpInterceptor
.kt:71)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)        
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.RealCall.getResponseWithInterceptorChain (RealCall.kt:184)
== APP ==     at okhttp3.RealCall.execute (RealCall.kt:66)
== APP ==     at io.dapr.client.DaprHttp.lambda$invokeApi$3 (DaprHttp.java:196)
== APP ==     at reactor.core.publisher.MonoCallable.subscribe (MonoCallable.java:56)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4105)
== APP ==     at reactor.core.publisher.MonoIgnorePublisher.subscribe (MonoIgnorePublisher.java:47)      
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4105)
== APP ==     at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap (FluxFlatMap.java:202)
== APP ==     at reactor.core.publisher.MonoFlatMap.subscribeOrReturn (MonoFlatMap.java:53)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4090)
    == APP ==     at reactor.core.publisher.Mono.block (Mono.java:1662)
== APP ==     at io.dapr.examples.state.StateClient.main (StateClient.java:39)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) 
== APP ==     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.j
ava:43)
== APP ==     at java.lang.reflect.Method.invoke (Method.java:566)
== APP ==     at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:282)
== APP ==     at java.lang.Thread.run (Thread.java:834)
    == APP == [INFO] ------------------------------------------------------------------------
== APP == [INFO] BUILD FAILURE
== APP == [INFO] ------------------------------------------------------------------------
== APP == [INFO] Total time:  7.293 s
== APP == [INFO] Finished at: 2020-02-05T14:03:55+01:00
== APP == [INFO] ------------------------------------------------------------------------
== APP == [ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.6.0:java (default-cli) on 
project dapr-sdk-examples: An exception occured while executing the Java class. java.net.ConnectException: Failed to connect to localhost/0:0:0:0:0:0:0:1:3006: Connection refused: connect -> [Help 1]
== APP == [ERROR]

Third Run

PS C:\Sources\dapr-java-sdk\examples> dapr run --port 3006 -- mvn exec:java -D exec.mainClass=io.dapr.examples.state.StateClient -D exec.args="'my message'"
Starting Dapr with id Scaleclear-Thorn. HTTP Port: 3006. gRPC Port: 51593
You're up and running! Both Dapr and your app logs will appear here.

== DAPR == time="2020-02-05T14:04:38+01:00" level=info msg="starting Dapr Runtime -- version 0.3.0 -- commit 
v0.3.0-rc.0-1-gfe6c306-dirty"
== DAPR == time="2020-02-05T14:04:38+01:00" level=info msg="log level set to: info"
== DAPR == time="2020-02-05T14:04:38+01:00" level=info msg="standalone mode configured"
== DAPR == time="2020-02-05T14:04:38+01:00" level=info msg="dapr id: Scaleclear-Thorn"
== DAPR == time="2020-02-05T14:04:38+01:00" level=info msg="loaded component messagebus (pubsub.redis)" 
== DAPR == time="2020-02-05T14:04:38+01:00" level=info msg="loaded component statestore (state.redis)"  
== DAPR == time="2020-02-05T14:04:38+01:00" level=info msg="loaded component sample123 (bindings.kafka)"
== DAPR == 2020-02-05 14:04:38.692081 I | redis: connecting to localhost:6379
== DAPR == 2020-02-05 14:04:38.699083 I | redis: connected to localhost:6379 (localAddr: [::1]:51594, rem
Addr: [::1]:6379)
== DAPR == time="2020-02-05T14:04:38+01:00" level=info msg="Initialized service discovery to standalone" 
== APP == [INFO] Scanning for projects...
== APP == [WARNING] 
== APP == [WARNING] Some problems were encountered while building the effective model for io.dapr:dapr-sd
k-examples:jar:0.2.0-beta-1
== APP == [WARNING] 'build.plugins.plugin.version' for org.apache.maven.plugins:maven-deploy-plugin is mi
ssing. @ line 130, column 15
== APP == [WARNING]
== APP == [WARNING] It is highly recommended to fix these problems because they threaten the stability of
 your build.
== APP == [WARNING]
== APP == [WARNING] For this reason, future Maven versions might no longer support building such malforme
d projects.
== APP == [WARNING]
== APP == [INFO] Inspecting build with total of 1 modules...
== APP == [INFO] Installing Nexus Staging features:
== APP == [INFO]   ... total of 1 executions of maven-deploy-plugin replaced with nexus-staging-maven-plu
gin
    == APP == [INFO] 
    == APP == [INFO] ---------------------< io.dapr:dapr-sdk-examples >----------------------
== APP == [INFO] Building dapr-sdk-examples 0.2.0-beta-1
== APP == [INFO] --------------------------------[ jar ]---------------------------------
    == APP == [INFO] 
    == APP == [INFO] --- exec-maven-plugin:1.6.0:java (default-cli) @ dapr-sdk-examples ---
    == DAPR == time="2020-02-05T14:04:48+01:00" level=warning msg="failed to init output binding bindings.kaf
ka: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)"
    == DAPR == time="2020-02-05T14:04:48+01:00" level=warning msg="failed to init input bindings: app channel
 not initialized"
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="actor runtime started. actor idle timeout: 1h
0m0s. actor scan interval: 30s"
    == DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="actors: starting connection attempt to placem
ent service at localhost:6050"
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="http server is running on port 3006"
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="gRPC server is running on port 51593"        
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="local service entry announced"
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="dapr initialized. Status: Running. Init Elaps
ed 10006.4966ms"
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="actors: established connection to placement s
ervice at localhost:6050"
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="actors: placement order received: lock"      
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="actors: placement order received: update"    
== DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="actors: placement tables updated"
    == DAPR == time="2020-02-05T14:04:48+01:00" level=info msg="actors: placement order received: unlock"
    == APP == 14:04:53.309 [io.dapr.examples.state.StateClient.main()] DEBUG reactor.util.Loggers$LoggerFacto
ry - Using Slf4j logging framework
    == APP == Saving class with message: my message
    == APP == Retrieved class message from state: my message
    == APP == Deleting state...
== APP == Trying to retrieve deleted state: null
    == APP == [WARNING] thread Thread[OkHttp ConnectionPool,5,io.dapr.examples.state.StateClient] was interru
pted but is still alive after waiting at least 14999msecs
    == APP == [WARNING] thread Thread[OkHttp ConnectionPool,5,io.dapr.examples.state.StateClient] will linger
 despite being asked to die via interruption
    == APP == [WARNING] thread Thread[Okio Watchdog,5,io.dapr.examples.state.StateClient] will linger despite
 being asked to die via interruption
== APP == [WARNING] NOTE: 2 thread(s) did not finish despite being asked to  via interruption. This is no
t a problem with exec:java, it is a problem with the running code. Although not serious, it should be remedied.     
== APP == [WARNING] Couldn't destroy threadgroup org.codehaus.mojo.exec.ExecJavaMojo$IsolatedThreadGroup[
name=io.dapr.examples.state.StateClient,maxpri=10]
== APP == java.lang.IllegalThreadStateException
== APP ==     at java.lang.ThreadGroup.destroy (ThreadGroup.java:776)
== APP ==     at org.codehaus.mojo.exec.ExecJavaMojo.execute (ExecJavaMojo.java:321)
== APP ==     at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo (DefaultBuildPluginManager
.java:137)
== APP ==     at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:210)        
== APP ==     at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:156)        
    == APP ==     at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:148)
== APP ==     at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject (LifecycleModule
Builder.java:117)
== APP ==     at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject (LifecycleModule
Builder.java:81)
== APP ==     at org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build (
SingleThreadedBuilder.java:56)
== APP ==     at org.apache.maven.lifecycle.internal.LifecycleStarter.execute (LifecycleStarter.java:128)

== APP ==     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:305)
== APP ==     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:192)
== APP ==     at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:105)
== APP ==     at org.apache.maven.cli.MavenCli.execute (MavenCli.java:957)
== APP ==     at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:289)
== APP ==     at org.apache.maven.cli.MavenCli.main (MavenCli.java:193)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) 
== APP ==     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.j
ava:43)
== APP ==     at java.lang.reflect.Method.invoke (Method.java:566)
== APP ==     at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced (Launcher.java:282)    
== APP ==     at org.codehaus.plexus.classworlds.launcher.Launcher.launch (Launcher.java:225)
== APP ==     at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode (Launcher.java:406)  
== APP ==     at org.codehaus.plexus.classworlds.launcher.Launcher.main (Launcher.java:347)
== APP == [INFO] ------------------------------------------------------------------------
== APP == [INFO] BUILD SUCCESS
== APP == [INFO] ------------------------------------------------------------------------
== APP == [INFO] Total time:  27.243 s
== APP == [INFO] Finished at: 2020-02-05T14:05:08+01:00
== APP == [INFO] ------------------------------------------------------------------------
== DAPR == time="2020-02-05T14:05:15+01:00" level=info msg="dapr shutting down. Waiting 5 seconds to finifini
sh outstanding operations"

terminated signal received: shutting down
== DAPR == time="2020-02-05T14:05:15+01:00" level=info msg="stop command issued. Shutting down all operations
"
Exited Dapr successfully

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Fields

    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions