[GH] (pekko/onComplete): Workflow run "Pull Requests" is working again!

2025-05-26 Thread GitBox
The GitHub Actions job "Pull Requests" on pekko.git/onComplete has succeeded. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 14a92fb3672d7841aa189b84fc4a9c678a7c3d26 / He-Pin feat: Add onComplete support for statefulMapConcat operator. Report URL: https://github.

Re: [I] Add Flow#aggregateUntilChanged operator [pekko]

2025-05-26 Thread via GitHub
He-Pin commented on issue #1821: URL: https://github.com/apache/pekko/issues/1821#issuecomment-2911155440 @pjfanning @mdedetrich wdyt about this? -- 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 t

Re: [PR] fix: Fix wrong name attribute for iterate and mapAsyncPartitionUnordered operators. [pekko]

2025-05-26 Thread via GitHub
He-Pin commented on code in PR #1869: URL: https://github.com/apache/pekko/pull/1869#discussion_r2108208399 ## stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala: ## @@ -1402,7 +1402,7 @@ trait FlowOps[+Out, +Mat] { } else { new MapAsyncPartitioned(par

Re: [PR] feat: Add onComplete support for statefulMapConcat operator. [pekko]

2025-05-26 Thread via GitHub
He-Pin commented on PR #1870: URL: https://github.com/apache/pekko/pull/1870#issuecomment-295650 I think this is the best I can do to keep binary compatibility for 1.2 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] feat: Add onComplete support for statefulMapConcat operator. [pekko]

2025-05-26 Thread via GitHub
He-Pin commented on code in PR #1870: URL: https://github.com/apache/pekko/pull/1870#discussion_r2108085600 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala: ## @@ -2337,13 +2338,25 @@ private[pekko] final class StatefulMapConcat[In, Out](val f: () => In =

[GH] (pekko/onComplete): Workflow run "Pull Requests" failed!

2025-05-26 Thread GitBox
The GitHub Actions job "Pull Requests" on pekko.git/onComplete has failed. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 969018911c97b9aa146fdbf13ca210481089713c / He-Pin feat: Add onComplete support for statefulMapConcat operator. Report URL: https://github.com

[GH] (pekko-grpc/main): Workflow run "Publish 1.0 Nightly" is working again!

2025-05-26 Thread GitBox
The GitHub Actions job "Publish 1.0 Nightly" on pekko-grpc.git/main has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 0702fac80cd8ceeac4966f77e5cdc0d6db42b2f5 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com> U

Re: [PR] feat: Add onComplete support for statefulMapConcat operator. [pekko]

2025-05-26 Thread via GitHub
He-Pin commented on code in PR #1870: URL: https://github.com/apache/pekko/pull/1870#discussion_r2108085600 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala: ## @@ -2337,13 +2338,25 @@ private[pekko] final class StatefulMapConcat[In, Out](val f: () => In =

Re: [PR] feat: Add onComplete support for statefulMapConcat operator. [pekko]

2025-05-26 Thread via GitHub
He-Pin commented on code in PR #1870: URL: https://github.com/apache/pekko/pull/1870#discussion_r2108078031 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala: ## @@ -2337,13 +2338,25 @@ private[pekko] final class StatefulMapConcat[In, Out](val f: () => In =

[GH] (pekko-connectors-kafka/main): Workflow run "Nightly Build and Test" failed!

2025-05-26 Thread GitBox
The GitHub Actions job "Nightly Build and Test" on pekko-connectors-kafka.git/main has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: a26e13ce2e5889dc27457b1d81292ea9c226f338 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.g

[GH] (pekko-persistence-cassandra/main): Workflow run "Unit Tests" failed!

2025-05-26 Thread GitBox
The GitHub Actions job "Unit Tests" on pekko-persistence-cassandra.git/main has failed. Run started by GitHub user mdedetrich (triggered by mdedetrich). Head commit for run: 171849f8cdbf220074069dc70a146237fd95bedc / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github

[GH] (pekko-management/main): Workflow run "Nightly Tests" is working again!

