Google Git
Sign in
apache / flink-connector-hive / HEAD
  1. bb95109 [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18) by Wencong Liu · 9 days ago main
  2. 0421326 [hotfix] Add release tools as submodule by Sergey Nuyanzin · 5 months ago
  3. 30bfa21 [hotfix] flink-connector-hive artifactId with scala version by slankka · 5 months ago
  4. e8131a7 [hotfix] Run end to end tests only if profile run-end-to-end-tests explicitely activated by Sergey Nuyanzin · 5 months ago
  5. 016bec3 [hotfix] Update NOTICE files to reflect year 2024 by Sergey Nuyanzin · 5 months ago
  6. 557a369 [hotfix] Allow manual trigger for weekly by Sergey Nuyanzin · 6 months ago
  7. 13424e8 [FLINK-30064][hive] Move Hive connector to external repo by Sergey Nuyanzin · 7 months ago
  8. 785660f [FLINK-33718][table] Cleanup the usage of deprecated StreamTableEnvironment#toAppendStream by Sergey Nuyanzin · 6 months ago
  9. 99818dd [hotfix][connector-hive][test] fix ArchUnit typo in pom by jingge · 6 months ago
  10. aa20473 [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit4 for table-planner module by Jiabao Sun · 6 months ago
  11. 079016f [FLINK-33418][test] Uses getHost() by Matthias Pohl · 7 months ago
  12. 58f0f4f [FLINK-32997][table-planner][JUnit5 Migration] Module: flink-connectors (StreamingTestBase) by Jiabao Sun · 9 months ago
  13. 7ceae5e [hotfix] Remove Calcite classes from Hive connector by Sergey Nuyanzin · 7 months ago
  14. 43491d0 [FLINK-33551][Connectors/Hive] Fix HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable nightly CI fails by Jiabao Sun · 7 months ago
  15. 4e3f699 [FLINK-33478][hive] Enable foldExpr by default in filter condition (#23682) by yunfan123 · 7 months ago
  16. 91a7419 [FLINK-33023][table-planner][JUnit5 Migration] Module: flink-connectors/flink-connector-hive (TableTestBase) by Jiabao Sun · 9 months ago
  17. 348503d [FLINK-33226][table] Forbid to drop current database by Ferenc Csaky · 8 months ago
  18. 7c75e69 [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect by yunfan123 · 8 months ago
  19. bec407e [FLINK-25593][table-planner] Skip redundant scan while partition table push down contains none-existent partition (#23423) by yunhong · 8 months ago
  20. 14234e2 [FLINK-32223][runtime][security] Add Hive delegation token support by jiaoqingbo · 8 months ago
  21. 634265b [FLINK-32978][flink-core] Migrate the usage of RichFunction#open(Configuration parameters) to RichFunction#open(OpenContext openContext) by Wencong Liu · 9 months ago
  22. 77a9bd4 [FLINK-32731][e2e] Fix NameNode uses port 9870 in hadoop3 by Shengkai · 9 months ago
  23. 7f71579 [FLINK-32620][sink] Migrate DiscardingSink to sinkv2. by Weijie Guo · 11 months ago
  24. 13ca975 [FLINK-32982][doc] Not to suggest to swap flink-table-planner lib for using Hive dialect by luoyuxia · 9 months ago
  25. b899b5a [FLINK-32731][e2e] Add retry mechanism when fails to start the namenode (#23267) by Shengkai · 9 months ago
  26. 44efc62 [FLINK-32760][Connectors/Hive] Reshade shaded parquet in flink-sql-connector-hive (#23166) by dongwoo6kim · 9 months ago
  27. 85d7729 Update version to 1.19-SNAPSHOT by jingge · 9 months ago
  28. 8df9a6b [FLINK-32731][e2e] Backup the hive-metastore, hdfs namenode and mysql logs (#23155) by Shengkai · 10 months ago
  29. 24be94e [FLINK-32656][table] Deprecate ManagedTable related APIs by Jane Chan · 10 months ago
  30. 292e985 Revert "[FLINK-32223][runtime][security] Add Hive delegation token support" by Matthias Pohl · 10 months ago
  31. fe21c31 [FLINK-32223][runtime][security] Add Hive delegation token support by jiaoqingbo · 10 months ago
  32. 2d23cf1 [FLINK-31575][hive] Avoid swapping table-planner-loader and table-planner to use hive dialect (#22862) by yuxia Luo · 10 months ago
  33. bc97ae3 [FLINK-32365][hive] Allow Hive source to scan table to get statistics in parallel (#22805) by baiwuchang · 11 months ago
  34. 22bf089 [FLINK-32388][filesystem]Add the ability to pass parameters to CUSTOM PartitionCommitPolicy (#22831) by Bangui Dunn · 11 months ago
  35. cbe7c2c [FLINK-32526] Bump Apache Parquet from 1.12.3 to 1.13.1 by Sergey Nuyanzin · 11 months ago
  36. f7de674 [FLINK-32410] Replace new LinkedHashMap<>(size) with CollectionUtil.newLinkedHashMapWithExpectedSize(size) by Stefan Richter · 12 months ago
  37. 55f31e4 [FLINK-32410] Replace new HashSet<>(size) with CollectionUtil.newHashSetWithExpectedSize(size) by Stefan Richter · 12 months ago
  38. d32bdf8 [FLINK-32410] Replace new HashMap<>(size) with CollectionUtil.newHashMapWithExpectedSize(size) by Stefan Richter · 12 months ago
  39. cb235d7 [FLINK-32032] Upgrade to flink-shaded 17.0. This closes #22546 by MartijnVisser · 11 months ago
  40. a9b331c [FLINK-31413][hive] Change scope of flink-table-planner dependency from provided to test in Hive connector by luoyuxia · 1 year, 1 month ago
  41. 1988323 [FLINK-31413][hive] HiveParser allows to parse Flink's special commands by luoyuxia · 1 year, 1 month ago
  42. b73ee29 [FLINK-31413][hive] Copy HintPredicate,NodeTypeHintPredicate, LogicalDistribution,LogicalScriptTransform,ExpressionBuilder by luoyuxia · 1 year, 1 month ago
  43. de1bd01 [FLINK-31413][hive] Remove usage org.apache.flink.table.planner.functions.* of in Hive connector by luoyuxia · 1 year, 1 month ago
  44. ff98871 [FLINK-31413][hive] Hive connector shouldn't use OperationConverterUtils by luoyuxia · 1 year, 1 month ago
  45. ba81cd7 [FLINK-31413][hive] Hive connector shouldn't use PlannerQueryOperation by luoyuxia · 1 year, 1 month ago
  46. 49741ce [FLINK-32294][e2e] Fix HiveITCase failure (#22740) by yuxia Luo · 12 months ago
  47. 8fc54f1 [FLINK-30660][e2e] Add e2e test for hive by luoyuxia · 1 year ago
  48. 7112338 [docs] Deduplicate mistakenly repeated words by Rich Bowen · 1 year ago
  49. 20ddff0 [FLINK-28203][build] Mark bundled dependencies as optional by Chesnay Schepler · 2 years ago
  50. 8953ca7 [hotfix][hive] Mark mapreduce-client-core as provided by Chesnay Schepler · 1 year, 1 month ago
  51. 021a39c [FLINK-30815][tests] Migrate BatchAbstractTestBase to junit5 by Yuxin Tan · 1 year, 1 month ago
  52. f5d7921 [FLINK-31409][hive] Hive dialect shouldn't use interfaces in table-planner to build LogicPlan by luoyuxia · 1 year, 3 months ago
  53. a7df471 [FLINK-31409][table] Introduce public interfaces for pluggable dialect by luoyuxia · 1 year, 3 months ago
  54. 3f18cab [FLINK-31804] Allow MiniClusterTestEnvironment by Chesnay Schepler · 1 year, 1 month ago
  55. 7202a3d [hotfix] replace deprecated calcite apis by Sergey Nuyanzin · 1 year, 6 months ago
  56. bb09935 [FLINK-31531][hive] Fix HiveCatalogHiveMetadataTest&HiveDialectITCase failure in Hive3 (#22230) by yuxia Luo · 1 year, 2 months ago
  57. 76b85cf [hotfix] Update copyright NOTICE year to 2023 by Robert Metzger · 1 year, 2 months ago
  58. 8fa2662 [FLINK-31487][table-planner] Add targetColumns to DynamicTableSink#Context by lincoln lee · 1 year, 2 months ago
  59. 337e2c7 [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector (#21522) by Aitozi · 1 year, 2 months ago
  60. dd328d2 [FLINK-31369][sql-gateway] Harden modifiers in tests for sql-gateway module by Sergey Nuyanzin · 1 year, 3 months ago
  61. 290ccf5 [FLINK-30659][hive] Drop flink-sql-parser-hive module (#22106) by yuxia Luo · 1 year, 3 months ago
  62. 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 · 1 year, 3 months ago
  63. e450d61 [FLINK-31239][hive] Fix native sum function can't get the corrected value when the argument type is string by fengli · 1 year, 3 months ago
  64. 79f1390 [FLINK-31124][Connectors/Hive] Add IT case for HiveTableSink speculative execution by shuiqiangchen · 1 year, 3 months ago
  65. 5f3adfe [FLINK-31132][hive] Let hive compact operator without setting parallelism subject to sink operator's configured parallelism. by Weijie Guo · 1 year, 3 months ago
  66. ac1d019 [hotfix][test] Migrate HiveTableCompactSinkTICase, HiveTableFactoryTest, HiveTableSinkITCase to Junit5 and AssertJ. by Weijie Guo · 1 year, 3 months ago
  67. 9683e33 [hotfix] Fix typo in HiveTableSink and HiveTableCompactSinkITCase. by Weijie Guo · 1 year, 3 months ago
  68. 8d80f85 [FLINK-31175][doc] Fix link doesn't work in hive_read_write doc (#21988) by Shengkai · 1 year, 3 months ago
  69. 43f0e85 [FLINK-31137][hive] Fix wrong ResultKind in DescribeTable and ShowCreateTable results (#21980) by Shengkai · 1 year, 3 months ago
  70. 90d8c1f [FLINK-30824][hive] Add document for option 'table.exec.hive.native-agg-function.enabled' by Ron · 1 year, 3 months ago
  71. 8f29257 Update version to 1.18-SNAPSHOT by Leonard Xu · 1 year, 4 months ago
  72. cbe2ab2 [FLINK-30386] Fix the issue that column constraint lacks primary key not enforced check by Jane Chan · 1 year, 4 months ago
  73. 4d26bcd [FLINK-30006][table-planner] Make all pure dynamic functions non-deterministic in streaming mode to avoid wrong plans by lincoln.lil · 1 year, 5 months ago
  74. b9d9ba8 [FLINK-30686][conf] Refine adaptive batch configurations by JunRuiLee · 1 year, 4 months ago
  75. 13a383b [FLINK-30685][runtime] Mark transformations of which the parallelism is infected by input transformations by JunRuiLee · 1 year, 4 months ago
  76. b793281 [FLINK-30684][runtime] Mark vertices which use the default parallelism by JunRuiLee · 1 year, 4 months ago
  77. 567afbf [FLINK-29880][hive] Introduce auto compaction for Hive sink in batch mode (#21703) by yuxia Luo · 1 year, 4 months ago
  78. d9d9875 [FLINK-30692][sql-client] Introduce SingleSessionManager to support REMOVE JAR syntax (#21771) by Shengkai · 1 year, 4 months ago
  79. f47d0c1 [FLINK-27920][hive] Supports native avg function for hive dialect by fengli · 1 year, 5 months ago
  80. 79e5519 [FLINK-30683][runtime] Use AdaptiveBatchScheduler as default batch scheduler by JunRuiLee · 1 year, 5 months ago
  81. ab7c501 [FLINK-30679][hive] Fix IndexOutOfBoundsException for Hive lookup join when column pushdown to Hive lookup table source #21731 by hehuiyuan · 1 year, 4 months ago
  82. 3a0703e [FLINK-29878][hive] Include libfb303 to fix fail to use flink-sql-connector-hive-3.1.3 by luoyuxia · 1 year, 4 months ago
  83. d57cf0a [FLINK-30567][hive] Fix wrong behavior for insert overwrite with Hive dialect when the table contains uppercase character (#21602) by yuxia Luo · 1 year, 4 months ago
  84. 4f184f9 [FLINK-29945][sql-client] Supports to submit SQL to an embedded SQL Gateway in the SQL Client by Shengkai · 1 year, 4 months ago
  85. 2230642 [FLINK-29722][hive] Supports native hive max function for hive dialect by fengli · 1 year, 5 months ago
  86. 4f058f2 [FLINK-29719][hive] Supports native count function for hive dialect by fengli · 1 year, 5 months ago
  87. 984d9da [FLINK-29721][hive] Supports native hive min function for hive dialect by Tartarus0zm · 1 year, 5 months ago
  88. ae5b376 [FLINK-30693][sql-gateway] Supports to specify RowFormat when fetching results by yuzelin · 1 year, 5 months ago
  89. 1ee0ce5 [FLINK-30579][hive] Introducing configurable option to use hive native function by fengli · 1 year, 5 months ago
  90. 3984b5d [FLINK-30617][hive] Fix wrong data type for cast null literal with Hive dialect by luoyuxia · 1 year, 5 months ago
  91. 1d3764a [FLINK-19883][table] Support "IF EXISTS" in DDL for ALTER TABLE by Jane Chan · 1 year, 5 months ago
  92. 5b2a8cf [FLINK-27640][Connector/Hive] Exclude pentaho-aggdesigner-algorithm from Hive connector dependencies. This closes #21653 by Chen Qin · 1 year, 5 months ago
  93. a94da37 [FLINK-29950][sql-gateway] Refactor ResultSet to an interface by yuzelin · 1 year, 5 months ago
  94. 483e91a [hotfix] Rename incorrect reference to Hive specific Hadoop version by Martijn Visser · 1 year, 5 months ago
  95. b1835c8 [FLINK-27640][Connector/Hive][SQL Client] Exclude Pentaho dependency from Hive to avoid build problems with newer Maven versions. Newer Maven versions block http repositories such as conjars. Conjars is where Pentaho artifacts are stored by Martijn Visser · 1 year, 5 months ago
  96. 9bb74b6 [FLINK-30491][hive] Hive table partition supports lazy deserialization during runtime by fengli · 1 year, 5 months ago
  97. 02e40a9 [FLINK-29710][Hadoop/Hive] Exclude Reload4J from all Hadoop and Hive dependencies by Martijn Visser · 1 year, 7 months ago
  98. 2def8a8 [FLINK-29710][Filesystem] Bump minimum supported Hadoop version to 2.10.2 by Martijn Visser · 1 year, 7 months ago
  99. 4ef3138 [FLINK-30592][doc] Remove unsupported hive version in hive overview document (#21611) by libowen · 1 year, 5 months ago
  100. ec603ef [FLINK-30497][table-api] Introduce TableChange to represent DROP change by Shengkai · 1 year, 5 months ago