issues  

Messages by Thread

• [PR] [FLINK-36779][table] Fix metric is incorrect and non-changing during the time in Rank [flink] via GitHub
  • Re: [PR] [FLINK-36779][table] Fix metric is incorrect and non-changing during the time in Rank [flink] via GitHub
• Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Xiqian Yu (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Xiqian Yu (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Samrat Deb (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Samrat Deb (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Yuepeng Pan (Jira)
• Re: [PR] [FLINK-39228][starrocks] Escape quoted default/comment literals in DDL [flink-cdc] via GitHub
• Re: [PR] [FLINK-39036][formats] Honor microsecond Avro logical types in RowDataToAvroConverters [flink] via GitHub
  • Re: [PR] [FLINK-39036][formats] Honor microsecond Avro logical types in RowDataToAvroConverters [flink] via GitHub
  • Re: [PR] [FLINK-39036][formats] Honor microsecond Avro logical types in RowDataToAvroConverters [flink] via GitHub
• [jira] [Resolved] (FLINK-39502) Performance regression in remoteSortPartition and compressedFilePartition David Anderson (Jira)
• [jira] [Updated] (FLINK-39502) Performance regression in remoteSortPartition and compressedFilePartition David Anderson (Jira)
• [jira] [Updated] (FLINK-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37248) Scala was removed in flink 2.0 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37340) Flink supports pushing metrics immediately at the end of the task. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37549) Some scala and markdown syntax errors in tableApi page Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37431) We should use guava Lists instead of curator shade Lists to avoid unnecessary error Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37404) Reenable Migration Tests for Filnk 2.x Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38516) Add configuration option to enable read-only mode for Flink SQL Gateway Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38172) Update japicmp configuration Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38151) Class MetricFetcherImpl's method fetchMetrics failed log level adjustment to error Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38510) Remove targetColumns from the digest generation of SinkReuser Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38071) FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37477) Emit full deletes from StreamJoin if it gets deletes on key on input Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37442) Properly delete the directories for ForSt remote storage Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38120) FLIP-536 Add latest checkpoint details endpoint Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37624) Support enableAsyncState and switch operator after datastream transformation Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37551) Improve the state compatibility of ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37593) Add Some Reduce Expression Rules Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-37554) Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37554) Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37526) Promote SinkV2 API classes from @Experimental to @PublicEvolving Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37117) Add docs for async state SQL operators in 2.0 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37088) When the Flink application is running in k8s, the taskmanager log lacks a mount mapping to the host machine. Once the container is restarted, the log will disappear. It is necessary to have a log mount mapping to the host machine Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3) Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3) ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36660) Release flink-connector-elasticsearch v4.0.0 for Flink 2.0 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36658) Support and Release Connectors for Flink 2.0 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38551) Extend MultiJoin tests based on current join tests Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38570) FLIP-554: Pipeline Testing Framework for Flink Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38595) Extend MultiJoin tests for further validation Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36399) cast result is incorrect Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36485) Remove deprecated method `StreamTableEnvironment#fromDataStream` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36487) Remove deprecated method `StreamTableEnvironment#createTemporaryView` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36381) Remove legacy csv source/sink in python module Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36479) Remove deprecated methods `Table#getSchema` and `Table#as` Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36186) Speed up RocksDB close during manual compaction Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36378) Fix type extraction bug between java BigDecimal and sql decimal. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-36378) Fix type extraction bug between java BigDecimal and sql decimal. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36354) Enable FORSTDB_BACKEND in async releated tests Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36363) Remove references to scala-relate api in tests among table modules Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36290) OutOfMemoryError in connect test run Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36339) Remove java serialization from SQL serializers Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36160) Support hive advanced configuration Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35206) Desc table syntax support materialized table Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-35761) FLIP-547: Support checkpoint during recovery Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35769) State files might not be deleted on task cancellation Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36046) Change the existing org.apache.flink.streaming.api.functions.sink#DiscardingSink and org.apache.flink.streaming.api.functions.sink#PrintSinkFunction to use the new interfaces Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36008) Guidance for previewing connector docs contributions Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35970) Update documentation about FLINK-26050 (merging small SST files) Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35698) Parquet connector fails to load ROW<x decimal(5, 2)> after save Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35688) Add materialized table develop guide docs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35557) MemoryManager only reserves memory per consumer type once Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35573) [FLIP-447] Upgrade FRocksDB from 6.20.3 to 8.10.0 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35582) Marking ingestDB as the default recovery mode for rescaling Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35535) Enable benchmark profiling in daily run Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35327) SQL Explain show push down condition Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35644) Add materialized table user guide doc Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35529) protobuf-format compatible protobuf bad indentifier Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35481) Add HISTOGRAM function in SQL & Table API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35480) Add FIELD function in SQL & Table API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39609) update Dynamic Kafka Source doc with new python/sql examples and other improvement details Bowen Li (Jira)
• [jira] [Updated] (FLINK-35145) Add timeout for cluster termination Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35103) [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34670) The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl can only create one worker thread Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34611) Migrate StreamPhysicalUnionRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34421) Skip post-compile checks in compile.sh if fast profile is active Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34612) Migrate StreamPhysicalValuesRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34981) FLIP-426: Grouping Remote State Access Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34610) Migrate StreamPhysicalLimitRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34397) Resource wait timeout can't be disabled Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34618) Migrate SplitPythonConditionFromJoinRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34445) Integrate new endpoint with Flink UI metrics section Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34605) Migrate BatchPhysicalDistributionRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34453) [Benchmark] Add warmup in SchedulerBenchmarkExecutor Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34603) Migrate BatchPhysicalBoundedStreamScanRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34431) Move static BlobWriter methods to separate util Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34608) Migrate BatchPhysicalValuesRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34607) Migrate BatchPhysicalUnionRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34609) Migrate BatchPhysicalScriptTransformRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34606) Migrate BatchPhysicalExpandRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34473) Migrate FlinkPruneEmptyRules Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34338) An exception is thrown when some named params change order when using window tvf Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35061) Migrate TemporalJoinUtil Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34315) Temporarily force disabling window join, window rank and window deduplicate optimization when using session window tvf Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34335) Query hints in RexSubQuery could not be printed Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34264) Prometheuspushgateway's hosturl can use basicAuth certification login Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34189) FLIP-416: Deprecate and remove the RestoreMode#LEGACY Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34156) Move Flink Calcite rules from Scala to Java Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34241) Transfer external connectors's CI result to Flink Slack #builds channel Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34191) Remove RestoreMode#LEGACY Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34129) MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-34066) LagFunction throw NPE when input argument are not null Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34066) LagFunction throw NPE when input argument are not null Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34066) LagFunction throw NPE when input argument are not null Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34033) flink json supports raw type Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33561) Externalize Pulsar Python connector code Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33950) Update max aggregate functions to new type system Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33626) Wrong style in flink ui Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33562) Externalize RabbitMQ Python connector code Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33895) Implement restore tests for PythonGroupWindowAggregate node Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33893) Implement restore tests for PythonCorrelate node Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33951) should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33584) Update Hadoop Filesystems to 3.3.6 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33819) Support setting CompressType in RocksDBStateBackend Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33674) In the wmassigners module, words are misspelled Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33631) Remove HA ConfigMap label setup Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields Natea Eshetu Beshada (Jira)
  • [jira] [Updated] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields Natea Eshetu Beshada (Jira)
• [jira] [Updated] (FLINK-35051) Treat handling of unaligned checkpoint barrier as the high priority mail Rui Fan (Jira)
• [jira] [Resolved] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39606][table] Add includeFreshness/includeRefreshMode flags to buildShowCreateMaterializedTableRow [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

• Earlier messages
• Later messages