diff --git a/src/Analyzer/FunctionNode.cpp b/src/Analyzer/FunctionNode.cpp
index e98b04fe9a9..8e4e0725a2d 100644
--- a/src/Analyzer/FunctionNode.cpp
+++ b/src/Analyzer/FunctionNode.cpp
@@ -242,7 +242,8 @@ ASTPtr FunctionNode::toASTImpl(const ConvertToASTOptions & options) const
     /// Avoid cast for `IN tuple(...)` expression.
     /// Tuples could be quite big, and adding a type may significantly increase query size.
     /// It should be safe because set type for `column IN tuple` is deduced from `column` type.
-    if (isNameOfInFunction(function_name) && argument_nodes.size() > 1 &&  argument_nodes[1]->getNodeType() == QueryTreeNodeType::CONSTANT)
+    if (isNameOfInFunction(function_name) && argument_nodes.size() > 1 && argument_nodes[1]->getNodeType() == QueryTreeNodeType::CONSTANT
+        && !static_cast<const ConstantNode *>(argument_nodes[1].get())->hasSourceExpression())
         new_options.add_cast_for_constants = false;
 
     const auto & parameters = getParameters();
diff --git a/tests/queries/0_stateless/01756_optimize_skip_unused_shards_rewrite_in.reference b/tests/queries/0_stateless/01756_optimize_skip_unused_shards_rewrite_in.reference
index 74a0356b11e..fc1ddcae595 100644
--- a/tests/queries/0_stateless/01756_optimize_skip_unused_shards_rewrite_in.reference
+++ b/tests/queries/0_stateless/01756_optimize_skip_unused_shards_rewrite_in.reference
@@ -49,7 +49,7 @@ order by query;
  tuple(2)
 select 'optimize_skip_unused_shards_rewrite_in(2,)';
 optimize_skip_unused_shards_rewrite_in(2,)
-with (select currentDatabase()) as id_2 select *, ignore(id_2) from dist_01756 where dummy in (2,);
+with (select currentDatabase()) as id_2 select *, ignore(id_2) from dist_01756 where dummy in (2);
 system flush logs;
 select splitByString('IN', query)[-1] from system.query_log where
     event_date >= yesterday() and
@@ -59,10 +59,10 @@ select splitByString('IN', query)[-1] from system.query_log where
     query like concat('%', currentDatabase(), '%AS%id_2%') and
     type = 'QueryFinish'
 order by query;
- tuple(2)
+ (2)
 select 'optimize_skip_unused_shards_rewrite_in(0,)';
 optimize_skip_unused_shards_rewrite_in(0,)
-with (select currentDatabase()) as id_00 select *, ignore(id_00) from dist_01756 where dummy in (0,);
+with (select currentDatabase()) as id_00 select *, ignore(id_00) from dist_01756 where dummy in (0);
 0	0
 system flush logs;
 select splitByString('IN', query)[-1] from system.query_log where
@@ -73,7 +73,7 @@ select splitByString('IN', query)[-1] from system.query_log where
     query like concat('%', currentDatabase(), '%AS%id_00%') and
     type = 'QueryFinish'
 order by query;
- tuple(0)
+ (0)
 -- signed column
 select 'signed column';
 signed column
diff --git a/tests/queries/0_stateless/01756_optimize_skip_unused_shards_rewrite_in.sql b/tests/queries/0_stateless/01756_optimize_skip_unused_shards_rewrite_in.sql
index bcbedeb3ada..0759fb93a44 100644
--- a/tests/queries/0_stateless/01756_optimize_skip_unused_shards_rewrite_in.sql
+++ b/tests/queries/0_stateless/01756_optimize_skip_unused_shards_rewrite_in.sql
@@ -63,7 +63,7 @@ select splitByString('IN', query)[-1] from system.query_log where
 order by query;
 
 select 'optimize_skip_unused_shards_rewrite_in(2,)';
-with (select currentDatabase()) as id_2 select *, ignore(id_2) from dist_01756 where dummy in (2,);
+with (select currentDatabase()) as id_2 select *, ignore(id_2) from dist_01756 where dummy in (2);
 system flush logs;
 select splitByString('IN', query)[-1] from system.query_log where
     event_date >= yesterday() and
@@ -75,7 +75,7 @@ select splitByString('IN', query)[-1] from system.query_log where
 order by query;
 
 select 'optimize_skip_unused_shards_rewrite_in(0,)';
-with (select currentDatabase()) as id_00 select *, ignore(id_00) from dist_01756 where dummy in (0,);
+with (select currentDatabase()) as id_00 select *, ignore(id_00) from dist_01756 where dummy in (0);
 system flush logs;
 select splitByString('IN', query)[-1] from system.query_log where
     event_date >= yesterday() and
diff --git a/tests/queries/0_stateless/03209_parallel_replicas_lost_decimal_conversion.reference b/tests/queries/0_stateless/03209_parallel_replicas_lost_decimal_conversion.reference
new file mode 100644
index 00000000000..e69de29bb2d
diff --git a/tests/queries/0_stateless/03209_parallel_replicas_lost_decimal_conversion.sql b/tests/queries/0_stateless/03209_parallel_replicas_lost_decimal_conversion.sql
new file mode 100644
index 00000000000..bcc9dec306b
--- /dev/null
+++ b/tests/queries/0_stateless/03209_parallel_replicas_lost_decimal_conversion.sql
@@ -0,0 +1,11 @@
+DROP TABLE IF EXISTS t_03209 SYNC;
+
+CREATE TABLE t_03209 ( `a` Decimal(18, 0), `b` Decimal(18, 1), `c` Decimal(36, 0) ) ENGINE = ReplicatedMergeTree('/clickhouse/{database}/test_03209', 'r1') ORDER BY tuple();
+INSERT INTO t_03209 VALUES ('33', '44.4', '35');
+
+SET max_parallel_replicas = 2, cluster_for_parallel_replicas='parallel_replicas';
+
+SELECT * FROM t_03209 WHERE a IN toDecimal32('33.3000', 4) SETTINGS allow_experimental_parallel_reading_from_replicas=0;
+SELECT * FROM t_03209 WHERE a IN toDecimal32('33.3000', 4) SETTINGS allow_experimental_parallel_reading_from_replicas=1;
+
+DROP TABLE t_03209 SYNC;