Skip to content

Commit 8e6bbd4

Browse files
author
zhilingc
committed
Remove withTimePartitioning
1 parent 57b574e commit 8e6bbd4

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

ingestion/src/main/java/feast/ingestion/transform/WriteToStore.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,8 +92,7 @@ public PDone expand(PCollection<FeatureRow> input) {
9292
.withWriteDisposition(WriteDisposition.WRITE_APPEND)
9393
.withExtendedErrorInfo()
9494
.withMethod(Method.STREAMING_INSERTS)
95-
.withFailedInsertRetryPolicy(InsertRetryPolicy.retryTransientErrors())
96-
.withTimePartitioning(timePartitioning));
95+
.withFailedInsertRetryPolicy(InsertRetryPolicy.retryTransientErrors()));
9796

9897
if (options.getDeadLetterTableSpec() != null) {
9998
bigqueryWriteResult

0 commit comments

Comments
 (0)