Title
#general
James

James

05/16/2022, 12:59 PM
hi, I am trying windowFunnel function following the guide: https://databend.rs/doc/reference/functions/aggregate-functions/aggregate-windowfunnel it hangs when I try to insert data into the test table:
databend :) INSERT INTO events VALUES(100123, 'login', '2022-05-14 10:01:00');


INSERT INTO events FORMAT Values

Query id: c94962b7-edda-46a0-b32f-50022c52e06d

Exception on client:
Code: 209. DB::NetException: Timeout exceeded while reading from socket (127.0.0.1:9000, 300000 ms): while receiving packet from localhost:9000. (SOCKET_TIMEOUT)
The message on
databend-query
side is:
2022-05-16T12:50:08.906845Z ERROR common_tracing::panic_hook: panicked at 'called `Result::unwrap()` on an `Err` value: Code: 1015, displayText = clickhouse-srv expception: FromSql(InvalidType { src: "DateTime", dst: "UInt32" }) (while in processor thread 0).

   0: std::backtrace_rs::backtrace::libunwind::trace
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/../../backtrace/src/backtrace/libunwind.rs:93:5
   1: std::backtrace_rs::backtrace::trace_unsynchronized
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/../../backtrace/src/backtrace/mod.rs:66:5
   2: std::backtrace::Backtrace::create
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/backtrace.rs:328:13
   3: common_exception::exception_code::<impl common_exception::exception::ErrorCode>::LogicalError
             at /Users/abei/Code/databend/common/exception/src/exception_code.rs:31:71
   4: databend_query::servers::clickhouse::writers::query_writer::from_clickhouse_err
             at /Users/abei/Code/databend/query/src/servers/clickhouse/writers/query_writer.rs:141:5
   5: core::ops::function::FnOnce::call_once
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/core/src/ops/function.rs:227:5
   6: core::result::Result<T,E>::map_err
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/core/src/result.rs:855:27
   7: databend_query::servers::clickhouse::writers::query_writer::from_clickhouse_block
             at /Users/abei/Code/databend/query/src/servers/clickhouse/writers/query_writer.rs:232:18
   8: <databend_query::pipelines::new::processors::sources::sync_ck_source_receiver::SyncReceiverCkSource as databend_query::pipelines::new::processors::sources::sync_source::SyncSource>::generate
             at /Users/abei/Code/databend/query/src/pipelines/new/processors/sources/sync_ck_source_receiver.rs:53:36
   9: <databend_query::pipelines::new::processors::sources::sync_source::SyncSourcer<T> as databend_query::pipelines::new::processors::processor::Processor>::process
             at /Users/abei/Code/databend/query/src/pipelines/new/processors/sources/sync_source.rs:94:15
  10: databend_query::pipelines::new::processors::processor::ProcessorPtr::process
             at /Users/abei/Code/databend/query/src/pipelines/new/processors/processor.rs:91:9
  11: databend_query::pipelines::new::executor::executor_worker_context::ExecutorWorkerContext::execute_sync_task
             at /Users/abei/Code/databend/query/src/pipelines/new/executor/executor_worker_context.rs:81:9
  12: databend_query::pipelines::new::executor::executor_worker_context::ExecutorWorkerContext::execute_task
             at /Users/abei/Code/databend/query/src/pipelines/new/executor/executor_worker_context.rs:71:46
  13: databend_query::pipelines::new::executor::pipeline_executor::PipelineExecutor::execute_single_thread
             at /Users/abei/Code/databend/query/src/pipelines/new/executor/pipeline_executor.rs:123:45
  14: databend_query::pipelines::new::executor::pipeline_executor::PipelineExecutor::execute_threads::{{closure}}
             at /Users/abei/Code/databend/query/src/pipelines/new/executor/pipeline_executor.rs:93:23
  15: common_base::base::thread::Thread::named_spawn::{{closure}}
             at /Users/abei/Code/databend/common/base/src/base/thread.rs:40:21
  16: std::sys_common::backtrace::__rust_begin_short_backtrace
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/sys_common/backtrace.rs:122:18
  17: std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/thread/mod.rs:498:17
  18: <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/core/src/panic/unwind_safe.rs:271:9
  19: std::panicking::try::do_call
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/panicking.rs:492:40
  20: std::panicking::try
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/panicking.rs:456:19
  21: std::panic::catch_unwind
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/panic.rs:137:14
  22: std::thread::Builder::spawn_unchecked_::{{closure}}
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/thread/mod.rs:497:30
  23: core::ops::function::FnOnce::call_once{{vtable.shim}}
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/core/src/ops/function.rs:227:5
  24: <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/alloc/src/boxed.rs:1861:9
  25: <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/alloc/src/boxed.rs:1861:9
  26: std::sys::unix::thread::Thread::new::thread_start
             at /rustc/76d770ac21d9521db6a92a48c7b3d5b2cc535941/library/std/src/sys/unix/thread.rs:108:17
  27: __pthread_deallocate
bohu

bohu

05/16/2022, 1:02 PM
There maybe a bug here on ClickHouse handler. Please try the MySQL client, it works fine.
James

James

05/16/2022, 2:08 PM
thanks!