Uploaded image for project: 'Apache Hudi'
  1. Apache Hudi
  2. HUDI-3725

no primary key error when spark read flink hudi table use default uuid

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Minor
    • Resolution: Not A Bug
    • None
    • None
    • flink
    • None

    Description

      flink sql like the following will not write default record key uuid to hoodie.properties, when use spark to read it will throw ...There are no primary key... Exception

      CREATE TABLE t1(
       uuid VARCHAR(20) ,
       name VARCHAR(10),
       age INT,
       ts TIMESTAMP(3),
       `partition` VARCHAR(20)
      )
      PARTITIONED BY (`partition`)
      WITH (
       'connector' = 'hudi',
       'path' = '${path}',
       'table.type' = 'MERGE_ON_READ' -- this creates a MERGE_ON_READ table, by default is COPY_ON_WRITE
      ); 

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              KnightChess KnightChess
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: