Skip to content

Commit fdb3f4d

Browse files
exAspArkexAspArk
committed
WIP
1 parent f399ed5 commit fdb3f4d

6 files changed

Lines changed: 6 additions & 6 deletions

iceberg-test/metadata/00006-d43945ca-a30e-4182-aeb5-99bd766b328b.metadata.json renamed to iceberg-test-optimized-manifests/00006-d43945ca-a30e-4182-aeb5-99bd766b328b.metadata.json

File renamed without changes.

iceberg-test/data/20250819_151236_00003_e5m2c-0ff4ea89-f153-46e5-901e-f2004ac5134d.parquet renamed to iceberg-test-optimized-manifests/20250819_151236_00003_e5m2c-0ff4ea89-f153-46e5-901e-f2004ac5134d.parquet

File renamed without changes.

iceberg-test/data/20250819_151240_00004_e5m2c-c85ae7de-4c8a-4da3-92fd-f0831d679ee0.parquet renamed to iceberg-test-optimized-manifests/20250819_151240_00004_e5m2c-c85ae7de-4c8a-4da3-92fd-f0831d679ee0.parquet

File renamed without changes.

iceberg-test/metadata/ace50a17-644b-4801-98a3-b0491e620eda-m0.avro renamed to iceberg-test-optimized-manifests/ace50a17-644b-4801-98a3-b0491e620eda-m0.avro

File renamed without changes.

iceberg-test/metadata/snap-4117982741288853649-1-ace50a17-644b-4801-98a3-b0491e620eda.avro renamed to iceberg-test-optimized-manifests/snap-4117982741288853649-1-ace50a17-644b-4801-98a3-b0491e620eda.avro

File renamed without changes.

‎src/syncer-common/trino.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -59,19 +59,19 @@ func (trino *Trino) QueryRowContext(ctx context.Context, query string, args ...i
5959
}
6060

6161
func (trino *Trino) CompactTable(quotedTrinoTablePath string) {
62-
ctx := context.Background()
62+
// ctx := context.Background()
6363

6464
// _, err := trino.ExecContext(ctx, "ALTER TABLE "+quotedTrinoTablePath+" EXECUTE optimize")
6565
// PanicIfError(trino.Config, err)
6666
//
6767
// _, err = trino.ExecContext(ctx, "ALTER TABLE "+quotedTrinoTablePath+" EXECUTE remove_orphan_files(retention_threshold => '0m')")
6868
// PanicIfError(trino.Config, err)
6969

70-
_, err := trino.ExecContext(ctx, "ALTER TABLE "+quotedTrinoTablePath+" EXECUTE optimize_manifests")
71-
PanicIfError(trino.Config, err)
72-
73-
_, err = trino.ExecContext(ctx, "ALTER TABLE "+quotedTrinoTablePath+" EXECUTE expire_snapshots(retention_threshold => '0m')")
74-
PanicIfError(trino.Config, err)
70+
// _, err := trino.ExecContext(ctx, "ALTER TABLE "+quotedTrinoTablePath+" EXECUTE optimize_manifests")
71+
// PanicIfError(trino.Config, err)
72+
//
73+
// _, err = trino.ExecContext(ctx, "ALTER TABLE "+quotedTrinoTablePath+" EXECUTE expire_snapshots(retention_threshold => '0m')")
74+
// PanicIfError(trino.Config, err)
7575
}
7676

7777
func (trino *Trino) CreateSchemaIfNotExists() {

0 commit comments

Comments
 (0)