Skip to content

Commit d256580

Browse files
authored
m1 again (apache#7)
* M1 fix again * export STATS_COMPUTE_INTERVAL_MINUTES env
1 parent e2bf896 commit d256580

5 files changed

Lines changed: 8 additions & 4 deletions

File tree

docker/data-generator/Dockerfile

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,9 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515

16-
FROM maven:3.6-jdk-8-slim AS builder
16+
ARG MAVEN_IMAGE=maven:3.8-openjdk-8-slim
17+
18+
FROM ${MAVEN_IMAGE} AS builder
1719

1820
# Get data producer code and compile it
1921
COPY ./src /opt/data-producer/src

table-walkthrough/README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ export KENSU_AUTH_TOKEN="eyJhbG...."
1616

1717
Open [http://localhost:8082/](http://localhost:8082/) to monitor Flink jobs status
1818

19-
You may modify the stats reporting interval in [./src/main/scala/org/apache/flink/playgrounds/spendreport/SpendReport.scala](./src/main/scala/org/apache/flink/playgrounds/spendreport/SpendReport.scala):
19+
You may modify the stats reporting interval by setting `STATS_COMPUTE_INTERVAL_MINUTES` environment variable or in [./src/main/scala/org/apache/flink/playgrounds/spendreport/SpendReport.scala](./src/main/scala/org/apache/flink/playgrounds/spendreport/SpendReport.scala):
2020
```scala
2121
object SpendReport {
2222
// the default value of `5.minute` would compute stats over non-overlapping (Tumble) windows of 5 minutes each, taking into account only the data inside the current window, and would report stats to Kensu at end of each such window

table-walkthrough/build-and-run.sh

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
export KENSU_INGESTION_URL
22
export KENSU_AUTH_TOKEN
3+
export STATS_COMPUTE_INTERVAL_MINUTES
34

45
source ./detect_platform.sh
56

table-walkthrough/docker-compose.yml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -107,14 +107,14 @@ services:
107107
volumes:
108108
- /var/run/docker.sock:/var/run/docker.sock
109109
data-generator:
110-
image: apache/data-generator:1
110+
image: kensuio/kensu-flink-collector:table-walkthrough-kafka-gen
111111
build: ../docker/data-generator
112112
environment:
113113
KAFKA_TOPIC: "transactions"
114114
depends_on:
115115
- kafka
116116
data-generator-two:
117-
image: apache/data-generator:1
117+
image: kensuio/kensu-flink-collector:table-walkthrough-kafka-gen
118118
build: ../docker/data-generator
119119
environment:
120120
KAFKA_TOPIC: "aborted_transactions"

table-walkthrough/run.sh

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
export KENSU_INGESTION_URL
22
export KENSU_AUTH_TOKEN
3+
export STATS_COMPUTE_INTERVAL_MINUTES
34

45
source ./detect_platform.sh
56

0 commit comments

Comments
 (0)