You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
We started using hadoop's openstack filesystem (Swift) as a storage backend for Apache Flink and ran into the problem that every few hours an error would be triggered that would cause our flink jobs to get restarted.
The problem happens when the token that is used to make api calls expires. At that point the server will return a 401 status code (unauthorized).
What should happen next is that the token should be refreshed and the request should be retried with the new token.
But what happens is that while a new token is requested , the request is retried with the old token and will always fail.
The fix is a simple one, set the correct authentication header on the request before retrying
It turns out that this issue had already been reported in 2016 and a patch was provided by the original reporter.
However for some reason the patch was never merged.
Because the code has changed a bit since the patch was created, i took the liberty of adapting it so it compiles cleanly on the current trunk. I also removed the test the original author created because it basically did a sleep until a token expired. (which usually takes hours)
The patch doesn't appear to include any new or modified tests. Please justify why no new tests are needed for this patch. Also please list what manual steps were performed to verify this patch.
_ trunk Compile Tests _
+1
mvninstall
1200
trunk passed
+1
compile
22
trunk passed
+1
checkstyle
21
trunk passed
+1
mvnsite
27
trunk passed
+1
shadedclient
786
branch has no errors when building and testing our client artifacts.
+1
javadoc
21
trunk passed
0
spotbugs
39
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
35
trunk passed
_ Patch Compile Tests _
+1
mvninstall
19
the patch passed
+1
compile
18
the patch passed
+1
javac
18
the patch passed
+1
checkstyle
15
the patch passed
+1
mvnsite
24
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
838
patch has no errors when building and testing our client artifacts.
The patch doesn't appear to include any new or modified tests. Please justify why no new tests are needed for this patch. Also please list what manual steps were performed to verify this patch.
_ trunk Compile Tests _
+1
mvninstall
1119
trunk passed
+1
compile
21
trunk passed
+1
checkstyle
15
trunk passed
+1
mvnsite
24
trunk passed
+1
shadedclient
682
branch has no errors when building and testing our client artifacts.
+1
javadoc
22
trunk passed
0
spotbugs
41
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
39
trunk passed
_ Patch Compile Tests _
+1
mvninstall
20
the patch passed
+1
compile
19
the patch passed
+1
javac
19
the patch passed
+1
checkstyle
14
the patch passed
+1
mvnsite
20
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
786
patch has no errors when building and testing our client artifacts.
The patch doesn't appear to include any new or modified tests. Please justify why no new tests are needed for this patch. Also please list what manual steps were performed to verify this patch.
_ trunk Compile Tests _
+1
mvninstall
1299
trunk passed
+1
compile
30
trunk passed
+1
checkstyle
28
trunk passed
+1
mvnsite
34
trunk passed
+1
shadedclient
956
branch has no errors when building and testing our client artifacts.
+1
javadoc
25
trunk passed
0
spotbugs
46
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
44
trunk passed
_ Patch Compile Tests _
+1
mvninstall
23
the patch passed
+1
compile
21
the patch passed
+1
javac
21
the patch passed
+1
checkstyle
17
the patch passed
+1
mvnsite
26
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
1009
patch has no errors when building and testing our client artifacts.
The patch doesn't appear to include any new or modified tests. Please justify why no new tests are needed for this patch. Also please list what manual steps were performed to verify this patch.
_ trunk Compile Tests _
+1
mvninstall
1162
trunk passed
+1
compile
17
trunk passed
+1
checkstyle
17
trunk passed
+1
mvnsite
20
trunk passed
+1
shadedclient
683
branch has no errors when building and testing our client artifacts.
+1
javadoc
19
trunk passed
0
spotbugs
34
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
33
trunk passed
_ Patch Compile Tests _
+1
mvninstall
17
the patch passed
+1
compile
15
the patch passed
+1
javac
15
the patch passed
+1
checkstyle
14
the patch passed
+1
mvnsite
17
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
725
patch has no errors when building and testing our client artifacts.
The patch doesn't appear to include any new or modified tests. Please justify why no new tests are needed for this patch. Also please list what manual steps were performed to verify this patch.
_ trunk Compile Tests _
+1
mvninstall
1115
trunk passed
+1
compile
19
trunk passed
+1
checkstyle
19
trunk passed
+1
mvnsite
20
trunk passed
+1
shadedclient
664
branch has no errors when building and testing our client artifacts.
+1
javadoc
16
trunk passed
0
spotbugs
30
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
29
trunk passed
_ Patch Compile Tests _
+1
mvninstall
15
the patch passed
+1
compile
13
the patch passed
+1
javac
13
the patch passed
+1
checkstyle
12
the patch passed
+1
mvnsite
16
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
725
patch has no errors when building and testing our client artifacts.
The patch doesn't appear to include any new or modified tests. Please justify why no new tests are needed for this patch. Also please list what manual steps were performed to verify this patch.
_ trunk Compile Tests _
+1
mvninstall
1240
trunk passed
+1
compile
17
trunk passed
+1
checkstyle
25
trunk passed
+1
mvnsite
29
trunk passed
+1
shadedclient
835
branch has no errors when building and testing our client artifacts.
+1
javadoc
25
trunk passed
0
spotbugs
42
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
39
trunk passed
_ Patch Compile Tests _
+1
mvninstall
21
the patch passed
+1
compile
18
the patch passed
+1
javac
18
the patch passed
+1
checkstyle
15
the patch passed
+1
mvnsite
19
the patch passed
+1
whitespace
1
The patch has no whitespace issues.
+1
shadedclient
857
patch has no errors when building and testing our client artifacts.
The patch doesn't appear to include any new or modified tests. Please justify why no new tests are needed for this patch. Also please list what manual steps were performed to verify this patch.
_ trunk Compile Tests _
+1
mvninstall
1104
trunk passed
+1
compile
18
trunk passed
+1
checkstyle
16
trunk passed
+1
mvnsite
20
trunk passed
+1
shadedclient
707
branch has no errors when building and testing our client artifacts.
+1
javadoc
20
trunk passed
0
spotbugs
33
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
31
trunk passed
_ Patch Compile Tests _
+1
mvninstall
18
the patch passed
+1
compile
17
the patch passed
+1
javac
17
the patch passed
+1
checkstyle
13
the patch passed
+1
mvnsite
16
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
748
patch has no errors when building and testing our client artifacts.
The patch doesn't appear to include any new or modified tests. Please justify why no new tests are needed for this patch. Also please list what manual steps were performed to verify this patch.
_ trunk Compile Tests _
+1
mvninstall
1210
trunk passed
+1
compile
17
trunk passed
+1
checkstyle
17
trunk passed
+1
mvnsite
21
trunk passed
+1
shadedclient
784
branch has no errors when building and testing our client artifacts.
+1
javadoc
19
trunk passed
0
spotbugs
33
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
30
trunk passed
_ Patch Compile Tests _
+1
mvninstall
17
the patch passed
+1
compile
14
the patch passed
+1
javac
14
the patch passed
+1
checkstyle
12
the patch passed
+1
mvnsite
17
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
855
patch has no errors when building and testing our client artifacts.
This change allows user to register the metrics on the per-container basis.
Tested in beam runner and works as expected.
Author: xiliu <[email protected]>
Reviewers: Prateek Maheshwari <[email protected]>
Closesapache#361 from xinyuiscool/SAMZA-1504
We're closing this stale PR because it has been open for 100 days with no activity. This isn't a judgement on the merit of the PR in any way. It's just a way of keeping the PR queue manageable.
If you feel like this was a mistake, or you would like to continue working on it, please feel free to re-open it and ask for a committer to remove the stale tag and review again.
Thanks all for your contribution.
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
We started using hadoop's openstack filesystem (Swift) as a storage backend for Apache Flink and ran into the problem that every few hours an error would be triggered that would cause our flink jobs to get restarted.
The problem happens when the token that is used to make api calls expires. At that point the server will return a 401 status code (unauthorized).
What should happen next is that the token should be refreshed and the request should be retried with the new token.
But what happens is that while a new token is requested , the request is retried with the old token and will always fail.
The fix is a simple one, set the correct authentication header on the request before retrying
It turns out that this issue had already been reported in 2016 and a patch was provided by the original reporter.
However for some reason the patch was never merged.
Because the code has changed a bit since the patch was created, i took the liberty of adapting it so it compiles cleanly on the current trunk. I also removed the test the original author created because it basically did a sleep until a token expired. (which usually takes hours)