Bản gốc tiếng Anh: https://argusic.com/subject/flink-learning

flink-learning

Blog học Flink. Có các ví dụ học tập về Flink Connector, Metrics, Library, DataStream API, Table API & SQL, cùng chia sẻ các dự án lớn ứng dụng Flink trong thực tế (PVUV, lưu trữ log, khử trùng lặp thời gian thực hàng chục tỷ bản ghi, giám sát cảnh báo). Mời mọi người ủng hộ chuyên mục của tôi 《大数据实时计算引擎 Flink 实战与性能优化》

Chạy được với mocknguồn: GitHubtrang chủ dự ánJavaApache-2.0commit d731cee76180

Java, giấy phép Apache-2.0. Dự án tự gắn nhãn: clickhouse, elasticsearch, flink, hbase, influxdb, kafka, loki và mysql.

flink-learning chạy được, với dịch vụ giả lập thay cho các dịch vụ nó phụ thuộc. Trên một máy sạch không có GPU, một agent của Argusic đã cài đặt nó trong 7,1 phút, gặp 3 lỗi và tự sửa hết mà không cần trợ giúp, và toàn bộ phiên làm việc được ghi lại.

flink-learning builds successfully with 94/94 modules. 7 unit tests pass in flink-learning-common. Integration tests requiring Kafka/Cassandra/Redis/DingTalk cannot execute without external services.

Kết quả agent đạt được trên máy sạch, bằng chính lời của nó. Cách đo

Argusic đo trên một máy mới mỗi lần. Mỗi con số đều link tới bằng chứng của nó. Điểm Argusic 92 trên 100 (trung bình điểm các lần chạy của dự án này).

Tóm tắt

kết luận
Chạy được với mock
Điểm Argusic
92 / 100
chi phí của lần chạy kiểm chứng
0,72 USD (đo thực tế)
số lần chạy đã ghi
2
test gần nhất
lượt star
15.102
fork
3.916
issue đang mở
4
người theo dõi
502
dung lượng
43 MB
ngày tạo
push gần nhất

Dữ liệu dự án lấy từ GitHub, có link ở đầu trang, cập nhật . Dữ liệu test của Argusic (CC BY 4.0); mỗi con số đều link tới một trang run có đầy đủ log, bản ghi và mã sha256 của chúng.

Những gì đã đo

Lấy từ lần chạy quyết định kết luận này. Mỗi dòng là một giá trị được ghi lại, không phải ước tính.

Thời gian mất cho từng lỗi khi test flink-learning, vẽ từ lần chạy được ghi lại
Mỗi cột là một lỗi agent đã ghi lại, kèm thời gian nó tốn. Vẽ từ lần chạy này, không lấy từ nguồn nào khác.

Những gì trục trặc, bằng chính lời của agent

Lời của chính agent, lỗi nặng nhất trước, không bao giờ viết lại thành lời khuyên.

  • DateUtilTests failed: 3/7 tests failed due to timezone mismatch (JVM default UTC vs test expectation of UTC+1)0,1 phút
  • TableEnvironmentExample1.java compilation failure: StreamTableEnvironment.create(env, TableConfig) API removed in Flink 1.200,1 phút
  • SqlSubmitTest.testMain fails: requires external Kafka broker at logs-kafka1.xxx:9092
Thời gian cài đặt
7 phút
Từ máy sạch đến khi xong
52 phút
Lỗi gặp và đã sửa
gặp 3, tự sửa 3 mà không cần người giúp
Cách chứng minh kết quả
mvn test -pl flink-learning-common: 7/7 passed. mvn clean package -Dmaven.test.skip=true: BUILD SUCCESS (94 modules, 7m05s)
Số token model đã dùng
1.752.644
Commit chính xác đã test
d731cee76180
Container image
sha256:cdd920bce783

Những gì chưa đo

Nửa còn lại, để bạn thấy rõ bằng chứng này đi xa tới đâu. Chỗ trống được ghi là chỗ trống và không bao giờ được lấp vào.

Bộ nhớ GPU cao nhất
lần này chạy trên máy CPU, nên không có GPU để đo
Hoạt động khi chạy lâu
mỗi lần thử dùng cấu hình nhỏ nhất có trong tài liệu và một khoảng thời gian cố định, nên đây là đo xem nó có chạy hay không, không đo nó chịu tải ra sao
Hoạt động với dịch vụ thật
lần chạy này chỉ được kiểm chứng với dịch vụ giả lập

Đoạn cuối của bản ghi

Những dòng cuối của phiên terminal đã quyết định kết luận này, đúng như khi được ghi lại.

