issues  

Messages by Thread

• • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
  • Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
• Re: [PR] [FLINK-17337][table] Support emitting UPDATE_BEFORE and UPDATE_AFTER records in streaming LEFT/RIGHT/FULL OUTER JOIN [flink] via GitHub
  • Re: [PR] [FLINK-17337][table] Support emitting UPDATE_BEFORE and UPDATE_AFTER records in streaming LEFT/RIGHT/FULL OUTER JOIN [flink] via GitHub
• Re: [PR] [FLINK-31863]kubernetes] Add Hostname enum val to kubernetes NodeAddress type [flink] via GitHub
  • Re: [PR] [FLINK-31863]kubernetes] Add Hostname enum val to kubernetes NodeAddress type [flink] via GitHub
• [jira] [Resolved] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Leonard Xu (Jira)
• [jira] [Updated] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Yanquan Lv (Jira)
• Re: [PR] [FLINK-17224][table] Support precision for TIME [flink] via GitHub
  • Re: [PR] [FLINK-17224][table] Support precision for TIME [flink] via GitHub
• Re: [PR] [FLINK-33882] UT/IT for checkpointing statistics [flink] via GitHub
• [PR] [hotfix][cdc-connector][test] Sleep to wait for the assign status to INITIAL_ASSIGNING_FINISHED so that newly added table won't be stuck. [flink-cdc] via GitHub
  • Re: [PR] [hotfix][cdc-connector][test] Sleep to wait for the assign status to INITIAL_ASSIGNING_FINISHED so that newly added table won't be stuck. [flink-cdc] via GitHub
  • Re: [PR] [hotfix][cdc-connector][test] Sleep to wait for the assign status to INITIAL_ASSIGNING_FINISHED so that newly added table won't be stuck. [flink-cdc] via GitHub
  • Re: [PR] [hotfix][cdc-connector][test] Sleep to wait for the assign status to INITIAL_ASSIGNING_FINISHED so that newly added table won't be stuck. [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Leonard Xu (Jira)
• [jira] [Updated] (FLINK-37577) Wait compaction only when table set deletion-vectors.enabled to true in PaimonWriter Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-37577) Wait compaction only when table set deletion-vectors.enabled to true in PaimonWriter Leonard Xu (Jira)
• Re: [PR] [FLINK-36659] Bump flink version to 2.0.0 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-36659] Bump flink version to 2.0.0 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-36659] Bump flink version to 2.0.0 [flink-connector-jdbc] via GitHub
• Re: [PR] A few documentation fixes [flink] via GitHub
  • Re: [PR] A few documentation fixes [flink] via GitHub
• Re: [PR] [FLINK-32763] [SocketSource] Catch exceptions for retry code to work [flink] via GitHub
  • Re: [PR] [FLINK-32763] [SocketSource] Catch exceptions for retry code to work [flink] via GitHub
• Re: [PR] [hotfix] [docs] Fix to remove .all from java opts under application profiling [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix to remove .all from java opts under application profiling [flink] via GitHub
• Re: [PR] fix: missing serialVersionUID of serializable classes [flink] via GitHub
• Re: [PR] [FLINK-32530][table] Fix array_position return null value semantic, w… [flink] via GitHub
  • Re: [PR] [FLINK-32530][table] Fix array_position return null value semantic, w… [flink] via GitHub
• Re: [PR] [FLINK-32175] [docs-zh] translate doc(datagen.md) into chinese [flink] via GitHub
• [jira] [Resolved] (FLINK-37304) Dynamic Kafka Source logs unnecessary information in plaintext under INFO Leonard Xu (Jira)
• Re: [PR] [FLINK-32422][test] Adds test to cover the issue of forwarding the revoke event immediately to the contender for the EmbeddedLeaderService [flink] via GitHub
  • Re: [PR] [FLINK-32422][test] Adds test to cover the issue of forwarding the revoke event immediately to the contender for the EmbeddedLeaderService [flink] via GitHub
• Re: [PR] [Hotfix] Fix NPE in print sink writer [flink] via GitHub
  • Re: [PR] [Hotfix] Fix NPE in print sink writer [flink] via GitHub
• Re: [PR] Bump follow-redirects from 1.15.1 to 1.15.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-32509][core] Avoid using skip in InputStreamFSInputWrapper [flink] via GitHub
  • Re: [PR] [FLINK-32509][core] Avoid using skip in InputStreamFSInputWrapper [flink] via GitHub
• Re: [PR] [FLINK-32198][runtime] Enforce single maxExceptions query parameter [flink] via GitHub
  • Re: [PR] [FLINK-32198][runtime] Enforce single maxExceptions query parameter [flink] via GitHub
• Re: [PR] [BP-1.17][FLINK-30629][Client/Job Submission] Increase clientHeartbeatTimeout … [flink] via GitHub
  • Re: [PR] [BP-1.17][FLINK-30629][Client/Job Submission] Increase clientHeartbeatTimeout … [flink] via GitHub
• Re: [PR] [FLINK-32564][table] Support Cast From BYTES to NUMBER [flink] via GitHub
  • Re: [PR] [FLINK-32564][table] Support Cast From BYTES to NUMBER [flink] via GitHub
• Re: [PR] [FLINK-31951][format] Mix schema record source creates corrupt record [flink] via GitHub
  • Re: [PR] [FLINK-31951][format] Mix schema record source creates corrupt record [flink] via GitHub
  • Re: [PR] [FLINK-31951][format] Mix schema record source creates corrupt record [flink] via GitHub
  • [PR] [FLINK-31951][format] Mix schema record source creates corrupt record [flink] via GitHub
  • Re: [PR] [FLINK-31951][format] Mix schema record source creates corrupt record [flink] via GitHub
• Re: [PR] [hotfix] [docs, RestartStrategyOptions]: update the default value of "restart-strategy.fixed-delay.attempts" to 1 in docs [flink] via GitHub
• Re: [PR] Bump okio from 1.17.2 to 3.4.0 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
  • Re: [PR] Bump okio from 1.17.2 to 3.4.0 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
  • Re: [PR] Bump okio from 1.17.2 to 3.4.0 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• Re: [PR] [FLINK-33741]Expose Rocksdb Histogram statistics in Flink metrics [flink] via GitHub
• Re: [PR] [hotfix][docs] fix typo in ddl data type [flink] via GitHub
• Re: [PR] [FLINK-32039][test] Adds graceful shutdown to TestExecutorExtension and TestExecutorResource [flink] via GitHub
  • Re: [PR] [FLINK-32039][test] Adds graceful shutdown to TestExecutorExtension and TestExecutorResource [flink] via GitHub
• Re: [PR] [FLINK-33951][table] Use aggCallNeedRetractions instead of needRetrac… [flink] via GitHub
• Re: [PR] [FLINK-32435][runtime][test] Merges different test implementations of LeaderContender into a single generic one [flink] via GitHub
  • Re: [PR] [FLINK-32435][runtime][test] Merges different test implementations of LeaderContender into a single generic one [flink] via GitHub
• Re: [PR] [FLINK-32575] add jobmanager cpu configuration [flink] via GitHub
  • Re: [PR] [FLINK-32575] add jobmanager cpu configuration [flink] via GitHub
• Re: [PR] [docs] kafka.md Fromat adjustment [flink] via GitHub
  • Re: [PR] [docs] kafka.md Fromat adjustment [flink] via GitHub
• Re: [PR] [FLINK-34004] Harden TestingCheckpointIDCounter [flink] via GitHub
• Re: [PR] [hotfix] Static import removed [flink] via GitHub
• Re: [PR] [FLINK-32281][table-planner] Enable two-phase HashAgg default when all aggregate functions in query support adaptive local HashAgg [flink] via GitHub
  • Re: [PR] [FLINK-32281][table-planner] Enable two-phase HashAgg default when all aggregate functions in query support adaptive local HashAgg [flink] via GitHub
