issues  

Messages by Thread

• [jira] [Updated] (FLINK-22594) Report oom killed pod in k8s resource manager Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22553) Improve error reporting on TM connection failures Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19432) Whether to capture the updates which don't change any monitored columns Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19527) Update SQL Pages Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source) Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19774) Introduce Sub Partition View Version for Approximate Local Recovery Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20865) Prevent potential resource deadlock in fine-grained resource management Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20952) Changelog json formats should support inherit options from JSON format Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21179) Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20920) Document how to connect to kerberized HMS Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21125) Sum or Sum0 overflow quietly Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21053) Prevent potential RejectedExecutionExceptions in CheckpointCoordinator failing JM Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20818) End to end test produce excessive amount of logs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses ASF GitHub Bot (Jira)
• [PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [flink] via GitHub
  • Re: [PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [flink] via GitHub
  • Re: [PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [flink] via GitHub
  • Re: [PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [flink] via GitHub
• [jira] [Created] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses Ramin Gharib (Jira)
• Re: [PR] [FLINK-34466][LINEAGE] Support dataset type facet for Avro [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-34466][LINEAGE] Support dataset type facet for Avro [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader [flink] via GitHub
• [jira] [Updated] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization ASF GitHub Bot (Jira)
• [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
  • Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink] via GitHub
• Re: [PR] [common] Add PatternCache to optimize regex compilation performance [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization Swapna Marru (Jira)
• [jira] [Updated] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields ASF GitHub Bot (Jira)
• [PR] [FLINK-39604][table] Surface PTF metadata in DESCRIBE FUNCTION EXTENDED [flink] via GitHub
  • Re: [PR] [FLINK-39604][table] Surface PTF metadata in DESCRIBE FUNCTION EXTENDED [flink] via GitHub
• [jira] [Commented] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state Sophia Izokun (Jira)
• [jira] [Created] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields Natea Eshetu Beshada (Jira)
• [jira] [Updated] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation ASF GitHub Bot (Jira)
• [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink] via GitHub
  • Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink] via GitHub
  • Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink] via GitHub
  • Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink] via GitHub
  • Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink] via GitHub
  • Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink] via GitHub
  • Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink] via GitHub
• [jira] [Updated] (FLINK-39603) Optimize NativeS3InputStream via seeks and reduce IOPS ASF GitHub Bot (Jira)
• [PR] [FLINK-39603] Optimize NativeS3InputStream via seeks and reduce IOPS [flink] via GitHub
  • Re: [PR] [FLINK-39603] Optimize NativeS3InputStream via seeks and reduce IOPS [flink] via GitHub
  • Re: [PR] [FLINK-39603] Optimize NativeS3InputStream via seeks and reduce IOPS [flink] via GitHub
• Re: [PR] [FLINK-39089][SQL] Enhanced projection field alias display [flink] via GitHub
• [jira] [Created] (FLINK-39603) Optimize NativeS3InputStream via seeks and reduce IOPS Samrat Deb (Jira)
• [jira] [Commented] (FLINK-39560) [PROPOSAL] Allow custom, pre-configured AWS S3 clients to be injected into new Native S3 filesystem Samrat Deb (Jira)
• [PR] Update Dockerfiles for 1.20.4 release [flink-docker] via GitHub
  • Re: [PR] Update Dockerfiles for 1.20.4 release [flink-docker] via GitHub
• [PR] Add GPG key for 1.20.4 release [flink-docker] via GitHub
  • Re: [PR] Add GPG key for 1.20.4 release [flink-docker] via GitHub
• [jira] [Updated] (FLINK-39602) Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions ASF GitHub Bot (Jira)
• [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
  • Re: [PR] [FLINK-39602][table] Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions [flink] via GitHub
• [jira] [Updated] (FLINK-39601) Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API ASF GitHub Bot (Jira)
• [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
  • Re: [PR] [FLINK-39601][table] Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API [flink] via GitHub
• [jira] [Created] (FLINK-39602) Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39601) Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais (Jira)
• [jira] [Commented] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil Khaled Hammouda (Jira)
• [jira] [Closed] (FLINK-39474) Release Testing Instructions: FLINK-37399: Watermark alignment can prevent backlogged jobs from using all available resources Piotr Nowojski (Jira)
• [PR] [hotfix][docs] Fix inaccurate description of slot sharing benefit [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix inaccurate description of slot sharing benefit [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix inaccurate description of slot sharing benefit [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix inaccurate description of slot sharing benefit [flink] via GitHub
• [PR] [FLINK-34620] Fix stack overflow in recursive protobuf message handling in `flink-protobuf` [flink] via GitHub
  • Re: [PR] [FLINK-34620] Fix stack overflow in recursive protobuf message handling in `flink-protobuf` [flink] via GitHub
• [jira] [Updated] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20154) Improve error messages when using CLI with wrong target Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka) Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19935) Supports configure heap memory of sql-client to avoid OOM Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21408) Clarify which DataStream sources support Batch execution Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21409) Add Avro to DataTypes & Serialization docs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft() Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18981) Support column comment for Hive tables Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16323) Support to join a static table in streaming mode Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17539) Migrate the configuration options which do not follow the xyz.max/min pattern. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19254) Invalid UTF-8 start byte exception Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39557) Invalid multi-release JAR for flink-shaded-jackson Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-15860) Store temporary functions as CatalogFunctions in FunctionCatalog Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17683) Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction， but not when it is a field of case class. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16799) add hive partition limit when read from hive Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16126) Translate all connector related pages into Chinese Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16701) Elasticsearch sink support alias for indices. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16137) Translate all DataStream API related pages into Chinese Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39595) Use GHA cache per branch Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14934) Remove error log statement in ES connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14707) Refactor checkpoint related methods within Environment Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14471) Hide error message when metric api failed Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14684) Add Pinterest to Chinese Powered By page Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14690) Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL Client Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-15000) WebUI Metrics is very slow in large parallelism Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-39561) Extend sensitive key redaction with missing access key patterns and user-configurable additional keys Gabor Somogyi (Jira)
• [jira] [Resolved] (FLINK-39561) Extend sensitive key redaction with missing access key patterns and user-configurable additional keys Gabor Somogyi (Jira)
• [jira] [Commented] (FLINK-39561) Extend sensitive key redaction with missing access key patterns and user-configurable additional keys Gabor Somogyi (Jira)
• [jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-15003) Improve hive test performance Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format Yuepeng Pan (Jira)

• Earlier messages