numaflow-java
numaflow-java copied to clipboard
numaproj
Numaflow Java SDK
We added defensive copy for setters in a pervious PR. We should also do so for Getters. Technically this is a backward-incompatible change because we don't know how existing users...
**Boolean** is used by sinker Response `success`, `fallback`. We should change it to **boolean**, such that when we new a Response object with a primitive boolean value, Java doesn't need...
Currently, if someone runs an image on an `arm64` machine they will get this error: `exec /usr/bin/java: exec format error`. We should modify the `pom.xml` to build all examples to...
Currently we are using `System.exit(0)` https://github.com/numaproj/numaflow-java/blob/main/src/main/java/io/numaproj/numaflow/mapper/Server.java#L96 Without `System.exit(0)` the shutdown will hang because there is lingering AKKA thread. To reproduce the issue, remove System.exit, you can write an error mapper...
I want to have a java pipeline containing java source, transformer, sink, map, udf, etc. Such that when I make a critical code change, I can let that pipeline run...
Encounters the following exception. Not able to resolve epoll/kqueue `Exception in thread "main" java.lang.UnsatisfiedLinkError: failed to load the required native library at io.netty.channel.epoll.Epoll.ensureAvailability(Epoll.java:81) at io.netty.channel.epoll.EpollEventLoop.(EpollEventLoop.java:57) at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:189) at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:37)` Steps...