• Re: [PR] Update content.zh/docs/dev/table/overview.md [flink] via GitHub
• Re: [PR] Explanation of Asynchronous Problem in Querying Data from HBase [flink] via GitHub
  • Re: [PR] Explanation of Asynchronous Problem in Querying Data from HBase [flink] via GitHub
• Re: [PR] [FLINK-32471][table]Add is_not_null to join push rule [flink] via GitHub
  • Re: [PR] [FLINK-32471][table]Add is_not_null to join push rule [flink] via GitHub
• Re: [PR] [WIP] support flush [flink] via GitHub
  • Re: [PR] [WIP] support flush [flink] via GitHub
• Re: [PR] [FLINK-32720][table] Add built-in GENERATE_SERIES function [flink] via GitHub
  • Re: [PR] [FLINK-32720][table] Add built-in GENERATE_SERIES function [flink] via GitHub
• Re: [PR] [FLINK-32711][planner] Fix the type mismatch when proctime() used as … [flink] via GitHub
  • Re: [PR] [FLINK-32711][planner] Fix the type mismatch when proctime() used as … [flink] via GitHub
• Re: [PR] [FLINK-32665][format] Support reading null value for csv format [flink] via GitHub
  • Re: [PR] [FLINK-32665][format] Support reading null value for csv format [flink] via GitHub
• Re: [PR] [FLINK-32649][runtime/Metrics] fix the dimension order for promethues reporter [flink] via GitHub
  • Re: [PR] [FLINK-32649][runtime/Metrics] fix the dimension order for promethues reporter [flink] via GitHub
• Re: [PR] [FLINK-32508][metrics][prometheus] Add support for native counters an… [flink] via GitHub
  • Re: [PR] [FLINK-32508][metrics][prometheus] Add support for native counters an… [flink] via GitHub
• Re: [PR] fix(sec): upgrade com.google.guava:guava to 32.0.0-jre [flink] via GitHub
  • Re: [PR] fix(sec): upgrade com.google.guava:guava to 32.0.0-jre [flink] via GitHub
• Re: [PR] [FLINK-7129]Support dynamically changing CEP patterns [flink] via GitHub
  • Re: [PR] [FLINK-7129]Support dynamically changing CEP patterns [flink] via GitHub
• Re: [PR] Bump word-wrap from 1.2.3 to 1.2.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump word-wrap from 1.2.3 to 1.2.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump word-wrap from 1.2.3 to 1.2.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-32603] Avoid consuming twice when two planners have the same table source [flink] via GitHub
  • Re: [PR] [FLINK-32603] Avoid consuming twice when two planners have the same table source [flink] via GitHub
• Re: [PR] [FLINK-32627] Add support for dynamic time window function [flink] via GitHub
  • Re: [PR] [FLINK-32627] Add support for dynamic time window function [flink] via GitHub
• Re: [PR] [FLINK-32594][runtime]Support EndOfStreamTrigger and isOutputOnEOF operator attribute to optimize task deployment [flink] via GitHub
  • Re: [PR] [FLINK-32594][runtime]Support EndOfStreamTrigger and isOutputOnEOF operator attribute to optimize task deployment [flink] via GitHub
• Re: [PR] Bump stylelint from 14.8.5 to 15.10.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump stylelint from 14.8.5 to 15.10.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump stylelint from 14.8.5 to 15.10.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-32573][docs-content.zh] Translate "Custom Serialization for Ma… [flink] via GitHub
  • Re: [PR] [FLINK-32573][docs-content.zh] Translate "Custom Serialization for Ma… [flink] via GitHub
• Re: [PR] [FLINK-32525][Deployment/YARN] Remove dependency convergence line for commons-beanutils [flink] via GitHub
  • Re: [PR] [FLINK-32525][Deployment/YARN] Remove dependency convergence line for commons-beanutils [flink] via GitHub
