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

Filesystem sink does not escape right bracket in partition name

    XMLWordPrintableJSON

Details

    Description

      How to reproduce the problem

      In the following code snippet filesystem sink creates a partition named "{date}" and writes value "1" to file.

      create table sink (
        val int,
        part string
      ) partitioned by (part) with (
        'connector' = 'filesystem',
        'path' = '/tmp/sink',
        'format' = 'csv'
      );
      
      insert into sink values (1, '{date}');
      

      Expected behavior

      Escaped "{" and "}" in partition name

      $ ls /tmp/sink/
      part=%7Bdate%7D
      

      Actual behavior

      Escaped only "{" in partition name

      $ ls /tmp/sink/
      part=%7Bdate}
      

      Attachments

        Issue Links

          Activity

            People

              trushev Alexander Trushev
              trushev Alexander Trushev
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: