Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 13, 2021

• [FLINK-20848][connector/kafka] Fix Kafka consumer client ID with subtask ID suffix (apache#14556)

  PatrickRen

  authored
  9313b01

  Copy full SHA for 9313b01

Commits on Jan 9, 2021

• [FLINK-20906][legal] Update copyright year to 2021 for NOTICE files.

  Show description for 67d167c
  xintongsong

  committed
  67d167c

  Copy full SHA for 67d167c

Commits on Jan 7, 2021

• [FLINK-18090] Update tests for new Row.toString

  Show description for 73cdd3d
  twalthr

  committed
  73cdd3d

  Copy full SHA for 73cdd3d

Commits on Jan 6, 2021

• [FLINK-20711][docs] Fix failure-handler parameter enumeration value typo in ES connector doc

  Show description for fd448ef
  

  Jie Wang

  authored and

  wuchong

  committed
  fd448ef

  Copy full SHA for fd448ef

Commits on Jan 5, 2021

• [FLINK-20822][hive] Don't check whether a function is generic in Hive catalog

  Show description for 4e9de84
  lirui-apache

  authored
  4e9de84

  Copy full SHA for 4e9de84

Commits on Dec 31, 2020

• [FLINK-20385][canal-json] Allow to read metadata for canal-json format

  Show description for 814fe0e
  SteNicholas

  authored
  814fe0e

  Copy full SHA for 814fe0e

Commits on Dec 28, 2020

• [FLINK-20651] Format code with Spotless/google-java-format

  

  Rufus Refactor

  authored and

  zentol

  committed
  c6997c9

  Copy full SHA for c6997c9

• [FLINK-20651] Fix formatting that doesn't work with google-java-format/checkstyle

  

  aljoscha

  authored and

  zentol

  committed
  ce427e7

  Copy full SHA for ce427e7

• [hotfix] Fix incorrect license headers

  

  aljoscha

  authored and

  zentol

  committed
  d7dae84

  Copy full SHA for d7dae84

• [FLINK-20540][jdbc] Fix JdbcCatalog connection exception when baseUrl doesn't end with slash

  Show description for 8da64d7
  

  kougazhang

  and

  zhao.zhang

  authored
  8da64d7

  Copy full SHA for 8da64d7

Commits on Dec 27, 2020

• [FLINK-20657][connectors/jdbc] Migrate jdbc InputFormat/LookupFunction to SimpleJdbcConnectionProvider for connection establishment

  Show description for 0c36b66
  kezhuw

  authored
  0c36b66

  Copy full SHA for 0c36b66

• [FLINK-19650][jdbc][table] Support limit push down for the JDBC connector

  Show description for a859e2c
  fsk119

  authored
  a859e2c

  Copy full SHA for a859e2c

Commits on Dec 25, 2020

• [FLINK-20710][hive] Hive reading fail when splits on different FileSystem nameservices

  Show description for 5ffcfca
  JackWangCS

  authored
  5ffcfca

  Copy full SHA for 5ffcfca

• [FLINK-19691][jdbc] Support connection.max-retry-timeout configuration for JDBC connector

  Show description for f5e829c
  

  肖佳文

  authored and

  wuchong

  committed
  f5e829c

  Copy full SHA for f5e829c

• [FLINK-20552][jdbc] JdbcDynamicTableSink doesn't sink buffered data on checkpoint

  Show description for 21a08ea
  

  meijies

  authored and

  wuchong

  committed
  21a08ea

  Copy full SHA for 21a08ea

Commits on Dec 23, 2020

• [FLINK-20519][hbase] Fix NOTICE file for bundled dependencies in flink-sql-connector-hbase-2.2

  Show description for a557658
  xintongsong

  committed
  a557658

  Copy full SHA for a557658

Commits on Dec 22, 2020

• [FLINK-20546][kafka] Fix util method misuse in KafkaDynamicTableFactoryTest

  Show description for 5fb6c0b
  zoucao

  authored
  5fb6c0b

  Copy full SHA for 5fb6c0b

• [FLINK-19942][jdbc] Support sink parallelism configuration for JDBC connector

  Show description for 2ac4735
  

  zhuxiaoshang

  and

  zhuxiaoshang

  authored
  2ac4735

  Copy full SHA for 2ac4735

Commits on Dec 21, 2020

• [FLINK-20629][kinesis] Migrate from DescribeStream to DescribeStreamSummary

  Show description for d900d90
  

  dannycranmer

  authored and

  tzulitai

  committed
  d900d90

  Copy full SHA for d900d90

• [FLINK-20630][dynamodb] DynamoDB Streams Consumer fails to consume from Latest

  Show description for 1fcbdb1
  

  dannycranmer

  authored and

  tzulitai

  committed
  1fcbdb1

  Copy full SHA for 1fcbdb1

• [FLINK-19435][connectors/jdbc] Fix deadlock when loading different sql driver classes concurrently using Class.forName

  Show description for 84ed653
  

  kezhuw

  authored and

  wuchong

  committed
  84ed653

  Copy full SHA for 84ed653

• [FLINK-19435][connectors/jdbc] Add hang test case to reveal deadlock when loading different sql driver classes concurrently using Class.forName

  Show description for 7ca2dd3
  

  kezhuw

  authored and

  wuchong

  committed
  7ca2dd3

  Copy full SHA for 7ca2dd3

Commits on Dec 19, 2020

• [FLINK-19905][jdbc] Fix the 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

  Show description for cc9ccc4
  

  xiaoHoly

  and

  肖佳文

  authored
  cc9ccc4

  Copy full SHA for cc9ccc4

Commits on Dec 16, 2020

• [FLINK-19259][kinesis] Remove references to allow classloader unloading

  rmetzger

  committed
  46d3f20

  Copy full SHA for 46d3f20

• [hotfix][jdbc] Fix invalid string format

  Show description for 4483e0b
  rmetzger

  committed
  4483e0b

  Copy full SHA for 4483e0b

Commits on Dec 15, 2020

• [FLINK-20509][table-planner-blink] Refactor verifyPlan methods in TableTestBase

  Show description for 7b68d53
  godfreyhe

  authored
  7b68d53

  Copy full SHA for 7b68d53

Commits on Dec 9, 2020

• [hotfix][elasticsearch] Fix javadoc of Elasticsearch6Configuration

  Show description for 3295a2b
  zhisheng17

  authored
  3295a2b

  Copy full SHA for 3295a2b

• [FLINK-20500][upsert-kafka] Fix unstable UpsertKafkaTableITCase.testTemporalJoin

  Show description for b82585f
  fsk119

  authored
  b82585f

  Copy full SHA for b82585f

Commits on Dec 8, 2020

• [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

  Show description for b361027
  azagrebin

  committed
  b361027

  Copy full SHA for b361027

• [FLINK-20419][hive] Add tests for dynamic partition with order by

  Show description for a40b261
  

  lirui-apache

  authored and

  wuchong

  committed
  a40b261

  Copy full SHA for a40b261

Commits on Dec 7, 2020

• [FLINK-20273][table/kafka] Fix the Kafka 'round-robin' partitioner behaviour when message keys are specified

  Show description for d59e9f9
  fsk119

  authored
  d59e9f9

  Copy full SHA for d59e9f9

• [hotfix][hbase][legal] Remove invalid NOTICE entries

  HuangXingBo

  authored
  869d5e6

  Copy full SHA for 869d5e6

• [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

  Show description for 09ec2ae
  leonardBang

  authored
  09ec2ae

  Copy full SHA for 09ec2ae

• [FLINK-20429][kafka] Using proper watermark interval in KafkaTableITCase#testKafkaTemporalJoinChangelog test

  Show description for 803ae41
  leonardBang

  authored
  803ae41

  Copy full SHA for 803ae41

• [FLINK-20455][build][legal] Bundle LICENSE/NOTICE in various deployed jars

  

  rmetzger

  authored and

  zentol

  committed
  8fe1928

  Copy full SHA for 8fe1928

Pagination

Previous

Next