Messages by Thread
-
[I] [Tech Debt] Unify sub-agent declarations with generic resource descriptors [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-40977) ForSt JUnit 5 migration is incomplete
Purushottam Sinha (Jira)
-
Re: [PR] [FLINK-39327][pipeline-connector/dws]add dws sink pipeline connector [flink-cdc]
via GitHub
-
[jira] [Commented] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee
Rango (Jira)
-
[jira] [Created] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee
Rango (Jira)
-
[jira] [Updated] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40982][pipeline-connector/fluss] Make ADD COLUMN replay idempotent [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed
Xiaobing Fang (Jira)
-
[jira] [Updated] (FLINK-40471) Add per-UDF concurrency and batch size support to DataFrame API
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40471][python] Support per-UDF concurrency and batch size in DataFrame API [flink]
via GitHub
-
[jira] [Updated] (FLINK-40433) Add map and map_batches support to DataFrame API
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40433][python] Add map and map_batches methods to DataFrame API [flink]
via GitHub
-
[PR] [python] Key built-in chat model calls by an explicit durable id [flink-agents]
via GitHub
-
[PR] [runtime][java][python] Keep durable gather outcomes completed before an ordinary cancellation [flink-agents]
via GitHub
-
[jira] [Assigned] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb
Martijn Visser (Jira)
-
Re: [PR] Add mysql operation metrics [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40903) Add source host info in TM disconnect error
Peter Huang (Jira)
-
[jira] [Created] (FLINK-40976) JoinToMultiJoinForReorderRule applies a post-join filter twice when merging joins for reorder
Hanyu Zheng (Jira)
-
Re: [PR] [FLINK-39380][table] Add test snapshotting and restoration to ProcessTableFunctionTestHarness [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40978) Cast from VARIANT through FromVariantConverter
Ramin Gharib (Jira)
-
Re: [PR] [FLINK-XXXXX][state-backends] Migrate RocksDB state backend tests to … [flink]
via GitHub
-
[jira] [Updated] (FLINK-40980) JsonRowDataSerDeSchemaTest array tests don't cover the JsonParser deserializer
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40977) ForSt JUnit 5 migration is incomplete
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40664][tests] Isolate MDC logging test clusters [flink]
via GitHub
-
[jira] [Resolved] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests
Rui Fan (Jira)
-
[I] [Bug] numOfActiveInputRuns double-counts runs identified during restore [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-36885) Multiple tests are incorrectly migrated to JUnit 5
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-31955) Prevent JUnit 4 usage for the new code with Checkstyle
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases
Martijn Visser (Jira)
-
[jira] [Comment Edited] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-40903) Add source host info in TM disconnect error
Peter Huang (Jira)
-
[jira] [Commented] (FLINK-26746) Update the documentation of Timer's Fault Tolerance section
ChenZhuo (Jira)
-
[jira] [Commented] (FLINK-40564) [JUnit5 Migration] Migrate flink-statebackend-changelog tests to JUnit 5 and AssertJ
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master
Martijn Visser (Jira)
-
[jira] [Comment Edited] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn
Yahya Kisana (Jira)
-
Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-hbase]
via GitHub
-
[jira] [Assigned] (FLINK-27939) [JUnit5 Migration] Module: flink-connector-hive
Martijn Visser (Jira)
-
[PR] [FLINK-40973][pipeline-connector/fluss] Retry transient periodic discovery failures [flink-cdc]
via GitHub
-
[PR] [FLINK-40972][table] Do not generate cast classes in case of Identity casts [flink]
via GitHub
-
[PR] [FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. [flink]
via GitHub
-
[jira] [Created] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history
Hao Yu (Jira)
-
[jira] [Commented] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history
Hao Yu (Jira)
-
[PR] [FLINK-33373][build] Publish Build Scans to develocity.apache.org from GitHub Actions [flink]
via GitHub
-
[jira] [Assigned] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0>
Ferenc Csaky (Jira)
-
[jira] [Closed] (FLINK-40133) Update HBase version to 2.6.6
Ferenc Csaky (Jira)
-
[jira] [Updated] (FLINK-33373) Capture build scans on develocity.apache.org to benefit from deep build insights
Clay Johnson (Jira)
-
Re: [PR] [FLINK-40902][table] Support LATERAL SNAPSHOT join without an equi-key [flink]
via GitHub
-
Re: [PR] [legal] Update NOTICE for bundled dependencies [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40978) Cast from VARIANT through FromVariantConverter
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40980][json] Run JsonRowDataSerDeSchemaTest array tests for both deserializers [flink]
via GitHub
-
[jira] [Updated] (FLINK-40974) JavaProgramTestBase runs its object reuse variant without object reuse
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-40574][build] Update SLF4J from 1.7.36 to 2.0.20 [flink]
via GitHub
-
[PR] [FLINK-40979][table-planner] Run HashAggITCase's inherited tests with adaptive local hash agg [flink]
via GitHub
-
[PR] [FLINK-40974][tests] Fix object reuse runs of JavaProgramTestBase [flink]
via GitHub
-
[jira] [Updated] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40981) ParameterizedTestExtension should fail tests that it does not parameterize
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40981) ParameterizedTestExtension should fail tests that it does not parameterize
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40980) JsonRowDataSerDeSchemaTest array tests don't cover the JsonParser deserializer
Martijn Visser (Jira)
-
[PR] [FLINK-40978][table] Cast from VARIANT through FromVariantConverter [flink]
via GitHub
-
[PR] [hotfix][build] Remove stale IllegalImport suppressions [flink]
via GitHub
-
[jira] [Closed] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0>
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-40977) ForSt JUnit 5 migration is incomplete
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results
Hanyu Zheng (Jira)
-
Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink]
via GitHub
-
[jira] [Commented] (FLINK-33533) Add documentation about performance for huge ProtoBuf definations
ChenZhuo (Jira)
-
[jira] [Commented] (FLINK-38078) DataStream API Execution Configuration doc contains deleted API usage
ChenZhuo (Jira)
-
[jira] [Commented] (FLINK-39237) Docs training links should not depend on the Flink release branch
ChenZhuo (Jira)
-
[jira] [Created] (FLINK-40974) HadoopIOFormatsITCase#testJobWithObjectReuse runs without object reuse
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40695] Add a retry state for failed ExecutionGraph creation [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40971][parquet] Run ParquetTimestampITCase for all its parameters [flink]
via GitHub
-
[jira] [Updated] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases
Purushottam Sinha (Jira)
-
[jira] [Commented] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-40973) Fluss source fails on retriable errors during periodic table discovery
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-40973) Fluss source fails on retriable errors during periodic table discovery
Xiaobing Fang (Jira)
-
[jira] [Created] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes
Sergey Nuyanzin (Jira)
-
[jira] [Comment Edited] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-32841) [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, highavailability and instance packages of flink-runtime module
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-32839) [JUnit5 Migration] The entrypoint, event, execution and externalresource packages of flink-runtime module
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-32838) [JUnit5 Migration] The deployment and dispatcher packages of flink-runtime module
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-32842) [JUnit5 Migration] The iterative, jobgraph and jobmanager packages of flink-runtime module
Martijn Visser (Jira)