Hi Yanfei, I'm using Flink SQL API, however isn't it like SQL is translated to DataStream's building blocks, so SQL window is in fact eg. SlicingWindowOperator?
I see only such rocks dbs under a TM' /tmp/flink-io-* directory: bash-4.4$ du -d 1 . -b 1 94262 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_7cf5648f97e9a8d62a22929db9aba45d__2_20__uuid_ece0ceb6-da61-46b2-94a5-7cab5e331b48 92611 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_7cf5648f97e9a8d62a22929db9aba45d__10_20__uuid_fd91da02-4b1c-48cd-82b5-069ef8b6e814 81135 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_7cf5648f97e9a8d62a22929db9aba45d__7_20__uuid_8f7583cc-0b43-4bb2-a4b4-3883173e272a 80406 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_7cf5648f97e9a8d62a22929db9aba45d__16_20__uuid_42bab3d9-6f1a-4807-8934-57f694ccbee3 95019 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_29ca1daf840faeefdca20aecaa41c014__2_20__uuid_0a3aedd1-e142-4f41-bcb0-d318045834f2 55907 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_29ca1daf840faeefdca20aecaa41c014__7_20__uuid_013b7208-64a4-431d-9ed5-c08f227ef410 41497 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_1d051901a12cde4f0aa3e1146f449d01__2_20__uuid_39293733-56f4-4b82-b1b5-1da0d3fd7a25 84687 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_29ca1daf840faeefdca20aecaa41c014__10_20__uuid_b106f83b-b29c-4de8-9540-ffdc148b89fb 41605 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_1d051901a12cde4f0aa3e1146f449d01__10_20__uuid_b9cd4b61-b6e9-4760-b356-f190140faa67 42302 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_1d051901a12cde4f0aa3e1146f449d01__7_20__uuid_2e0edbf6-f293-43b1-b0de-7bfb0d9a79f7 41687 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_1d051901a12cde4f0aa3e1146f449d01__16_20__uuid_2a6ac907-99d6-46e2-8385-9c3150c27067 72442 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_29ca1daf840faeefdca20aecaa41c014__16_20__uuid_ea8ddf6b-1a9e-45dc-9d8e-58ef2bd1e9fc 64451 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_522e271815529deb43d184c4d1674539__2_20__uuid_ff7c3069-e002-4420-8902-d4069ec797b4 73967 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_522e271815529deb43d184c4d1674539__7_20__uuid_60f6274c-e475-444b-97cd-ff841d0b3262 66927 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_522e271815529deb43d184c4d1674539__16_20__uuid_2f0264c6-19ed-4713-9775-1e1f00084e84 39247 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_522e271815529deb43d184c4d1674539__10_20__uuid_e873a94a-071a-44f9-9955-c27990f054b9 34951 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_61c3177285765d860988843192a07bd8__2_20__uuid_8182e420-94c7-4fc6-a405-2a7078054ea2 42125 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_61c3177285765d860988843192a07bd8__7_20__uuid_3b3c8caa-4dc6-49a3-9b6c-95d161c2793a 41248 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_61c3177285765d860988843192a07bd8__10_20__uuid_ee7c0098-ee7f-4b67-bc9b-a2960691b83c 42251 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_61c3177285765d860988843192a07bd8__16_20__uuid_7526a9f0-630e-433a-9d29-2320b1228980 34951 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_038fbf55966f2c12d41bb3d10451b570__2_20__uuid_d952d3c5-fac2-4b62-8288-2a45ec8764e0 34951 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_038fbf55966f2c12d41bb3d10451b570__7_20__uuid_ecf1b11c-c4e9-466f-a154-7379766d40c2 34953 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_038fbf55966f2c12d41bb3d10451b570__10_20__uuid_b95324fe-7ce4-4137-80ce-1984590eeabe 34953 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_038fbf55966f2c12d41bb3d10451b570__16_20__uuid_6b838d00-3f39-4de9-b04e-534673bc28d7 98281 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_282314b9b73bf96d481985905979d370__7_20__uuid_05db2ad5-183a-4a51-97b8-72325c3b5735 68379 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_282314b9b73bf96d481985905979d370__10_20__uuid_79d80a0d-a102-4108-ae5f-0521cbcb780d 77057 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_282314b9b73bf96d481985905979d370__2_20__uuid_f8026c5c-e4f9-41f5-ab8b-6914304cdf80 95008 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_282314b9b73bf96d481985905979d370__16_20__uuid_51708fd3-d8aa-4121-a471-db4b2176483e 34953 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_7e703eb6a2314988f4f8ed8c032a671f__10_20__uuid_4998ab7e-8fcb-4100-9f61-c9a9b2def8f9 34953 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_7e703eb6a2314988f4f8ed8c032a671f__16_20__uuid_3c99cd34-da84-4536-8d94-5be6f0dfcf78 34951 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_7e703eb6a2314988f4f8ed8c032a671f__2_20__uuid_da7d8ab9-9942-4ad4-852a-fe2ae350b371 34951 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_7e703eb6a2314988f4f8ed8c032a671f__7_20__uuid_6453f74d-dbd3-4e87-bd73-077ca36ba8de 34951 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_431a88cd843fcaf531da2a7f02556582__2_20__uuid_bb9885b0-0e31-43ba-97af-fe4c10988df7 41776 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_431a88cd843fcaf531da2a7f02556582__7_20__uuid_59c3c38b-4e36-48a9-9922-1580e5a5f939 41810 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_431a88cd843fcaf531da2a7f02556582__16_20__uuid_027d342c-f8e9-451a-bf2d-5ec88f92e3e5 41810 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_431a88cd843fcaf531da2a7f02556582__10_20__uuid_b4511ddf-3d8b-4ca8-920f-b218fb066a99 34951 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_8cfb4a36877fbd6a712778b4098e9d17__7_20__uuid_5e2c8057-515b-4273-bf2f-50adc0433e4f 34951 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_8cfb4a36877fbd6a712778b4098e9d17__2_20__uuid_542b30b7-fe9e-46f3-9210-b6f0e4bd8aed 34953 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_8cfb4a36877fbd6a712778b4098e9d17__10_20__uuid_d5902efc-c9b4-4527-aaee-094afd013690 34953 ./job_00000000000000000000000000000000_op_SlicingWindowOperator_8cfb4a36877fbd6a712778b4098e9d17__16_20__uuid_64862e0c-4504-4365-8a3e-dbdcc526eb45 Best, Adam. On Fri, 7 Jun 2024 at 05:23, Yanfei Lei <fredia...@gmail.com> wrote: > Hi Adam, > > Is your job a datastream job or a sql job? After I looked through the > window-related code(I'm not particularly familiar with this part of > the code), this problem should only exist in datastream. > > Adam Domanski <adoman...@gmail.com> 于2024年6月3日周一 16:54写道： > > > > Dear Flink users, > > > > I spotted the ever growing checkpoint size in my Flink application which > uses tumble windows. > > > > I found such a ticket: https://issues.apache.org/jira/browse/FLINK-33192, > but no comments. > > > > Can somebody confirm the issue? > > > > BR, > > Adam. > > > > > > > -- > Best, > Yanfei >
