issues  

Messages by Thread

• [jira] [Commented] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter Michael Koepf (Jira)
• [jira] [Updated] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter Michael Koepf (Jira)
  • [jira] [Updated] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter Michael Koepf (Jira)
  • [jira] [Updated] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter Michael Koepf (Jira)
  • [jira] [Updated] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter Michael Koepf (Jira)
• [jira] [Created] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter Michael Koepf (Jira)
• [jira] [Commented] (FLINK-28516) UI is misleading when source doesn't emit watermark due to misconfigured idleness Poorvank Bhatia (Jira)
• [PR] [WIP][FLINK-37453][tests] Port Ruby migration tests to Java [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37533) Reduce Stale PR Action timeouts Thomas Cooper (Jira)
• Re: [PR] [FLINK-19059]: Add NonTimeRangeUnboundedPrecedingFunction for OverAggregate [flink] via GitHub
• [jira] [Created] (FLINK-37534) Add Liniting checks to all PRs Thomas Cooper (Jira)
• Re: [PR] [FLINK-37533][CI] Reduce the stale PR github action timouts [flink] via GitHub
• [jira] [Updated] (FLINK-37533) Reduce Stale PR Action timeouts ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-37532) Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure Gyula Fora (Jira)
• [jira] [Created] (FLINK-37532) Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure Jun He (Jira)
• Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink] via GitHub
  • Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink] via GitHub
  • Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink] via GitHub
  • Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink] via GitHub
• [jira] [Updated] (FLINK-35350) Add documentation for Kudu connector Ferenc Csaky (Jira)
• Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
  • Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
• [jira] [Updated] (FLINK-37531) Respect the design of chain programming for RpcServiceBuilder ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37531) Respect the design of chain programming for RpcServiceBuilder Jiaan Geng (Jira)
• [jira] [Closed] (FLINK-37527) Add `KuduSource` documentation Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37530) Upgrade savepoints are not added to deprecated savepointinfo Gyula Fora (Jira)
• Re: [PR] [FLINK-36829] Add better validation of pipeline config [flink-cdc] via GitHub
• Re: [PR] [FLINK-35713][common] Support set parallelism in source and sink [flink-cdc] via GitHub
• [PR] [hotfix] Rename the variable `result` to `config` [flink] via GitHub
  • Re: [PR] [hotfix] Rename the variable `result` to `config` [flink] via GitHub
• [jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules Jiaan Geng (Jira)
  • [jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules Jiaan Geng (Jira)
  • [jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules Jiaan Geng (Jira)
• Re: [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink] via GitHub
  • Re: [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink] via GitHub
  • Re: [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink] via GitHub
• [jira] [Updated] (FLINK-37528) Protobuf Format (proto3): Handle default values for optional primitive types and primitive types in one of fields Sai Sharath Dandi (Jira)
• [jira] [Resolved] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Gabor Somogyi (Jira)
• Re: [PR] [FLINK-30284][flink-metrics] Adding datacenter url property to datadog [flink] via GitHub
• [jira] [Closed] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Gabor Somogyi (Jira)
• [PR] [FLINK-37527] Add `KuduSource` documentation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-37527] Add `KuduSource` documentation [flink-connector-kudu] via GitHub
  • Re: [PR] [FLINK-37527] Add `KuduSource` documentation [flink-connector-kudu] via GitHub
• [jira] [Updated] (FLINK-37527) Add `KuduSource` documentation ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-37505) Pyflink is not able to handle the new YAML based configs Gabor Somogyi (Jira)
• [jira] [Closed] (FLINK-37505) Pyflink is not able to handle the new YAML based configs Gabor Somogyi (Jira)
• Re: [PR] Cp FLINK-37222 [flink] via GitHub
• [jira] [Commented] (FLINK-27419) Endpoint to cancel savepoints Anirudh Prabhakaran (Jira)
• [PR] [FLINK-37423][table] Support PTFs in Table API [flink] via GitHub
  • Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink] via GitHub
  • Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink] via GitHub
  • Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink] via GitHub
  • Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink] via GitHub
• [jira] [Created] (FLINK-37527) Add `KuduSource` documentation Ferenc Csaky (Jira)
• Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
  • Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
  • Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
  • Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
• [jira] [Updated] (FLINK-37375) Checkpoint supports the Operator to customize asynchronous snapshot state ASF GitHub Bot (Jira)
• [PR] [FLINK-37525] Introduce a overload findModuleFactory to improve the performance of installModules [flink] via GitHub
• [jira] [Created] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules Jiaan Geng (Jira)
• [jira] [Created] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint Yue Ma (Jira)
• [jira] [Updated] (FLINK-37523) e2e: Test stream python udf sql job fails Fabian Paul (Jira)
• [jira] [Created] (FLINK-37523) e2e: Test stream python udf sql job fails Fabian Paul (Jira)
• [jira] [Updated] (FLINK-37520) Introduce KeyedCoProcessOperator with async state API Yanfei Lei (Jira)
• [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
  • Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
• [jira] [Updated] (FLINK-37521) Introduce CoStreamFlatMap with async state API ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-37521) Introduce CoStreamFlatMap with async state API Yanfei Lei (Jira)
• [jira] [Commented] (FLINK-37505) Pyflink is not able to handle the new YAML based configs Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-37505) Pyflink is not able to handle the new YAML based configs Gabor Somogyi (Jira)
• [jira] [Updated] (FLINK-37522) Add description for the config about file system connection limit ASF GitHub Bot (Jira)
• [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink] via GitHub
  • Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink] via GitHub
  • Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink] via GitHub
  • Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink] via GitHub
  • Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink] via GitHub
• [jira] [Created] (FLINK-37522) Add description for the config about file system connection limit Jiaan Geng (Jira)
• [jira] [Updated] (FLINK-37481) FLIP-516: Multi way join operator Timo Walther (Jira)
  • [jira] [Updated] (FLINK-37481) FLIP-516: Multi way join operator Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-37481) FLIP-516: Multi way join operator Gustavo de Morais (Jira)
• [jira] [Comment Edited] (FLINK-37481) Multi way join operator Timo Walther (Jira)
• [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink] via GitHub
  • Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink] via GitHub
  • Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink] via GitHub
  • Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink] via GitHub
  • Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink] via GitHub
• [jira] [Assigned] (FLINK-36443) Flaky Test: assertEquals in PushPartitionIntoTableSourceScanRuleTest.testWithUdf lincoln lee (Jira)
• [jira] [Created] (FLINK-37520) One input datastream operator with async state Yanfei Lei (Jira)
• [jira] [Created] (FLINK-37521) Two input datastream operators with async state Yanfei Lei (Jira)
• [jira] [Updated] (FLINK-37520) One input datastream operators with async state Yanfei Lei (Jira)
• Re: [PR] [FLINK-36659] Bump to 2.0-preview1. [flink-connector-jdbc] via GitHub
• [jira] [Assigned] (FLINK-37519) Add clearer logs when fail to write to YAML DataSink. Leonard Xu (Jira)
• [jira] [Updated] (FLINK-37516) Whether to only synchronize the structure of the table. vertern (Jira)
• [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
  • Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
  • Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
  • Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
  • Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
  • Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
  • Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
  • Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
  • Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-37519) Add clearer logs when fail to write to YAML DataSink. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37518) Optimize number of files created by flink history server Biao Geng (Jira)
