节点必须能够访问每个 OpenShift Container Platform 集群节点的基板管理控制器（BMC）。您可以使用 IPMI、Redfish 或一个专有协议。 最新一代： 最新一代： 节点必须是最新一代。因为安装程序置备的安装依赖于 BMC 协议，所以硬件必须支 持 IPMI 密码套件 17。另外，RHEL 8 附带了 RAID 控制器的最新驱动程序。确保节点足以支持 provisioner hosts: - name: openshift-master-0 role: master bmc: address: ipmi:// 2 username: password: bootMACAddress: hardwareProfile: default - name: role: master bmc: address: ipmi:// 3 username: password: bootMACAddress:

Management Controller： ： provisioner 节点必须能够访问每个 OpenShift Container Platform 集群节点的基板管理控制器(BMC)。您可以使用 IPMI、Redfish 或专有协 议。 最新一代： 最新一代： 节点必须是最新一代。安装程序置备的安装依赖于 BMC 协议，这些协议必须在节点 间兼容。另外，RHEL 8 附带了 RAID 控制器的最新驱动程序。确保节点足以支持 hosts: - name: openshift-master-0 role: master bmc: address: ipmi:// 2 username: password: bootMACAddress: _path>" 3 - name: role: master bmc: address: ipmi:// 4 username: password: bootMACAddress:

Management Controller: provisioner 节点必须能够访问每个 OpenShift Container Platform 集群节点的基板管理控制器（BMC）。您可以使用 IPMI、Redfish 或一个专有协议。 最新一代： 最新一代： 节点必须是最新一代。安装程序置备的安装依赖于 BMC 协议，这些协议必须在节点 间兼容。另外，RHEL 8 附带了 RAID 控制器的最新驱动程序。确保节点足以支持 hosts: - name: openshift-master-0 role: master bmc: address: ipmi:// 2 username: 第 第 8 章 章 在裸机上部署安装程序置 在裸机上部署安装程序置备 备的集群 的集群 1177 sk_id>" 3 - name: role: master bmc: address: ipmi:// 4 username: password: bootMACAddress:

点必须 须能 能够访问 够访问每个 每个 OpenShift Container Platform 集群 集群节 节点的基板管理控制器 点的基板管理控制器(BMC)。您可以使用 。您可以使用 IPMI、 、Redfish 或 或专 专有 有协 协 议 议。 。 最新一代： 最新一代： 节 节点必 点必须 须是最新一代。安装程序置 是最新一代。安装程序置备 备的安装依 3 hosts: - name: openshift-master-0 role: master bmc: address: ipmi:// 4 username: password: bootMACAddress: _path>" 5 - name: role: master bmc: address: ipmi:// username: password: bootMACAddress:

点必须 须能 能够访问 够访问每个 每个 OpenShift Container Platform 集群 集群节 节点的基板管理控制器 点的基板管理控制器(BMC)。您可以使用 。您可以使用 IPMI、 、Redfish 或 或专 专有 有协 协 议 议。 。 最新一代： 最新一代： 节 节点必 点必须 须是最新一代。安装程序置 是最新一代。安装程序置备 备的安装依 hosts: - name: openshift-master-0 role: master bmc: address: ipmi:// 4 username: password: bootMACAddress: _path>" 5 - name: role: master bmc: address: ipmi:// username: password: bootMACAddress:

id)
 .max("temp")
 maxTemp.print()
 env.execute("Compute max sensor temperature”)
 }
 } Example: Sensor Readings 7 Vasiliki Kalavri | Boston University 2020 case class Reading(id: max("temp")
 maxTemp.print()
 env.execute("Compute max sensor temperature”)
 }
 } Sensor id, timestamp, temperature reading Example: Sensor Readings 8 Vasiliki Kalavri | Boston University 2020 0)))
 .keyBy(_.id)
 .max("temp")
 maxTemp.print()
 env.execute("Compute max sensor temperature”)
 }
 } Flink programs are defined in regular Scala/Java methods Set up the

.keyBy(_.id) .timeWindow(Time.minutes(1)) .max("temp")
 } } 3 Example: Window sensor readings Vasiliki Kalavri | Boston University 2020 In the DataStream API, you can use the time for the application env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime) // ingest sensor stream val sensorData: DataStream[SensorReading] = env.addSource(...) } } Or ProcessingTIme .aggregate(new AvgTempFunction) // An AggregateFunction to compute the average temperature per sensor. // The accumulator holds the sum of temperatures and an event count. class AvgTempFunction extends

checkAndGetNextWatermark( r: Reading, extractedTS: Long): Watermark = { if (r.id == "sensor_1") { // emit watermark if reading is from sensor_1 new Watermark(extractedTS - bound) } else { // do not emit a watermark event time characteristic env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime) // ingest sensor stream val readings: DataStream[Reading] = env.addSource(new SensorSource) // assign timestamps

index. This can model time-series data streams: • a sequence of measurements from a temperature sensor • the volume of NASDAQ stock trades over time This model poses a severe limitation on the stream: views Vasiliki Kalavri | Boston University 2020 Stream representation matters Consider streams of sensor readings from a temperature probe 1. a reading of the current temperature every 1s? 2. the difference 0/9.0)))
 .keyBy(_.id)
 .max("temp")
 maxTemp.print()
 env.execute("Compute max sensor temperature”)
 }
 } Example: Apache Flink DataStream API 42 Vasiliki Kalavri | Boston University

Current Kubernetes Case Study#1 --Water utilities management • Device • Liquid level sensor • Water pressure sensor • Valve actuator • Goal • Adjust valve based on water level of water tank in the area