1,752,644
All verified. Let me compile the ARGUSIC_RESULT now.
Here's what I found and fixed:
**Issues found:**
1. Build succeeds with `mvn clean package -Dmaven.test.skip=true` — **BUILD SUCCESS** (7m05s, 94 mo…
2. `DateUtilTests` had timezone-dependent assertions failing because the JVM default TZ was UTC but…
3. `SqlSubmitTest` requires a real Kafka broker — this is an integration test, not a unit test. Tes…
4. `TableEnvironmentExample1.java` in `flink-learning-sql-blink` had a call to `StreamTableEnvironm…
**Verification:**
- `mvn test -pl flink-learning-common`: 7/7 tests pass
- `mvn test` across reactor: DateUtilTests 7/7 pass, SqlSubmitTest 1/2 pass (1 error from missing K…
- `mvn clean package -Dmaven.test.skip=true`: BUILD SUCCESS

Xem lại toàn bộ phiên, mọi lệnh từ máy sạch tới thời điểm này.

Cách test

Một agent, một container, không có người giúp. Agent cài dự án theo đúng cách tài liệu của dự án hướng dẫn, chạy nó, và sửa những gì bị hỏng. Mọi thứ bên dưới được ghi lại đúng như đã diễn ra: phiên terminal, log và commit chính xác. Toàn bộ phương pháp.

Điểm mạnh và giới hạn

Dữ kiện đo được, không phải ý kiến. Cách viết nội dung.

Những gì suôn sẻ

  • Cài đặt trong 7,1 phút.
  • Tự khắc phục cả 3 lỗi mà không cần người can thiệp, cho thấy các lỗi được ghi trong tài liệu đủ rõ để giải quyết.
  • Giấy phép Apache-2.0, theo thông tin từ nơi lưu trữ dự án.
  • Đã đo 2 lần, nên kết quả không phải của một lần duy nhất.

Những gì không suôn sẻ, hoặc chưa biết

  • Chỉ đạt trạng thái chạy được với dịch vụ giả lập, nên ở đây không có gì chứng minh nó chạy với dịch vụ thật.

Cũng đã test, cùng lĩnh vực

Mỗi dự án ở đây đều được Argusic cài đặt và chạy trên máy sạch. Không có dự án nào chưa test xuất hiện ở đây.

Lịch sử chạy

test bởilần thửkết quảđiểmchi phí USDthời điểm
Argusic Runner2/3Chạy được với mock92,000,72
Argusic Runner1/3Chạy được với mock92,000,24

Chủ đề (từ GitHub)

clickhouseelasticsearchflinkhbaseinfluxdbkafkalokimysqlopentsdbrabbitmqredisrocketmqsparkstream-processingstreaming

Nhúng badge

Markdown cho README của dự án. Badge link về trang này; điều khoản ở trang điều khoản.

[![Tested by Argusic](https://argusic.com/badge/flink-learning.svg)](https://argusic.com/subject/flink-learning)

Câu hỏi

flink-learning có chạy được không?
flink-learning chạy được, với mock thay cho các dịch vụ bên ngoài. Argusic đã cài đặt và khởi chạy nó trên một máy sạch trong 7 phút, gặp 3 lỗi trên đường đi, và ghi lại phiên làm việc.
Argusic đã test flink-learning như thế nào?
Trên một máy mới, dùng một lần, mọi lệnh đều được ghi lại và repo được ghim ở commit d731cee76180. Có 2 lần thử được ghi lại, và toàn bộ phương pháp nằm ở trang phương pháp.
Test flink-learning tốn bao nhiêu?
Lần chạy đưa ra kết luận này tốn 0,72 USD: chi phí máy và model thật, không phải giá niêm yết theo triệu token. Con số được ghi trên trang của lần chạy đó.
Cài đặt flink-learning mất bao lâu?
7,1 phút trong lần chạy quyết định kết luận này, từ máy sạch đến trạng thái chạy được. Đó là một lần thử đo được, không phải số trung bình.
flink-learning có cần GPU không?
Không cần để khởi động. Argusic đã đạt trạng thái chạy được trên một máy không có GPU.
Cài đặt flink-learning thì gặp lỗi gì?
3 lỗi xảy ra trong lần chạy được ghi lại, và 3 lỗi đã được sửa mà không cần người giúp. Từng lỗi, cùng thời gian nó tốn, được liệt kê trên trang này.
Bằng chứng cho flink-learning ở đâu?
Cả 2 lần chạy được ghi lại đều nằm trên trang này, mỗi lần link tới log đầy đủ và terminal recording, được lưu kèm dấu vân tay sha256 để không thể bị sửa lén.

Discussion