Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / numaproj/numaflow-java issues and pull requests

#158 - chore: prepare for releasing 0.9.0

Pull Request - State: closed - Opened by KeranYang 20 days ago - 1 comment

#156 - refactor: abstract gRPC server

Pull Request - State: closed - Opened by KeranYang 20 days ago - 1 comment

#154 - abstract gRPC server creation and shutdown

Issue - State: closed - Opened by KeranYang 21 days ago

#153 - A single pipeline to test all java containers

Issue - State: open - Opened by KeranYang 21 days ago
Labels: good first issue

#152 - chore: gracefully shutdown when error encountered

Pull Request - State: closed - Opened by KeranYang 22 days ago - 1 comment

#151 - (WIP) debug graceful shutdown

Pull Request - State: closed - Opened by KeranYang 23 days ago - 1 comment

#150 - (Debugging WIP) add debugging logs

Pull Request - State: closed - Opened by KeranYang 24 days ago - 1 comment

#149 - chore: Batch ack requests and sink responses for better performance

Pull Request - State: closed - Opened by yhl25 28 days ago - 2 comments

#148 - Support for building numaflow-java with openjdk17

Issue - State: open - Opened by RohanAshar about 1 month ago

#147 - chore: add IsReady of MapStream

Pull Request - State: closed - Opened by yhl25 about 1 month ago - 1 comment

#146 - feat: Unify MapStream and Unary Map Operations Using a Shared gRPC Protocol

Pull Request - State: closed - Opened by yhl25 about 1 month ago - 1 comment

#145 - chore: send eot response for batchmap operations

Pull Request - State: closed - Opened by yhl25 about 2 months ago - 1 comment

#144 - feat: Unify Batch Map and Unary Map Operations Using a Shared gRPC Protocol

Pull Request - State: closed - Opened by yhl25 about 2 months ago - 2 comments

#143 - feat: use gRPC Bidirectional Streaming for Mapper and Transformer

Pull Request - State: closed - Opened by yhl25 about 2 months ago - 2 comments

#142 - fix: return early after ack handshake

Pull Request - State: closed - Opened by yhl25 2 months ago - 1 comment

#141 - feat: udsink bidirectional streaming

Pull Request - State: closed - Opened by yhl25 2 months ago - 1 comment

#140 - feat: container-type level version compatibility check

Pull Request - State: closed - Opened by KeranYang 2 months ago - 1 comment

#139 - docs: add instructions on how to update MINIMUM_NUMAFLOW_VERSION

Pull Request - State: closed - Opened by KeranYang 2 months ago - 2 comments

#138 - feat: bidirectional streaming source

Pull Request - State: closed - Opened by yhl25 2 months ago - 1 comment

#137 - Graceful shutdown of gRPC servers when there are exceptions in the User Code

Issue - State: closed - Opened by yhl25 3 months ago - 4 comments

#136 - chore: graceful shutdown of sink server

Pull Request - State: closed - Opened by yhl25 3 months ago

#135 - chore: release version 0.8.0

Pull Request - State: closed - Opened by KeranYang 3 months ago - 2 comments

#134 - fix: upade for adding example for batchmap

Pull Request - State: closed - Opened by RohanAshar 4 months ago - 1 comment

#133 - fix: update execution id for batch map example

Pull Request - State: closed - Opened by KeranYang 4 months ago

#132 - feat: Add Map batch

Pull Request - State: closed - Opened by RohanAshar 4 months ago - 2 comments

#131 - chore: force shutdown the server if not terminated gracefully

Pull Request - State: closed - Opened by yhl25 4 months ago - 3 comments

#130 - test: enable displaying codecov report

Pull Request - State: closed - Opened by KeranYang 5 months ago - 1 comment

#128 - chore: release 0.7.4 version

Pull Request - State: closed - Opened by KeranYang 5 months ago

#127 - fix: use the shared grpc version

Pull Request - State: closed - Opened by KeranYang 5 months ago

#126 - fix: update netty and GRPC version

Pull Request - State: closed - Opened by Rooknj 5 months ago

#125 - chore: remove unused code

Pull Request - State: closed - Opened by ayildirim21 5 months ago

#124 - chore: remove unnecessary flag

Pull Request - State: closed - Opened by ayildirim21 5 months ago

#123 - Set up codecov

Issue - State: closed - Opened by whynowy 5 months ago

#122 - chore: update to v0.7.3

Pull Request - State: closed - Opened by yhl25 7 months ago

#121 - chore: Restart if there are any uncaught exceptions.

Pull Request - State: closed - Opened by yhl25 7 months ago

#120 - fix: missing version.properties file in the sdk

Pull Request - State: closed - Opened by nagarajatantry 7 months ago

#119 - chore: prepare for releasing v0.7.2

Pull Request - State: closed - Opened by KeranYang 7 months ago

#118 - fix: pass headers to test kit server

Pull Request - State: closed - Opened by yhl25 7 months ago

#111 - feat: Test Kit for Servers

Pull Request - State: closed - Opened by yhl25 8 months ago

#109 - chore: add minimum client version to server info class

Pull Request - State: closed - Opened by ayildirim21 8 months ago - 2 comments

#100 - fix: compile pom.xml before building

Pull Request - State: closed - Opened by ayildirim21 8 months ago

#99 - feat: implement update script and build/push workflow

Pull Request - State: closed - Opened by ayildirim21 8 months ago

#98 - feat: support headers for message

Pull Request - State: closed - Opened by yhl25 8 months ago

#97 - chore: update to version 0.6.1 for the server info changes

