This is an automated email from the ASF dual-hosted git repository. jark pushed a commit to branch ci-rename-to-apache in repository https://gitbox.apache.org/repos/asf/fluss.git
commit 78b503c15d3dedd52c4a546d9c4bd637cea93f4f Author: Jark Wu <[email protected]> AuthorDate: Mon Aug 25 13:58:34 2025 +0800 WIP --- LICENSE | 356 ++++++++++----------- .../fluss/flink/adapter/CatalogTableAdapter.java | 0 .../adapter/SingleThreadFetcherManagerAdapter.java | 0 ...ngleThreadMultiplexSourceReaderBaseAdapter.java | 0 .../fluss/flink/adapter/CatalogTableAdapter.java | 0 .../fluss/flink/catalog/Flink21CatalogITCase.java | 4 - .../fluss/flink/metrics/Flink21MetricsITCase.java | 0 .../flink/procedure/Flink21ProcedureITCase.java | 0 .../security/acl/Flink21AuthorizationITCase.java | 0 .../fluss/flink/sink/Flink21TableSinkITCase.java | 0 .../source/Flink21TableSourceBatchITCase.java | 0 .../source/Flink21TableSourceFailOverITCase.java | 0 .../flink/source/Flink21TableSourceITCase.java | 0 .../fluss/flink/adapter/CatalogTableAdapter.java | 0 .../adapter/SingleThreadFetcherManagerAdapter.java | 0 ...ngleThreadMultiplexSourceReaderBaseAdapter.java | 0 .../apache}/fluss/flink/lake/LakeCatalog.java | 25 +- .../fluss/flink/lake/LakeRecordRecordEmitter.java | 25 +- .../fluss/flink/lake/LakeSplitGenerator.java | 0 .../fluss/flink/lake/LakeSplitReaderGenerator.java | 0 .../fluss/flink/lake/LakeSplitSerializer.java | 0 .../flink/lake/LakeSplitStateInitializer.java | 0 .../apache}/fluss/flink/lake/LakeTableFactory.java | 25 +- .../fluss/flink/lake/reader/KeyValueRow.java | 0 .../reader/LakeSnapshotAndLogSplitScanner.java | 0 .../flink/lake/reader/LakeSnapshotScanner.java | 0 .../fluss/flink/lake/reader/SortMergeReader.java | 26 +- .../lake/split/LakeSnapshotAndFlussLogSplit.java | 0 .../fluss/flink/lake/split/LakeSnapshotSplit.java | 0 .../state/LakeSnapshotAndFlussLogSplitState.java | 0 .../flink/lake/state/LakeSnapshotSplitState.java | 0 .../fluss/flink/lake/LakeSplitSerializerTest.java | 0 .../flink/lake/reader/SortMergeReaderTest.java | 0 .../replica/fetcher/ReplicaFetcherThread.java | 2 +- website/blog/2025-06-01-partial-updates.md | 2 +- 35 files changed, 230 insertions(+), 235 deletions(-) diff --git a/LICENSE b/LICENSE index 5c274b510..da868f307 100644 --- a/LICENSE +++ b/LICENSE @@ -210,191 +210,191 @@ Apache License 2.0 -------------------------------------- Apache Arrow-java -./fluss-common/src/main/java/com/alibaba/fluss/compression/ArrowCompressionFactory.java -./fluss-common/src/main/java/com/alibaba/fluss/compression/Lz4ArrowCompressionCodec.java -./fluss-common/src/main/java/com/alibaba/fluss/compression/ZstdArrowCompressionCodec.java +./fluss-common/src/main/java/org/apache/fluss/compression/ArrowCompressionFactory.java +./fluss-common/src/main/java/org/apache/fluss/compression/Lz4ArrowCompressionCodec.java +./fluss-common/src/main/java/org/apache/fluss/compression/ZstdArrowCompressionCodec.java Apache Flink -./fluss-client/src/main/java/com/alibaba/fluss/client/token/DefaultSecurityTokenManager.java -./fluss-common/src/main/java/com/alibaba/fluss/classloading/ComponentClassLoader.java -./fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOption.java -./fluss-common/src/main/java/com/alibaba/fluss/config/Configuration.java -./fluss-common/src/main/java/com/alibaba/fluss/config/ConfigurationUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/config/GlobalConfiguration.java -./fluss-common/src/main/java/com/alibaba/fluss/config/MemorySize.java -./fluss-common/src/main/java/com/alibaba/fluss/fs/FSDataOutputStream.java -./fluss-common/src/main/java/com/alibaba/fluss/fs/FileSystem.java -./fluss-common/src/main/java/com/alibaba/fluss/fs/FileSystemSafetyNet.java -./fluss-common/src/main/java/com/alibaba/fluss/fs/FsPath.java -./fluss-common/src/main/java/com/alibaba/fluss/fs/SafetyNetCloseableRegistry.java -./fluss-common/src/main/java/com/alibaba/fluss/fs/SafetyNetWrapperFileSystem.java -./fluss-common/src/main/java/com/alibaba/fluss/fs/local/LocalFileSystem.java -./fluss-common/src/main/java/com/alibaba/fluss/memory/AbstractPagedOutputView.java -./fluss-common/src/main/java/com/alibaba/fluss/memory/MemorySegment.java -./fluss-common/src/main/java/com/alibaba/fluss/memory/MemoryUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/metrics/MeterView.java -./fluss-common/src/main/java/com/alibaba/fluss/metrics/groups/AbstractMetricGroup.java -./fluss-common/src/main/java/com/alibaba/fluss/metrics/groups/MetricGroup.java -./fluss-common/src/main/java/com/alibaba/fluss/metrics/registry/MetricRegistryImpl.java -./fluss-common/src/main/java/com/alibaba/fluss/plugin/DefaultPluginManager.java -./fluss-common/src/main/java/com/alibaba/fluss/plugin/DirectoryBasedPluginFinder.java -./fluss-common/src/main/java/com/alibaba/fluss/plugin/PluginLoader.java -./fluss-common/src/main/java/com/alibaba/fluss/row/BinarySegmentUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/row/BinaryString.java -./fluss-common/src/main/java/com/alibaba/fluss/row/Decimal.java -./fluss-common/src/main/java/com/alibaba/fluss/types/DataType.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/AbstractAutoCloseableRegistry.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/DateTimeUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/DecimalUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/ExceptionUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/ExecutorUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/FatalExitExceptionHandler.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/FileUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/IOUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/InstantiationUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/MurmurHashUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/NetUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/OperatingSystem.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/SerializedValue.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/TimeUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/UnsafeUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent/ExecutorThreadFactory.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent/FutureUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/types/Either.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/types/Tuple.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/types/Tuple2.java -./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/HadoopDataInputStream.java -./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/HadoopDataOutputStream.java -./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/HadoopFileSystem.java -./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/HadoopFsPlugin.java -./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/utils/HadoopUtils.java -./fluss-filesystems/fluss-fs-oss/src/main/java/com/alibaba/fluss/fs/oss/OSSFileSystem.java -./fluss-filesystems/fluss-fs-oss/src/main/java/com/alibaba/fluss/fs/oss/OSSFileSystemPlugin.java -./fluss-filesystems/fluss-fs-s3/src/main/java/com/alibaba/fluss/fs/s3/token/S3DelegationTokenReceiver.java -./fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/CatalogPropertiesUtils.java -./fluss-metrics/fluss-metrics-jmx/src/main/java/com/alibaba/fluss/metrics/jmx/JMXService.java -./fluss-metrics/fluss-metrics-prometheus/src/main/java/com/alibaba/fluss/metrics/prometheus/PrometheusReporter.java -./fluss-metrics/fluss-metrics-prometheus/src/main/java/com/alibaba/fluss/metrics/prometheus/PrometheusReporterPlugin.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/rocksdb/RocksDBKvBuilder.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/rocksdb/RocksDBResourceContainer.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/rocksdb/RocksDBWriteBatchWrapper.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/AsyncSnapshotCallable.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshot.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshotHandle.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshotStore.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/PeriodicSnapshotManager.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/RocksIncrementalSnapshot.java -./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SharedKvFileRegistry.java -./fluss-server/src/main/java/com/alibaba/fluss/server/metrics/ServerMetricUtils.java -./fluss-server/src/main/java/com/alibaba/fluss/server/utils/ResourceGuard.java -./fluss-server/src/main/java/com/alibaba/fluss/server/utils/ShutdownHookUtil.java -./fluss-test-utils/src/main/java/com/alibaba/fluss/testutils/common/TestLoggerExtension.java +./fluss-client/src/main/java/org/apache/fluss/client/token/DefaultSecurityTokenManager.java +./fluss-common/src/main/java/org/apache/fluss/classloading/ComponentClassLoader.java +./fluss-common/src/main/java/org/apache/fluss/config/ConfigOption.java +./fluss-common/src/main/java/org/apache/fluss/config/Configuration.java +./fluss-common/src/main/java/org/apache/fluss/config/ConfigurationUtils.java +./fluss-common/src/main/java/org/apache/fluss/config/GlobalConfiguration.java +./fluss-common/src/main/java/org/apache/fluss/config/MemorySize.java +./fluss-common/src/main/java/org/apache/fluss/fs/FSDataOutputStream.java +./fluss-common/src/main/java/org/apache/fluss/fs/FileSystem.java +./fluss-common/src/main/java/org/apache/fluss/fs/FileSystemSafetyNet.java +./fluss-common/src/main/java/org/apache/fluss/fs/FsPath.java +./fluss-common/src/main/java/org/apache/fluss/fs/SafetyNetCloseableRegistry.java +./fluss-common/src/main/java/org/apache/fluss/fs/SafetyNetWrapperFileSystem.java +./fluss-common/src/main/java/org/apache/fluss/fs/local/LocalFileSystem.java +./fluss-common/src/main/java/org/apache/fluss/memory/AbstractPagedOutputView.java +./fluss-common/src/main/java/org/apache/fluss/memory/MemorySegment.java +./fluss-common/src/main/java/org/apache/fluss/memory/MemoryUtils.java +./fluss-common/src/main/java/org/apache/fluss/metrics/MeterView.java +./fluss-common/src/main/java/org/apache/fluss/metrics/groups/AbstractMetricGroup.java +./fluss-common/src/main/java/org/apache/fluss/metrics/groups/MetricGroup.java +./fluss-common/src/main/java/org/apache/fluss/metrics/registry/MetricRegistryImpl.java +./fluss-common/src/main/java/org/apache/fluss/plugin/DefaultPluginManager.java +./fluss-common/src/main/java/org/apache/fluss/plugin/DirectoryBasedPluginFinder.java +./fluss-common/src/main/java/org/apache/fluss/plugin/PluginLoader.java +./fluss-common/src/main/java/org/apache/fluss/row/BinarySegmentUtils.java +./fluss-common/src/main/java/org/apache/fluss/row/BinaryString.java +./fluss-common/src/main/java/org/apache/fluss/row/Decimal.java +./fluss-common/src/main/java/org/apache/fluss/types/DataType.java +./fluss-common/src/main/java/org/apache/fluss/utils/AbstractAutoCloseableRegistry.java +./fluss-common/src/main/java/org/apache/fluss/utils/DateTimeUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/DecimalUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/ExceptionUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/ExecutorUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/FatalExitExceptionHandler.java +./fluss-common/src/main/java/org/apache/fluss/utils/FileUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/IOUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/InstantiationUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/MurmurHashUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/NetUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/OperatingSystem.java +./fluss-common/src/main/java/org/apache/fluss/utils/SerializedValue.java +./fluss-common/src/main/java/org/apache/fluss/utils/TimeUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/UnsafeUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/concurrent/ExecutorThreadFactory.java +./fluss-common/src/main/java/org/apache/fluss/utils/concurrent/FutureUtils.java +./fluss-common/src/main/java/org/apache/fluss/utils/types/Either.java +./fluss-common/src/main/java/org/apache/fluss/utils/types/Tuple.java +./fluss-common/src/main/java/org/apache/fluss/utils/types/Tuple2.java +./fluss-filesystems/fluss-fs-hadoop/src/main/java/org/apache/fluss/fs/hdfs/HadoopDataInputStream.java +./fluss-filesystems/fluss-fs-hadoop/src/main/java/org/apache/fluss/fs/hdfs/HadoopDataOutputStream.java +./fluss-filesystems/fluss-fs-hadoop/src/main/java/org/apache/fluss/fs/hdfs/HadoopFileSystem.java +./fluss-filesystems/fluss-fs-hadoop/src/main/java/org/apache/fluss/fs/hdfs/HadoopFsPlugin.java +./fluss-filesystems/fluss-fs-hadoop/src/main/java/org/apache/fluss/fs/hdfs/utils/HadoopUtils.java +./fluss-filesystems/fluss-fs-oss/src/main/java/org/apache/fluss/fs/oss/OSSFileSystem.java +./fluss-filesystems/fluss-fs-oss/src/main/java/org/apache/fluss/fs/oss/OSSFileSystemPlugin.java +./fluss-filesystems/fluss-fs-s3/src/main/java/org/apache/fluss/fs/s3/token/S3DelegationTokenReceiver.java +./fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/CatalogPropertiesUtils.java +./fluss-metrics/fluss-metrics-jmx/src/main/java/org/apache/fluss/metrics/jmx/JMXService.java +./fluss-metrics/fluss-metrics-prometheus/src/main/java/org/apache/fluss/metrics/prometheus/PrometheusReporter.java +./fluss-metrics/fluss-metrics-prometheus/src/main/java/org/apache/fluss/metrics/prometheus/PrometheusReporterPlugin.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/rocksdb/RocksDBKvBuilder.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/rocksdb/RocksDBResourceContainer.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/rocksdb/RocksDBWriteBatchWrapper.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/AsyncSnapshotCallable.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/CompletedSnapshot.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/CompletedSnapshotHandle.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/CompletedSnapshotStore.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/PeriodicSnapshotManager.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/RocksIncrementalSnapshot.java +./fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/SharedKvFileRegistry.java +./fluss-server/src/main/java/org/apache/fluss/server/metrics/ServerMetricUtils.java +./fluss-server/src/main/java/org/apache/fluss/server/utils/ResourceGuard.java +./fluss-server/src/main/java/org/apache/fluss/server/utils/ShutdownHookUtil.java +./fluss-test-utils/src/main/java/org/apache/fluss/testutils/common/TestLoggerExtension.java Apache Kafka -./fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchBuffer.java -./fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchCollector.java -./fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetcher.java -./fluss-client/src/main/java/com/alibaba/fluss/client/write/IdempotenceManager.java -./fluss-client/src/main/java/com/alibaba/fluss/client/write/RecordAccumulator.java -./fluss-client/src/main/java/com/alibaba/fluss/client/write/Sender.java -./fluss-common/src/main/java/com/alibaba/fluss/compression/FlussLZ4BlockInputStream.java -./fluss-common/src/main/java/com/alibaba/fluss/compression/FlussLZ4BlockOutputStream.java -./fluss-common/src/main/java/com/alibaba/fluss/record/DefaultLogRecordBatch.java -./fluss-common/src/main/java/com/alibaba/fluss/record/FileLogInputStream.java -./fluss-common/src/main/java/com/alibaba/fluss/record/FileLogRecords.java -./fluss-common/src/main/java/com/alibaba/fluss/record/IndexedLogRecord.java -./fluss-common/src/main/java/com/alibaba/fluss/record/MemoryLogRecords.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent/FlussScheduler.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/crc/Checksums.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/crc/Crc32C.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/crc/Java.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/crc/PureJavaCrc32C.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/log/ByteBufferUnmapper.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/log/FairBucketStatusMap.java -./fluss-common/src/main/java/com/alibaba/fluss/utils/ExponentialBackoff.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/jaas/AuthenticateCallbackHandler.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/jaas/DefaultLogin.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/jaas/JaasConfig.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/jaas/JaasContext.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/jaas/Login.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/jaas/LoginManager.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/jaas/SaslClientCallbackHandler.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/jaas/SaslServerFactory.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/plain/PlainAuthenticateCallback.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/plain/PlainLoginModule.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/plain/PlainSaslServer.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/plain/PlainSaslServerProvider.java -./fluss-common/src/main/java/com/alibaba/fluss/security/auth/sasl/plain/PlainServerCallbackHandler.java -./fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine/ReplicaStateMachine.java -./fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine/TableBucketStateMachine.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/AbstractIndex.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LazyIndex.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LocalLog.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogLoader.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogManager.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetMetadata.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetSnapshot.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogSegment.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogSegments.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogTablet.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/OffsetIndex.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/TimeIndex.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/checkpoint/CheckpointFile.java -./fluss-server/src/main/java/com/alibaba/fluss/server/log/checkpoint/OffsetCheckpointFile.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/AdjustIsrManager.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/FollowerReplica.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedFetchLog.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedOperation.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedOperationManager.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedWrite.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java -./fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherThread.java -./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/DefaultTimer.java -./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/Timer.java -./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/TimerTask.java -./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/TimerTaskEntry.java -./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/TimerTaskList.java -./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/TimingWheel.java +./fluss-client/src/main/java/org/apache/fluss/client/table/scanner/log/LogFetchBuffer.java +./fluss-client/src/main/java/org/apache/fluss/client/table/scanner/log/LogFetchCollector.java +./fluss-client/src/main/java/org/apache/fluss/client/table/scanner/log/LogFetcher.java +./fluss-client/src/main/java/org/apache/fluss/client/write/IdempotenceManager.java +./fluss-client/src/main/java/org/apache/fluss/client/write/RecordAccumulator.java +./fluss-client/src/main/java/org/apache/fluss/client/write/Sender.java +./fluss-common/src/main/java/org/apache/fluss/compression/FlussLZ4BlockInputStream.java +./fluss-common/src/main/java/org/apache/fluss/compression/FlussLZ4BlockOutputStream.java +./fluss-common/src/main/java/org/apache/fluss/record/DefaultLogRecordBatch.java +./fluss-common/src/main/java/org/apache/fluss/record/FileLogInputStream.java +./fluss-common/src/main/java/org/apache/fluss/record/FileLogRecords.java +./fluss-common/src/main/java/org/apache/fluss/record/IndexedLogRecord.java +./fluss-common/src/main/java/org/apache/fluss/record/MemoryLogRecords.java +./fluss-common/src/main/java/org/apache/fluss/utils/concurrent/FlussScheduler.java +./fluss-common/src/main/java/org/apache/fluss/utils/crc/Checksums.java +./fluss-common/src/main/java/org/apache/fluss/utils/crc/Crc32C.java +./fluss-common/src/main/java/org/apache/fluss/utils/crc/Java.java +./fluss-common/src/main/java/org/apache/fluss/utils/crc/PureJavaCrc32C.java +./fluss-common/src/main/java/org/apache/fluss/utils/log/ByteBufferUnmapper.java +./fluss-common/src/main/java/org/apache/fluss/utils/log/FairBucketStatusMap.java +./fluss-common/src/main/java/org/apache/fluss/utils/ExponentialBackoff.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/jaas/AuthenticateCallbackHandler.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/jaas/DefaultLogin.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/jaas/JaasConfig.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/jaas/JaasContext.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/jaas/Login.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/jaas/LoginManager.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/jaas/SaslClientCallbackHandler.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/jaas/SaslServerFactory.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/plain/PlainAuthenticateCallback.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/plain/PlainLoginModule.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/plain/PlainSaslServer.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/plain/PlainSaslServerProvider.java +./fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/plain/PlainServerCallbackHandler.java +./fluss-server/src/main/java/org/apache/fluss/server/coordinator/statemachine/ReplicaStateMachine.java +./fluss-server/src/main/java/org/apache/fluss/server/coordinator/statemachine/TableBucketStateMachine.java +./fluss-server/src/main/java/org/apache/fluss/server/log/AbstractIndex.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LazyIndex.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LocalLog.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LogLoader.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LogManager.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LogOffsetMetadata.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LogOffsetSnapshot.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LogSegment.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LogSegments.java +./fluss-server/src/main/java/org/apache/fluss/server/log/LogTablet.java +./fluss-server/src/main/java/org/apache/fluss/server/log/OffsetIndex.java +./fluss-server/src/main/java/org/apache/fluss/server/log/TimeIndex.java +./fluss-server/src/main/java/org/apache/fluss/server/log/WriterStateManager.java +./fluss-server/src/main/java/org/apache/fluss/server/log/checkpoint/CheckpointFile.java +./fluss-server/src/main/java/org/apache/fluss/server/log/checkpoint/OffsetCheckpointFile.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/AdjustIsrManager.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/FollowerReplica.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/IsrState.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/delay/DelayedFetchLog.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/delay/DelayedOperation.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/delay/DelayedOperationManager.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/delay/DelayedWrite.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherManager.java +./fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java +./fluss-server/src/main/java/org/apache/fluss/server/utils/timer/DefaultTimer.java +./fluss-server/src/main/java/org/apache/fluss/server/utils/timer/Timer.java +./fluss-server/src/main/java/org/apache/fluss/server/utils/timer/TimerTask.java +./fluss-server/src/main/java/org/apache/fluss/server/utils/timer/TimerTaskEntry.java +./fluss-server/src/main/java/org/apache/fluss/server/utils/timer/TimerTaskList.java +./fluss-server/src/main/java/org/apache/fluss/server/utils/timer/TimingWheel.java Apache Paimon -./fluss-common/src/main/java/com/alibaba/fluss/predicate/And.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/CompareUtils.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/CompoundPredicate.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/Contains.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/EndsWith.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/Equal.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/FieldRef.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/FunctionVisitor.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/GreaterOrEqual.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/GreaterThan.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/In.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/IsNotNull.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/IsNull.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/LeafFunction.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/LeafPredicate.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/LeafUnaryFunction.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/LessOrEqual.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/LessThan.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/NotEqual.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/NotIn.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/NullFalseLeafBinaryFunction.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/Or.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/PartitionPredicateVisitor.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/Predicate.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/PredicateBuilder.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/PredicateVisitor.java -./fluss-common/src/main/java/com/alibaba/fluss/predicate/StartsWith.java -./fluss-common/src/main/java/com/alibaba/fluss/row/encode/paimon/PaimonBinaryRowWriter.java -./fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lakehouse/paimon/reader/PaimonSnapshotScanner.java +./fluss-common/src/main/java/org/apache/fluss/predicate/And.java +./fluss-common/src/main/java/org/apache/fluss/predicate/CompareUtils.java +./fluss-common/src/main/java/org/apache/fluss/predicate/CompoundPredicate.java +./fluss-common/src/main/java/org/apache/fluss/predicate/Contains.java +./fluss-common/src/main/java/org/apache/fluss/predicate/EndsWith.java +./fluss-common/src/main/java/org/apache/fluss/predicate/Equal.java +./fluss-common/src/main/java/org/apache/fluss/predicate/FieldRef.java +./fluss-common/src/main/java/org/apache/fluss/predicate/FunctionVisitor.java +./fluss-common/src/main/java/org/apache/fluss/predicate/GreaterOrEqual.java +./fluss-common/src/main/java/org/apache/fluss/predicate/GreaterThan.java +./fluss-common/src/main/java/org/apache/fluss/predicate/In.java +./fluss-common/src/main/java/org/apache/fluss/predicate/IsNotNull.java +./fluss-common/src/main/java/org/apache/fluss/predicate/IsNull.java +./fluss-common/src/main/java/org/apache/fluss/predicate/LeafFunction.java +./fluss-common/src/main/java/org/apache/fluss/predicate/LeafPredicate.java +./fluss-common/src/main/java/org/apache/fluss/predicate/LeafUnaryFunction.java +./fluss-common/src/main/java/org/apache/fluss/predicate/LessOrEqual.java +./fluss-common/src/main/java/org/apache/fluss/predicate/LessThan.java +./fluss-common/src/main/java/org/apache/fluss/predicate/NotEqual.java +./fluss-common/src/main/java/org/apache/fluss/predicate/NotIn.java +./fluss-common/src/main/java/org/apache/fluss/predicate/NullFalseLeafBinaryFunction.java +./fluss-common/src/main/java/org/apache/fluss/predicate/Or.java +./fluss-common/src/main/java/org/apache/fluss/predicate/PartitionPredicateVisitor.java +./fluss-common/src/main/java/org/apache/fluss/predicate/Predicate.java +./fluss-common/src/main/java/org/apache/fluss/predicate/PredicateBuilder.java +./fluss-common/src/main/java/org/apache/fluss/predicate/PredicateVisitor.java +./fluss-common/src/main/java/org/apache/fluss/predicate/StartsWith.java +./fluss-common/src/main/java/org/apache/fluss/row/encode/paimon/PaimonBinaryRowWriter.java +./fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lakehouse/paimon/reader/PaimonSnapshotScanner.java Apache Spark -./fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/NettyLogger.java +./fluss-rpc/src/main/java/org/apache/fluss/rpc/netty/NettyLogger.java LightProto -./fluss-common/src/main/java/com/alibaba/fluss/utils/ProtoCodecUtils.java -./fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtoGen.java -./fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufMessage.java -./fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufNumberField.java -./fluss-protogen/fluss-protogen-maven-plugin/src/main/java/com/alibaba/fluss/protogen/maven/plugin/ProtoGenMojo.java +./fluss-common/src/main/java/org/apache/fluss/utils/ProtoCodecUtils.java +./fluss-protogen/fluss-protogen-generator/src/main/java/org/apache/fluss/protogen/generator/generator/ProtoGen.java +./fluss-protogen/fluss-protogen-generator/src/main/java/org/apache/fluss/protogen/generator/generator/ProtobufMessage.java +./fluss-protogen/fluss-protogen-generator/src/main/java/org/apache/fluss/protogen/generator/generator/ProtobufNumberField.java +./fluss-protogen/fluss-protogen-maven-plugin/src/main/java/org/apache/fluss/protogen/maven/plugin/ProtoGenMojo.java diff --git a/fluss-flink/fluss-flink-1.18/src/main/java/com/alibaba/fluss/flink/adapter/CatalogTableAdapter.java b/fluss-flink/fluss-flink-1.18/src/main/java/org/apache/fluss/flink/adapter/CatalogTableAdapter.java similarity index 100% rename from fluss-flink/fluss-flink-1.18/src/main/java/com/alibaba/fluss/flink/adapter/CatalogTableAdapter.java rename to fluss-flink/fluss-flink-1.18/src/main/java/org/apache/fluss/flink/adapter/CatalogTableAdapter.java diff --git a/fluss-flink/fluss-flink-1.18/src/main/java/com/alibaba/fluss/flink/adapter/SingleThreadFetcherManagerAdapter.java b/fluss-flink/fluss-flink-1.18/src/main/java/org/apache/fluss/flink/adapter/SingleThreadFetcherManagerAdapter.java similarity index 100% rename from fluss-flink/fluss-flink-1.18/src/main/java/com/alibaba/fluss/flink/adapter/SingleThreadFetcherManagerAdapter.java rename to fluss-flink/fluss-flink-1.18/src/main/java/org/apache/fluss/flink/adapter/SingleThreadFetcherManagerAdapter.java diff --git a/fluss-flink/fluss-flink-1.18/src/main/java/com/alibaba/fluss/flink/adapter/SingleThreadMultiplexSourceReaderBaseAdapter.java b/fluss-flink/fluss-flink-1.18/src/main/java/org/apache/fluss/flink/adapter/SingleThreadMultiplexSourceReaderBaseAdapter.java similarity index 100% rename from fluss-flink/fluss-flink-1.18/src/main/java/com/alibaba/fluss/flink/adapter/SingleThreadMultiplexSourceReaderBaseAdapter.java rename to fluss-flink/fluss-flink-1.18/src/main/java/org/apache/fluss/flink/adapter/SingleThreadMultiplexSourceReaderBaseAdapter.java diff --git a/fluss-flink/fluss-flink-1.19/src/main/java/com/alibaba/fluss/flink/adapter/CatalogTableAdapter.java b/fluss-flink/fluss-flink-1.19/src/main/java/org/apache/fluss/flink/adapter/CatalogTableAdapter.java similarity index 100% rename from fluss-flink/fluss-flink-1.19/src/main/java/com/alibaba/fluss/flink/adapter/CatalogTableAdapter.java rename to fluss-flink/fluss-flink-1.19/src/main/java/org/apache/fluss/flink/adapter/CatalogTableAdapter.java diff --git a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/catalog/Flink21CatalogITCase.java b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/catalog/Flink21CatalogITCase.java similarity index 74% rename from fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/catalog/Flink21CatalogITCase.java rename to fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/catalog/Flink21CatalogITCase.java index cae4d4ebb..b12aaa5e8 100644 --- a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/catalog/Flink21CatalogITCase.java +++ b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/catalog/Flink21CatalogITCase.java @@ -15,11 +15,7 @@ * limitations under the License. */ -<<<<<<<< HEAD:fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/catalog/Flink21CatalogITCase.java package org.apache.fluss.flink.catalog; -======== -package org.apache.fluss.flink; ->>>>>>>> c4d07399 ([INFRA] The project package name updated to org.apache.fluss.):fluss-flink/fluss-flink-1.19/src/main/java/org/apache/fluss/flink/DummyClass119.java /** IT case for catalog in Flink 2.1. */ public class Flink21CatalogITCase extends FlinkCatalogITCase {} diff --git a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/metrics/Flink21MetricsITCase.java b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/metrics/Flink21MetricsITCase.java similarity index 100% rename from fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/metrics/Flink21MetricsITCase.java rename to fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/metrics/Flink21MetricsITCase.java diff --git a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/procedure/Flink21ProcedureITCase.java b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/procedure/Flink21ProcedureITCase.java similarity index 100% rename from fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/procedure/Flink21ProcedureITCase.java rename to fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/procedure/Flink21ProcedureITCase.java diff --git a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/security/acl/Flink21AuthorizationITCase.java b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/security/acl/Flink21AuthorizationITCase.java similarity index 100% rename from fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/security/acl/Flink21AuthorizationITCase.java rename to fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/security/acl/Flink21AuthorizationITCase.java diff --git a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/sink/Flink21TableSinkITCase.java b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/sink/Flink21TableSinkITCase.java similarity index 100% rename from fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/sink/Flink21TableSinkITCase.java rename to fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/sink/Flink21TableSinkITCase.java diff --git a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/source/Flink21TableSourceBatchITCase.java b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/source/Flink21TableSourceBatchITCase.java similarity index 100% rename from fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/source/Flink21TableSourceBatchITCase.java rename to fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/source/Flink21TableSourceBatchITCase.java diff --git a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/source/Flink21TableSourceFailOverITCase.java b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/source/Flink21TableSourceFailOverITCase.java similarity index 100% rename from fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/source/Flink21TableSourceFailOverITCase.java rename to fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/source/Flink21TableSourceFailOverITCase.java diff --git a/fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/source/Flink21TableSourceITCase.java b/fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/source/Flink21TableSourceITCase.java similarity index 100% rename from fluss-flink/fluss-flink-2.1/src/test/java/com/alibaba/fluss/flink/source/Flink21TableSourceITCase.java rename to fluss-flink/fluss-flink-2.1/src/test/java/org/apache/fluss/flink/source/Flink21TableSourceITCase.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/adapter/CatalogTableAdapter.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/adapter/CatalogTableAdapter.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/adapter/CatalogTableAdapter.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/adapter/CatalogTableAdapter.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/adapter/SingleThreadFetcherManagerAdapter.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/adapter/SingleThreadFetcherManagerAdapter.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/adapter/SingleThreadFetcherManagerAdapter.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/adapter/SingleThreadFetcherManagerAdapter.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/adapter/SingleThreadMultiplexSourceReaderBaseAdapter.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/adapter/SingleThreadMultiplexSourceReaderBaseAdapter.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/adapter/SingleThreadMultiplexSourceReaderBaseAdapter.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/adapter/SingleThreadMultiplexSourceReaderBaseAdapter.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeCatalog.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeCatalog.java similarity index 63% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeCatalog.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeCatalog.java index ff1846fcb..0df4c544b 100644 --- a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeCatalog.java +++ b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeCatalog.java @@ -1,20 +1,21 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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 + * Copyright (c) 2025 Alibaba Group Holding Ltd. * - * http://www.apache.org/licenses/LICENSE-2.0 + * 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 * - * 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. + * 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 org.apache.fluss.flink.lake; + import org.apache.flink.table.catalog.CatalogBaseTable; import org.apache.flink.table.catalog.ObjectPath; import org.apache.flink.table.catalog.exceptions.CatalogException; diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeRecordRecordEmitter.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeRecordRecordEmitter.java similarity index 66% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeRecordRecordEmitter.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeRecordRecordEmitter.java index 566ef053c..3114f10ef 100644 --- a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeRecordRecordEmitter.java +++ b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeRecordRecordEmitter.java @@ -1,20 +1,21 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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 + * Copyright (c) 2025 Alibaba Group Holding Ltd. * - * http://www.apache.org/licenses/LICENSE-2.0 + * 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 * - * 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. + * 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 org.apache.fluss.flink.lake; + import org.apache.flink.api.connector.source.SourceOutput; import org.apache.fluss.client.table.scanner.ScanRecord; import org.apache.fluss.flink.lake.state.LakeSnapshotAndFlussLogSplitState; diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeSplitGenerator.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitGenerator.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeSplitGenerator.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitGenerator.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeSplitReaderGenerator.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitReaderGenerator.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeSplitReaderGenerator.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitReaderGenerator.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeSplitSerializer.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitSerializer.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeSplitSerializer.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitSerializer.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeSplitStateInitializer.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitStateInitializer.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeSplitStateInitializer.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitStateInitializer.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeTableFactory.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeTableFactory.java similarity index 65% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeTableFactory.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeTableFactory.java index b7f0da3da..f772848b6 100644 --- a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/LakeTableFactory.java +++ b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeTableFactory.java @@ -1,21 +1,20 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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 + * Copyright (c) 2025 Alibaba Group Holding Ltd. * - * http://www.apache.org/licenses/LICENSE-2.0 + * 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 * - * 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. + * 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. */ -import org.apache.flink.table.catalog.ObjectIdentifier; +package org.apache.fluss.flink.lake;import org.apache.flink.table.catalog.ObjectIdentifier; import org.apache.flink.table.connector.source.DynamicTableSource; import org.apache.flink.table.factories.DynamicTableFactory; import org.apache.flink.table.factories.FactoryUtil; diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/KeyValueRow.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/KeyValueRow.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/KeyValueRow.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/KeyValueRow.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/LakeSnapshotAndLogSplitScanner.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/LakeSnapshotAndLogSplitScanner.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/LakeSnapshotAndLogSplitScanner.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/LakeSnapshotAndLogSplitScanner.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/LakeSnapshotScanner.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/LakeSnapshotScanner.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/LakeSnapshotScanner.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/LakeSnapshotScanner.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/SortMergeReader.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/SortMergeReader.java similarity index 95% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/SortMergeReader.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/SortMergeReader.java index 4a85d9b9e..8e4e9b669 100644 --- a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/reader/SortMergeReader.java +++ b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/reader/SortMergeReader.java @@ -1,22 +1,20 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 + * Copyright (c) 2025 Alibaba Group Holding Ltd. * - * http://www.apache.org/licenses/LICENSE-2.0 + * 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 * - * 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. + * 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. */ -import org.apache.fluss.record.LogRecord; +package org.apache.fluss.flink.lake.reader;import org.apache.fluss.record.LogRecord; import org.apache.fluss.row.InternalRow; import org.apache.fluss.row.ProjectedRow; import org.apache.fluss.utils.CloseableIterator; diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/split/LakeSnapshotAndFlussLogSplit.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/split/LakeSnapshotAndFlussLogSplit.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/split/LakeSnapshotAndFlussLogSplit.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/split/LakeSnapshotAndFlussLogSplit.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/split/LakeSnapshotSplit.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/split/LakeSnapshotSplit.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/split/LakeSnapshotSplit.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/split/LakeSnapshotSplit.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/state/LakeSnapshotAndFlussLogSplitState.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/state/LakeSnapshotAndFlussLogSplitState.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/state/LakeSnapshotAndFlussLogSplitState.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/state/LakeSnapshotAndFlussLogSplitState.java diff --git a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/state/LakeSnapshotSplitState.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/state/LakeSnapshotSplitState.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lake/state/LakeSnapshotSplitState.java rename to fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/state/LakeSnapshotSplitState.java diff --git a/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/lake/LakeSplitSerializerTest.java b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/lake/LakeSplitSerializerTest.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/lake/LakeSplitSerializerTest.java rename to fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/lake/LakeSplitSerializerTest.java diff --git a/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/lake/reader/SortMergeReaderTest.java b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/lake/reader/SortMergeReaderTest.java similarity index 100% rename from fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/lake/reader/SortMergeReaderTest.java rename to fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/lake/reader/SortMergeReaderTest.java diff --git a/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java b/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java index 81fc841bc..4ba16240c 100644 --- a/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java +++ b/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java @@ -337,7 +337,7 @@ final class ReplicaFetcherThread extends ShutdownableThread { || e instanceof OutOfOrderSequenceException || e instanceof InvalidOffsetException) { // TODO this part of logic need to be removed after we introduce leader epoch cache. - // Trace by https://github.com/alibaba/fluss/issues/673 + // Trace by https://github.com/apache/fluss/issues/673 LOG.error( "Founding recoverable error while processing data for bucket {} at offset {}, try to " + "truncate to LeaderEndOffsetSnapshot", diff --git a/website/blog/2025-06-01-partial-updates.md b/website/blog/2025-06-01-partial-updates.md index b9c535d9c..a774c313a 100644 --- a/website/blog/2025-06-01-partial-updates.md +++ b/website/blog/2025-06-01-partial-updates.md @@ -265,7 +265,7 @@ Flink SQL> SELECT * FROM user_rec_wide; Now let's switch to `batch` mode and query the current snapshot of the `user_rec_wide` table. -But before that, let's start the [Tiering Service](https://alibaba.github.io/fluss-docs/docs/maintenance/tiered-storage/lakehouse-storage/#start-the-datalake-tiering-service) that allows offloading the tables as `Lakehouse` tables. +But before that, let's start the [Tiering Service](/docs/maintenance/tiered-storage/lakehouse-storage.md#start-the-datalake-tiering-service) that allows offloading the tables as `Lakehouse` tables. **Step 7:** Open a new terminal 💻 in the `Coordinator Server` and run the following command to start the `Tiering Service`: ```shell
