apache/flink issues and pull requests

#21140 - [FLINK-25909][runtime][security] Add HBaseDelegationTokenProvider

Pull Request - State: closed - Opened by gaborgsomogyi about 2 years ago - 7 comments
Labels: component=<none>

#21098 - [FLINK-29622][runtime][security] Start kerberos delegation token provider only if the user provided valid credentials

Pull Request - State: closed - Opened by gaborgsomogyi about 2 years ago - 4 comments
Labels: component=Runtime/Coordination, component=Tests

#21073 - [FLINK-26822] Add Source for Cassandra connector

Pull Request - State: closed - Opened by echauchot about 2 years ago - 10 comments
Labels: component=Connectors/Cassandra

#20991 - [FLINK-25538][flink-connector-kafka] JUnit5 Migration

Pull Request - State: closed - Opened by ashmeet-kandhari about 2 years ago - 28 comments
Labels: component=Connectors/Kafka

#20926 - Update ch temporal_table_function.md

Pull Request - State: closed - Opened by Alex5876 about 2 years ago - 1 comment

#20923 - Update temporal_table_function.md

Pull Request - State: closed - Opened by Alex5876 about 2 years ago - 2 comments

#20922 - [DRAFT] Apply changes for calcite 1.3x

Pull Request - State: open - Opened by snuyanzin about 2 years ago - 8 comments

#20922 - [DRAFT] Apply changes for calcite 1.3x

Pull Request - State: open - Opened by snuyanzin about 2 years ago - 9 comments

#20877 - [hotfix] Make doc ide_setup.md format better for code formatting

Pull Request - State: closed - Opened by liuml07 about 2 years ago - 5 comments

#20779 - [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

Pull Request - State: closed - Opened by SwimSweet about 2 years ago - 11 comments
Labels: component=flink-contrib, component=Deployment/Kubernetes

#20775 - [FLINK-29088][table] Extract the common project to enhance source reuse

Pull Request - State: open - Opened by Aitozi about 2 years ago - 8 comments
Labels: component=TableSQL/Planner

#20764 - [FLINK-29153][connector/kafka] Retry KafkaConsumer#commitAsync on WakeupException in KafkaConsumerThread

Pull Request - State: closed - Opened by PatrickRen about 2 years ago - 6 comments
Labels: component=Connectors/Kafka

#20701 - [FLINK-29128][Connectors/Kafka] Add a new situation for split changes handling result.

Pull Request - State: closed - Opened by leozhangsr about 2 years ago - 4 comments
Labels: component=Connectors/Kafka

#20671 - [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

Pull Request - State: closed - Opened by SwimSweet about 2 years ago - 9 comments
Labels: component=flink-contrib, component=Deployment/Kubernetes

#20562 - [FLINK-28950][HBase] Disable HBase2 version check in hbase-default.xml

Pull Request - State: closed - Opened by xicm over 2 years ago - 3 comments
Labels: component=Connectors/HBase

#20475 - [FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

Pull Request - State: closed - Opened by sap1ens over 2 years ago - 7 comments
Labels: component=Connectors/Kafka

#20382 - [FLINK-28419][table] Add runtime provider interface for full caching lookup + implement Periodic and Timed cache reload triggers

Pull Request - State: closed - Opened by SmirAlex over 2 years ago - 9 comments
Labels: component=<none>

#20368 - [FLINK-28696][runtime] Fix the bug that the blocklist listeners will not be notified when there are no newly added nodes (only merge nodes)

Pull Request - State: closed - Opened by wanglijie95 over 2 years ago - 1 comment
Labels: component=<none>

#20343 - [FLINK-25916][connector-kafka] Using upsert-kafka with a flush buffer…

Pull Request - State: closed - Opened by paul8263 over 2 years ago - 18 comments
Labels: component=Connectors/Kafka, component=TableSQL/Runtime

#20340 - [FLINK-26369][doc-zh] Translate the part zh-page mixed with not be translated.

Pull Request - State: closed - Opened by GOODBOY008 over 2 years ago - 7 comments
Labels: component=Documentation

#20340 - [FLINK-26369][doc-zh] Translate the part zh-page mixed with not be translated.

Pull Request - State: open - Opened by GOODBOY008 over 2 years ago - 2 comments
Labels: component=Documentation

#20327 - [FLINK-28595][Connectors/kafka] KafkaSource should not read metadata of unmatched regex topics