• Re: [PR] FLINK-28171 enable add appProtocol via the configuration [flink] via GitHub
  • Re: [PR] FLINK-28171 enable add appProtocol via the configuration [flink] via GitHub
• Re: [PR] [FLINK-32501][table-planner] Fix wrong plan of a proctime window aggregation generated due to incorrect cost evaluation [flink] via GitHub
• Re: [PR] kafka.md Format adjustment [flink] via GitHub
  • Re: [PR] kafka.md Format adjustment [flink] via GitHub
• Re: [PR] [FLINK-32216][table-planner] Delete the redundant else statement in SetOperationParseStrategy [flink] via GitHub
  • Re: [PR] [FLINK-32216][table-planner] Delete the redundant else statement in SetOperationParseStrategy [flink] via GitHub
• Re: [PR] [FLINK-31883] Using the unboxed types that prevent nullability issues [flink] via GitHub
  • Re: [PR] [FLINK-31883] Using the unboxed types that prevent nullability issues [flink] via GitHub
• Re: [PR] [FLINK-32488][REST] Introduce separate configuration to control expiry of E… [flink] via GitHub
  • Re: [PR] [FLINK-32488][REST] Introduce separate configuration to control expiry of E… [flink] via GitHub
• Re: [PR] [FLINK-32454] deserializeStreamStateHandle of checkpoint read byte in… [flink] via GitHub
  • Re: [PR] [FLINK-32454] deserializeStreamStateHandle of checkpoint read byte in… [flink] via GitHub
• Re: [PR] [WIP] Don't merge, just for CI test [flink] via GitHub
  • Re: [PR] [WIP] Don't merge, just for CI test [flink] via GitHub
• Re: [PR] [FLINK-32253][runtime] Update pending resource requests on nodes unblocked. [flink] via GitHub
  • Re: [PR] [FLINK-32253][runtime] Update pending resource requests on nodes unblocked. [flink] via GitHub
• Re: [PR] [FLINK-32263]-table-Add-ELT-function [flink] via GitHub
  • Re: [PR] [FLINK-32263]-table-Add-ELT-function [flink] via GitHub
• Re: [PR] [FLINK-32264][table] Add-built-in FIELD-function. [flink] via GitHub
  • Re: [PR] [FLINK-32264][table] Add-built-in FIELD-function. [flink] via GitHub
• Re: [PR] [hotfix] Fix typo in setMaxParallelism() when create iteration sink [flink] via GitHub
  • Re: [PR] [hotfix] Fix typo in setMaxParallelism() when create iteration sink [flink] via GitHub
• Re: [PR] [FLINK-32305] [History Server] Add number of workers to parallelize job archive processing [flink] via GitHub
  • Re: [PR] [FLINK-32305] [History Server] Add number of workers to parallelize job archive processing [flink] via GitHub
• Re: [PR] [FLINK-30093][protobuf] Fix compile errors for google.protobuf.Timestamp type [flink] via GitHub
  • Re: [PR] [FLINK-30093][protobuf] Fix compile errors for google.protobuf.Timestamp type [flink] via GitHub
• Re: [PR] [FLINK-32159] AbstractColumnReader throws NPE [flink] via GitHub
  • Re: [PR] [FLINK-32159] AbstractColumnReader throws NPE [flink] via GitHub
• Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink] via GitHub
• Re: [PR] [FLINK-32188][Table SQL / Planner] Support to "where" query and simplify condition for an array-type filed of temporary table. [flink] via GitHub
  • Re: [PR] [FLINK-32188][Table SQL / Planner] Support to "where" query and simplify condition for an array-type filed of temporary table. [flink] via GitHub
• Re: [PR] [FLINK-23190][runtime] Make schedulers allocate slots more evenly [flink] via GitHub
  • Re: [PR] [FLINK-23190][runtime] Make schedulers allocate slots more evenly [flink] via GitHub
