tree b43f21950b6759add9467051aef0294aceeef2bb
parent 164a59ac1bb4dd39e6532478c30234eeafd76cd0
author Anton Kalashnikov <kaa.dev@yandex.ru> 1631844937 +0200
committer GitHub <noreply@github.com> 1631844937 +0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJhQ/pJCRBK7hj4Ov3rIwAA7tgIAGOKg3FVzMIuXeaF64/Fum1C
 Hf/PjLRk4eRjBkIo3YueP2WjPJOUwEp5/p0I+J1zLp+FUOJGrVcbIa4mwZIfNdsy
 dfQfl9N5XVuzbWEsqZTNiRk6aPFQz9W07BRab+6ev4J09IJ7lIshca6vhZAlVOlS
 EGBiQkrklCjKDoRNa9ad9rN4lysy5nphv/vj8V+BxsxIczqDI+mH7C1/BI/cwYhC
 VPSvD/sz/GVqiRsVG6zMXDNUz01v8ITE6VaDkzvvJv2HssryK74ib3Yi16gpRyCV
 Nz+BE4GFxCd/eo50Z1Zp4xe1/4RLKlpvaeymBQT4uvJsZjwXXBpry5OcY0WogBg=
 =T2V+
 -----END PGP SIGNATURE-----
 

[FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor (#17187)

* [refactor][streaming] Ability to change bufferTimeout for StreamEdge in StreamConfigChainer

* [FLINK-11250][streaming] Correctly clean up stream task on every place it uses