Comments (4)
I'd like to take this issue.
from bitsail.
A sample job config is as follows:
{
"job": {
"common": {
"job_type": "STREAMING",
"job_plugin_lib_dir": "plugin",
"job_plugin_conf_dir": "plugin_conf",
"enable_dynamic_loader": true,
"instance_id": "1",
"internal_instance_id": "1",
"extra_properties": {
"update-mode": "append"
}
},
"reader": {
"pulsar": {
"source": {
"enableAutoAcknowledgeMessage": true
},
"client": {
"serviceUrl": "pulsar://lcoalhost:8080"
},
"admin": {
"adminUrl": "http://localhost:6650",
"topics": "TBW102",
"topicMode": "list"
},
"consumer": {
"startCursorMode": "latest",
"subscriptionType": "Exclusive"
}
},
"columns": [
{
"name": "ID",
"type": "string"
}
],
"format_type": "json",
"class": "com.bytedance.bitsail.connector.pulsar.source.PulsarSourceV1"
},
"writer": {
"class": "com.bytedance.bitsail.connector.legacy.print.sink.PrintSink"
}
}
}
P.S., I always get the slf4j warnings
SLF4J: Class path contains multiple SLF4J bindings.
, SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
, and no log is printed which impacts the testing processing. Any help is appreciated.
from bitsail.
@qidian99 assigned to you!
from bitsail.
Reminder, is there any problem encountered in this task, we can discuss it together @qidian99
from bitsail.
Related Issues (20)
- [Improve][UT] UT on macos is redundant
- [BitSail][Core] Support new Flink version HOT 1
- [Improve] Add new module for the flink in client & core module
- [Improve] Support Flink1.16 in bitsail client module
- [Improve] Support Flink 1.16 in bitsail-core-flink
- [Improve][Pom] Duplicate declaration of version of connector-redis
- [Improve][Core] Update Exception Information in DelegateFlinkWriter
- [Improve][Connector] Remove unused option in print connector
- [Bug][Connector] RocketMQ Source Get Start Offset
- [Bug][JsonRowDeserializationSchema] 解析json写入hdfs失败
- [Bug][Maven] Fails to clean maven HOT 1
- [Bug][Test] Test testCreateGenericExecutor method would fail with NullPointerException
- 使用读连接器连接MongoDB,报错Caused by: com.mongodb.MongoCommandException: Command failed with error 18 (AuthenticationFailed): 'Authentication failed.' on server HOT 1
- [Improve][Connector] Kudu source refactor
- [BitSail][Bug] TypeInfoCompatiblesColumnCompareTest not pass
- [Bug][bitsail-entry] missing jobId HOT 2
- [Bug] 文档错误
- [Bug][Connector] KafkaConnector not registered
- [Improve][connector] Support stream read from Hudi table HOT 1
- [Bug][connetor] mysql 为sink表 insert 模式,partition_pattern_format为非必填项,但是不填写会报空指针异常 HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from bitsail.