[flink-table-store] branch master updated: [hotfix] Change the variable name sekableInputStream to seekableInputStream

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new 8621adbd [hotfix] Change the variable name sekableInputStream to 
seekableInputStream
8621adbd is described below

commit 8621adbd364d2d71fa846a2ed54381a441414145
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Tue Mar 14 16:37:46 2023 +0800

    [hotfix] Change the variable name sekableInputStream to seekableInputStream
    
    This closes #597
---
 .../store/format/fs/HadoopReadOnlyFileSystem.java  | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git 
a/flink-table-store-format/src/main/java/org/apache/flink/table/store/format/fs/HadoopReadOnlyFileSystem.java
 
b/flink-table-store-format/src/main/java/org/apache/flink/table/store/format/fs/HadoopReadOnlyFileSystem.java
index 7a925619..14aadb53 100644
--- 
a/flink-table-store-format/src/main/java/org/apache/flink/table/store/format/fs/HadoopReadOnlyFileSystem.java
+++ 
b/flink-table-store-format/src/main/java/org/apache/flink/table/store/format/fs/HadoopReadOnlyFileSystem.java
@@ -145,29 +145,29 @@ public class HadoopReadOnlyFileSystem extends FileSystem {
     private static class FSDataWrappedInputStream extends InputStream
             implements Seekable, PositionedReadable {
 
-        private final org.apache.flink.table.store.fs.SeekableInputStream 
sekableInputStream;
+        private final org.apache.flink.table.store.fs.SeekableInputStream 
seekableInputStream;
 
         private FSDataWrappedInputStream(
-                org.apache.flink.table.store.fs.SeekableInputStream 
sekableInputStream) {
-            this.sekableInputStream = sekableInputStream;
+                org.apache.flink.table.store.fs.SeekableInputStream 
seekableInputStream) {
+            this.seekableInputStream = seekableInputStream;
         }
 
         @Override
         public int read() throws IOException {
-            return sekableInputStream.read();
+            return seekableInputStream.read();
         }
 
         @Override
         public int read(long position, byte[] buffer, int offset, int length) 
throws IOException {
-            sekableInputStream.seek(position);
-            return sekableInputStream.read(buffer, offset, length);
+            seekableInputStream.seek(position);
+            return seekableInputStream.read(buffer, offset, length);
         }
 
         @Override
         public void readFully(long position, byte[] buffer, int offset, int 
length)
                 throws IOException {
-            sekableInputStream.seek(position);
-            IOUtils.readFully(sekableInputStream, buffer, offset, length);
+            seekableInputStream.seek(position);
+            IOUtils.readFully(seekableInputStream, buffer, offset, length);
         }
 
         @Override
@@ -177,12 +177,12 @@ public class HadoopReadOnlyFileSystem extends FileSystem {
 
         @Override
         public void seek(long pos) throws IOException {
-            sekableInputStream.seek(pos);
+            seekableInputStream.seek(pos);
         }
 
         @Override
         public long getPos() throws IOException {
-            return sekableInputStream.getPos();
+            return seekableInputStream.getPos();
         }
 
         @Override
@@ -192,7 +192,7 @@ public class HadoopReadOnlyFileSystem extends FileSystem {
 
         @Override
         public void close() throws IOException {
-            sekableInputStream.close();
+            seekableInputStream.close();
         }
     }
 }