issues  

Messages by Thread

• Re: [PR] Bump org.apache.httpcomponents.core5:httpcore5-h2 from 5.4.2 to 5.4.3 [flink-connector-opensearch] via GitHub
  • Re: [PR] Bump org.apache.httpcomponents.core5:httpcore5-h2 from 5.4.2 to 5.4.3 [flink-connector-opensearch] via GitHub
• Re: [PR] Bump org.apache.httpcomponents.core5:httpcore5 from 5.4.2 to 5.4.3 [flink-connector-opensearch] via GitHub
  • Re: [PR] Bump org.apache.httpcomponents.core5:httpcore5 from 5.4.2 to 5.4.3 [flink-connector-opensearch] via GitHub
• [jira] [Commented] (FLINK-40543) Race condition and ConcurrentModificationException in MockSplitEnumeratorContext.getSentSourceEvent() Qiu Yanjun (Jira)
• [jira] [Commented] (FLINK-40354) StateTtlConfig background cleanup does not work for async State v2 MapState on ForSt state backend seungjoo choi (Jira)
• [jira] [Commented] (FLINK-40623) [cdc-base] JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime; with default connection.pool.size=20 the 21st incremental-snapshot job on the same JobManager can never start wglbd12 (Jira)
• [PR] [python] Use a reserved host in the redirect user-info test fixture [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40623) [cdc-base] JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime; with default connection.pool.size=20 the 21st incremental-snapshot job on the same JobManager can never start ASF GitHub Bot (Jira)
• [PR] [FLINK-40623][cdc-base] Release chunk splitter JDBC connection once a table is split [flink-cdc] via GitHub
• [PR] [FLINK-40639][kubernetes] Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default [flink] via GitHub
  • Re: [PR] [FLINK-40639][kubernetes] Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default [flink] via GitHub
• [jira] [Updated] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default sepuri sai krishna (Jira)
  • [jira] [Updated] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default sepuri sai krishna (Jira)
• Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] via GitHub
  • Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] via GitHub
• Re: [PR] [FLINK-39668] Add get kafka offsets SQL table function [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39668] Add get kafka offsets SQL table function [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-39928][ci] If there are changes in tests only then skip non related CI jobs in GHA [flink] via GitHub
• [jira] [Commented] (FLINK-40435) Add explode support to DataFrame API Bettle (Jira)
• [jira] [Commented] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes Bettle (Jira)
• [jira] [Updated] (FLINK-40420) Add set operations to DataFrame API ASF GitHub Bot (Jira)
• [PR] [FLINK-40420][python] Add set operations to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40420][python] Add set operations to DataFrame API [flink] via GitHub
• Re: [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-opensearch] via GitHub
  • Re: [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-opensearch] via GitHub
• [jira] [Commented] (FLINK-40508) Support DB2 pipeline connector suntectec (Jira)
• [PR] [FLINK-40637][table] Expand catalog views hermetically against the view's own database [flink] via GitHub
  • Re: [PR] [FLINK-40637][table] Expand catalog views hermetically against the view's own database [flink] via GitHub
• [PR] [FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector [flink-cdc] via GitHub
• Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• [jira] [Updated] (FLINK-40637) Catalog view expansion falls back to the session database for unresolved references ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
  • Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• [PR] [FLINK-40418][python] Support attribute-based column access on DataFrame [flink] via GitHub
  • Re: [PR] [FLINK-40418][python] Support attribute-based column access on DataFrame [flink] via GitHub
• [jira] [Updated] (FLINK-40418) Support attribute-based column access on DataFrame ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-35012][table] Fix flaky ChangelogNormalizeRestoreTest by adding padding records to prevent mini-batch merging [flink] via GitHub
• Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-40634) E2E are extremely slow in Azure Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs Sylwester Lachiewicz (Jira)
• [jira] [Updated] (FLINK-40638) Add optional custom URL handlers for JobManager and TaskManager logs in the history server ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40633) Make download-crt-jars.sh maven command agnostic ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator Bob Thomson (Jira)
• [jira] [Closed] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• [jira] [Updated] (FLINK-30277) Allow PYTHONPATH of Python Worker configurable Bob Thomson (Jira)
• [PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink] via GitHub
  • Re: [PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink] via GitHub
  • Re: [PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink] via GitHub
  • Re: [PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink] via GitHub
