Search results

How to pause the source task to not send output to downstream?

Status: Open.

#67 In sane-lab/flink;

· maxCodeVector opened on Dec 28, 2020

May need to pause down stream task

Status: Open.

#66 In sane-lab/flink;

· maxCodeVector opened on Dec 28, 2020

Implement the scale related API "deploy and cancel task".

Status: Open.

#63 In sane-lab/flink;

· yancanmao opened on Dec 1, 2020

Key mapping about Stateless Operator

Status: Open.

#61 In sane-lab/flink;

· maxCodeVector opened on Nov 29, 2020

Scale out error when executing some special application:　Cannot find matched InputGateDeploymentDescriptor

bugSomething isn't workingSomething isn't working

Status: Open.

#58 In sane-lab/flink;

· maxCodeVector opened on Oct 21, 2020

BUG3 - Metrics inconsistency, caused by restarting gates and partitions, it is unavoidable if we use the existing partitions and gates creation logic, need to find out a way to solve elegantly.

Status: Open.

#52 In sane-lab/flink;

· yancanmao opened on Aug 14, 2020

Systematically test the framework, answer:

Status: Open.

#47 In sane-lab/flink;

· yancanmao opened on Aug 11, 2020

Thread RescaleActionQueue start multiple times when job status changed

Status: Open.

#43 In sane-lab/flink;

· maxCodeVector opened on Aug 5, 2020

Scaling is too low when there are some special operator (time window) if using barrier

Status: Open.

#40 In sane-lab/flink;

· maxCodeVector opened on Jul 30, 2020

Multiple scale actions on JobRescalecoordinator

Status: Open.

#39 In sane-lab/flink;

· maxCodeVector opened on Jul 30, 2020