Google Git
Sign in
apache / flink-connector-hive / HEAD
  1. 98e4258 [FLINK-34961] Use dedicated CI name for Hive connector to differentiate it in infra-reports by Kunni · 5 months ago main
  2. c8aa0cc [hotfix] Enable tests for java 11 with hive2 by Sergey Nuyanzin · 6 months ago
  3. 385f37d [hotfix] Bump commons-net:commons-net from 3.6 to 3.9.0 by dependabot[bot] · 6 months ago
  4. 9a845b4 [hotfix] Update dependencies by Sergey Nuyanzin · 6 months ago
  5. e9b15d5 [hotfix] Dependency convergence by Sergey Nuyanzin · 6 months ago
  6. 204c8bd [hotfix] Apply 1.20.0 in github ci by Sergey Nuyanzin · 6 months ago
  7. 56740ed [FLINK-35656][hive] Fix the issue that Hive Source incorrectly set max parallelism in dynamic inference mode by sunxia · 1 year, 1 month ago
  8. 4aefc5b [hotfix][doc] Update the Kafka DDL example in the hive catalog page to the new parameter style by Feng Jin · 1 year, 5 months ago
  9. 7172309 [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 adapt for external connector by Sergey Nuyanzin · 6 months ago
  10. e7a0158 [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 (#24905) by Cheng Pan · 1 year, 1 month ago
  11. 31e841c [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: core (#24881) by gongzhongqiang · 1 year, 1 month ago
  12. cab36b3 [FLINK-35293][hive] Hive source supports dynamic parallelism inference by sunxia · 1 year, 2 months ago
  13. 54dfc32 [FLINK-29050][test-utils] Rename AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase with JUnit4 suffix. by Roc Marshal · 2 years, 1 month ago
  14. b5d928a [FLINK-35188][table-api] Introduce CatalogMaterializedTable interface to support materialized table by fengli · 1 year, 3 months ago
  15. ddf03a3 [FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource (#23777) by Alexander Fedulov · 1 year, 3 months ago
  16. 66c3d01 [FLINK-33984][runtime] Support batch snapshot for OperatorCoordinator. by JunRuiLee · 1 year, 5 months ago
  17. 55f1063 [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory by Jane Chan · 1 year, 4 months ago
  18. ddbb538 [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18) by Wencong Liu · 1 year, 2 months ago
  19. da3c3ba [FLINK-16627][json] Support ignore null fields when serializing into JSON by zhouyisha · 1 year, 5 months ago
  20. 756b1d9 [FLINK-34204][core] Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig by Weijie Guo · 1 year, 6 months ago
  21. d96d035 [FLINK-34081][configuration] Refactor all callers of deprecated `getXxx(ConfigOption<Xxx>)`, `getXxx(ConfigOption<Xxx>, Xxx)` and `setXxx(ConfigOption<Integer>, Xxx)` methods of Configuration by Rui Fan · 1 year, 6 months ago
  22. 917e84c [hotfix] Use guava instead of flink-shaded by Sergey Nuyanzin · 6 months ago
  23. 38d857f [FLINK-33705] Upgrade to flink-shaded 18.0 by Sergey Nuyanzin · 1 year, 6 months ago
  24. d852274 [hotfix] Bump Flink to 1.19.0 by Sergey Nuyanzin · 6 months ago
  25. 74c0ad0 [FLINK-33905][core] Unify the provision of metadata in RuntimeContext by Wencong Liu · 1 year, 7 months ago
  26. 1292676 Revert "[FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18)" by Sergey Nuyanzin · 6 months ago
  27. bb95109 [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18) by Wencong Liu · 1 year, 2 months ago
  28. 0421326 [hotfix] Add release tools as submodule by Sergey Nuyanzin · 1 year, 6 months ago
  29. 30bfa21 [hotfix] flink-connector-hive artifactId with scala version by slankka · 1 year, 6 months ago
  30. e8131a7 [hotfix] Run end to end tests only if profile run-end-to-end-tests explicitely activated by Sergey Nuyanzin · 1 year, 6 months ago
  31. 016bec3 [hotfix] Update NOTICE files to reflect year 2024 by Sergey Nuyanzin · 1 year, 6 months ago
  32. 557a369 [hotfix] Allow manual trigger for weekly by Sergey Nuyanzin · 1 year, 8 months ago
  33. 13424e8 [FLINK-30064][hive] Move Hive connector to external repo by Sergey Nuyanzin · 1 year, 8 months ago
  34. 785660f [FLINK-33718][table] Cleanup the usage of deprecated StreamTableEnvironment#toAppendStream by Sergey Nuyanzin · 1 year, 8 months ago
  35. 99818dd [hotfix][connector-hive][test] fix ArchUnit typo in pom by jingge · 1 year, 8 months ago
  36. aa20473 [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit4 for table-planner module by Jiabao Sun · 1 year, 8 months ago
  37. 079016f [FLINK-33418][test] Uses getHost() by Matthias Pohl · 1 year, 9 months ago
  38. 58f0f4f [FLINK-32997][table-planner][JUnit5 Migration] Module: flink-connectors (StreamingTestBase) by Jiabao Sun · 1 year, 10 months ago
  39. 7ceae5e [hotfix] Remove Calcite classes from Hive connector by Sergey Nuyanzin · 1 year, 8 months ago
  40. 43491d0 [FLINK-33551][Connectors/Hive] Fix HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable nightly CI fails by Jiabao Sun · 1 year, 8 months ago
  41. 4e3f699 [FLINK-33478][hive] Enable foldExpr by default in filter condition (#23682) by yunfan123 · 1 year, 8 months ago
  42. 91a7419 [FLINK-33023][table-planner][JUnit5 Migration] Module: flink-connectors/flink-connector-hive (TableTestBase) by Jiabao Sun · 1 year, 10 months ago
  43. 348503d [FLINK-33226][table] Forbid to drop current database by Ferenc Csaky · 1 year, 9 months ago
  44. 7c75e69 [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect by yunfan123 · 1 year, 9 months ago
  45. bec407e [FLINK-25593][table-planner] Skip redundant scan while partition table push down contains none-existent partition (#23423) by yunhong · 1 year, 9 months ago
  46. 14234e2 [FLINK-32223][runtime][security] Add Hive delegation token support by jiaoqingbo · 1 year, 10 months ago
  47. 634265b [FLINK-32978][flink-core] Migrate the usage of RichFunction#open(Configuration parameters) to RichFunction#open(OpenContext openContext) by Wencong Liu · 1 year, 11 months ago
  48. 77a9bd4 [FLINK-32731][e2e] Fix NameNode uses port 9870 in hadoop3 by Shengkai · 1 year, 11 months ago
  49. 7f71579 [FLINK-32620][sink] Migrate DiscardingSink to sinkv2. by Weijie Guo · 2 years ago
  50. 13ca975 [FLINK-32982][doc] Not to suggest to swap flink-table-planner lib for using Hive dialect by luoyuxia · 1 year, 11 months ago
  51. b899b5a [FLINK-32731][e2e] Add retry mechanism when fails to start the namenode (#23267) by Shengkai · 1 year, 11 months ago
  52. 44efc62 [FLINK-32760][Connectors/Hive] Reshade shaded parquet in flink-sql-connector-hive (#23166) by dongwoo6kim · 1 year, 11 months ago
  53. 85d7729 Update version to 1.19-SNAPSHOT by jingge · 1 year, 11 months ago
  54. 8df9a6b [FLINK-32731][e2e] Backup the hive-metastore, hdfs namenode and mysql logs (#23155) by Shengkai · 2 years ago
  55. 24be94e [FLINK-32656][table] Deprecate ManagedTable related APIs by Jane Chan · 2 years ago
  56. 292e985 Revert "[FLINK-32223][runtime][security] Add Hive delegation token support" by Matthias Pohl · 2 years ago
  57. fe21c31 [FLINK-32223][runtime][security] Add Hive delegation token support by jiaoqingbo · 2 years ago
  58. 2d23cf1 [FLINK-31575][hive] Avoid swapping table-planner-loader and table-planner to use hive dialect (#22862) by yuxia Luo · 2 years ago
  59. bc97ae3 [FLINK-32365][hive] Allow Hive source to scan table to get statistics in parallel (#22805) by baiwuchang · 2 years ago
  60. 22bf089 [FLINK-32388][filesystem]Add the ability to pass parameters to CUSTOM PartitionCommitPolicy (#22831) by Bangui Dunn · 2 years, 1 month ago
  61. cbe7c2c [FLINK-32526] Bump Apache Parquet from 1.12.3 to 1.13.1 by Sergey Nuyanzin · 2 years, 1 month ago
  62. f7de674 [FLINK-32410] Replace new LinkedHashMap<>(size) with CollectionUtil.newLinkedHashMapWithExpectedSize(size) by Stefan Richter · 2 years, 1 month ago
  63. 55f31e4 [FLINK-32410] Replace new HashSet<>(size) with CollectionUtil.newHashSetWithExpectedSize(size) by Stefan Richter · 2 years, 1 month ago
  64. d32bdf8 [FLINK-32410] Replace new HashMap<>(size) with CollectionUtil.newHashMapWithExpectedSize(size) by Stefan Richter · 2 years, 1 month ago
  65. cb235d7 [FLINK-32032] Upgrade to flink-shaded 17.0. This closes #22546 by MartijnVisser · 2 years, 1 month ago
  66. a9b331c [FLINK-31413][hive] Change scope of flink-table-planner dependency from provided to test in Hive connector by luoyuxia · 2 years, 2 months ago
  67. 1988323 [FLINK-31413][hive] HiveParser allows to parse Flink's special commands by luoyuxia · 2 years, 2 months ago
  68. b73ee29 [FLINK-31413][hive] Copy HintPredicate,NodeTypeHintPredicate, LogicalDistribution,LogicalScriptTransform,ExpressionBuilder by luoyuxia · 2 years, 2 months ago
  69. de1bd01 [FLINK-31413][hive] Remove usage org.apache.flink.table.planner.functions.* of in Hive connector by luoyuxia · 2 years, 2 months ago
  70. ff98871 [FLINK-31413][hive] Hive connector shouldn't use OperationConverterUtils by luoyuxia · 2 years, 2 months ago
  71. ba81cd7 [FLINK-31413][hive] Hive connector shouldn't use PlannerQueryOperation by luoyuxia · 2 years, 2 months ago
  72. 49741ce [FLINK-32294][e2e] Fix HiveITCase failure (#22740) by yuxia Luo · 2 years, 1 month ago
  73. 8fc54f1 [FLINK-30660][e2e] Add e2e test for hive by luoyuxia · 2 years, 2 months ago
  74. 7112338 [docs] Deduplicate mistakenly repeated words by Rich Bowen · 2 years, 2 months ago
  75. 20ddff0 [FLINK-28203][build] Mark bundled dependencies as optional by Chesnay Schepler · 3 years, 1 month ago
  76. 8953ca7 [hotfix][hive] Mark mapreduce-client-core as provided by Chesnay Schepler · 2 years, 2 months ago
  77. 021a39c [FLINK-30815][tests] Migrate BatchAbstractTestBase to junit5 by Yuxin Tan · 2 years, 3 months ago
  78. f5d7921 [FLINK-31409][hive] Hive dialect shouldn't use interfaces in table-planner to build LogicPlan by luoyuxia · 2 years, 5 months ago
  79. a7df471 [FLINK-31409][table] Introduce public interfaces for pluggable dialect by luoyuxia · 2 years, 5 months ago
  80. 3f18cab [FLINK-31804] Allow MiniClusterTestEnvironment by Chesnay Schepler · 2 years, 3 months ago
  81. 7202a3d [hotfix] replace deprecated calcite apis by Sergey Nuyanzin · 2 years, 8 months ago
  82. bb09935 [FLINK-31531][hive] Fix HiveCatalogHiveMetadataTest&HiveDialectITCase failure in Hive3 (#22230) by yuxia Luo · 2 years, 4 months ago
  83. 76b85cf [hotfix] Update copyright NOTICE year to 2023 by Robert Metzger · 2 years, 4 months ago
  84. 8fa2662 [FLINK-31487][table-planner] Add targetColumns to DynamicTableSink#Context by lincoln lee · 2 years, 4 months ago
  85. 337e2c7 [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector (#21522) by Aitozi · 2 years, 4 months ago
  86. dd328d2 [FLINK-31369][sql-gateway] Harden modifiers in tests for sql-gateway module by Sergey Nuyanzin · 2 years, 4 months ago
  87. 290ccf5 [FLINK-30659][hive] Drop flink-sql-parser-hive module (#22106) by yuxia Luo · 2 years, 4 months ago
  88. 3ef7081 [FLINK-31239][hive] Add some notes in document about table.exec.hive.native-agg-function.enabled option can't turned on per job when using it via SqlClient by fengli · 2 years, 5 months ago
  89. e450d61 [FLINK-31239][hive] Fix native sum function can't get the corrected value when the argument type is string by fengli · 2 years, 5 months ago
  90. 79f1390 [FLINK-31124][Connectors/Hive] Add IT case for HiveTableSink speculative execution by shuiqiangchen · 2 years, 5 months ago
  91. 5f3adfe [FLINK-31132][hive] Let hive compact operator without setting parallelism subject to sink operator's configured parallelism. by Weijie Guo · 2 years, 5 months ago
  92. ac1d019 [hotfix][test] Migrate HiveTableCompactSinkTICase, HiveTableFactoryTest, HiveTableSinkITCase to Junit5 and AssertJ. by Weijie Guo · 2 years, 5 months ago
  93. 9683e33 [hotfix] Fix typo in HiveTableSink and HiveTableCompactSinkITCase. by Weijie Guo · 2 years, 5 months ago
  94. 8d80f85 [FLINK-31175][doc] Fix link doesn't work in hive_read_write doc (#21988) by Shengkai · 2 years, 5 months ago
  95. 43f0e85 [FLINK-31137][hive] Fix wrong ResultKind in DescribeTable and ShowCreateTable results (#21980) by Shengkai · 2 years, 5 months ago
  96. 90d8c1f [FLINK-30824][hive] Add document for option 'table.exec.hive.native-agg-function.enabled' by Ron · 2 years, 5 months ago
  97. 8f29257 Update version to 1.18-SNAPSHOT by Leonard Xu · 2 years, 5 months ago
  98. cbe2ab2 [FLINK-30386] Fix the issue that column constraint lacks primary key not enforced check by Jane Chan · 2 years, 5 months ago
  99. 4d26bcd [FLINK-30006][table-planner] Make all pure dynamic functions non-deterministic in streaming mode to avoid wrong plans by lincoln.lil · 2 years, 6 months ago
  100. b9d9ba8 [FLINK-30686][conf] Refine adaptive batch configurations by JunRuiLee · 2 years, 6 months ago