| Age | Commit message (Collapse) | Author |
|---|
|
operators.
|
|
FilterProcessorFactory.The Factory add supportsType method for supporting legency type of avaitor.
|
|
Identifier 统一为type，与任务配置文件保持一致.
|
|
增加groot-spi模块，解耦core和common模块之间的复杂依赖关系，移除一些不需要的类库。
|
|
Rename lookup_fields and output_fields to lookupFields and outputFields.
|
|
test topology.
|
|
during testClickHouse.
|
|
|
|
from application/properties to application/env/properties, and add support for defining variables via the runtime CLI. (GAL-651)
|
|
|
|
|
|
description.
|
|
Flink job
|
|
clickhouse.jdbc.version with version 0.6.3.
|
|
|
|
quota test based on the topic.
|
|
flink-shaded-hadoop-2-uber-2.7.5-8.0.jar. Add mock data to kafka integration test.
|
|
longer executed by default during the mvn compile and deploy process. In the job template for processor and filter, describe the implementation type based on identifiers.
|
|
|
|
|
|
inline-to-kafka config.
|
|
|
|
|
|
|
|
test-common and test-e2e-base submodules. Support Inline to Print test in Flink13 Container.
|
|
|
|
|
|
函数待持续优化）
|
|
|
|
�为便于测试，暂时对groot-bootstrap基于shade封装各个模块打一个jar包。
|
|
|
|
�立打包，去掉函数注册main_class
|
