Questions tagged [sink]
Command in the programming language R. Sends R Output to a connection.
sink
189
questions
0
votes
0
answers
7
views
Flink job produces bad characters with a queueLimit > 1
I'm trying to fix an old flink job, and running into some issues. If setQueueLimit is > 1, i will randomly get messages where the key becomes part of the message, along with some bad characters, ...
- 2,742
0
votes
0
answers
15
views
Kafka Producer test sink postgres connector
I want to test kafka producer on postgresql database :
create table test (id derial primary key, value text)
I insert on kafka producer, this value
/opt/kafka/bin/kafka-console-consumer.sh --...
- 13
0
votes
0
answers
74
views
Is it possible for a Flink job to be executed without a sink?
I'm trying to cut down the processing time of one of my flink jobs and came to discover that some operators are being executed no matter if they are or not connected to any sinks. Is that even ...
- 143
0
votes
0
answers
23
views
Sink AVRO messages from pulsar topic to elasticsearch
It is possible to sink messages from pulsar topic which uses avro schema? Im try to use this solution:
https://pulsar.apache.org/docs/next/io-elasticsearch-sink/
But my problem is if i want to use the ...
0
votes
1
answer
61
views
Azure DataFactories link to Synapse Analytics sqloperationfailed error
I try to create linked service in Data Factory from ADLS to Synapse sql serverless sql pool but I get error:
SqlOperationFailed
A database operation failed with the following error: 'External table '...
- 3
0
votes
1
answer
381
views
.Net 6 logging to oracle database using Serilog sink feature
I'm trying to log the information and errors to the oracle database using serilog
I see only examples for MS SQL Server. I created this config using that as an example. I don't see any blog or info ...
3
votes
1
answer
2k
views
Python Polars: Low memory read, process, writing of parquet to/from Hadoop
I would like to be able to process very large files in Polars without running out of memory. In the documentation they suggest using scanning, lazyframes and sinks, but it is hard to find proper ...
- 3,622
0
votes
0
answers
43
views
sink function with future.callr
I have this R script:
test.R
library(future.callr)
plan(callr)
executeInternalActivity<-function(){
sink(file = "output.txt",append = TRUE)
print(Sys.time())
Sys.sleep(3)
...
- 823
1
vote
1
answer
49
views
My subscriber cannot receive subscription
I have a problem of using combine send and sink method.
the publisher like this
//ViewModel
let reviewCellData = CurrentValueSubject<[ArchivingReviewCellModel], Never>([])
I surely checked the ...
- 61
0
votes
1
answer
69
views
apache flink sink for elasticserach NoClassDefFoundError
I am writing a Flink job to send a data stream to elasticsearch. I am using Maven and IntelliJ. When I try to test the job within IntelliJ I get the following error: java.lang.NoClassDefFoundError: ...
-1
votes
1
answer
399
views
Using Data Flow activity inside For each activity in Azure Data Factory
I'm working on a pipeline in which I get the file names from some file I need to process from a SFTP using the get metadata activity, then filter the file names get just the files I need, after that I ...
0
votes
2
answers
121
views
R sink to .csv with predefined width
I've got an R script that exports a data frame and some other lines to .csv file using sink. Another script collects the data from multiple csv's exported in this way.
These scripts need to be used ...
- 331
0
votes
0
answers
93
views
How can I use my Raspberry Pi as a Bluetooth sink with AVRCP protocol?
I've been searching the internet for two days now and have made several attempts to use my Raspberry Pi (Computemodule 4) as a Bluetooth sink with AVRCP protocol. Unfortunately, I have come to no real ...
0
votes
0
answers
133
views
JDBC sink connector fail with error non-null key non-null struct
I am new to connector. Doing POC with JDBC sink for oracle. Connector fails with below error
"sink connector is configured with "delete.enabled=true" and pk.mode=record_key" and ...
1
vote
2
answers
705
views
Map Publisher to another publishers sequentially and handle errors for each step separately (or skip) in Swift Combine?
Code:
import Combine
func login() -> Future<Token, Error> { ... }
func updateImage() -> Future<Status, Never> { ... }
func getProfile() -> Future<Profile, Error> { ... }
I ...
- 1,339