issues  

Messages by Thread

• • Re: [PR] [BP-2.3][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] 1996fanrui (via GitHub) via issues
• [jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-36186) Speed up RocksDB close during manual compaction Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36186) Speed up RocksDB close during manual compaction Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-38444) Join calculates upsert keys with null keys for left join Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38444) Join calculates upsert keys with null keys for left join Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Nikhil S (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-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-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-37477) Emit full deletes from StreamJoin if it gets deletes on key on input Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37477) Emit full deletes from StreamJoin if it gets deletes on key on input Yuepeng Pan (Jira) via issues
• Re: [PR] [FLINK-40452] Cap exception fetching by size instead of line count [flink-kubernetes-operator] via GitHub
• [jira] [Assigned] (FLINK-40630) Use Apache Parent POM 39 in flink-connector-parent Martijn Visser (Jira)
• [jira] [Commented] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Purushottam Sinha (Jira)
  • [jira] [Commented] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Purushottam Sinha (Jira)
  • [jira] [Commented] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Rui Fan (Jira) via issues
• [jira] [Updated] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Martijn Visser (Jira)
• [jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system Yuepeng Pan (Jira)
• Re: [PR] [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] via GitHub
  • Re: [PR] [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] via GitHub
  • Re: [PR] [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] via GitHub
  • Re: [PR] [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] via GitHub
• [jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs Yuepeng Pan (Jira)
• Re: [PR] [BP-2.2][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• [jira] [Updated] (FLINK-33120) FLIP-361: Improve GC Metrics Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-33120) FLIP-361: Improve GC Metrics Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-33120) FLIP-361: Improve GC Metrics Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-28893) Add conv function supported in SQL & Table API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-28893) Add conv function supported in SQL & Table API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE, TIME or a lower precision returns a wrong value Ramin Gharib (Jira)
  • [jira] [Updated] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE, TIME or a lower precision returns a wrong value Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-35061) Migrate TemporalJoinUtil Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35061) Migrate TemporalJoinUtil Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35061) Migrate TemporalJoinUtil Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline Yuepeng Pan (Jira)
• Re: [PR] [FLINK-41192][connector-http] Fail the HTTP sink request when a retry attempt throws [flink-connector-http] via GitHub
• [jira] [Updated] (FLINK-25244) Deprecate Java 8 support Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-25244) Deprecate Java 8 support 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-19659) Array type supports equals and not_equals operator when element types are different but castable Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24636) Move cluster deletion operation cache into ResourceManager Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-24636) Move cluster deletion operation cache into ResourceManager Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39543) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39543) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40304) Incorrect upsert key inference for PTFs with multiple table arguments Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-40304) Incorrect upsert key inference for PTFs with multiple table arguments Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-33562) Externalize RabbitMQ Python connector code Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-33562) Externalize RabbitMQ Python connector code Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath Yuepeng Pan (Jira) via issues
  • [jira] [Updated] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend 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-39991) Drop ReplaceIntersectWithSemiJoinRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39991) Drop ReplaceIntersectWithSemiJoinRule Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-34421) Skip post-compile checks in compile.sh if fast profile is active 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-27242) Support RENAME PARTITION statement for partitioned table Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-27242) Support RENAME PARTITION statement for partitioned table Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40997) Regular join picks a random state key among equal-length upsert keys Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-40997) Regular join picks a random state key among equal-length upsert keys Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-37117) Add docs for async state SQL operators in 2.0 Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37117) Add docs for async state SQL operators in 2.0 Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-37340) Flink supports pushing metrics immediately at the end of the task. Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37340) Flink supports pushing metrics immediately at the end of the task. Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-35103) [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35103) [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35103) [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer Yuepeng Pan (Jira)
• Re: [PR] [FLINK-41251] Validate the memory configuration when the spec sets memory [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41251] Validate the memory configuration when the spec sets memory [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41251] Validate the memory configuration when the spec sets memory [flink-kubernetes-operator] vsantwana (via GitHub) via issues
  • Re: [PR] [FLINK-41251] Validate the memory configuration when the spec sets memory [flink-kubernetes-operator] vsantwana (via GitHub) via issues
• [jira] [Commented] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Robin Varghese (Jira) via issues
• [jira] [Updated] (FLINK-32738) PROTOBUF format supports projection push down Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-32738) PROTOBUF format supports projection push down Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-32738) PROTOBUF format supports projection push down Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]] Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]] Yuepeng Pan (Jira)
• Re: [PR] [FLINK-41135][jdbc] Don't start a transaction after the end of input [flink-connector-jdbc] via GitHub
• Re: [PR] [FLINK-41060][jdbc] Commit XA transactions in the JdbcSink committer [flink-connector-jdbc] via GitHub
• [jira] [Commented] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira) via issues
  • [jira] [Commented] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira) via issues
• Re: [PR] [BP-1.20][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-35970) Update documentation about FLINK-26050 (merging small SST files) Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35970) Update documentation about FLINK-26050 (merging small SST files) Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35970) Update documentation about FLINK-26050 (merging small SST files) Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` Yuepeng Pan (Jira) via issues
  • [jira] [Updated] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-34611) Migrate StreamPhysicalUnionRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34611) Migrate StreamPhysicalUnionRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34611) Migrate StreamPhysicalUnionRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access 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-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-35529) protobuf-format compatible protobuf bad indentifier Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35529) protobuf-format compatible protobuf bad indentifier Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35529) protobuf-format compatible protobuf bad indentifier Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34607) Migrate BatchPhysicalUnionRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34607) Migrate BatchPhysicalUnionRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34607) Migrate BatchPhysicalUnionRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35206) Desc table syntax support materialized table Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35206) Desc table syntax support materialized table Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35206) Desc table syntax support materialized table Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34608) Migrate BatchPhysicalValuesRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34608) Migrate BatchPhysicalValuesRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34608) Migrate BatchPhysicalValuesRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-33893) Implement restore tests for PythonCorrelate node Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-33893) Implement restore tests for PythonCorrelate node Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule Yuepeng Pan (Jira) via issues
• [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) Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-35327) SQL Explain show push down condition Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35327) SQL Explain show push down condition Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35327) SQL Explain show push down condition Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34445) Integrate new endpoint with Flink UI metrics section Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34445) Integrate new endpoint with Flink UI metrics section Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34445) Integrate new endpoint with Flink UI metrics section Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36399) cast result is incorrect Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36399) cast result is incorrect Yuepeng Pan (Jira) via issues
  • [jira] [Updated] (FLINK-36399) cast result is incorrect Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35582) Marking ingestDB as the default recovery mode for rescaling Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35582) Marking ingestDB as the default recovery mode for rescaling Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35582) Marking ingestDB as the default recovery mode for rescaling Yuepeng Pan (Jira)

• Earlier messages
• Later messages