JiangXin

## What is the purpose of the change *(For example: This pull request makes user can stop workflow externally.)* ## Brief change log *(for example:)* - *Send StopDagEvent to Airflow...

### Describe the bug task1 action_on_task_status(task2, success) when task1 failed, task2 would not be scheduled, but the status of workflow execution is still running. I think the status shoud be...

### Describe the feature Currently, the event is broadcasting, once the wanted event is sent, all workflow executions of this workflow would be triggered. ### Describe the solution you'd like...

### Describe the bug ### Your environment #### Operating system #### Database #### Python version ### To Reproduce Steps to reproduce the behavior (if you can): 1. Submit a '...'...

### Describe the feature AIFlow support python3.6 ### Describe the solution you'd like ### Describe alternatives you've considered ### Additional context When run aiflow with python3.6, notification server blocks wich...

### Describe the bug Cannot use one EmbeddedNotificationClient instance in multiple threads. ### Your environment #### Operating system #### Database #### Python version ### To Reproduce ``` def test_create_client_multiple_threads(self): import...

…iles ## What is the purpose of the change Add QuantileSummary to help calculate approximate quantiles ## Brief change log - Add implementation of GK algorithm. - Add merge operation...

[FLINK-33879] Avoids the potential hang of Hybrid Shuffle during redistribution

5

## What is the purpose of the change This PR is to avoid the potential hang of Hybrid Shuffle during redistribution. The details about how a hang happens, please see...

[FLINK-33668] Decoupling Shuffle network memory and job topology

2

## What is the purpose of the change This pull request decouples shuffle network memory and job topology which resolves the [issue](https://issues.apache.org/jira/browse/FLINK-33668) ## Brief change log - Redefines the redistribution...

Currently, we can construct a Source with timestamp_field set but not contained in the schema like the following test. We should raise an exception in Feathub instead of failing until...