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
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.

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ởi | lần thử | kết quả | điểm | chi phí USD | thời điểm |
|---|---|---|---|---|---|
| Argusic Runner | 2/3 | Chạy được với mock | 92,00 | 0,72 | |
| Argusic Runner | 1/3 | Chạy được với mock | 92,00 | 0,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.
[](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.