[jira] [Created] (FLINK-30857) Create table does not create topic with multiple partitions

[Vicky Papavasileiou (Jira)]

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)