Pull Request - State: closed - Opened by JasonLeeCoding over 2 years ago - 14 comments
Labels: component=Connectors/Kafka

#20307 - [FLINK-28608][runtime][security]Make Hadoop FS token renewer configurable

Pull Request - State: closed - Opened by gaborgsomogyi over 2 years ago - 9 comments
Labels: component=<none>

#20289 - [FLINK-23633][FLIP-150][connector/common] HybridSource: Support dynamic stop position in FileSource

Pull Request - State: open - Opened by xinbinhuang over 2 years ago - 12 comments
Labels: component=Connectors/FileSystem

#20271 - [FLINK-28547][runtime] Add IT cases for SpeculativeScheduler.

Pull Request - State: closed - Opened by wanglijie95 over 2 years ago - 1 comment
Labels: component=Runtime/Coordination

#20265 - [FLINK-25910][runtime][security] Propagate obtained delegation tokens to TaskManagers

Pull Request - State: closed - Opened by gaborgsomogyi over 2 years ago - 13 comments
Labels: component=<none>

#20232 - [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

Pull Request - State: closed - Opened by X-czh over 2 years ago - 9 comments
Labels: component=Runtime/WebFrontend, component=Runtime/REST

#20231 - [FLINK-27056] "pipeline.time-characteristic" should be deprecated have EVENT_TIME as default value

Pull Request - State: closed - Opened by X-czh over 2 years ago - 1 comment
Labels: component=Runtime/Configuration

#20218 - [FLINK-28145][runtime] Let ResourceManager supports blocklist

Pull Request - State: closed - Opened by wanglijie95 over 2 years ago - 8 comments
Labels: component=Runtime/Coordination

#20164 - [FLINK-28370][connector/kafka] add close method to the interface KafkaRecordSerializationSchema

Pull Request - State: closed - Opened by ruanhang1993 over 2 years ago - 2 comments
Labels: component=Connectors/Kafka

#20137 - Just for CI

Pull Request - State: closed - Opened by 1996fanrui over 2 years ago - 1 comment

#20122 - [FLINK-27607][tests] Migrate module flink-connector-files to JUnit5

Pull Request - State: open - Opened by GOODBOY008 over 2 years ago - 2 comments
Labels: component=Tests

#20122 - [FLINK-27607][tests] Migrate module flink-connector-files to JUnit5

Pull Request - State: open - Opened by GOODBOY008 over 2 years ago - 2 comments
Labels: component=Tests

#20066 - [FLINK-25908][runtime][security] Add HadoopFSDelegationTokenProvider

Pull Request - State: closed - Opened by gaborgsomogyi over 2 years ago - 11 comments
Labels: component=<none>

#20048 - [FLINK-19869][connectors/jdbc] Add support for postgres UUID type

Pull Request - State: closed - Opened by bobby-richard over 2 years ago - 5 comments
Labels: component=Connectors/JDBC

#20011 - [FLINK-28112][filesystems] Fix error message when directly supported file system is not able to be handled

Pull Request - State: closed - Opened by gaborgsomogyi over 2 years ago - 7 comments
Labels: component=FileSystems

#19970 - [FLINK-27970][tests][JUnit5 migration] flink-hadoop-bulk

Pull Request - State: closed - Opened by RyanSkraba over 2 years ago - 4 comments
Labels: component=<none>

#19953 - [FLINK-28044][runtime][security] Make hadoop filesystems configuration available to all deployment targets

Pull Request - State: closed - Opened by gaborgsomogyi over 2 years ago - 4 comments
Labels: component=Connectors/Common

#19933 - [FLINK-28000][runtime][security] Throw exception when principal is set in the configuration without keytab

Pull Request - State: closed - Opened by gaborgsomogyi over 2 years ago - 4 comments
Labels: component=Deployment/YARN, component=Connectors/Common, component=Deployment/Kubernetes

#19897 - [FLINK-27885][tests][JUnit5 migration] flink-csv

Pull Request - State: closed - Opened by RyanSkraba over 2 years ago - 9 comments
Labels: component=Tests

#19873 - [FLINK-27891][Table] Add ARRAY_APPEND and ARRAY_PREPEND functions

Pull Request - State: open - Opened by snuyanzin over 2 years ago - 11 comments
Labels: component=TableSQL/API

#19870 - [FLINK-27882][tests][table] Migrate flink-scala to JUnit5

Pull Request - State: closed - Opened by snuyanzin over 2 years ago - 12 comments
Labels: component=Tests

