diff --git a/expression/builtin_time_vec.go b/expression/builtin_time_vec.go index 71ff6f395dcd6..186c407a4d696 100644 --- a/expression/builtin_time_vec.go +++ b/expression/builtin_time_vec.go @@ -964,12 +964,11 @@ func (b *builtinMicroSecondSig) vecEvalInt(input *chunk.Chunk, result *chunk.Col result.ResizeInt64(n, false) result.MergeNulls(buf) i64s := result.Int64s() - ds := buf.GoDurations() for i := 0; i < n; i++ { if result.IsNull(i) { continue } - i64s[i] = int64((ds[i] % time.Second) / time.Microsecond) + i64s[i] = int64(buf.GetDuration(i, int(types.UnspecifiedFsp)).MicroSecond()) } return nil } diff --git a/expression/integration_test.go b/expression/integration_test.go index e2f620da24811..b4e25560d9753 100644 --- a/expression/integration_test.go +++ b/expression/integration_test.go @@ -10198,3 +10198,16 @@ func (s *testIntegrationSuite) TestIssue28643(c *C) { tk.MustExec("set tidb_enable_vectorized_expression = off;") tk.MustQuery("select hour(a) from t;").Check(testkit.Rows("838", "838")) } + +func (s *testIntegrationSuite) TestIssue29244(c *C) { + tk := testkit.NewTestKit(c, s.store) + tk.MustExec("use test") + tk.MustExec("drop table if exists t") + tk.MustExec("create table t(a time(4));") + tk.MustExec("insert into t values(\"-700:10:10.123456111\");") + tk.MustExec("insert into t values(\"700:10:10.123456111\");") + tk.MustExec("set tidb_enable_vectorized_expression = on;") + tk.MustQuery("select microsecond(a) from t;").Check(testkit.Rows("123500", "123500")) + tk.MustExec("set tidb_enable_vectorized_expression = off;") + tk.MustQuery("select microsecond(a) from t;").Check(testkit.Rows("123500", "123500")) +}