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

support hbase connector 2.2 to write to hbase 2.4.9

    XMLWordPrintableJSON

Details

    Description

      hbase does version checks when creating configurations by default

      ```
      private static void checkDefaultsVersion(Configuration conf) {
      if (conf.getBoolean("hbase.defaults.for.version.skip", Boolean.FALSE)) return;
      String defaultsVersion = conf.get("hbase.defaults.for.version");
      String thisVersion = VersionInfo.getVersion();
      if (!thisVersion.equals(defaultsVersion))

      { throw new RuntimeException( "hbase-default.xml file seems to be for an older version of HBase (" + defaultsVersion + "), this version is " + thisVersion); }

      }
      ```

      so this prevents using connector2.2 to write to like hbase 2.4.9. however this restriction is not necessary.

      Attachments

        Issue Links

          Activity

            People

              zhenw Zhen Wang
              zhenw Zhen Wang
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: