flink-learning

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

Runs with mockssource: GitHubJavaApache-2.0commit d731cee76180

Java, Apache-2.0 licensed. The project labels itself: clickhouse, elasticsearch, flink, hbase, influxdb, kafka, loki and mysql.

flink-learning runs, with stand-ins for the services it depends on. An Argusic agent installed it in 53 minutes and hit 8 errors and fixed every one without help on a clean machine with no GPU, and the whole session was recorded.

The full 94-module Maven reactor builds successfully with all compilation errors fixed; 78 JARs are produced; the test suite runs with only 3 pre-existing timezone-dependent assertion failures in DateUtilTests and 1 pre-existing Kafka-required error in SqlSubmitTest; all other tests pass.

What the agent ended up with on a clean machine, in its own words. How this is measured

Measured by Argusic on a fresh machine every time. Every number links to its evidence. Argusic Score 92 of 100 (the mean of this project's run scores).

At a glance

verdict
Runs with mocks
Argusic Score
92 / 100
cost of the verifying run
$0.24 (measured)
recorded runs
1
last tested
stars
15,101
forks
0
open issues
0
watchers
0
created
-
last push
-

Subject data from GitHub, linked at the top of this page. Test data by Argusic (CC BY 4.0); every number links to a run page with the full log, the recording, and their sha256 hashes.

What was measured

From the run that decided this verdict. Every line is a recorded value, not an estimate.

Time lost to each failure while testing flink-learning, drawn from the recorded run
Every bar is a failure the agent recorded, with the time it cost. Drawn from this run, not from anywhere else.

What went wrong, in the agent's own words

The agent's own words, worst first, never rewritten into advice.

  • Java 17+ and Maven 3.9+ not pre-installed in container3 minutes
  • flink-learning-extends Log4jKafkaAppender and Log4j2KafkaAppender: slf4j-api missing (only slf4j-log4j12/log4j-slf4j-impl in provided scope)2 minutes
  • Alibaba Cloud Maven mirror (aliyun) returned 502 for some artifacts2 minutes
  • flink-learning-paimon missing Flink table API dependencies (pom.xml had no <dependencies>)1 minute
  • Log4j2KafkaAppender ExceptionUtilTest imported com.zhisheng.log.util.ExceptionUtil (wrong package - correct is com.zhisheng.flink.util.ExceptionUtil in KafkaAppenderCommon)1 minute
  • flink-learning-sql-blink test: TableConfig.getDefault() return type changed in Flink 1.20 (no longer compatible with StreamTableEnvironment.create)1 minute
Install time
53 minutes
Cold machine to finish
53 minutes
Errors hit and fixed
8 hit, 8 fixed with no human help
How the result was proved
mvn install -Dmaven.test.skip=true on all 94 reactor modules produced BUILD SUCCESS with 78 JAR artifacts. mvn test -Dmaven.test.failure.ignore=true ran: DateUtilTests 7/3 failed (pre-existing timezone), SqlSubmitTest 2/1 error (needs Kafka), all other 5 test classes passed (0 failures across RedisTest, Test1, DingDingMsgTest, TestWindowSize, ExceptionUtilTest). All JAR files confirmed present under target/ directories.
Model tokens used
1,659,497
Exact commit tested
d731cee76180
Container image
sha256:cdd920bce783

What was not measured

The other half, so you can see exactly how far this evidence goes. A gap is printed as a gap and never filled in.

Peak GPU memory
this ran on a CPU machine, so there was no GPU to sample
Behaviour over a long run
each attempt uses the smallest documented settings and a fixed time budget, so this measures whether it runs, not how it holds up under load
Behaviour against real services
this run was verified against stand-in services only

The end of the recording

The last lines of the terminal session that decided this verdict, exactly as they were recorded.

Install start: 13:15 UTC
Current: 14:08 UTC
Now I have all the data. Let me produce the final structured report.
**Time start:** ~13:15 UTC (first `ls` command)
**Time end:** ~14:08 UTC
**Total elapsed:** ~53 minutes
tokens used
1,659,497
Now I have all the data. Let me produce the final structured report.
**Time start:** ~13:15 UTC (first `ls` command)
**Time end:** ~14:08 UTC
**Total elapsed:** ~53 minutes

Replay the whole session, every command from a clean machine to this point.

How it was tested

One agent, one container, no human help. It installs the project the way its own documentation says to, runs it, and fixes what breaks. Everything below is recorded as it happened: the terminal session, the log and the exact commit. The full method.

Strengths and limits

Measured facts, not opinions. How this is written.

What went well

  • Installed in 53 minutes.
  • Recovered from all 8 errors without a human stepping in, which says the failures are documented well enough to solve.
  • Licensed Apache-2.0, as reported by its host.

What did not, or is not known

  • Only reached a running state against stand-in services, so nothing here proves it works against the real ones.
  • Measured once so far. A single attempt shows it can run, not that it runs reliably.

Also tested, in the same area

Every one of these was installed and run by Argusic on a clean machine. Nothing appears here that was not tested.

Run history

tested byattemptoutcomescorecost USDwhen
Argusic Runner1/3Runs with mocks92.000.24

Topics (from GitHub)

clickhouseelasticsearchflinkhbaseinfluxdbkafkalokimysqlopentsdbrabbitmqredisrocketmqsparkstream-processingstreaming

Embed the badge

Markdown for the project README. It links back here; terms on the terms page.

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

Questions

Does flink-learning run?
flink-learning runs, with mocks standing in for external services. Argusic installed and launched it on a clean machine in 53 minutes, hitting 8 errors on the way, and recorded the session.
How did Argusic test flink-learning?
On a fresh, disposable machine, with every command recorded and the repository pinned at commit d731cee76180. One attempt is recorded, and the full method is on the methodology page.
What did it cost to test flink-learning?
The run that produced this verdict cost $0.24: real compute and model cost, not a list price per million tokens. It is recorded on that run's page.
How long does flink-learning take to install?
53 minutes in the run that decided this verdict, from a clean machine to a running state. That is one measured attempt, not an average.
Does flink-learning need a GPU?
Not to start. Argusic reached a running state on a machine with no GPU.
What goes wrong when installing flink-learning?
8 things broke in the recorded run, and 8 were fixed without human help. Each one, and the time it cost, is listed on this page.
Where is the evidence for flink-learning?
The recorded run is on this page, each linking to its full log and terminal recording, stored with a sha256 fingerprint so it cannot be quietly altered.

Discussion