Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-19 Thread via GitHub
RyanSkraba commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1572359539 ## flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java: ## @@ -140,4 +144,56 @@ public void skipFully(long

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-18 Thread via GitHub
masteryhx closed pull request #24632: [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer URL: https://github.com/apache/flink/pull/24632 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-18 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1570109129 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-18 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1570106555 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,210 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-18 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1570103838 ## flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java: ## @@ -140,4 +144,43 @@ public void skipFully(long

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
Zakelly commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1569850955 ## flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java: ## @@ -140,4 +144,43 @@ public void skipFully(long

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1568937355 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1568925383 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1568925383 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1568923544 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-16 Thread via GitHub
Zakelly commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1567124524 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-16 Thread via GitHub
ljz2051 commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1566847884 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java: ## @@ -0,0 +1,102 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-15 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1566625643 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java: ## @@ -0,0 +1,153 @@ +/* + * Licensed to

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-15 Thread via GitHub
ljz2051 commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1565730166 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,191 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-10 Thread via GitHub
masteryhx commented on PR #24632: URL: https://github.com/apache/flink/pull/24632#issuecomment-2047200220 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-08 Thread via GitHub
flinkbot commented on PR #24632: URL: https://github.com/apache/flink/pull/24632#issuecomment-2042228701 ## CI report: * aadf8efad983aa85d8d484211c6d9eb90dee3d84 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-08 Thread via GitHub
masteryhx opened a new pull request, #24632: URL: https://github.com/apache/flink/pull/24632 ## What is the purpose of the change As described in FLIP-427, ForStFileSystem is introduced to support reading and writing with ByteBuffer, which will bridge between ForSt FileSystem