Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-27806

Datagen add binary & varbinary type support

    XMLWordPrintableJSON

Details

    Description

      Datagen connector currently not support BYTES type. e.g. BINARY & VARBINARY. It will cause exception when use

      CREATE TABLE t3 (
      f0 BIGINT,
      f1 VARBINARY
      ) WITH (
      'connector' = 'datagen',
      ....
      );

      StackTrace:
      Caused by: org.apache.flink.table.api.ValidationException: Unsupported type: BYTES at org.apache.flink.connector.datagen.table.RandomGeneratorVisitor.defaultMethod(RandomGeneratorVisitor.java:317) at org.apache.flink.connector.datagen.table.RandomGeneratorVisitor.defaultMethod(RandomGeneratorVisitor.java:60) at org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor.visit(LogicalTypeDefaultVisitor.java:82) at org.apache.flink.table.types.logical.VarBinaryType.accept(VarBinaryType.java:151) at org.apache.flink.connector.datagen.table.DataGenTableSourceFactory.createContainer(DataGenTableSourceFactory.java:128) at org.apache.flink.connector.datagen.table.DataGenTableSourceFactory.createDynamicTableSource(DataGenTableSourceFactory.java:98) at org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:147)

      Attachments

        1. sequence.png
          51 kB
          Ran Tao
        2. random.png
          65 kB
          Ran Tao

        Issue Links

          Activity

            People

              taoran Ran Tao
              taoran Ran Tao
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: