issues  

Messages by Thread

• Re: [PR] [WIP] Extend error labeling to avoid restart loops. [flink] via GitHub
• Re: [PR] [FLINK-34477][table] Support capture groups in REGEXP_REPLACE [flink] via GitHub
• Re: [PR] [FLINK-33524][ API / DataStream] fix IntervalJoinOperator 's judgment on isLate function bug [flink] via GitHub
• Re: [PR] Refactor @Test(expected) with assertThrows [flink] via GitHub
  • Re: [PR] Refactor @Test(expected) with assertThrows [flink] via GitHub
• Re: [PR] [WIP][FLINK-34442][table] Support optimizations for pre-partitioned data sources [flink] via GitHub
• [jira] [Created] (FLINK-37611) Deflake ExactlyOnceKafkaWriterITCase#shouldAbortLingeringTransactions Arvid Heise (Jira)
• Re: [PR] [FLINK-20312][doc] Complete TriggerResult's PURGE description for cla… [flink] via GitHub
  • Re: [PR] [FLINK-20312][doc] Complete TriggerResult's PURGE description for cla… [flink] via GitHub
• Re: [PR] [FLINK-33510] Update plugin for SBOM generation to 2.7.10 [flink] via GitHub
  • Re: [PR] [FLINK-33510] Update plugin for SBOM generation to 2.7.10 [flink] via GitHub
• Re: [PR] [FLINK-34535] Support JobPlanInfo for the explain result [flink] via GitHub
• Re: [PR] [FLINK-33507][json]Support zero-timestamp.behavior option for JSON fo… [flink] via GitHub
• Re: [PR] Feature/expand sql cep [flink] via GitHub
  • Re: [PR] Feature/expand sql cep [flink] via GitHub
• Re: [PR] [FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint [flink] via GitHub
• Re: [PR] [FLINK-34542][docs] improved example quickstart build.gradle [flink] via GitHub
• Re: [PR] [FLINK-33053][runtime] Refactoring of workaround to fix thread leakage on the ZooKeeper server side. [flink] via GitHub
• Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink] via GitHub
• Re: [PR] [FLINK-33685][client] Refactor StandaloneClusterId to distinguish different remote clusters [flink] via GitHub
• Re: [PR] [FLINK-33688][client] Reuse connections in RestClient to save connection establish time [flink] via GitHub
• Re: [PR] [hotfix][docs] fix flink-table-api-java-bridge artifactId error… [flink] via GitHub
  • Re: [PR] [hotfix][docs] fix flink-table-api-java-bridge artifactId error… [flink] via GitHub
• Re: [PR] [FLINK-33267] Support PreparedStatement in JDBC Driver [flink] via GitHub
  • Re: [PR] [FLINK-33267] Support PreparedStatement in JDBC Driver [flink] via GitHub
• Re: [PR] [hotfix] [docs] Flink comment typo in pyflink datastream [flink] via GitHub
• Re: [PR] [FLINK-33398][runtime] Support switching from batch to stream mode for one input stream operator [flink] via GitHub
  • Re: [PR] [FLINK-33398][runtime] Support switching from batch to stream mode for one input stream operator [flink] via GitHub
• Re: [PR] [FLINK-33797] Change log level for Application CANCELED/FAILED logs to WARN [flink] via GitHub
• Re: [PR] [FLINK-33509] Fix flaky test testNodeAffinity() in InitTaskManagerDecoratorTest.java [flink] via GitHub
• Re: [PR] [FLINK-34597][table] Migrate SimplifyFilterConditionRule to java [flink] via GitHub
• Re: [PR] [FLINK-34045][ci] Refactors docs build scripts and adds CI for pushing docs changes [flink] via GitHub
• Re: [PR] [FLINK-33700] CustomSSLEngineProvider supports SHA-256 [flink] via GitHub
• Re: [PR] [FLINK-33809] HiveCatalog load hivemetastore-site.xml [flink] via GitHub
• Re: [PR] [FLINK-34060][table] Migrate UserDefinedTableAggFunctions to JavaUserDefinedTableAggFunctions [flink] via GitHub
• Re: [PR] [FLINK-23598] [core] Fix a bug that caused position to be updated twice when writing a string to a byte array [flink] via GitHub
• Re: [PR] [FLINK-33212][core] Introduce job status changed listener for lineage [flink] via GitHub
• Re: [PR] [FLINK-34463] Open catalog in CatalogManager should use proper context classloader [flink] via GitHub
• Re: [PR] Bump ip from 2.0.0 to 2.0.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [jira] [Created] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Hangxiang Yu (Jira)
• Re: [PR] [FLINK-34497][REST] Avoid using system classloader in SerializedThrowableDeserializer [flink] via GitHub
• Re: [PR] [FLINK-34462][table-planner] Improve the exception for negative parameters in window TVF [flink] via GitHub
• Re: [PR] [FLINK-34603][table] Migrate BatchPhysicalBoundedStreamScanRule to java. [flink] via GitHub
• Re: [PR] [FLINK-33687][client] Reuse RestClusterClient in StandaloneClusterDescriptor [flink] via GitHub
• Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-sql-connector-hive-3.1.3 [flink] via GitHub
  • Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-sql-connector-hive-3.1.3 [flink] via GitHub
  • Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-sql-connector-hive-3.1.3 [flink] via GitHub
• Re: [PR] [FLINK-34480] support user jar class overwrite flink inner when meet the same. [flink] via GitHub
• Re: [PR] [FLINK-33428] Flink SQL CEP support 'followed','notNext' and 'notFollowedBy' semantics [flink] via GitHub
• Re: [PR] FLINK-30893 Replace not specifying a driver in Minikube by something … [flink] via GitHub
  • Re: [PR] FLINK-30893 Replace not specifying a driver in Minikube by something … [flink] via GitHub
• Re: [PR] Clarity And Impact: Revamped Flink Feature Descriptions [flink] via GitHub
• Re: [PR] [FLINK-32806]EmbeddedJobResultStore set ttly for non dirty job [flink] via GitHub
  • Re: [PR] [FLINK-32806]EmbeddedJobResultStore set ttly for non dirty job [flink] via GitHub
• Re: [PR] [DRAFT] Experiment of bulk sync task states [flink] via GitHub
• Re: [PR] [FLINK-32986][test] Fix createTemporaryFunction type inference error [flink] via GitHub
  • Re: [PR] [FLINK-32986][test] Fix createTemporaryFunction type inference error [flink] via GitHub
• Re: [PR] [FLINK-34609][table] Migrate BatchPhysicalScriptTransformRule to java. [flink] via GitHub
• Re: [PR] [DRAFT][FLINK-34637][table] Migrate JoinConditionEqualityTransferRule to java [flink] via GitHub
• Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink] via GitHub
  • Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink] via GitHub
• Re: [PR] [FLINK-34508][ci] Migrates S3 ITCases to Minio tests [flink] via GitHub
• Re: [PR] [FLINK-34522] Changing the Time to Duration for StateTtlConfig.Builder.cleanupInRocksdbCompactFilter [flink] via GitHub
• Re: [PR] Bump com.github.tomakehurst:wiremock-jre8 from 2.32.0 to 2.35.1 in /flink-metrics/flink-metrics-influxdb [flink] via GitHub
  • Re: [PR] Bump com.github.tomakehurst:wiremock-jre8 from 2.32.0 to 2.35.1 in /flink-metrics/flink-metrics-influxdb [flink] via GitHub
  • Re: [PR] Bump com.github.tomakehurst:wiremock-jre8 from 2.32.0 to 2.35.1 in /flink-metrics/flink-metrics-influxdb [flink] via GitHub
• Re: [PR] [FLINK-32853][runtime][JUnit5 Migration] The security, taskmanager an… [flink] via GitHub
  • Re: [PR] [FLINK-32853][runtime][JUnit5 Migration] The security, taskmanager an… [flink] via GitHub
• Re: [PR] [FLINK-33159] [build] use variables in pom file for Java and Maven versions [flink] via GitHub
  • Re: [PR] [FLINK-33159] [build] use variables in pom file for Java and Maven versions [flink] via GitHub
• Re: [PR] [FLINK-34147][table-planner] Enhance the java doc of TimestampData to distinguish the different usage of Instant and LocalDateTime [flink] via GitHub
• Re: [PR] [FLINK-34264[plugins] add pushgateway http basic auth [flink] via GitHub
• Re: [PR] Chore: Change metric types, "numSplitsProcessed" in metrics.md [flink] via GitHub
• Re: [PR] [FLINK-34421] Skip post-compile checks if 'fast' profile is active [flink] via GitHub
• Re: [PR] [FLINK-34372][table-api] Support DESCRIBE CATALOG [flink] via GitHub
• Re: [PR] [hotfix][sql-client] remove duplicated code in CliUtils [flink] via GitHub
• Re: [PR] [FLINK-32756][ha] Implement reusable ClientHAServices and reuse it when creating RestClusterClient [flink] via GitHub
• Re: [PR] [FLINK-33686][client] Reuse ClusterDescriptor in AbstractSessionClusterExecutor [flink] via GitHub
• Re: [PR] [hotfix] [tests] Per-class the lifecycle of mini-cluster in `ClientHeartbeatTest`. [flink] via GitHub
• Re: [PR] [FLINK-33628][runtime] Upgrades default ZooKeeper version from 3.7.1 to 3.8.3 [flink] via GitHub
• Re: [PR] [FLINK-33751] use modules correctly when deserializing json plan [flink] via GitHub
• Re: [PR] [FLINK-33684][datastream] Use IncrementalDelayRetryStrategy in CollectResultFetcher [flink] via GitHub
• Re: [PR] [FLINK-33680][docs]Failed to build document with docker [flink] via GitHub
• Re: [PR] [FLINK-33095] Job jar issue should be reported as BAD_REQUEST instead of INTERNAL_SERVER_ERROR. [flink] via GitHub
  • Re: [PR] [FLINK-33095] Job jar issue should be reported as BAD_REQUEST instead of INTERNAL_SERVER_ERROR. [flink] via GitHub
• Re: [PR] [FLINK-33472][Client] Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded [flink] via GitHub
• Re: [PR] [hotfix] Fix wrong flink-conf.yaml file path [flink] via GitHub
• Re: [PR] Bump com.squareup.okio:okio from 1.17.2 to 1.17.6 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• Re: [PR] [flink-xxxxx][flink-connectors] Skip missing planned files [flink] via GitHub
  • Re: [PR] [flink-xxxxx][flink-connectors] Skip missing planned files [flink] via GitHub
• Re: [PR] [FLINK-33130]reuse source and sink operator io metrics for task [flink] via GitHub
  • Re: [PR] [FLINK-33130]reuse source and sink operator io metrics for task [flink] via GitHub
• Re: [PR] [FLINK-33508] [HistoryServer] Support for wildcard paths in Flink History Server for multi cluster environment [flink] via GitHub
• Re: [PR] Bump @babel/traverse from 7.19.4 to 7.23.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @babel/traverse from 7.19.4 to 7.23.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @babel/traverse from 7.19.4 to 7.23.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-33156][Test]Remove flakiness from tests in OperatorStateBackendTest.java [flink] via GitHub
  • Re: [PR] [FLINK-33156][Test]Remove flakiness from tests in OperatorStateBackendTest.java [flink] via GitHub
• Re: [PR] [FLINK-33408] Bump the snakeyaml from 1.33 to 2.0 to fix the container vulnerability. [flink] via GitHub
  • Re: [PR] [FLINK-33408] Bump the snakeyaml from 1.33 to 2.0 to fix the container vulnerability. [flink] via GitHub
• Re: [PR] Draft [FLINK-33335] (CI) [flink] via GitHub
  • Re: [PR] Draft [FLINK-33335] (CI) [flink] via GitHub
• Re: [PR] [FLINK-33373][build] Capture build scans on ge.apache.org to benefit from deep build insights [flink] via GitHub
• Re: [PR] [FLINK-33362][doc] Document Externalized Declarative Resource Management With Chinese [flink] via GitHub
  • Re: [PR] [FLINK-33362][doc] Document Externalized Declarative Resource Management With Chinese [flink] via GitHub
• Re: [PR] [FLINK-33328] Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable [flink] via GitHub
  • Re: [PR] [FLINK-33328] Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable [flink] via GitHub
• Re: [PR] [FLINK-31065] New split assigner to reduce task failover cost in batch mode. [flink] via GitHub
  • Re: [PR] [FLINK-31065] New split assigner to reduce task failover cost in batch mode. [flink] via GitHub
• Re: [PR] [FLINK-33345][sql-parse] Sql parse only single statement supported [flink] via GitHub
  • Re: [PR] [FLINK-33345][sql-parse] Sql parse only single statement supported [flink] via GitHub
• Re: [PR] Srichter local rescaling [flink] via GitHub
  • Re: [PR] Srichter local rescaling [flink] via GitHub
• Re: [PR] [FLINK-33218] Replace glob with version parameter [flink] via GitHub
  • Re: [PR] [FLINK-33218] Replace glob with version parameter [flink] via GitHub
• Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-connector-hive [flink] via GitHub
  • Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-connector-hive [flink] via GitHub
  • Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-connector-hive [flink] via GitHub
• Re: [PR] [FLINK-33249][table-planner] comment should be parsed by StringLitera… [flink] via GitHub
  • Re: [PR] [FLINK-33249][table-planner] comment should be parsed by StringLitera… [flink] via GitHub
• Re: [PR] [FLINK-32488][REST] Introduce configuration for web cache TTL [flink] via GitHub
  • Re: [PR] [FLINK-32488][REST] Introduce configuration for web cache TTL [flink] via GitHub
• Re: [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 2.6.3 in /flink-end-to-end-tests/flink-sql-client-test [flink] via GitHub
  • Re: [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 2.6.3 in /flink-end-to-end-tests/flink-sql-client-test [flink] via GitHub
  • Re: [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 2.6.3 in /flink-end-to-end-tests/flink-sql-client-test [flink] via GitHub
• Re: [PR] [FLINK-33034][Backport][runtime] Correct ValueState creating for StateBackendTestBase#testGetKeysAndNamespaces [flink] via GitHub
  • Re: [PR] [FLINK-33034][Backport][runtime] Correct ValueState creating for StateBackendTestBase#testGetKeysAndNamespaces [flink] via GitHub
• Re: [PR] [FLINK-33085][table-planner] Improve the error message when the invalidated lookupTableSource without primary key is used as temporal join table [flink] via GitHub
  • Re: [PR] [FLINK-33085][table-planner] Improve the error message when the invalidated lookupTableSource without primary key is used as temporal join table [flink] via GitHub
• Re: [PR] [BP-1.18][FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode [flink] via GitHub
  • Re: [PR] [BP-1.18][FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode [flink] via GitHub
• Re: [PR] [FLINK-32958][table-planner] Support view as source table of the LIKE clause in the CREATE TABLE statement [flink] via GitHub
  • Re: [PR] [FLINK-32958][table-planner] Support view as source table of the LIKE clause in the CREATE TABLE statement [flink] via GitHub
• Re: [PR] [hotfix][docs] Update the parameter types of StreamGraph#addOperator in javadocs [flink] via GitHub
  • Re: [PR] [hotfix][docs] Update the parameter types of StreamGraph#addOperator in javadocs [flink] via GitHub
• Re: [PR] [FLINK-32954][Metrics] Metrics expose number of heap timer [flink] via GitHub
  • Re: [PR] [FLINK-32954][Metrics] Metrics expose number of heap timer [flink] via GitHub
• Re: [PR] [docs-zh] fix one word translation issue of flink-architecture.md [flink] via GitHub
  • Re: [PR] [docs-zh] fix one word translation issue of flink-architecture.md [flink] via GitHub
• Re: [PR] [FLINK-32910][build] Set default parameters for curl and wget [flink] via GitHub
  • Re: [PR] [FLINK-32910][build] Set default parameters for curl and wget [flink] via GitHub
• [jira] [Created] (FLINK-37610) Running Over agg without OrderBy throws IndexOutOfBoundsException Bonnie Varghese (Jira)
• [PR] [FLINK-37609][format] Bump parquet from 1.14.4 to 1.15.1 [flink] via GitHub
  • Re: [PR] [FLINK-37609][format] Bump parquet from 1.14.4 to 1.15.1 [flink] via GitHub
  • Re: [PR] [FLINK-37609][format] Bump parquet from 1.14.4 to 1.15.1 [flink] via GitHub
  • Re: [PR] [FLINK-37609][format] Bump parquet from 1.14.4 to 1.15.1 [flink] via GitHub
  • Re: [PR] [FLINK-37609][format] Bump parquet from 1.14.4 to 1.15.1 [flink] via GitHub
  • Re: [PR] [FLINK-37609][format] Bump parquet from 1.14.4 to 1.15.1 [flink] via GitHub
• [jira] [Created] (FLINK-37609) Bump parquet libs to 1.15.1 Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Hangxiang Yu (Jira)
  • [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Hangxiang Yu (Jira)
  • [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Hangxiang Yu (Jira)
• [jira] [Resolved] (FLINK-37577) Wait compaction only when table set deletion-vectors.enabled to true in PaimonWriter Leonard Xu (Jira)
• [jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name Arvid Heise (Jira)
• Re: [PR] [FLINK-37304] Reduce the log level about metadataUpdateEvent in DynamicKafkaSourceEnumerator. [flink-connector-kafka] via GitHub
• [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
• Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
• Re: [PR] [FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator [flink] via GitHub
  • Re: [PR] [FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator [flink] via GitHub
• [jira] [Updated] (FLINK-37598) Support ListView and MapView in PTFs ASF GitHub Bot (Jira)
• [PR] [FLINK-37598][table] Support list and map state in PTFs [flink] via GitHub
  • Re: [PR] [FLINK-37598][table] Support list and map state in PTFs [flink] via GitHub

• Earlier messages
• Later messages