• [jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder Bob Thomson (Jira)
• [jira] [Closed] (FLINK-34246) Allow only archive failed job to history server Robert Metzger (Jira)
• [jira] [Updated] (FLINK-40551) FileMergingChannelStateITCase is very flaky ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40632) Remove Experimental Annotation of Native S3 ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-38262][table] show create connection operation [flink] via GitHub
• [jira] [Updated] (FLINK-17037) add e2e tests for reading array data types from postgres with JDBCTableSource and PostgresCatalog Bob Thomson (Jira)
• [jira] [Created] (FLINK-40638) Add optional custom URL handlers for JobManager and TaskManager logs in the history server Archit Goyal (Jira)
• [jira] [Assigned] (FLINK-40633) Make download-crt-jars.sh maven command agnostic Gabor Somogyi (Jira)
• [jira] [Resolved] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-34246) Allow only archive failed job to history server Robert Metzger (Jira)
• [jira] [Created] (FLINK-40633) Make download-crt-jars.sh maven command agnostic Gabor Somogyi (Jira)
• [PR] [FLINK-40398][connector/kafka] Inject a clock for retention expiry [flink-connector-kafka] via GitHub
• [jira] [Assigned] (FLINK-40592) PrometheusPushGatewayReporter fails to initialize with basic authentication Martijn Visser (Jira)
• [jira] [Created] (FLINK-40637) Catalog view expansion falls back to the session database for unresolved references Talat Uyarer (Jira)
• [jira] [Created] (FLINK-40632) Remove Experimental Annotation of Native S3 Samrat Deb (Jira)
• [jira] [Updated] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Purushottam Sinha (Jira)
• Re: [PR] [FLINK-40179] Support windowed states in state catalog [flink] via GitHub
• [jira] [Updated] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure Bob Thomson (Jira)
• [jira] [Assigned] (FLINK-40420) Add set operations to DataFrame API Dian Fu (Jira)
• [jira] [Comment Edited] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Martijn Visser (Jira)
• [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
  • Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
  • Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
  • Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
  • Re: [PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink] via GitHub
• [jira] [Assigned] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
  • [jira] [Assigned] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
• [jira] [Closed] (FLINK-40424) Add windowing TVF support to DataFrame API Dian Fu (Jira)
• [PR] [FLINK-40633][s3] Allow overriding the Maven executable in download-crt-jars.sh [flink] via GitHub
  • Re: [PR] [FLINK-40633][s3] Allow overriding the Maven executable in download-crt-jars.sh [flink] via GitHub
• [jira] [Updated] (FLINK-33100) Implement YarnJobFetcher for Standalone Autoscaler Bob Thomson (Jira)
• [jira] [Updated] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue Bob Thomson (Jira)
• [jira] [Created] (FLINK-40635) Test CalcRestoreTest>RestoreTestBase.testRestore failing Samrat Deb (Jira)
• [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
  • Re: [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
  • Re: [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
  • Re: [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
  • Re: [PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink] via GitHub
• [jira] [Updated] (FLINK-22091) env.java.home option didn't take effect in resource negotiator Bob Thomson (Jira)
• [jira] [Updated] (FLINK-30375) SqlClient leaks flink-table-planner jar under /tmp Bob Thomson (Jira)
• [jira] [Updated] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream Bob Thomson (Jira)
• [jira] [Updated] (FLINK-31518) HighAvailabilityServiceUtils resolves wrong webMonitorAddress in Standalone mode Bob Thomson (Jira)
• [jira] [Updated] (FLINK-33101) Add the integration test for standalone autoscaler Bob Thomson (Jira)
• [jira] [Updated] (FLINK-39581) Document the available config params in a single place for s3 native connector Bob Thomson (Jira)
• [jira] [Resolved] (FLINK-40600) Web dashboard: finish Vitest smoke-test coverage and tighten thin specs Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) Sergey Nuyanzin (Jira)
• [PR] [FLINK-40634][ci] Reuse mirror list to prepare faster image [flink] via GitHub
  • Re: [PR] [FLINK-40634][ci] Reuse mirror list to prepare faster image [flink] via GitHub
• [PR] [hotfix][connect/mysql] Fix potential comparison failure when PK is VARBINARY [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40634) E2E are extremely slow in Azure ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation Bob Thomson (Jira)
• [jira] [Commented] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases yongfu.gao (Jira)
  • [jira] [Commented] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases Avi Sanwal (Jira)
• [PR] [hotfix][runtime] Fix unable to take __data_event_type__ from REPLACE events [flink-cdc] via GitHub
• [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
  • Re: [PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink] via GitHub
• [jira] [Assigned] (FLINK-40600) Web dashboard: finish Vitest smoke-test coverage and tighten thin specs Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40588) DynamicKafkaSourceReaderTest.testNotifyNoMoreSplits is flaky Bhanu Chander Vallabaneni (Jira)
• [jira] [Commented] (FLINK-40624) KafkaCommitter and ExactlyOnceKafkaWriter do not handle InvalidProducerEpochException alongside ProducerFencedException Bhanu Chander Vallabaneni (Jira)
• [jira] [Comment Edited] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions Han You (Jira)
• Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39938) FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Chanhae Oh (Jira)
• [jira] [Commented] (FLINK-39911) FLIP-584: Support Pluggable Storage Backend for HistoryServer Chanhae Oh (Jira)
• [jira] [Commented] (FLINK-40097) FLIP-585: Introduce Lazy Loading for HistoryServer Chanhae Oh (Jira)
• [jira] [Comment Edited] (FLINK-39911) FLIP-584: Support Pluggable Storage Backend for HistoryServer Chanhae Oh (Jira)
  • [jira] [Comment Edited] (FLINK-39911) FLIP-584: Support Pluggable Storage Backend for HistoryServer Chanhae Oh (Jira)
• [jira] [Commented] (FLINK-40630) Use Apache Parent POM 39 in flink-connector-parent Sylwester Lachiewicz (Jira)
• [PR] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
  • Re: [PR] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
  • Re: [PR] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
  • Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
• Re: [PR] [FLINK-39765][cdc-pipeline/mysql] Implement lineage (FLIP-314) support for mysql source connectors [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) ASF GitHub Bot (Jira)
• [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
  • Re: [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
  • Re: [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
  • Re: [PR] [FLINK-40631][table-planner] Regenerate calc-variant restore savepoint after Variant type change [flink] via GitHub
• [jira] [Created] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) Purushottam Sinha (Jira)
• [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-40629][ci] Keep the license check honest on Maven 3.9 [flink-connector-shared-utils] via GitHub
• [jira] [Updated] (FLINK-40629) Bump the build/enforced Maven version from 3.8.6 to 3.9.16 in flink-connector-kafka ASF GitHub Bot (Jira)
• [PR] [FLINK-40629][build] Bump Maven from 3.8.6 to 3.9.16 [flink-connector-kafka] via GitHub
• [PR] [BP-4.0][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
  • Re: [PR] [BP-4.0][FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-40630) Use Apache Parent POM 39 in flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-40629) Bump the build/enforced Maven version from 3.8.6 to 3.9.16 in flink-connector-kafka Martijn Visser (Jira)
• [jira] [Closed] (FLINK-40593) Add batch recursive S3 deletes to native S3 connector Samrat Deb (Jira)
• [jira] [Commented] (FLINK-33466) Bounded Kafka source never finishes after restore from savepoint Martijn Visser (Jira)
• [jira] [Commented] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
  • [jira] [Updated] (FLINK-40493) VARIANT CAST for UUID (code 20) ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40626) KafkaCommitter leaves the newer open transaction under a reused transactional id after a fenced commit Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40628) PyFlink TTL initialization can hang task threads and leave jobs stuck in INITIALIZING ASF GitHub Bot (Jira)
• [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
  • Re: [PR] [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization [flink] via GitHub
• [jira] [Commented] (FLINK-40593) Add batch recursive S3 deletes to native S3 connector Samrat Deb (Jira)
• [jira] [Created] (FLINK-40628) PyFlink TTL initialization can hang task threads and leave jobs stuck in INITIALIZING Bowen Li (Jira)
• [PR] [FLINK-40621][Connectors/Kafka] Flush before fencing in producer reset test [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40621][Connectors/Kafka] Flush before fencing in producer reset test [flink-connector-kafka] via GitHub
• [jira] [Commented] (FLINK-33224) Flink Batch Job does not complete when using Kafka topics with empty partitions Sylwester Lachiewicz (Jira)
• [jira] [Commented] (FLINK-37330) Add state migration test for Flink 2.0 Sylwester Lachiewicz (Jira)
• [jira] [Commented] (FLINK-34693) Memory leak in KafkaWriter Sylwester Lachiewicz (Jira)
• [jira] [Commented] (FLINK-34320) Flink Kafka connector tests time out Sylwester Lachiewicz (Jira)
• [jira] [Commented] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema Sylwester Lachiewicz (Jira)
• [jira] [Commented] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Purushottam Sinha (Jira)
• [jira] [Assigned] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable Martijn Visser (Jira)
• [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort the newer transaction under a reused id after a fenced commit [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort superseded precommitted transactions on recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40626][Connectors/Kafka] Abort superseded precommitted transactions on recovery [flink-connector-kafka] via GitHub
• [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
  • [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
  • [jira] [Comment Edited] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-40551) FileMergingChannelStateITCase is very flaky Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Martijn Visser (Jira)
• [jira] [Commented] (FLINK-37291) Weekly Kafka CI detects producer leaks Sylwester Lachiewicz (Jira)
• [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• [jira] (FLINK-33466) Bounded Kafka source never finishes after restore from savepoint Martijn Visser (Jira)
• [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)

• Earlier messages