Pinned
1,064 contributions in the last year
Less
More
Activity overview
Contribution activity
April 2021
Created 48 commits in 3 repositories
Created a pull request in apache/flink that received 3 comments
[FLINK-22069] Reduce various logging issues
A collection of various issues around logging. Each commit is self-contained and addresses a separate issue.
+75
−55
•
3
comments
Opened 11 other pull requests in 2 repositories
apache/flink
1
open
8
merged
- [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests
- [FLINK-21659][coordination] Properly expose checkpoint settings for initializing jobs
- [FLINK-20723][cassandra][tests] Retry on NoHostAvailableException
- [FLINK-21859][coordination] Ignore outdated slot offer responses
- [FLINK-22180][coordination] Only reclaim slots if job is removed
- [FLINK-22252][docs][config] Fix backticks rendering
- [FLINK-22208][build] Bump snappy-java to 1.1.8.3
- [FLINK-22184][client] Shutdown client outside of netty thread
- [FLINK-21152][build] Bump flink-shaded to 13.0
apache/flink-web
2
merged
Reviewed 22 pull requests in 2 repositories
apache/flink 21 pull requests
- [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs
- [FLINK-20723][cassandra][tests] Retry on NoHostAvailableException
- [FLINK-21659][coordination] Properly expose checkpoint settings for initializing jobs
- [hotfix][docs] Fix some typos and sample codes syntax issues in sever…
- [FLINK-22396][legal] Remove unnecessary entries from sql hbase connector NOTICE file
- [FLINK-22373][docs] Add Flink 1.13 release notes
- [FLINK-22359][python] Set the version to 1.13.dev0 for PyFlink
- [FLINK-22352][mesos] Deprecates Mesos support
- [FLINK-22351][coordination] Promote resource declaration log to INFO …
- [FLINK-21859][coordination] Ignore outdated slot offer responses
- [FLINK-22180][coordination] Only reclaim slots if job is removed
- [FLINK-22069] Reduce various logging issues
- [FLINK-21954][tests] Harden JobMasterQueryableStateTest, JobMasterTest.testRestoringFromSavepoint and .testRequestNextInputSplitWithGlobalFailover
- [FLINK-21152][build] Bump flink-shaded to 13.0
- [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler
- [BP-1.11][FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData
- [BP-1.12][FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData
- [FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData
- [FLINK-16947][Azure] Attempt to fix the "Entry has not been leased fr…
- [FLINK-22094] Update release scripts after documentation switch to Hugo
- [FLINK-16947][Azure] Use latest docker image for CI