issues  

Messages by Thread

• [jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-25244) Deprecate Java 8 support Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-25283) End-to-end application modules create oversized jars Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-25043) Allow calls to public @VisibleForTesting from the same package Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24901) Some further improvements of the pluggable shuffle framework Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24683) Add Support for Azure Synapse Analytics Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24547) A function named row_kind() can get row_kind Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24666) Add job level "table.exec.state-stale.error-handling" option and apply to related stateful stream operators Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24636) Move cluster deletion operation cache into ResourceManager Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24517) Streamline Flink releases Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21184) Support temporary table/function for hive connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24258) Connection timed out or very slowly when visiting Flink website Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24306) group by index throw SqlValidatorException Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22237) Flamegraph component calls draw method from template Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23379) interval left join null value result out of order Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24048) Move changeLog inference out of optimizing phase Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24192) Sql get plan failed. All the inputs have relevant nodes, however the cost is still infinite Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24201) HistoryServer didn't contain TaskManager Logs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24140) Enhance the ITCase for FLIP-147 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23997) Improvement for SQL windowing table-valued function Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24169) Flaky local YARN tests relying on log files Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24125) Rethink relationship between DeclarativeSlotPool and *Bridge Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24122) Add support to do clean in history server Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24094) Support DROP PARTITION by partial partition specification Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23752) Add document for using HiveSource API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23900) Migrate to ClusterActorRefProvider Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23660) Hive Catalog support truncate table Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23623) Over expression should allow to order by any fields in batch mode Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23403) Decrease default values for heartbeat timeout and interval Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23412) Improve sourceSink description Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23445) Separate data and timer connection into different channels for Python Table API operators Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23147) ThreadPools can be poisoned by context class loaders Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22960) Temporal join TTL should use enableTimeToLive of state instead of timer Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22975) Specify port or range for k8s service Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22371) Chinese grammatical error Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent Yuepeng Pan (Jira)
• [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)

• Earlier messages