From adc59acdac4aa5b6c7ceea24cc16ce82191da926 Mon Sep 17 00:00:00 2001
From: Rison <2462301753@qq.com>
Date: Sun, 13 Jun 2021 16:25:03 +0800
Subject: [PATCH] =?UTF-8?q?fix=20=E7=94=A8=E6=88=B7=E5=85=B4=E8=B6=A3flink?=
 =?UTF-8?q?=E7=8A=B6=E6=80=81=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/demo/map/UserHistoryWithInterestMapFunction.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-2-hbase/src/main/java/com/demo/map/UserHistoryWithInterestMapFunction.java b/flink-2-hbase/src/main/java/com/demo/map/UserHistoryWithInterestMapFunction.java
index 9b0c4c9..01a6a2e 100644
--- a/flink-2-hbase/src/main/java/com/demo/map/UserHistoryWithInterestMapFunction.java
+++ b/flink-2-hbase/src/main/java/com/demo/map/UserHistoryWithInterestMapFunction.java
@@ -38,6 +38,7 @@ public String map(LogEntity logEntity) throws Exception {
         int times = 1;
         // 如果用户没有操作 则为state创建值
         if (actionLastTime == null) {
+            state.update(actionThisTime);
             actionLastTime = actionThisTime;
             saveToHBase(logEntity, 1);
         }else{