From fb54726c6456a74d248f7cd9bc7ce44a80cc1b7a Mon Sep 17 00:00:00 2001 From: Takahiro Nakayama Date: Sun, 19 Mar 2023 06:11:06 +0900 Subject: [PATCH 1/2] Remove unnecessary if clause Signed-off-by: Takahiro Nakayama --- .../embulk/input/dynamodb/operation/DynamodbScanOperation.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/org/embulk/input/dynamodb/operation/DynamodbScanOperation.scala b/src/main/scala/org/embulk/input/dynamodb/operation/DynamodbScanOperation.scala index 0fe2a5d..bd507c3 100644 --- a/src/main/scala/org/embulk/input/dynamodb/operation/DynamodbScanOperation.scala +++ b/src/main/scala/org/embulk/input/dynamodb/operation/DynamodbScanOperation.scala @@ -77,7 +77,7 @@ case class DynamodbScanOperation(task: DynamodbScanOperation.Task) case _ => f(result.getItems.asScala.map(_.asScala.toMap).toSeq) Option(result.getLastEvaluatedKey) match { - case Some(v) if (loadableRecords.isDefined) => + case Some(v) => runInternal( dynamodb, embulkTaskIndex, From e31ebf45ef36d85063b7969dbdd8e727522d5e2e Mon Sep 17 00:00:00 2001 From: Takahiro Nakayama Date: Sun, 19 Mar 2023 06:12:39 +0900 Subject: [PATCH 2/2] Update changelog Signed-off-by: Takahiro Nakayama --- CHANGELOG.md | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index d5ef05e..e381fe4 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,3 +1,8 @@ +1.0.4 (2023-03-19) +================== + +- [fix] [#32](https://github.com/civitaspo/embulk-input-dynamodb/pull/32) Remove unnecessary if clause (follow up [#31](https://github.com/civitaspo/embulk-input-dynamodb/pull/31)). + 1.0.3 (2023-02-17) ==================