Skip to content

Instantly share code, notes, and snippets.

@pitrou

pitrou/gist:d1814bde928d3b08fd29a923053a9ed0 Secret

Created June 27, 2023 16:00
Show Gist options
  • Save pitrou/d1814bde928d3b08fd29a923053a9ed0 to your computer and use it in GitHub Desktop.
Save pitrou/d1814bde928d3b08fd29a923053a9ed0 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
[ RUN ] AsofJoinNodeTest/AsofJoinBasicTest.TestBasic7Forward/1
/Users/runner/work/arrow/arrow/cpp/src/arrow/testing/gtest_util.cc:505: Failure
Failed
Unequal at absolute position 3
@@ -2, +2 @@
-null
+00:00:00.000012
Expected:
[
00:00:00.000010,
null,
00:00:00.000012
]
Actual:
[
00:00:00.000010,
null,
null
]
Google Test trace:
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:630: Right-1 type: timestamp[ns, tz=UTC]
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:628: Right-0 type: time64[us]
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:626: Left type: double
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:624: Key type: uint64
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:622: Time type: timestamp[s, tz=UTC]
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:620: Iteration: 22
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:611: Types seed: 1687773302518726
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:998: AsofJoinBasicTest_TestBasic7_DoubleByKey
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:1002: AsofJoinBasicTest_TestBasic7Forward_DoubleByKey
AsofJoinTest debug:
AsofjoinNode(0x7ff7b6edff60): received batch from input 2:
time: [
1970-01-01 00:00:00,
1970-01-01 00:25:00,
1970-01-01 00:41:40
]
key: [
1,
1,
1
]
r1_v0: [
1970-01-01 00:00:00.000000100,
1970-01-01 00:00:00.000000101,
1970-01-01 00:00:00.000000102
]
AsofjoinNode(0x7ff7b6edff60): received batch from input 1:
time: [
1970-01-01 00:00:00,
1970-01-01 00:25:00,
1970-01-01 00:41:40
]
key: [
1,
1,
1
]
r0_v0: [
00:00:00.000010,
00:00:00.000011,
00:00:00.000012
]
AsofjoinNode(0x7ff7b6edff60): received batch from input 0:
time: [
1970-01-01 00:00:00
]
key: [
1
]
l_v0: [
1
]
AsofjoinNode(0x70000563b6e0): Advancing input 1
AsofjoinNode(0x70000563b390): key hasher 1 got hashes [1995776682898084128, 1995776682898084128, 1995776682898084128]
AsofjoinNode(0x70000563b590): memo 1 store: for_time=0 row=0 time=0 key=1995776682898084128
AsofjoinNode(0x70000563b6e0): Advancing input 1 hit distant time=1500 at=0
AsofjoinNode(0x70000563b570): memo 1 remove: ts=0
AsofjoinNode(0x70000563b6e0): Advancing input 1 updated=0
AsofjoinNode(0x70000563b6e0): Advancing input 2
AsofjoinNode(0x70000563b390): key hasher 2 got hashes [1995776682898084128, 1995776682898084128, 1995776682898084128]
AsofjoinNode(0x70000563b590): memo 2 store: for_time=0 row=0 time=0 key=1995776682898084128
AsofjoinNode(0x70000563b6e0): Advancing input 2 hit distant time=1500 at=0
AsofjoinNode(0x70000563b570): memo 2 remove: ts=0
AsofjoinNode(0x70000563b6e0): Advancing input 2 updated=0
AsofjoinNode(0x70000563b440): key hasher 0 got hashes [1995776682898084128]
AsofjoinNode(0x70000563b790): Emplace: key=1995776682898084128 lhs_latest_row=0 lhs_latest_time=0
AsofjoinNode(0x70000563b790): i=1 has_entry=1 time=0 row=0 accepted=1
AsofjoinNode(0x70000563b790): i=2 has_entry=1 time=0 row=0 accepted=1
AsofjoinNode(0x70000563bc40): produce batch 0:
time: [
1970-01-01 00:00:00
]
key: [
1
]
l_v0: [
1
]
r0_v0: [
00:00:00.000010
]
r1_v0: [
1970-01-01 00:00:00.000000100
]
AsofjoinNode(0x7ff7b6edff60): received batch from input 0:
time: [
1970-01-01 00:16:40
]
key: [
2
]
l_v0: [
2
]
AsofjoinNode(0x70000563b6e0): Advancing input 1
AsofjoinNode(0x70000563b590): memo 1 store: for_time=1000 row=1 time=1500 key=1995776682898084128
AsofjoinNode(0x70000563b6e0): Advancing input 1 hit distant time=2500 at=1000
AsofjoinNode(0x70000563b590): memo 1 store: for_time=1000 row=2 time=2500 key=1995776682898084128
AsofjoinNode(0x70000563b570): memo 1 remove: ts=1000
AsofjoinNode(0x70000563b6e0): Advancing input 1 updated=1
AsofjoinNode(0x70000563b6e0): Advancing input 2
AsofjoinNode(0x70000563b590): memo 2 store: for_time=1000 row=1 time=1500 key=1995776682898084128
AsofjoinNode(0x70000563b6e0): Advancing input 2 hit distant time=2500 at=1000
AsofjoinNode(0x70000563b590): memo 2 store: for_time=1000 row=2 time=2500 key=1995776682898084128
AsofjoinNode(0x70000563b570): memo 2 remove: ts=1000
AsofjoinNode(0x70000563b6e0): Advancing input 2 updated=1
AsofjoinNode(0x70000563b440): key hasher 0 got hashes [13341026232577309880]
AsofjoinNode(0x70000563b790): Emplace: key=13341026232577309880 lhs_latest_row=0 lhs_latest_time=1000
AsofjoinNode(0x70000563b790): i=1 has_entry=0 time=0 row=0 accepted=0
AsofjoinNode(0x70000563b790): i=2 has_entry=0 time=0 row=0 accepted=0
AsofjoinNode(0x70000563bc40): produce batch 1:
time: [
1970-01-01 00:16:40
]
key: [
2
]
l_v0: [
2
]
r0_v0: [
null
]
r1_v0: [
null
]
AsofjoinNode(0x7ff7b6edff60): received batch from input 0:
time: [
1970-01-01 00:33:20
]
key: [
1
]
l_v0: [
3
]
AsofjoinNode(0x70000563b6e0): Advancing input 1
AsofjoinNode(0x70000563b570): memo 1 remove: ts=2000
AsofjoinNode(0x70000563b6e0): Advancing input 2
AsofjoinNode(0x70000563b570): memo 2 remove: ts=2000
AsofjoinNode(0x70000563b790): Emplace: key=13341026232577309880 lhs_latest_row=0 lhs_latest_time=2000
AsofjoinNode(0x70000563b790): i=1 has_entry=0 time=0 row=0 accepted=0
AsofjoinNode(0x70000563b790): i=2 has_entry=0 time=0 row=0 accepted=0
AsofjoinNode(0x70000563bc40): produce batch 2:
time: [
1970-01-01 00:33:20
]
key: [
1
]
l_v0: [
3
]
r0_v0: [
null
]
r1_v0: [
null
]
Comparing flattened expected table:
time: timestamp[s, tz=UTC]
key: uint64
l_v0: double
r0_v0: time64[us]
r1_v0: timestamp[ns, tz=UTC]
----
time:
[
[
1970-01-01 00:00:00,
1970-01-01 00:16:40,
1970-01-01 00:33:20
]
]
key:
[
[
1,
2,
1
]
]
l_v0:
[
[
1,
2,
3
]
]
r0_v0:
[
[
00:00:00.000010,
null,
00:00:00.000012
]
]
r1_v0:
[
[
1970-01-01 00:00:00.000000100,
null,
1970-01-01 00:00:00.000000102
]
]
with flattened result table:
time: timestamp[s, tz=UTC]
key: uint64
l_v0: double
r0_v0: time64[us]
r1_v0: timestamp[ns, tz=UTC]
----
time:
[
[
1970-01-01 00:00:00
],
[
1970-01-01 00:16:40
],
[
1970-01-01 00:33:20
]
]
key:
[
[
1
],
[
2
],
[
1
]
]
l_v0:
[
[
1
],
[
2
],
[
3
]
]
r0_v0:
[
[
00:00:00.000010
],
[
null
],
[
null
]
]
r1_v0:
[
[
1970-01-01 00:00:00.000000100
],
[
null
],
[
null
]
]
[ FAILED ] AsofJoinNodeTest/AsofJoinBasicTest.TestBasic7Forward/1, where GetParam() = AsofJoinBasicParams: DoubleByKey (164 ms)
[ RUN ] AsofJoinNodeTest/AsofJoinBasicTest.TestBasic7Forward/2
/Users/runner/work/arrow/arrow/cpp/src/arrow/testing/gtest_util.cc:505: Failure
Failed
Unequal at absolute position 3
@@ -1, +1 @@
-11
+null
Expected:
[
10,
null,
12
]
Actual:
[
10,
11,
12
]
Google Test trace:
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:630: Right-1 type: float
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:628: Right-0 type: uint64
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:626: Left type: timestamp[us, tz=UTC]
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:624: Key type: timestamp[ms, tz=UTC]
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:622: Time type: uint16
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:620: Iteration: 6
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:611: Types seed: 1687773302683078
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:998: AsofJoinBasicTest_TestBasic7_MutateByKey
/Users/runner/work/arrow/arrow/cpp/src/arrow/acero/asof_join_node_test.cc:1002: AsofJoinBasicTest_TestBasic7Forward_MutateByKey
AsofJoinTest debug:
AsofjoinNode(0x7ff7b6edfc00): received batch from input 2:
time: [
0,
1500,
2500
]
key2: [
1970-01-01 00:00:00.000,
1970-01-01 00:00:00.000,
1970-01-01 00:00:00.000
]
key: [
1970-01-01 00:00:00.001,
1970-01-01 00:00:00.001,
1970-01-01 00:00:00.001
]
r1_v0: [
100,
101,
102
]
AsofjoinNode(0x7ff7b6edfc00): received batch from input 1:
time: [
0,
1500,
2500
]
key2: [
1970-01-01 00:00:00.000,
1970-01-01 00:00:00.000,
1970-01-01 00:00:00.000
]
key: [
1970-01-01 00:00:00.001,
1970-01-01 00:00:00.001,
1970-01-01 00:00:00.001
]
r0_v0: [
10,
11,
12
]
AsofjoinNode(0x7ff7b6edfc00): received batch from input 0:
time: [
0
]
key2: [
1970-01-01 00:00:00.000
]
key: [
1970-01-01 00:00:00.001
]
l_v0: [
1970-01-01 00:00:00.000001
]
AsofjoinNode(0x70000563b6e0): Advancing input 1
AsofjoinNode(0x70000563b390): key hasher 1 got hashes [10621589963589458110, 10621589963589458110, 10621589963589458110]
AsofjoinNode(0x70000563b590): memo 1 store: for_time=0 row=0 time=0 key=10621589963589458110
AsofjoinNode(0x70000563b6e0): Advancing input 1 hit distant time=1500 at=0
AsofjoinNode(0x70000563b570): memo 1 remove: ts=0
AsofjoinNode(0x70000563b6e0): Advancing input 1 updated=0
AsofjoinNode(0x70000563b6e0): Advancing input 2
AsofjoinNode(0x70000563b390): key hasher 2 got hashes [10621589963589458110, 10621589963589458110, 10621589963589458110]
AsofjoinNode(0x70000563b590): memo 2 store: for_time=0 row=0 time=0 key=10621589963589458110
AsofjoinNode(0x70000563b6e0): Advancing input 2 hit distant time=1500 at=0
AsofjoinNode(0x70000563b570): memo 2 remove: ts=0
AsofjoinNode(0x70000563b6e0): Advancing input 2 updated=0
AsofjoinNode(0x70000563b440): key hasher 0 got hashes [10621589963589458110]
AsofjoinNode(0x70000563b790): Emplace: key=10621589963589458110 lhs_latest_row=0 lhs_latest_time=0
AsofjoinNode(0x70000563b790): i=1 has_entry=1 time=0 row=0 accepted=1
AsofjoinNode(0x70000563b790): i=2 has_entry=1 time=0 row=0 accepted=1
AsofjoinNode(0x70000563bc40): produce batch 0:
time: [
0
]
key2: [
1970-01-01 00:00:00.000
]
key: [
1970-01-01 00:00:00.001
]
l_v0: [
1970-01-01 00:00:00.000001
]
r0_v0: [
10
]
r1_v0: [
100
]
AsofjoinNode(0x7ff7b6edfc00): received batch from input 0:
time: [
1000
]
key2: [
1970-01-01 00:00:00.000
]
key: [
1970-01-01 00:00:00.002
]
l_v0: [
1970-01-01 00:00:00.000002
]
AsofjoinNode(0x70000563b6e0): Advancing input 1
AsofjoinNode(0x70000563b590): memo 1 store: for_time=1000 row=1 time=1500 key=10621589963589458110
AsofjoinNode(0x70000563b6e0): Advancing input 1 hit distant time=2500 at=1000
AsofjoinNode(0x70000563b590): memo 1 store: for_time=1000 row=2 time=2500 key=10621589963589458110
AsofjoinNode(0x70000563b570): memo 1 remove: ts=1000
AsofjoinNode(0x70000563b6e0): Advancing input 1 updated=1
AsofjoinNode(0x70000563b6e0): Advancing input 2
AsofjoinNode(0x70000563b590): memo 2 store: for_time=1000 row=1 time=1500 key=10621589963589458110
AsofjoinNode(0x70000563b6e0): Advancing input 2 hit distant time=2500 at=1000
AsofjoinNode(0x70000563b590): memo 2 store: for_time=1000 row=2 time=2500 key=10621589963589458110
AsofjoinNode(0x70000563b570): memo 2 remove: ts=1000
AsofjoinNode(0x70000563b6e0): Advancing input 2 updated=1
AsofjoinNode(0x70000563b790): Emplace: key=10621589963589458110 lhs_latest_row=0 lhs_latest_time=1000
AsofjoinNode(0x70000563b790): i=1 has_entry=1 time=1500 row=1 accepted=1
AsofjoinNode(0x70000563b790): i=2 has_entry=1 time=1500 row=1 accepted=1
AsofjoinNode(0x70000563bc40): produce batch 1:
time: [
1000
]
key2: [
1970-01-01 00:00:00.000
]
key: [
1970-01-01 00:00:00.002
]
l_v0: [
1970-01-01 00:00:00.000002
]
r0_v0: [
11
]
r1_v0: [
101
]
AsofjoinNode(0x7ff7b6edfc00): received batch from input 0:
time: [
2000
]
key2: [
1970-01-01 00:00:00.000
]
key: [
1970-01-01 00:00:00.001
]
l_v0: [
1970-01-01 00:00:00.000003
]
AsofjoinNode(0x70000563b6e0): Advancing input 1
AsofjoinNode(0x70000563b570): memo 1 remove: ts=2000
AsofjoinNode(0x70000563b6e0): Advancing input 2
AsofjoinNode(0x70000563b570): memo 2 remove: ts=2000
AsofjoinNode(0x70000563b790): Emplace: key=10621589963589458110 lhs_latest_row=0 lhs_latest_time=2000
AsofjoinNode(0x70000563b790): i=1 has_entry=1 time=2500 row=2 accepted=1
AsofjoinNode(0x70000563b790): i=2 has_entry=1 time=2500 row=2 accepted=1
AsofjoinNode(0x70000563bc40): produce batch 2:
time: [
2000
]
key2: [
1970-01-01 00:00:00.000
]
key: [
1970-01-01 00:00:00.001
]
l_v0: [
1970-01-01 00:00:00.000003
]
r0_v0: [
12
]
r1_v0: [
102
]
Comparing flattened expected table:
time: uint16
key2: timestamp[ms, tz=UTC]
key: timestamp[ms, tz=UTC]
l_v0: timestamp[us, tz=UTC]
r0_v0: uint64
r1_v0: float
----
time:
[
[
0,
1000,
2000
]
]
key2:
[
[
1970-01-01 00:00:00.000,
1970-01-01 00:00:00.000,
1970-01-01 00:00:00.000
]
]
key:
[
[
1970-01-01 00:00:00.001,
1970-01-01 00:00:00.002,
1970-01-01 00:00:00.001
]
]
l_v0:
[
[
1970-01-01 00:00:00.000001,
1970-01-01 00:00:00.000002,
1970-01-01 00:00:00.000003
]
]
r0_v0:
[
[
10,
null,
12
]
]
r1_v0:
[
[
100,
null,
102
]
]
with flattened result table:
time: uint16
key2: timestamp[ms, tz=UTC]
key: timestamp[ms, tz=UTC]
l_v0: timestamp[us, tz=UTC]
r0_v0: uint64
r1_v0: float
----
time:
[
[
0
],
[
1000
],
[
2000
]
]
key2:
[
[
1970-01-01 00:00:00.000
],
[
1970-01-01 00:00:00.000
],
[
1970-01-01 00:00:00.000
]
]
key:
[
[
1970-01-01 00:00:00.001
],
[
1970-01-01 00:00:00.002
],
[
1970-01-01 00:00:00.001
]
]
l_v0:
[
[
1970-01-01 00:00:00.000001
],
[
1970-01-01 00:00:00.000002
],
[
1970-01-01 00:00:00.000003
]
]
r0_v0:
[
[
10
],
[
11
],
[
12
]
]
r1_v0:
[
[
100
],
[
101
],
[
102
]
]
[ FAILED ] AsofJoinNodeTest/AsofJoinBasicTest.TestBasic7Forward/2, where GetParam() = AsofJoinBasicParams: MutateByKey (56 ms)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment