argoproj-labs/old-argo-dataflow

Issues

• ArgoLabs Dataflow is on hold - use Numaflow

  #529 opened 2 years ago by alexec
  11

• Multiple Kafka sinks

  #672 opened 2 years ago by higginbottomm
  1

• request influxdb as a sink

  #642 opened 2 years ago by licheng5625
  1

• Does it support reading data from multiple pod volumes?

  #625 opened 2 years ago by SaltedFishChili
  1

• Runner can only return SASL or TLS not both

  #627 opened 2 years ago by krise86
  0

• Add SECURITY.md

  #565 opened 2 years ago by jessesuen
  1

• [bug]fatal error: concurrent map read and map write

  #588 opened 2 years ago by hwzp99
  1

• AMQP support

  #522 opened 2 years ago by amitza
  1

• Maybe remove FIFO

  #518 opened 2 years ago by alexec
  3

• test issue

  #575 opened 2 years ago by alexec
  4

• Provide a helm chart

  #487 opened 2 years ago by boniek83
  4

• Ability to specify envs for code step

  #517 opened 2 years ago by zewelor
  4

• Updating a label in argo dataflow does not redeploy pipeline

  #519 opened 2 years ago by louisnow
  4

• Add Common Labels to Pods created

  #463 opened 2 years ago by Udit107710
  4

• Could you explain what advantage is argo-dataflow with regard to flink? flink can be deployed on kubernetes now

  #497 opened 2 years ago by liujiong1982
  4

• Cluster variable

  #534 opened 2 years ago by IvanKolbasiuk
  3

• Add ZeroMQ support

  #506 opened 2 years ago by jsallay
  4

• More Landscape Research

  #477 opened 2 years ago by alexec
  1

• Source async commit/ack

  #496 opened 2 years ago by alexec
  1

• Propagate the root source URN and root message ID

  #488 opened 2 years ago by alexec
  1

• Back-pressure, flow-control, rate-limiting

  #479 opened 2 years ago by alexec
  1

• ...vs Apache Nifi

  #473 opened 2 years ago by alexec
  1

• ...vs Bethos

  #474 opened 2 years ago by alexec
  1

• ... vs Flink

  #475 opened 2 years ago by alexec
  1

• ...vs Akka Streams

  #476 opened 2 years ago by alexec
  1

• Improve the examples so they are a lesson in dataflow that users can run

  #478 opened 2 years ago by alexec
  1

• Step not scaling

  #462 opened 2 years ago by Udit107710
  6

• Step retrying even after updating to not retry

  #461 opened 2 years ago by Udit107710
  5

• Quickstart does not seem to work with examples

  #448 opened 2 years ago by Rob-Fletcher
  6

• NSQ

  #459 opened 2 years ago by alexec
  2

• Document resource request tuning

  #460 opened 2 years ago by alexec
  1

• Use commandlet pattern to get rid of sidecar

  #452 opened 2 years ago by alexec
  1

• Configuration Python DSL

  #445 opened 2 years ago by alexec
  1

• In-process the built-in steps

  #451 opened 2 years ago by alexec
  1

• Kafka "Local: Message timed out"

  #509 opened 2 years ago by alexec
  5

• Removed `dedupe` processor

  #499 opened 2 years ago by alexec
  0

• Remove `group` processor

  #500 opened 2 years ago by alexec
  0

• Cluster-scoped manifests

  #498 opened 3 years ago by alexec
  0

• Multiple Sources to single Step

  #501 opened 3 years ago by Udit107710
  7

• Unable to pull images

  #502 opened 3 years ago by Udit107710
  0

• "Async to Kafka failed" means messages are lost

  #494 opened 3 years ago by alexec
  5

• Investigate Redis Streams

  #484 opened 3 years ago by alexec
  1

• Allow user to specify the base image for code steps

  #482 opened 3 years ago by alexec
  0

• Dead Letter Queues failing

  #486 opened 3 years ago by inishchith
  6

• Upgrade to Golang 1.17

  #458 opened 3 years ago by alexec
  0

• Low Friction Contribution

  #442 opened 3 years ago by alexec
  1

• Investigate Kafka errors

  #466 opened 3 years ago by alexec
  0

• Have "make kubebuilder" detect OS and architecture

  #470 opened 3 years ago by dseapy
  0

• STAN logs "failed to reconnect" at error level, should it log at info level

  #456 opened 3 years ago by alexec
  1

• Investigate STAN error

  #465 opened 3 years ago by alexec
  4