Skip to content

Actions: apache/flink-connector-kafka

Actions

All workflows

Actions

Loading...
Loading

Showing runs from all workflows
563 workflow runs
563 workflow runs

Filter by Event

Filter by Status

Filter by Branch

Filter by Actor

[FLINK-39072] Handle InvalidPidMappingException as known failure in KafkaCommitter Flink Connector Kafka CI #1242: Pull request #225 opened by nateab
Action required nateab:handle-invalid-pid-mapping-exception
nateab:handle-invalid-pid-mapping-exception
Action required
Stale PRs Stale PRs #86: Scheduled
8s main
main
8s
[FLINK-39012]Add global kafka enumerator support Flink Connector Kafka CI #1241: Pull request #223 synchronize by lnbest0707
Action required lnbest0707:oss/global-enumerator
lnbest0707:oss/global-enumerator
Action required
[FLINK-39054] DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers Flink Connector Kafka CI #1240: Pull request #224 synchronize by bowenli86
25m 40s bowenli86:v2
bowenli86:v2
25m 40s
[FLINK-39054] DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers Flink Connector Kafka CI #1239: Pull request #224 synchronize by bowenli86
1m 29s bowenli86:v2
bowenli86:v2
1m 29s
Stale PRs Stale PRs #85: Scheduled
9s main
main
9s
[FLINK-39054] DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers Flink Connector Kafka CI #1238: Pull request #224 synchronize by bowenli86
25m 4s bowenli86:v2
bowenli86:v2
25m 4s
[FLINK-39054] DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers Flink Connector Kafka CI #1237: Pull request #224 synchronize by bowenli86
8m 17s bowenli86:v2
bowenli86:v2
8m 17s
[FLINK-39054] DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers Flink Connector Kafka CI #1236: Pull request #224 opened by bowenli86
1m 36s bowenli86:v2
bowenli86:v2
1m 36s
[FLINK-39037] support query kafka cluster id as metadata in records of DynamicKafkaTableSource Flink Connector Kafka CI #1235: Pull request #222 synchronize by bowenli86
25m 16s bowenli86:clusterid
bowenli86:clusterid
25m 16s
[FLINK-39037] support query kafka cluster id as metadata in records of DynamicKafkaTableSource Flink Connector Kafka CI #1234: Pull request #222 synchronize by bowenli86
1m 26s bowenli86:clusterid
bowenli86:clusterid
1m 26s
Stale PRs Stale PRs #84: Scheduled
11s main
main
11s
Stale PRs Stale PRs #83: Scheduled
8s main
main
8s
Weekly Flink Connector Kafka CI Weekly Flink Connector Kafka CI #197: Scheduled
17m 14s main
main
17m 14s
Stale PRs Stale PRs #82: Scheduled
8s main
main
8s
Stale PRs Stale PRs #81: Scheduled
9s main
main
9s
[FLINK-39037] support query kafka cluster id as metadata in records of DynamicKafkaTableSource Flink Connector Kafka CI #1233: Pull request #222 synchronize by bowenli86
25m 34s bowenli86:clusterid
bowenli86:clusterid
25m 34s
[FLINK-39012]Add global kafka enumerator support Flink Connector Kafka CI #1232: Pull request #223 synchronize by lnbest0707
59s lnbest0707:oss/global-enumerator
lnbest0707:oss/global-enumerator
59s
[FLINK-39012]Add global kafka enumerator support Flink Connector Kafka CI #1231: Pull request #223 opened by lnbest0707
Action required lnbest0707:oss/global-enumerator
lnbest0707:oss/global-enumerator
Action required
[FLINK-39037] support query kafka cluster id as metadata in records of DynamicKafkaTableSource Flink Connector Kafka CI #1230: Pull request #222 synchronize by bowenli86
25m 42s bowenli86:clusterid
bowenli86:clusterid
25m 42s
[FLINK-39037] support query kafka cluster id as metadata in records of DynamicKafkaTableSource Flink Connector Kafka CI #1229: Pull request #222 opened by bowenli86
1m 28s bowenli86:clusterid
bowenli86:clusterid
1m 28s
[FLINK-39013] add E2E test for DynamicKafkaTableSource (#218) Flink Connector Kafka CI #1228: Commit cdbd635 pushed by bowenli86
25m 57s main
main
25m 57s
Revert [FLINK-38869] InitializationContext for KafkaSubscriber (#208) Flink Connector Kafka CI #1227: Pull request #221 synchronize by Efrat19
Action required Efrat19:FLINK-38869-revert
Efrat19:FLINK-38869-revert
Action required
Revert [FLINK-38869] InitializationContext for KafkaSubscriber (#208) Flink Connector Kafka CI #1226: Pull request #221 opened by Efrat19
Action required Efrat19:FLINK-38869-revert
Efrat19:FLINK-38869-revert
Action required
Stale PRs Stale PRs #80: Scheduled
1m 46s main
main
1m 46s