[apache#737] flink-rss-support first commit.

slfan1989 · May 19, 2024 · 5a817ca · 5a817ca
1 parent 3b69e30
commit 5a817ca
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/client-flink/flink-1.15/src/main/java/org/apache/uniffle/flink/RssShuffleEnvironment.java b/client-flink/flink-1.15/src/main/java/org/apache/uniffle/flink/RssShuffleEnvironment.java
@@ -136,7 +136,6 @@ public List<ResultPartitionWriter> createResultPartitionWriters(
         ResultPartitionID resultPartitionId = shuffleDescriptor.getResultPartitionID();
         ResultPartitionType partitionType = descriptor.getPartitionType();
         int numberOfSubpartitions = descriptor.getNumberOfSubpartitions();
-        int totalNumberOfPartitions = descriptor.getTotalNumberOfPartitions();
         int maxParallelism = descriptor.getMaxParallelism();
 
         String compressionCodec =

diff --git a/client-flink/flink-1.15/src/main/java/org/apache/uniffle/flink/RssShuffleInputGate.java b/client-flink/flink-1.15/src/main/java/org/apache/uniffle/flink/RssShuffleInputGate.java
@@ -98,7 +98,7 @@ public EndOfDataStatus hasReceivedEndOfData() {
 
   @Override
   public Optional<BufferOrEvent> getNext() {
-    throw new UnsupportedOperationException("Not implemented.");
+    throw new UnsupportedOperationException("Not implemented yet.");
   }
 
   @Override
@@ -108,12 +108,12 @@ public Optional<BufferOrEvent> pollNext() throws IOException {
 
   @Override
   public void sendTaskEvent(TaskEvent event) {
-    throw new FlinkRuntimeException("Method should not be called.");
+    throw new FlinkRuntimeException("Not implemented yet.");
   }
 
   @Override
   public void resumeConsumption(InputChannelInfo channelInfo) throws IOException {
-    throw new FlinkRuntimeException("Method should not be called.");
+    throw new FlinkRuntimeException("Not implemented yet.");
   }
 
   @Override