Pull Request - State: closed - Opened by ayildirim21 10 months ago

#95 - chore: add separate server info file paths for services

Pull Request - State: closed - Opened by ayildirim21 10 months ago

#94 - feat: implement sdk for session reduce

Pull Request - State: closed - Opened by KeranYang 10 months ago - 1 comment

#93 - chore: write server info for sideinput sdk

Pull Request - State: closed - Opened by ayildirim21 10 months ago

#92 - Use protoc to generate source code

Issue - State: open - Opened by whynowy 10 months ago

#91 - feat: implement reduce stream sdk

Pull Request - State: closed - Opened by KeranYang 11 months ago

#90 - chore: apply latest reducer proto to the reducer SDK

Pull Request - State: closed - Opened by KeranYang 11 months ago

#89 - chore: release version 0.6.0

Pull Request - State: closed - Opened by KeranYang 11 months ago

#88 - chore: adding partitions for user defined source

Pull Request - State: closed - Opened by yhl25 12 months ago

#87 - Fix dependency vulnerability

Issue - State: closed - Opened by KeranYang 12 months ago

#86 - fix: require event time when dropping messages

Pull Request - State: closed - Opened by KeranYang 12 months ago

#85 - fix: counter example

Pull Request - State: closed - Opened by yhl25 about 1 year ago

#84 - chore: add e2e image build to example pom file

Pull Request - State: closed - Opened by KeranYang about 1 year ago

#83 - Build a performance test framework

Issue - State: open - Opened by KeranYang about 1 year ago - 1 comment

#82 - chore: upgrade netty version

Pull Request - State: closed - Opened by KeranYang about 1 year ago

#81 - Numaflow reducer doesn't output grouped message right after fixed time window

Issue - State: open - Opened by borkox about 1 year ago - 15 comments

#80 - chore: update version

Pull Request - State: closed - Opened by KeranYang about 1 year ago

#79 - fix: upgrade netty to mitigate Vulnerability issue

Pull Request - State: closed - Opened by KeranYang about 1 year ago

#78 - chore: update sdk version

Pull Request - State: closed - Opened by KeranYang about 1 year ago

#77 - Fix a vulnerability

Issue - State: closed - Opened by KeranYang about 1 year ago - 1 comment

#76 - chore: unify the event time of messages to drop

Pull Request - State: closed - Opened by KeranYang about 1 year ago

#75 - Fix: Need to investigate about Java Instant.now() time conversion to protobuf then to numaflow

Issue - State: closed - Opened by shashank10456 about 1 year ago - 3 comments
Labels: bug

#74 - chore: get ready for 0.5.3 release

Pull Request - State: closed - Opened by KeranYang about 1 year ago

#73 - fix: allow returning negative value from source pending api

Pull Request - State: closed - Opened by KeranYang about 1 year ago

#72 - chore: simplify sinker interface

Pull Request - State: closed - Opened by yhl25 about 1 year ago

#71 - feat: support for user-defined source

Pull Request - State: closed - Opened by yhl25 about 1 year ago - 3 comments

#70 - refactor: simplify sinker api

Pull Request - State: closed - Opened by KeranYang about 1 year ago - 2 comments

#69 - chore: update sink interface

Pull Request - State: closed - Opened by yhl25 about 1 year ago

#68 - chore: update sdk version

Pull Request - State: closed - Opened by yhl25 about 1 year ago

#67 - Side input support for Java SDK

Issue - State: closed - Opened by yhl25 over 1 year ago

#66 - Java SDK Changes

Issue - State: closed - Opened by yhl25 over 1 year ago

#65 - feat: support for side input

Pull Request - State: closed - Opened by yhl25 over 1 year ago - 1 comment

#64 - chore: use common constants for sink

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#63 - chore: separate servers for each service

Pull Request - State: closed - Opened by yhl25 over 1 year ago - 1 comment

#62 - chore: release version 0.4.8

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#61 - fix: npe inside message list builder

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#60 - chore: update default gPRC msg size to 64 MB

Pull Request - State: closed - Opened by whynowy over 1 year ago

#59 - chore: use kqueue when epoll is not available for netty worker group

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#58 - grpc server doesn't start in m1

Issue - State: closed - Opened by yhl25 over 1 year ago

#57 - chore: update version in examples pom

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#56 - chore: update pom.xml

Pull Request - State: closed - Opened by vigith over 1 year ago

#55 - chore: update slf4j version

Pull Request - State: closed - Opened by yhl25 over 1 year ago - 1 comment

#54 - chore: minor changes

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#53 - feat: grpc error handling for Map/MapT/MapStream/Reduce/Sink

Pull Request - State: closed - Opened by xdevxy over 1 year ago

#52 - chore: add map stream udf example

Pull Request - State: closed - Opened by xdevxy over 1 year ago

#51 - feat: introduce MapStreamFn for streaming map udf

Pull Request - State: closed - Opened by xdevxy over 1 year ago

#50 - Logging is broken in numaflow udf

Issue - State: closed - Opened by sourikghosh over 1 year ago - 11 comments

#49 - chore: move nexus plugin to ossrh profile

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#48 - chore: publish to github packages

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#47 - feat: publishing to maven central

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#46 - feat: publishing to maven central

Pull Request - State: closed - Opened by yhl25 over 1 year ago

#45 - fix: enable logging for simple sink

Pull Request - State: closed - Opened by KeranYang over 1 year ago

#44 - Bulk build and publish new version of test images

Issue - State: closed - Opened by KeranYang over 1 year ago
Labels: good first issue, hacktoberfest