• Re: [PR] [FLINK-32203] Remove monitoringInterval to reduce probability of ClassLoader memory leak [flink] via GitHub
  • Re: [PR] [FLINK-32203] Remove monitoringInterval to reduce probability of ClassLoader memory leak [flink] via GitHub
• Re: [PR] KafkaSource: disable setting client id prefix if client.id is set [flink] via GitHub
  • Re: [PR] KafkaSource: disable setting client id prefix if client.id is set [flink] via GitHub
• Re: [PR] [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese [flink] via GitHub
  • Re: [PR] [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese [flink] via GitHub
• Re: [PR] [FLINK-32122] Update the Azure Blob Storage document to assist in configuring the MSI provider with a shaded class name [flink] via GitHub
  • Re: [PR] [FLINK-32122] Update the Azure Blob Storage document to assist in configuring the MSI provider with a shaded class name [flink] via GitHub
• Re: [PR] Updating docs on how to upgrade kafka connectors [flink] via GitHub
  • Re: [PR] Updating docs on how to upgrade kafka connectors [flink] via GitHub
• Re: [PR] [FLINK-32006] Harden and speed up AsyncWaitOperatorTest#testProcessingTimeAlwaysTimeoutFunctionWithRetry [flink] via GitHub
  • Re: [PR] [FLINK-32006] Harden and speed up AsyncWaitOperatorTest#testProcessingTimeAlwaysTimeoutFunctionWithRetry [flink] via GitHub
• Re: [PR] [FLINK-32044][table-api] Validate catalog name when listFunctions in FunctionCatalog [flink] via GitHub
  • Re: [PR] [FLINK-32044][table-api] Validate catalog name when listFunctions in FunctionCatalog [flink] via GitHub
• Re: [PR] [FLINK-31928][build] Upgrade okhttp3 to 4.11.0 [flink] via GitHub
  • Re: [PR] [FLINK-31928][build] Upgrade okhttp3 to 4.11.0 [flink] via GitHub
  • Re: [PR] [FLINK-31928][build] Upgrade okhttp3 to 4.11.0 [flink] via GitHub
  • Re: [PR] [FLINK-31928][build] Upgrade okhttp3 to 4.11.0 [flink] via GitHub
• Re: [PR] [FLINK-31947] enable stdout for flink-console.sh [flink] via GitHub
  • Re: [PR] [FLINK-31947] enable stdout for flink-console.sh [flink] via GitHub
• Re: [PR] [FLINK-31755][planner] Make SqlRowOperator to create row with PEEK_FIELDS_NO_EXPAND struct type [flink] via GitHub
  • Re: [PR] [FLINK-31755][planner] Make SqlRowOperator to create row with PEEK_FIELDS_NO_EXPAND struct type [flink] via GitHub
• Re: [PR] [FLINK-31828][planner] Use the inner serializer for RawType when doin… [flink] via GitHub
  • Re: [PR] [FLINK-31828][planner] Use the inner serializer for RawType when doin… [flink] via GitHub
• Re: [PR] [FLINK-31875][filesystems] Override the flink-parent dependencyManagement definition for hadoop-common of OSS [flink] via GitHub
  • Re: [PR] [FLINK-31875][filesystems] Override the flink-parent dependencyManagement definition for hadoop-common of OSS [flink] via GitHub
• Re: [PR] [FLINK-31689][flink-connector-files] Check expired file state before … [flink] via GitHub
  • Re: [PR] [FLINK-31689][flink-connector-files] Check expired file state before … [flink] via GitHub
• Re: [PR] [FLINK-31518][Runtime / REST] Fix StandaloneHaServices#getClusterRestEndpointLeaderRetreiver to return correct rest port [flink] via GitHub
  • Re: [PR] [FLINK-31518][Runtime / REST] Fix StandaloneHaServices#getClusterRestEndpointLeaderRetreiver to return correct rest port [flink] via GitHub
• Re: [PR] [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator [flink] via GitHub
  • Re: [PR] [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator [flink] via GitHub

• Earlier messages
• Later messages