2025-05-26 Thread GitBox
The GitHub Actions job "Nightly Tests" on pekko-management.git/main has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 88efa0c665a6116387755a7fc9f3ef137b96161c / PJ Fanning remove outdated release info in README.md (#437) Report URL: https://gi

[GH] (pekko-grpc/main): Workflow run "Nightly Snapshot Dependency Test" is working again!

2025-05-26 Thread GitBox
The GitHub Actions job "Nightly Snapshot Dependency Test" on pekko-grpc.git/main has succeeded. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 0702fac80cd8ceeac4966f77e5cdc0d6db42b2f5 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github

[GH] (pekko-http/main): Workflow run "Publish nightly snapshots and documentation" is working again!

2025-05-26 Thread GitBox
The GitHub Actions job "Publish nightly snapshots and documentation" on pekko-http.git/main has succeeded. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: efeefa1d11f246b77a4f21e4b203d4eaeadfd1d5 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.nor

[GH] (pekko-http/main): Workflow run "Publish nightly 1.1 snapshots" is working again!

2025-05-26 Thread GitBox
The GitHub Actions job "Publish nightly 1.1 snapshots" on pekko-http.git/main has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: efeefa1d11f246b77a4f21e4b203d4eaeadfd1d5 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.git

[GH] (pekko/main): Workflow run "Nightly Builds (1.1)" failed!

2025-05-26 Thread GitBox
The GitHub Actions job "Nightly Builds (1.1)" on pekko.git/main has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 81559093dddf74d9f7ac08aa004d9e4fe632 / PJ Fanning allow compat check in cluster test (#1865) Report URL: https://github.com/apach

[GH] (pekko-projection/main): Workflow run "Publish 1.0.x Nightly" failed!

2025-05-26 Thread GitBox
The GitHub Actions job "Publish 1.0.x Nightly" on pekko-projection.git/main has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 695ce1fa9e9237303d9af0c09ea91b67190236af / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.c

Re: [PR] feat: Add onComplete support for statefulMapConcat operator. [pekko]

2025-05-26 Thread via GitHub
pjfanning commented on code in PR #1870: URL: https://github.com/apache/pekko/pull/1870#discussion_r2106192399 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala: ## @@ -2337,13 +2338,25 @@ private[pekko] final class StatefulMapConcat[In, Out](val f: () => I

Re: [I] Task monad based on `Materializer` [pekko]

2025-05-26 Thread via GitHub
pjfanning commented on issue #1801: URL: https://github.com/apache/pekko/issues/1801#issuecomment-2910554978 I'm happy to treat this as an API that is documented as experimental and allow for later changes. In my mind, it might be better to not immediately add this to pekko core but

[GH] (pekko/join-cluster-akka): Workflow run "Pull Requests" failed!

2025-05-26 Thread GitBox
The GitHub Actions job "Pull Requests" on pekko.git/join-cluster-akka has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 7c52a69fe8bea469da30676e4c35f5dc205e5e27 / PJ Fanning extra test Report URL: https://github.com/apache/pekko/actions/runs/1525

Re: [PR] enable TransactionsPartitionedSourceSpec [pekko-connectors-kafka]

2025-05-26 Thread via GitHub
pjfanning closed pull request #317: enable TransactionsPartitionedSourceSpec URL: https://github.com/apache/pekko-connectors-kafka/pull/317 -- 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 specifi

Re: [PR] enable TransactionsPartitionedSourceSpec [pekko-connectors-kafka]

2025-05-26 Thread via GitHub
pjfanning commented on PR #317: URL: https://github.com/apache/pekko-connectors-kafka/pull/317#issuecomment-2910154056 In the test run on CI, TransactionsPartitionedSourceSpec seems to hang or be very slow. That might explain why the test is ignored. -- This is an automated message from

Re: [PR] enable TransactionsPartitionedSourceSpec [pekko-connectors-kafka]

2025-05-26 Thread via GitHub
pjfanning commented on PR #317: URL: https://github.com/apache/pekko-connectors-kafka/pull/317#issuecomment-2910168510 TransactionsPartitionedSourceSpec did complete eventually but failed. -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GH] (pekko-connectors-kafka/enable-int-test): Workflow run "CI" failed!

2025-05-26 Thread GitBox
The GitHub Actions job "CI" on pekko-connectors-kafka.git/enable-int-test has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 030bf7f8b73cd840226998524f26306e8be76f81 / PJ Fanning enable TransactionsPartitionedSourceSpec Report URL: https://github

[PR] enable TransactionsPartitionedSourceSpec [pekko-connectors-kafka]

2025-05-26 Thread via GitHub
pjfanning opened a new pull request, #317: URL: https://github.com/apache/pekko-connectors-kafka/pull/317 so far, an experiment -- 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 commen

Re: [I] Pekko-based Application Pods Idle at Startup, Not Consuming Kafka Messages Due to Consumer Group Creation Behavior [pekko-connectors-kafka]

2025-05-26 Thread via GitHub
pjfanning commented on issue #248: URL: https://github.com/apache/pekko-connectors-kafka/issues/248#issuecomment-2910047352 @dahiyahimanshu the logs would be really useful. It is time consuming and error prone to expect someone to reproduce the scenario themselves. -- This is an automate

[GH] (pekko/join-cluster-akka): Workflow run "Pull Requests" is working again!

2025-05-26 Thread GitBox
The GitHub Actions job "Pull Requests" on pekko.git/join-cluster-akka has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 7c52a69fe8bea469da30676e4c35f5dc205e5e27 / PJ Fanning extra test Report URL: https://github.com/apache/pekko/actions/runs/1

Re: [PR] remove outdated release info in README.md [pekko-management]

2025-05-26 Thread via GitHub
pjfanning merged PR #437: URL: https://github.com/apache/pekko-management/pull/437 -- 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. To unsubscribe, e-mail: notifications-unsubsc

[PR] remove outdated release info in README.md [pekko-management]

2025-05-26 Thread via GitHub
pjfanning opened a new pull request, #437: URL: https://github.com/apache/pekko-management/pull/437 (no comment) -- 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. To unsubscr

[I] cluster-bootstrap should support setting auth headers in client requests [pekko-management]

2025-05-26 Thread via GitHub
pjfanning opened a new issue, #436: URL: https://github.com/apache/pekko-management/issues/436 * related to but separate from #426 * the question is if we should allow users to supply the auth settings statically via config * or if we should strive to derive the auth settings based on

Re: [PR] chore(deps): bump sbt/setup-sbt from 1.1.7 to 1.1.8 [pekko]

2025-05-26 Thread via GitHub
pjfanning commented on PR #1871: URL: https://github.com/apache/pekko/pull/1871#issuecomment-2909880639 > > * it might be best to disable dependabot > > * from approx August, we will have to get approval from ASF Infra team to use specific action versions > > According to https://

Re: [I] Apache Pekko based Streaming application is idle and not consuming from kafka topic post rebalancing [pekko-connectors-kafka]

2025-05-26 Thread via GitHub
pjfanning commented on issue #249: URL: https://github.com/apache/pekko-connectors-kafka/issues/249#issuecomment-2909859612 This is not a component that I currently use. Take any suggestions that I make with a grain of salt. I notice there is a `committablePartitionedSource` which is parti

Re: [PR] Update kafka-clients to 3.9.1 [pekko-connectors-kafka]

2025-05-26 Thread via GitHub
pjfanning merged PR #315: URL: https://github.com/apache/pekko-connectors-kafka/pull/315 -- 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. To unsubscribe, e-mail: notifications-u

[GH] (pekko/join-cluster-akka): Workflow run "Build and test Pekko with Scala 3" is working again!

2025-05-26 Thread GitBox
The GitHub Actions job "Build and test Pekko with Scala 3" on pekko.git/join-cluster-akka has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 4f7bdeee5dd0ffe57e24c95bb008a5f52dbe2be0 / PJ Fanning add test Report URL: https://github.com/apache/pe

Re: [PR] fix: Fix wrong name attribute for iterate and mapAsyncPartitionUnordered operators. [pekko]

2025-05-26 Thread via GitHub
pjfanning commented on code in PR #1869: URL: https://github.com/apache/pekko/pull/1869#discussion_r2107205825 ## stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala: ## @@ -1402,7 +1402,7 @@ trait FlowOps[+Out, +Mat] { } else { new MapAsyncPartitioned(

Re: [I] Apache Pekko based Streaming application is idle and not consuming from kafka topic post rebalancing [pekko-connectors-kafka]

2025-05-26 Thread via GitHub
roy-tc commented on issue #249: URL: https://github.com/apache/pekko-connectors-kafka/issues/249#issuecomment-2909771033 @pjfanning unfortunately we were not able to extract any useful logging. For now, our workaround will be to restart services whenever their kafka consumer will get st

Re: [PR] fix: Fix wrong name attribute for iterate and mapAsyncPartitionUnordered operators. [pekko]

2025-05-26 Thread via GitHub
He-Pin commented on code in PR #1869: URL: https://github.com/apache/pekko/pull/1869#discussion_r2107301009 ## stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala: ## @@ -1402,7 +1402,7 @@ trait FlowOps[+Out, +Mat] { } else { new MapAsyncPartitioned(par

Re: [PR] allow compat check in cluster test (#1865) [pekko]

2025-05-26 Thread via GitHub
raboof merged PR #1874: URL: https://github.com/apache/pekko/pull/1874 -- 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. To unsubscribe, e-mail: notifications-unsubscr...@pekko.a

Re: [I] reproducible builds: proto files in google-cloud artifacts [pekko-connectors]

2025-05-26 Thread via GitHub
raboof commented on issue #738: URL: https://github.com/apache/pekko-connectors/issues/738#issuecomment-2909585038 > I cloned the repo and verified that the .proto files are included in the published jars but missing in my local builds, reproducing the issue. Great! > Please l

Re: [PR] chore(deps): bump sbt/setup-sbt from 1.1.7 to 1.1.8 [pekko]

2025-05-26 Thread via GitHub
raboof commented on PR #1871: URL: https://github.com/apache/pekko/pull/1871#issuecomment-2909582321 > * it might be best to disable dependabot > * from approx August, we will have to get approval from ASF Infra team to use specific action versions According to https://github.com/

[GH] (pekko/test-backfit): Workflow run "Build and test Pekko with Scala 3" failed!

2025-05-26 Thread GitBox
The GitHub Actions job "Build and test Pekko with Scala 3" on pekko.git/test-backfit has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 07fcc896f8805c261b9e5376653a8dd177b1d7dd / PJ Fanning allow compat check in cluster test (#1865) Report URL: ht

Re: [D] GraalVM compatibility [pekko]

2025-05-26 Thread via GitHub
GitHub user Tochemey added a comment to the discussion: GraalVM compatibility @raboof Thanks for the links. GitHub link: https://github.com/apache/pekko/discussions/1873#discussioncomment-13272079 This is an automatically sent email for notifications@pekko.apache.org. To unsubscribe, ple

Re: [PR] feat: Add preMaterializeIntoSource [pekko]

2025-05-26 Thread via GitHub
pjfanning commented on code in PR #1831: URL: https://github.com/apache/pekko/pull/1831#discussion_r2107197962 ## stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala: ## @@ -108,6 +108,21 @@ final class Source[+Out, +Mat]( (mat, Source.fromPublisher(pub))

Re: [PR] allow compat check in cluster test [pekko]

2025-05-26 Thread via GitHub
raboof merged PR #1865: URL: https://github.com/apache/pekko/pull/1865 -- 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. To unsubscribe, e-mail: notifications-unsubscr...@pekko.a

Re: [PR] chore(deps): bump sbt/setup-sbt from 1.1.7 to 1.1.8 [pekko]

2025-05-26 Thread via GitHub
pjfanning commented on PR #1871: URL: https://github.com/apache/pekko/pull/1871#issuecomment-2909363034 * it might be best to disable dependabot * from approx August, we will have to get approval from ASF Infra team to use specific action versions -- This is an automated message from t

[PR] allow compat check in cluster test (#1865) [pekko]

2025-05-26 Thread via GitHub
pjfanning opened a new pull request, #1874: URL: https://github.com/apache/pekko/pull/1874 cherry pick 81559093dddf74d9f7ac08aa004d9e4fe632 #1865 -- 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

Re: [PR] enable compatibility check in cluster test [pekko]

2025-05-26 Thread via GitHub
raboof merged PR #1864: URL: https://github.com/apache/pekko/pull/1864 -- 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. To unsubscribe, e-mail: notifications-unsubscr...@pekko.a

Re: [D] GraalVM compatibility [pekko]

2025-05-26 Thread via GitHub
GitHub user raboof added a comment to the discussion: GraalVM compatibility (this is assuming you want to create a native image - using Pekko with the GraalVM JVM should work without changes AFAIK) GitHub link: https://github.com/apache/pekko/discussions/1873#discussioncomment-13271001

Re: [D] GraalVM compatibility [pekko]

2025-05-26 Thread via GitHub
GitHub user raboof added a comment to the discussion: GraalVM compatibility https://github.com/vmencik/akka-graal-config and https://github.com/vmencik/akka-graal-native might also be interesting GitHub link: https://github.com/apache/pekko/discussions/1873#discussioncomment-13270994 Th

Re: [D] GraalVM compatibility [pekko]

2025-05-26 Thread via GitHub
GitHub user He-Pin added a comment to the discussion: GraalVM compatibility you need read the graalvm doc, and generating the config file yourself GitHub link: https://github.com/apache/pekko/discussions/1873#discussioncomment-13270983 This is an automatically sent email for notificatio

Re: [D] GraalVM compatibility [pekko]

2025-05-26 Thread via GitHub
GitHub user Tochemey edited a comment on the discussion: GraalVM compatibility @He-Pin Ok thanks for the swift reply. Please is there any sample project that has done it that I can get some inspiration from? GitHub link: https://github.com/apache/pekko/discussions/1873#discussioncomment-1327

Re: [D] GraalVM compatibility [pekko]

2025-05-26 Thread via GitHub
GitHub user Tochemey added a comment to the discussion: GraalVM compatibility Ok thanks for the swift reply. Please is there any sample project that has done it that I can get some inspiration from? GitHub link: https://github.com/apache/pekko/discussions/1873#discussioncomment-13270776

Re: [D] GraalVM compatibility [pekko]

2025-05-26 Thread via GitHub
GitHub user He-Pin added a comment to the discussion: GraalVM compatibility @Tochemey No, there is no config files for graalvm out of box, GitHub link: https://github.com/apache/pekko/discussions/1873#discussioncomment-13270762 This is an automatically sent email for notifications@pekko