#19866 - [FLINK-27876][table-planner] Choose the right side as build side when using default shuffle hash strategy if left size is equal with right

Pull Request - State: closed - Opened by xuyangzhong over 2 years ago - 9 comments
Labels: component=TableSQL/Planner

#19850 - [FLINK-27851][table-planner] support to access source pks through MiniBatchAssigner

Pull Request - State: closed - Opened by xuyangzhong over 2 years ago - 7 comments
Labels: component=TableSQL/Planner

#19825 - [FLINK-27171][runtime][security] Add periodic kerberos delegation token obtain possibility to DelegationTokenManager

Pull Request - State: closed - Opened by gaborgsomogyi over 2 years ago - 15 comments
Labels: component=<none>

#19811 - [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5

Pull Request - State: closed - Opened by snuyanzin over 2 years ago - 5 comments
Labels: component=Tests, component=TableSQL/Runtime

#19781 - Just for test : output buffer aligned to uc

Pull Request - State: closed - Opened by 1996fanrui over 2 years ago - 1 comment

#19684 - Add support to pass Datadog API Key as environment variable

Pull Request - State: open - Opened by pinxiu over 2 years ago - 2 comments

#19563 - [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core

Pull Request - State: closed - Opened by GOODBOY008 over 2 years ago - 4 comments
Labels: component=API/Core

#19468 - [FLINK-18286][table] Port type inference for collection types

Pull Request - State: closed - Opened by slinkydeveloper over 2 years ago - 2 comments
Labels: component=TableSQL/API

#19380 - [FLINK-25055][runtime] Support listen and notify mechanism for partition request

Pull Request - State: closed - Opened by FangYongs over 2 years ago - 3 comments
Labels: component=Runtime/Network

#19372 - [FLINK-26043][runtime][security] Add periodic kerberos relogin to KerberosDelegationTokenManager

Pull Request - State: closed - Opened by gaborgsomogyi over 2 years ago - 26 comments
Labels: component=<none>

#19300 - [hotfix] [connectors/hbase] Fix equal method of HBaseWriteOptions

Pull Request - State: closed - Opened by LB-Yu over 2 years ago - 2 comments

#19269 - [FLINK-26033][BP-1.13][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.11

Pull Request - State: closed - Opened by shizhengchao over 2 years ago - 3 comments
Labels: component=Connectors/Kafka

#19268 - [FLINK-26033][BP-1.14][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.11

Pull Request - State: closed - Opened by shizhengchao over 2 years ago - 4 comments
Labels: component=Connectors/Kafka

#19068 - [FLINK-26601][Connector/HBase]Flink HBase HBaseRowDataAsyncLookupFunc…

Pull Request - State: closed - Opened by zhisheng17 over 2 years ago - 3 comments
Labels: component=Connectors/HBase

#19067 - [FLINK-26614]Upsert Kafka SQL Connector:Support startup mode of timestamp and specific offsets

Pull Request - State: closed - Opened by mnmaning over 2 years ago - 6 comments
Labels: component=Connectors/Kafka

#18863 - [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.11

Pull Request - State: closed - Opened by shizhengchao over 2 years ago - 20 comments
Labels: component=Connectors/Kafka

#18849 - [FLINK-24407][doc-zh]Pulsar connector chinese document link to Pulsar document location incorrectly.

Pull Request - State: closed - Opened by GOODBOY008 over 2 years ago - 3 comments
Labels: component=Documentation

#18796 - [FLINK-26166][runtime-web] Add auto newline detection to prettier formatter

Pull Request - State: closed - Opened by gaborgsomogyi almost 3 years ago - 12 comments
Labels: component=Runtime/WebFrontend

#18794 - [FLINK-27986] Refactor the name of finish method for JdbcOutputFormatBuilder

Pull Request - State: closed - Opened by xleoken almost 3 years ago - 6 comments
Labels: component=<none>

#18752 - [FLINK-25651][docs] Modify the instance method variable in kafka.md of branch release-1.14

Pull Request - State: closed - Opened by jelly-1203 almost 3 years ago - 3 comments
Labels: component=Connectors/Kafka

#18744 - [FLINK-20454][format][debezium] Allow to read metadata for debezium-avro-confluent format

Pull Request - State: open - Opened by limer2 almost 3 years ago - 10 comments
Labels: component=Formats, component=TableSQL/Ecosystem

#18744 - [FLINK-20454][format][debezium] Allow to read metadata for debezium-avro-confluent format

