Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore: add transformer to MonoVertex example #1935

Merged
merged 2 commits into from
Aug 13, 2024
Merged

chore: add transformer to MonoVertex example #1935

merged 2 commits into from
Aug 13, 2024

Conversation

vigith
Copy link
Member

@vigith vigith commented Aug 13, 2024

Based on user request on the ex.

@vigith vigith requested a review from whynowy as a code owner August 13, 2024 17:56
@vigith vigith requested a review from kohlisid August 13, 2024 17:56
Copy link

codecov bot commented Aug 13, 2024

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 58.24%. Comparing base (2017f0c) to head (3b086eb).

Additional details and impacted files
@@            Coverage Diff             @@
##             main    #1935      +/-   ##
==========================================
+ Coverage   57.96%   58.24%   +0.28%     
==========================================
  Files         401      401              
  Lines       27769    27769              
==========================================
+ Hits        16095    16174      +79     
+ Misses      10743    10665      -78     
+ Partials      931      930       -1     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

@kohlisid
Copy link
Contributor

2024-08-13T18:16:36.831801Z  INFO Read batch size: 500 and latency - 2ms
2024-08-13T18:16:36.845226Z  INFO Transformer latency - 13ms
2024-08-13T18:16:36.862412Z  INFO Sink latency - 17ms
2024-08-13T18:16:36.863297Z  INFO Ack latency - 0ms
2024-08-13T18:16:36.864789Z  INFO Read batch size: 500 and latency - 1ms
2024-08-13T18:16:36.877946Z  INFO Transformer latency - 13ms
2024-08-13T18:16:36.894761Z  INFO Sink latency - 16ms
2024-08-13T18:16:36.895666Z  INFO Ack latency - 0ms
2024-08-13T18:16:36.895677Z  INFO Forwarded 15500 messages at time 2024-08-13 18:16:36.895677142 UTC
2024-08-13T18:16:36.897122Z  INFO Read batch size: 500 and latency - 1ms
2024-08-13T18:16:36.911895Z  INFO Transformer latency - 14ms
2024-08-13T18:16:36.928537Z  INFO Sink latency - 16ms
2024-08-13T18:16:36.929535Z  INFO Ack latency - 0ms
2024-08-13T18:16:36.931104Z  INFO Read batch size: 500 and latency - 1ms
2024-08-13T18:16:36.944937Z  INFO Transformer latency - 13ms
2024-08-13T18:16:36.966619Z  INFO Sink latency - 21ms
2024-08-13T18:16:36.967615Z  INFO Ack latency - 0ms
2024-08-13T18:16:36.969082Z  INFO Read batch size: 500 and latency - 1ms
2024-08-13T18:16:36.982251Z  INFO Transformer latency - 13ms
2024-08-13T18:16:36.998401Z  INFO Sink latency - 16ms
2024-08-13T18:16:36.999279Z  INFO Ack latency - 0ms
2024-08-13T18:16:37.000842Z  INFO Read batch size: 500 and latency - 1ms
2024-08-13T18:16:37.014800Z  INFO Transformer latency - 13ms
2024-08-13T18:16:37.032363Z  INFO Sink latency - 17ms
2024-08-13T18:16:37.033219Z  INFO Ack latency - 0ms
2024-08-13T18:16:37.035565Z  INFO Read batch size: 500 and latency - 2ms
2024-08-13T18:16:37.049433Z  INFO Transformer latency - 13ms

@kohlisid
Copy link
Contributor

Events:
  Type     Reason     Age                  From               Message
  ----     ------     ----                 ----               -------
  Normal   Scheduled  116s                 default-scheduler  Successfully assigned default/simple-mono-vertex-mv-0-sravp to kind-control-plane
  Normal   Pulled     116s                 kubelet            Container image "quay.io/numaproj/numaflow:latest" already present on machine
  Normal   Created    116s                 kubelet            Created container numa
  Normal   Started    115s                 kubelet            Started container numa
  Normal   Pulled     115s                 kubelet            Container image "quay.io/numaio/numaflow-java/source-simple-source:stable" already present on machine
  Normal   Created    115s                 kubelet            Created container udsource
  Normal   Started    115s                 kubelet            Started container udsource
  Normal   Pulling    115s                 kubelet            Pulling image "quay.io/numaio/numaflow-rs/source-transformer-now:stable"
  Normal   Pulled     112s                 kubelet            Successfully pulled image "quay.io/numaio/numaflow-rs/source-transformer-now:stable" in 2.742s (2.742s including waiting)
  Normal   Created    112s                 kubelet            Created container transformer
  Normal   Started    112s                 kubelet            Started container transformer
  Normal   Pulled     112s                 kubelet            Container image "quay.io/numaio/numaflow-java/simple-sink:stable" already present on machine
  Normal   Created    112s                 kubelet            Created container udsink

@vigith vigith merged commit 13d917e into main Aug 13, 2024
25 checks passed
@vigith vigith deleted the add-txfr branch August 13, 2024 18:18
SaniyaKalamkar pushed a commit to SaniyaKalamkar/numaflow that referenced this pull request Aug 14, 2024
KeranYang pushed a commit that referenced this pull request Aug 19, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants