Hello Vahid,
am testing one of our Kafka Stream Apps with the 2.2.1-rc, after few
minutes, I see this WARN:
2019-05-09 13:14:37,025 WARN [test-app-id-dc27624a-8e02-
4031-963b-7596a8a77097-StreamThread-1] internals.ProcessorStateManager (
ProcessorStateManager.java:349) - task [0_0] Failed to write offset
checkpoint file to [/tmp/kafka-stream-app/test-app-id/0_0/.checkpoint]
java.io.FileNotFoundException:
/tmp/kafka-stream-app/test-app-id/0_0/.checkpoint.tmp (No such file or
directory)
at java.io.FileOutputStream.open0(Native Method) ~[?:1.8.0_191]
at java.io.FileOutputStream.open(FileOutputStream.java:270) ~[?:1.8.0_191]
at java.io.FileOutputStream.(FileOutputStream.java:213) ~[?:1.8.0_191]
at java.io.FileOutputStream.(FileOutputStream.java:162) ~[?:1.8.0_191]
at org.apache.kafka.streams.state.internals.OffsetCheckpoint.write(
OffsetCheckpoint.java:79) ~[kafka-streams-2.2.1.jar:?]
at
org.apache.kafka.streams.processor.internals.ProcessorStateManager.checkpoint(
ProcessorStateManager.java:347) [kafka-streams-2.2.1.jar:?]
at org.apache.kafka.streams.processor.internals.StreamTask.commit(
StreamTask.java:476) [kafka-streams-2.2.1.jar:?]
at org.apache.kafka.streams.processor.internals.StreamTask.suspend(
StreamTask.java:598) [kafka-streams-2.2.1.jar:?]
at org.apache.kafka.streams.processor.internals.StreamTask.close(
StreamTask.java:724) [kafka-streams-2.2.1.jar:?]
at org.apache.kafka.streams.processor.internals.AssignedTasks.close(
AssignedTasks.java:337) [kafka-streams-2.2.1.jar:?]
at org.apache.kafka.streams.processor.internals.TaskManager.shutdown(
TaskManager.java:267) [kafka-streams-2.2.1.jar:?]
at
org.apache.kafka.streams.processor.internals.StreamThread.completeShutdown(
StreamThread.java:1208) [kafka-streams-2.2.1.jar:?]
at org.apache.kafka.streams.processor.internals.StreamThread.run(
StreamThread.java:785) [kafka-streams-2.2.1.jar:?]
Checking the system, in fact, the folder does not exist, but, others were
created:
# ls /tmp/kafka-stream-app/test-app-id/
# 1_0 1_1 1_2
After restarting the App, the same WARN shows-up but in this case, the
folders were created but not the .checkpoint.tmp file:
# ls /tmp/kafka-stream-app/test-app-id/
# 0_0 0_1 0_2 1_0 1_1 1_2
Am just reporting this because I found it strange/suspicious.
Cheers!
--
Jonathan
On Wed, May 8, 2019 at 9:26 PM Vahid Hashemian
wrote:
> Hello Kafka users, developers and client-developers,
>
> This is the first candidate for release of Apache Kafka 2.2.1, which
> includes many bug fixes for Apache Kafka 2.2.
>
> Release notes for the 2.2.1 release:
> https://home.apache.org/~vahid/kafka-2.2.1-rc0/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, May 13, 6:00 pm PT.
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> https://kafka.apache.org/KEYS
>
> * Release artifacts to be voted upon (source and binary):
> https://home.apache.org/~vahid/kafka-2.2.1-rc0/
>
> * Maven artifacts to be voted upon:
> https://repository.apache.org/content/groups/staging/org/apache/kafka/
>
> * Javadoc:
> https://home.apache.org/~vahid/kafka-2.2.1-rc0/javadoc/
>
> * Tag to be voted upon (off 2.2 branch) is the 2.2.1 tag:
> https://github.com/apache/kafka/releases/tag/2.2.1-rc0
>
> * Documentation:
> https://kafka.apache.org/22/documentation.html
>
> * Protocol:
> https://kafka.apache.org/22/protocol.html
>
> * Successful Jenkins builds for the 2.2 branch:
> Unit/integration tests: https://builds.apache.org/job/kafka-2.2-jdk8/106/
>
> Thanks,
> --Vahid
>
--
Santilli Jonathan
