amoro

amoro copied to clipboard

shidayang

Add env preparation without docker.

zstraw

[ARCTIC-108][Flink] Support projection push down to arctic source reader

1

Fix #108. `ArcticDynamicSource` should implement the `SupportsProjectionPushDown` interface to accelerate data querying. **The brief change log** - `ArcticDynamicSource` and `KafkaDynamicSource` implement the `SupportsProjectionPushDown` interface to support `supportsNestedProjection` and `applyProjection` methods.

SteNicholas

zstraw

If arctic's file-store only have data in base-table, but nothing in change-table, arctic source will reading nothing in ContinuousSplitPlannerImpl#discoverInitialSplits because changeSnapshot in change-table is null. The data in base-table can...

zstraw

case: Writing CDC data to Arctic tables with primary key via Flink, after multiple update/delete commits，continous optimizing could not be triggered as expected

hameizi

complete method createInternalRowWriterFactory in ArcticWriter. add some classes for writer. add TestDelegateHiveTable which test for delegate hive table.

HuangFru

[Flink] Arctic table supports real-time dimension table join

1

Background: There are some requirements for real-time data widening. Now hive supports lookup join, but this solution is not available for production, and the hive table needs to be loaded...

YesOrNo828

Affected flink versions: 1.12, 1.14. ArcticDynamicSource should implement the `SupportsProjectionPushDown` interface to accelerate data querying.

YesOrNo828

This issue should affect Flink versions: flink1.12/flink1.14

YesOrNo828