added license to newly added file & removed unwanted comments

Author: MehulBatra

fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/source/reader/FlinkSourceReader.java

@@ -48,7 +48,6 @@
 public class FlinkSourceReader
         extends SingleThreadMultiplexSourceReaderBase<
                 RecordAndPos, RowData, SourceSplitBase, SourceSplitState> {
-    // todo take changes for changeloftable columns
     public FlinkSourceReader(
             FutureCompletingBlockingQueue<RecordsWithSplitIds<RecordAndPos>> elementsQueue,
             Configuration flussConfig,
@@ -70,7 +69,6 @@ public FlinkSourceReader(
                                         projectedFields,
                                         flinkSourceReaderMetrics),
                         (ignore) -> {}),
-                // todo should have a special FlussRowToFlinkRowConverter that converts the Fluss
                 // InternalRow into Flink RowData with the additional metadata columns
                 new FlinkRecordEmitter(sourceOutputType, isChangelog),
                 context.getConfiguration(),

fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/utils/ChangelogRowConverter.java

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2024 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package com.alibaba.fluss.connector.flink.utils;
 
 import com.alibaba.fluss.client.table.scanner.ScanRecord;

fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/utils/FlussRowToFlinkRowConverter.java

@@ -47,7 +47,6 @@ public class FlussRowToFlinkRowConverter {
     private final FlussDeserializationConverter[] toFlinkFieldConverters;
     private final InternalRow.FieldGetter[] flussFieldGetters;
 
-    // todo converts the Fluss InternalRow into Flink RowData with the additional metadata columns
     public FlussRowToFlinkRowConverter(RowType rowType) {
         this.toFlinkFieldConverters = new FlussDeserializationConverter[rowType.getFieldCount()];
         this.flussFieldGetters = new InternalRow.FieldGetter[rowType.getFieldCount()];

fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorService.java

@@ -137,9 +137,6 @@ public CompletableFuture<DropDatabaseResponse> dropDatabase(DropDatabaseRequest
         return CompletableFuture.completedFuture(response);
     }
 
-    // todo keep a validation that whether the created table using system reserved columns
-    // (_change_type, _log_offset, _commit_timestamp)
-
     @Override
     public CompletableFuture<CreateTableResponse> createTable(CreateTableRequest request) {
         TablePath tablePath = toTablePath(request.getTablePath());