(hbase-site) branch asf-site updated: INFRA-10751 Empty commit
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/hbase-site.git The following commit(s) were added to refs/heads/asf-site by this push: new a70735bca33 INFRA-10751 Empty commit a70735bca33 is described below commit a70735bca33fbab9a51a3f4c0f2b7f66070a04cb Author: jenkins AuthorDate: Sun Jun 16 14:47:16 2024 + INFRA-10751 Empty commit
(hbase) 02/02: HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit e844daa84c59b9ed7f6a0eeb35d7801e0468a209
Author: Charles Connell
AuthorDate: Sat Jun 15 22:15:20 2024 -0400
HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets
(#5994)
In WALEntryStream, always use current WALTailingReader if one exists
Signed-off-by: Duo Zhang
(cherry picked from commit bd8ad45a259a1b0066068e41a25ef4c9098d374a)
---
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 6068f23ace8..1b8562bab33 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -220,6 +220,7 @@ class WALEntryStream implements Closeable {
// we will read from the beginning so we should always clear the
compression context
reader.resetTo(-1, true);
}
+ return HasNext.YES;
} catch (FileNotFoundException e) {
// For now, this could happen only when reading meta wal for meta
replicas.
// In this case, raising UncheckedIOException will let the endpoint
deal with resetting
(hbase) branch branch-2.6 updated (564887fed82 -> e844daa84c5)
This is an automated email from the ASF dual-hosted git repository. zhangduo pushed a change to branch branch-2.6 in repository https://gitbox.apache.org/repos/asf/hbase.git from 564887fed82 HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994) new 0aa8e105cbb Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)" new e844daa84c5 HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994) The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes:
(hbase) 01/02: Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)"
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 0aa8e105cbb9c2e0fc3a1f6e4b07bde6559e6dbd
Author: Duo Zhang
AuthorDate: Sun Jun 16 17:14:25 2024 +0800
Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked
sockets (#5994)"
This reverts commit 564887fed82081079ca76b100ce4636810742620.
---
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 1b8562bab33..6068f23ace8 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -220,7 +220,6 @@ class WALEntryStream implements Closeable {
// we will read from the beginning so we should always clear the
compression context
reader.resetTo(-1, true);
}
- return HasNext.YES;
} catch (FileNotFoundException e) {
// For now, this could happen only when reading meta wal for meta
replicas.
// In this case, raising UncheckedIOException will let the endpoint
deal with resetting
(hbase) 01/02: Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)"
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit a4adde11314765a07ce730c182b627050e5fe87a
Author: Duo Zhang
AuthorDate: Sun Jun 16 17:13:48 2024 +0800
Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked
sockets (#5994)"
This reverts commit 5db6e5e762608d891c7f3fb3f380420b5671d099.
---
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 1b8562bab33..6068f23ace8 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -220,7 +220,6 @@ class WALEntryStream implements Closeable {
// we will read from the beginning so we should always clear the
compression context
reader.resetTo(-1, true);
}
- return HasNext.YES;
} catch (FileNotFoundException e) {
// For now, this could happen only when reading meta wal for meta
replicas.
// In this case, raising UncheckedIOException will let the endpoint
deal with resetting
(hbase) branch branch-2 updated (5db6e5e7626 -> 26157182636)
This is an automated email from the ASF dual-hosted git repository. zhangduo pushed a change to branch branch-2 in repository https://gitbox.apache.org/repos/asf/hbase.git from 5db6e5e7626 HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994) new a4adde11314 Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)" new 26157182636 HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994) The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes:
(hbase) 02/02: HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 2615718263659498f9fd7fb434161fb741e2cbad
Author: Charles Connell
AuthorDate: Sat Jun 15 22:15:20 2024 -0400
HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets
(#5994)
In WALEntryStream, always use current WALTailingReader if one exists
Signed-off-by: Duo Zhang
(cherry picked from commit bd8ad45a259a1b0066068e41a25ef4c9098d374a)
---
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 6068f23ace8..1b8562bab33 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -220,6 +220,7 @@ class WALEntryStream implements Closeable {
// we will read from the beginning so we should always clear the
compression context
reader.resetTo(-1, true);
}
+ return HasNext.YES;
} catch (FileNotFoundException e) {
// For now, this could happen only when reading meta wal for meta
replicas.
// In this case, raising UncheckedIOException will let the endpoint
deal with resetting
(hbase) 02/02: HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-3
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 9270519eadda8dce5dad4c6936ce27b77766dd7a
Author: Charles Connell
AuthorDate: Sat Jun 15 22:15:20 2024 -0400
HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets
(#5994)
In WALEntryStream, always use current WALTailingReader if one exists
Signed-off-by: Duo Zhang
(cherry picked from commit bd8ad45a259a1b0066068e41a25ef4c9098d374a)
---
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 186d5b7c4d1..8d74d0e0399 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -219,6 +219,7 @@ class WALEntryStream implements Closeable {
// we will read from the beginning so we should always clear the
compression context
reader.resetTo(-1, true);
}
+ return HasNext.YES;
} catch (IOException e) {
LOG.warn("Failed to reset reader {} to pos {}, reset
compression={}", currentPath,
currentPositionOfEntry, state.resetCompression(), e);
(hbase) 01/02: Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)"
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-3
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit a33b8c2ad1d8c9724deb461f47b099981a345f26
Author: Duo Zhang
AuthorDate: Sun Jun 16 17:13:14 2024 +0800
Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked
sockets (#5994)"
This reverts commit 0b70d6c9cf0749f67151b862edc728e72f72d9b6.
---
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 8d74d0e0399..186d5b7c4d1 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -219,7 +219,6 @@ class WALEntryStream implements Closeable {
// we will read from the beginning so we should always clear the
compression context
reader.resetTo(-1, true);
}
- return HasNext.YES;
} catch (IOException e) {
LOG.warn("Failed to reset reader {} to pos {}, reset
compression={}", currentPath,
currentPositionOfEntry, state.resetCompression(), e);
(hbase) branch branch-3 updated (0b70d6c9cf0 -> 9270519eadd)
This is an automated email from the ASF dual-hosted git repository. zhangduo pushed a change to branch branch-3 in repository https://gitbox.apache.org/repos/asf/hbase.git from 0b70d6c9cf0 HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994) new a33b8c2ad1d Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)" new 9270519eadd HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994) The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes:
(hbase) 02/02: HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 60c46118e21319651c099928ab929800d0de92b4
Author: Charles Connell
AuthorDate: Sat Jun 15 22:15:20 2024 -0400
HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets
(#5994)
In WALEntryStream, always use current WALTailingReader if one exists
Signed-off-by: Duo Zhang
---
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 186d5b7c4d1..8d74d0e0399 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -219,6 +219,7 @@ class WALEntryStream implements Closeable {
// we will read from the beginning so we should always clear the
compression context
reader.resetTo(-1, true);
}
+ return HasNext.YES;
} catch (IOException e) {
LOG.warn("Failed to reset reader {} to pos {}, reset
compression={}", currentPath,
currentPositionOfEntry, state.resetCompression(), e);
(hbase) branch master updated (bd8ad45a259 -> 60c46118e21)
This is an automated email from the ASF dual-hosted git repository. zhangduo pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/hbase.git from bd8ad45a259 HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994) new 9ef621db90a Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)" new 60c46118e21 HBASE-28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994) The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes:
(hbase) 01/02: Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)"
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 9ef621db90a77f55c187a037e6fc6eeb7bc0f69f
Author: Duo Zhang
AuthorDate: Sun Jun 16 17:12:00 2024 +0800
Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked
sockets (#5994)"
This reverts commit bd8ad45a259a1b0066068e41a25ef4c9098d374a.
---
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 8d74d0e0399..186d5b7c4d1 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -219,7 +219,6 @@ class WALEntryStream implements Closeable {
// we will read from the beginning so we should always clear the
compression context
reader.resetTo(-1, true);
}
- return HasNext.YES;
} catch (IOException e) {
LOG.warn("Failed to reset reader {} to pos {}, reset
compression={}", currentPath,
currentPositionOfEntry, state.resetCompression(), e);