Pull Request - State: open - Opened by limer2 almost 3 years ago - 10 comments
Labels: component=Formats, component=TableSQL/Ecosystem

#18664 - [FLINK-25907][runtime][security] Add pluggable delegation token manager

Pull Request - State: closed - Opened by gaborgsomogyi almost 3 years ago - 18 comments
Labels: component=<none>

#18407 - [FLINK-25669][runtime] Support register operator coordinators for newly initialized ExecutionJobVertex

Pull Request - State: closed - Opened by wanglijie95 almost 3 years ago - 4 comments
Labels: component=Runtime/Coordination

#18375 - [FLINK-25476][table-planner] support CHAR type in function MAX and MIN

Pull Request - State: closed - Opened by xuyangzhong almost 3 years ago - 2 comments
Labels: component=TableSQL/Planner

#18334 - [BP-1.14][FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to a…

Pull Request - State: open - Opened by paul8263 almost 3 years ago - 4 comments

#18304 - [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp

Pull Request - State: closed - Opened by cuibo01 almost 3 years ago - 21 comments
Labels: component=Formats

#18244 - [flink-24970] Reserve resources After waiting for the resources to be released, delete the topic

Pull Request - State: closed - Opened by kaori-seasons almost 3 years ago - 4 comments
Labels: component=Connectors/Kafka

#18109 - [FLINK-25284][Table SQL / API] Add proportion of null values to generate with datagen

Pull Request - State: open - Opened by snuyanzin almost 3 years ago - 8 comments
Labels: component=TableSQL/API

#17958 - FLINK-25029: Hadoop Caller Context Setting in Flink

Pull Request - State: open - Opened by liufangqi almost 3 years ago - 10 comments
Labels: component=FileSystems

#17830 - [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

Pull Request - State: open - Opened by snuyanzin almost 3 years ago - 19 comments
Labels: component=TableSQL/Client

#17830 - [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

Pull Request - State: open - Opened by snuyanzin almost 3 years ago - 19 comments
Labels: component=TableSQL/Client

#17765 - [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

Pull Request - State: closed - Opened by hililiwei about 3 years ago - 8 comments
Labels: component=Connectors/Kafka

#17536 - [FLINK-24530][datastream] GlobalCommitter might not commit all records on drain

Pull Request - State: closed - Opened by AHeise about 3 years ago - 3 comments
Labels: component=API/DataStream, component=Connectors/Common

#17357 - [FLINK-24375] Let name of flush thread in RecordWriter contain subtask index.

Pull Request - State: closed - Opened by wanglijie95 about 3 years ago - 2 comments
Labels: component=Runtime/Network

#17156 - [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

Pull Request - State: closed - Opened by gaborgsomogyi about 3 years ago - 4 comments
Labels: review=description?, component=Runtime/WebFrontend

#17022 - [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

Pull Request - State: closed - Opened by gaborgsomogyi about 3 years ago - 11 comments
Labels: review=description?, component=Runtime/WebFrontend

#16991 - [yarn] add a non empty check in registerMultipleLocalResources

Pull Request - State: closed - Opened by wangjunyou about 3 years ago - 2 comments
Labels: review=description?

#16973 - [FLINK-23953] In the AvroSerializerSnapshot set the serializer compatibility to 'AS IS' in case when underlying Avro schemas are compatible

Pull Request - State: open - Opened by izeigerman about 3 years ago - 3 comments
Labels: review=description?, component=API/TypeSerializationSystem

#16859 - [FLINK-23719] [connectors/hbase] Support switch WAL in Flink SQL DDL options for HBase sink

Pull Request - State: closed - Opened by LB-Yu over 3 years ago - 5 comments
Labels: review=description?, component=Connectors/HBase

#16764 - [FLINK-23693][tests] Add principal creation possibilities to SecureTestEnvironment

Pull Request - State: closed - Opened by gaborgsomogyi over 3 years ago - 7 comments
Labels: review=description?, component=Tests

#16758 - [FLINK-23688][hadoop] Make JaasModule.getAppConfigurationEntries public

Pull Request - State: closed - Opened by gaborgsomogyi over 3 years ago - 6 comments
Labels: review=description?, component=Connectors/HadoopCompatibility

#16629 - [FLINK-23847][connectors][kafka] improve error message when valueDeseriali…

Pull Request - State: closed - Opened by camilesing over 3 years ago - 5 comments
Labels: review=description?, component=Connectors/Kafka