• [jira] [Updated] (FLINK-37517) Bump flink 2.0 for elasticsearch connector ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-37517][[Connectors/Elasticsearch] Bump flink to 2.0.0 [flink-connector-elasticsearch] via GitHub
• Re: [PR] [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationC… [flink] via GitHub
• [jira] [Created] (FLINK-37516) Whether to only synchronize the structure of the table. vertern (Jira)
• [jira] [Created] (FLINK-37517) Bump flink 2.0 for elasticsearch connector Weijie Guo (Jira)
• [jira] [Closed] (FLINK-35350) Add documentation for Kudu Ferenc Csaky (Jira)
• [jira] [Commented] (FLINK-37248) Scala was removed in flink 2.0 911432 (Jira)
• [jira] [Updated] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the Services Julian (Jira)
• [jira] [Closed] (FLINK-34928) FLIP-439: Externalize Kudu Connector from Bahir Ferenc Csaky (Jira)
• [jira] [Commented] (FLINK-37504) Handle TLS Certificate Renewal David Radley (Jira)
  • [jira] [Commented] (FLINK-37504) Handle TLS Certificate Renewal Nicolas Fraison (Jira)
  • [jira] [Commented] (FLINK-37504) Handle TLS Certificate Renewal Gabor Somogyi (Jira)
• Re: [PR] FLINK-35350 [flink-connector-kudu] via GitHub
• [jira] [Created] (FLINK-37515) FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Sergio Chong (Jira)
• [jira] [Updated] (FLINK-29058) Analyze table xxx For columns will thrown error while encounter String type column with null value Weijie Guo (Jira)
• [jira] [Updated] (FLINK-36986) Migrate SplitRemoteConditionFromJoinRule Weijie Guo (Jira)
• [jira] [Comment Edited] (FLINK-37504) Handle TLS Certificate Renewal David Radley (Jira)
• [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] via GitHub
• [jira] [Resolved] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned Matthias Pohl (Jira)
• [jira] [Updated] (FLINK-37511) JobPlan properties aren't listed in OpenAPI spec Efrat Levitan (Jira)
• [jira] [Created] (FLINK-37514) Display if incremental checkpoints are enabled on Flink dashboard's checkpoints tab Hong Liang Teoh (Jira)
• Re: [PR] [FLINK-37511][rest] Use Jackson serialization in JobPlanInfo.Plan [flink] via GitHub
• [PR] [FLINK-37491][release] Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs [flink] via GitHub
  • Re: [PR] [FLINK-37491][release] Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs [flink] via GitHub
• [jira] [Created] (FLINK-37513) CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP invalid regex Maciej Bak (Jira)
• [jira] [Closed] (FLINK-37032) Prepare Flink 2.0 Release Xintong Song (Jira)
• [jira] [Closed] (FLINK-37040) [Release-2.0] Review and update documentation Xintong Song (Jira)
• Re: [PR] [FLINK-37511] Use Jackson serialization in JobPlanInfo.Plan [flink] via GitHub
• [jira] [Assigned] (FLINK-37511) JobPlanInfo properties aren't listed in OpenAPI spec Chesnay Schepler (Jira)
• [jira] [Updated] (FLINK-37512) SlidingEventTimeWindows causes OOM ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37512) SlidingEventTimeWindows causes OOM Jiaan Geng (Jira)
• [jira] [Updated] (FLINK-37511) JobPlanInfo properties aren't listed in OpenAPI spec Efrat Levitan (Jira)
  • [jira] [Updated] (FLINK-37511) JobPlanInfo properties aren't listed in OpenAPI spec ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-21752) NullPointerException on restore in PojoSerializer Hao Yu (Jira)
• [jira] [Created] (FLINK-37511) JobPlan properties aren't listed in OpenAPI spec Efrat Levitan (Jira)
• [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink] via GitHub
  • Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink] via GitHub
• Re: [PR] [minor][docs][style] Update documentation link and improve code style [flink-cdc] via GitHub
  • Re: [PR] [minor][docs][style] Update documentation link and improve code style [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-37510) Avoid duplicate calculations for SlidingEventTimeWindows Jiaan Geng (Jira)
  • [jira] [Updated] (FLINK-37510) Avoid duplicate calculations for SlidingEventTimeWindows ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37510) Improve the code for SlidingEventTimeWindows Jiaan Geng (Jira)
• [jira] [Resolved] (FLINK-37497) Deploy Python artifacts to PyPI Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-37499) Create Git tag and mark version as released in Jira Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-37500) Publish the Dockerfiles for the new release Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-37498) Deploy artifacts to Maven Central Repository Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-37494) Update reference data for Migration Tests Weijie Guo (Jira)
• [jira] [Updated] (FLINK-37491) Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-37491) Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs Weijie Guo (Jira)
• [jira] [Commented] (FLINK-37494) Update reference data for Migration Tests Weijie Guo (Jira)
• [jira] [Assigned] (FLINK-37039) [Release-2.0] Triage release-blocking issues in JIRA Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-37039) [Release-2.0] Triage release-blocking issues in JIRA Weijie Guo (Jira)
• [jira] [Updated] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory Weijie Guo (Jira)
• [jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods Weijie Guo (Jira)
• [jira] [Commented] (FLINK-37509) Increment scan source no need to buffer data when enable skipping backfill. Hongshun Wang (Jira)
• [jira] [Commented] (FLINK-37508) Postgres CDC Jdbc query should use debezium.snapshot.fetch.size rather than debezium.query.fetch.size. Hongshun Wang (Jira)
• [jira] [Updated] (FLINK-37506) Print detailed exception stack when pipeline transform fails ASF GitHub Bot (Jira)
• [PR] [code clean] clean unuse code for schema operator&coordinator. [flink-cdc] via GitHub
  • Re: [PR] [code clean] clean unuse code for schema operator&coordinator. [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37509) Increment scan source no need to buffer data when enable skipping backfill. Hongshun Wang (Jira)

• Earlier messages