xuesong1cao opened a new issue #10608:
URL: https://github.com/apache/pulsar/issues/10608


   
   
   function 一直正常运行,突然早晨就挂了,报了个Haven't received health check from spawner in a 
while. Stopping instance
   
   
   00:05:23.453 [function-timer-thread-7-1] INFO  
org.apache.pulsar.functions.runtime.JavaInstanceMain - Haven't received health 
check from spawner in a while. Stopping instance...
   00:05:23.459 [111/222/333-0-0] INFO  
org.apache.pulsar.functions.instance.JavaInstanceRunnable - Encountered 
exception in source read: 
   java.lang.InterruptedException: null
        at 
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
 ~[?:1.8.0_251]
        at 
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
 ~[?:1.8.0_251]
        at 
java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) 
~[?:1.8.0_251]
        at org.apache.pulsar.io.core.PushSource.read(PushSource.java:49) 
~[java-instance.jar:2.4.0]
        at 
org.apache.pulsar.functions.instance.JavaInstanceRunnable.readInput(JavaInstanceRunnable.java:440)
 [java-instance.jar:2.4.0]
        at 
org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:235)
 [java-instance.jar:2.4.0]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_251]
   00:05:23.462 [111/222/333-0-0] ERROR 
org.apache.pulsar.functions.instance.JavaInstanceRunnable - [111/222/333-0:0] 
Uncaught exception in Java Instance
   java.lang.RuntimeException: java.lang.InterruptedException
        at 
org.apache.pulsar.functions.instance.JavaInstanceRunnable.readInput(JavaInstanceRunnable.java:444)
 ~[java-instance.jar:2.4.0]
        at 
org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:235)
 [java-instance.jar:2.4.0]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_251]
   Caused by: java.lang.InterruptedException
        at 
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
 ~[?:1.8.0_251]
        at 
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
 ~[?:1.8.0_251]
        at 
java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) 
~[?:1.8.0_251]
        at org.apache.pulsar.io.core.PushSource.read(PushSource.java:49) 
~[java-instance.jar:2.4.0]
        at 
org.apache.pulsar.functions.instance.JavaInstanceRunnable.readInput(JavaInstanceRunnable.java:440)
 ~[java-instance.jar:2.4.0]
        ... 2 more
   00:05:23.463 [111/222/333-0-0] INFO  
org.apache.pulsar.functions.instance.JavaInstanceRunnable - Closing instance
   00:05:23.469 [pulsar-client-io-1-1] INFO  
org.apache.pulsar.client.impl.ConsumerImpl - 
[persistent://4a/audit/parse_devlog] [111/222/333-0] Closed consumer
   
   
   `[pulsar@pulsar03 pulsar-2.4.0]$ bin/pulsar-admin brokers healthcheck
   HTTP 500 Internal Server Error
   
   Reason: HTTP 500 Internal Server Error
   [pulsar@pulsar03 pulsar-2.4.0]$ ll
   `
   
   
   #### Steps to reproduce
   
   **我不清楚broker的healthcheck  
报500是不是直接导致的function挂掉,其他的function正常运行,其他消息的发布和接收也是正常的,这个问题该如何排查呢,请大佬们帮忙看下!
   
   第一次发布issue,有哪些不太规范的,请大家及时指正**
   
   #### System configuration
   **Pulsar version**:  2.4
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to