Commits

Breadcrumbs

History for

on42c8aa5

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 4, 2019

• [FLINK-12572][hive]Implement HiveInputFormat to read Hive tables

  Show description for 38557bf
  

  zjuwangg

  authored and

  bowenli86

  committed
  38557bf

  Copy full SHA for 38557bf

• [FLINK-11249][kafka] Fix migration from FlinkKafkaProducer0.11 to universal

  Show description for 1de854a
  pnowojski

  committed
  1de854a

  Copy full SHA for 1de854a

• [FLINK-11249][kafka,test] Update Kafka migration resources with new NextTransactionalIdHint serializer

  pnowojski

  committed
  9be40f6

  Copy full SHA for 9be40f6

• [FLINK-11249][kafka] Use custom serializers for NextTransactionalIdHint in 0.11 and universal FlinkKafkaProducer

  

  yanghua

  authored and

  pnowojski

  committed
  70fa80e

  Copy full SHA for 70fa80e

Commits on Jun 3, 2019

• [FLINK-12568][hive] Implement OutputFormat to write Hive tables

  Show description for 1e0a166
  

  lirui-apache

  authored and

  bowenli86

  committed
  1e0a166

  Copy full SHA for 1e0a166

• [hotfix][hive] include jdo-api for hive-metastore to enable tests for profile hive-1.2.1

  bowenli86

  committed
  35f3996

  Copy full SHA for 35f3996

Commits on May 31, 2019

• [hotfix][hive] move hive metastore client and shim related classes to package 'org.apache.flink.table.catalog.hive.client'

  bowenli86

  committed
  8dd07bf

  Copy full SHA for 8dd07bf

• [hotfix][hive] remove jdo-api dependency from profile hive-1.2.1 in flink-connector-hive

  bowenli86

  committed
  9fa4ece

  Copy full SHA for 9fa4ece

• [hotfix][hive] make hive-metastore dependency scope to 'provided' as pre-requisite to support multiple hive versions

  Show description for 5bab9cd
  bowenli86

  committed
  5bab9cd

  Copy full SHA for 5bab9cd

• [FLINK-12649][hive] Add a shim layer to support multiple versions of Hive Metastore

  Show description for 038ab38
  

  lirui-apache

  authored and

  bowenli86

  committed
  038ab38

  Copy full SHA for 038ab38

• [FLINK-12676][table][sql-client] Add descriptor, validator, and factory of GenericInMemoryCatalog for table discovery service

  Show description for c691c13
  bowenli86

  committed
  c691c13

  Copy full SHA for c691c13

• [FLINK-12678][table] Add AbstractCatalog to manage the common catalog name and default database name for catalogs

  bowenli86

  committed
  ba648a5

  Copy full SHA for ba648a5

Commits on May 29, 2019

• [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

  tweise

  committed
  793a784

  Copy full SHA for 793a784

Commits on May 28, 2019

• [FLINK-12418][hive] Add input/output format and SerDeLib information when creating Hive table in HiveCatalog and add 'hive-exec' as provided dependency

  Show description for 97510aa
  

  lirui-apache

  authored and

  bowenli86

  committed
  97510aa

  Copy full SHA for 97510aa

Commits on May 27, 2019

• [FLINK-12618][build] Rework jdk.tools exclusion

  Show description for 5f27cb2
  zentol

  committed
  5f27cb2

  Copy full SHA for 5f27cb2

Commits on May 24, 2019

• [FLINK-12235][hive] Support partition related operations in HiveCatalog

  Show description for 95e1686
  

  lirui-apache

  authored and

  bowenli86

  committed
  95e1686

  Copy full SHA for 95e1686

Commits on May 23, 2019

• [FLINK-12236][hive] Support Hive function in HiveCatalog

  Show description for f74bbec
  bowenli86

  committed
  f74bbec

  Copy full SHA for f74bbec

• [FLINK-12127][network] Consolidate network options in NetworkEnvironmentOptions

  

  zhijiangW

  authored and

  zentol

  committed
  2f39736

  Copy full SHA for 2f39736

• [hotfix][connector-hive] Fix Hive type mapping to Table API type information

  twalthr

  committed
  9f19345

  Copy full SHA for 9f19345

• [FLINK-12582][table][hive] Alteration APIs in catalogs should check existing object and new object are of the same class

  Show description for aca9c01
  bowenli86

  committed
  aca9c01

  Copy full SHA for aca9c01

Commits on May 22, 2019

• [hotfix][hive] unify instantiateHiveDatabase() in HiveCatalog

  bowenli86

  committed
  702c489

  Copy full SHA for 702c489

• [FLINK-12241][hive] Support Flink functions in catalog function APIs of HiveCatalog

  Show description for 3813bb9
  bowenli86

  committed
  3813bb9

  Copy full SHA for 3813bb9

Commits on May 21, 2019

• [FLINK-12580][hive] Rename GenericHiveMetastoreCatalogTest to HiveCatalogFlinkMetadataTest, and HiveCatalogTest to HiveCatalogHiveMetadataTest

  Show description for fc8f567
  bowenli86

  committed
  fc8f567

  Copy full SHA for fc8f567

• [FLINK-12552][table]: Combine HiveCatalog and GenericHiveMetastoreCatalog

  Show description for 3fba21a
  

  Xuefu Zhang

  authored and

  bowenli86

  committed
  3fba21a

  Copy full SHA for 3fba21a

Commits on May 17, 2019

• [FLINK-12549][hive] include exceptions thrown by Hive metastore client in CatalogException in HiveCatalogBase

  bowenli86

  committed
  bd85d25

  Copy full SHA for bd85d25

• [hotfix] move HiveTypeUtil to util package 'org.apache.flink.table.catalog.hive.util'

  bowenli86

  committed
  a6cde22

  Copy full SHA for a6cde22

• [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

  Show description for ba30707
  bowenli86

  committed
  ba30707

  Copy full SHA for ba30707

Commits on May 16, 2019

• [hotfix][hive] return early in alterTable() to improve readability

  bowenli86

  committed
  04d3974

  Copy full SHA for 04d3974

Commits on May 15, 2019

• [FLINK-12511][table][hive] make variable 'comment' in all catalog metadata classes final

  Show description for 2b2c064
  bowenli86

  committed
  2b2c064

  Copy full SHA for 2b2c064

• [FLINK-12436][hive] Differentiate Flink database properties from Hive database properties

  Show description for 83324ec
  bowenli86

  committed
  83324ec

  Copy full SHA for 83324ec

Commits on May 14, 2019

• [FLINK-12234][hive] Support view related operations in HiveCatalog

  Show description for 544903d
  bowenli86

  committed
  544903d

  Copy full SHA for 544903d

• [FLINK-12505][hive] Unify database operations to HiveCatalogBase from its subclasses

  Show description for f7ecfdb
  bowenli86

  committed
  f7ecfdb

  Copy full SHA for f7ecfdb

• [FLINK-12469][table] Clean up catalog API on default/current database

  Show description for 1c3ac2f
  

  Xuefu Zhang

  authored and

  bowenli86

  committed
  1c3ac2f

  Copy full SHA for 1c3ac2f

Commits on May 13, 2019

• [FLINK-12233][hive] Support table related operations in HiveCatalog

  Show description for f919b23
  bowenli86

  committed
  f919b23

  Copy full SHA for f919b23

Commits on May 8, 2019

• [FLINK-12417][table] Unify ReadableCatalog and ReadableWritableCatalog interfaces to Catalog interface

  Show description for c954780
  bowenli86

  committed
  c954780

  Copy full SHA for c954780

Pagination

Previous

Next