Vicky Papavasileiou created FLINK-30857:
-------------------------------------------
Summary: Create table does not create topic with multiple
partitions
Key: FLINK-30857
URL: https://issues.apache.org/jira/browse/FLINK-30857
Project: Flink
Issue Type: Bug
Reporter: Vicky Papavasileiou
{code:java}
CREATE CATALOG table_store_catalog WITH (
'type'='table-store',
'warehouse'='s3://my-bucket/table-store'
);
USE CATALOG table_store_catalog;
SET 'execution.checkpointing.interval' = '10 s';
CREATE TABLE word_count_kafka (
word STRING PRIMARY KEY NOT ENFORCED,
cnt BIGINT
) WITH (
'log.system' = 'kafka',
'kafka.bootstrap.servers' = 'broker:9092',
'kafka.topic' = 'word_count_log',
'bucket'='4'
);
{code}
The created topic has only one partition
{code:java}
Topic: word_count_log TopicId: udeJwBIkRsSybkf1EerphA PartitionCount: 1
ReplicationFactor: 1 Configs:
Topic: word_count_log Partition: 0 Leader: 1 Replicas: 1 Isr:
1{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
