30-Day Free Trial: Itās Never Been Easier To Get Started With StreamSets
Hello!! Currently, Iām using the SDK to extract metrics from some jobs. However, instead of having only {run_count, input_count, output_count, total_error_count} from sch.job.metrics, I would like to have some other metrics as well, such as counting each record for each step of my job. Is this possible? How can I achieve this? Iām also looking to get the last received record (for each pipeline) that we can see in the real-time summary. How can I get this metric from ControlHub using the SDK?
Hi , I am creating a new Connection with SFTP protocol and trying to connect to the SFTP server using a private key . I inputted these while creating the Connection: Authentication as Private Key , Private Key provider as plain text Private Key as the text that i copied from the ppk file Username the correct one there was no Passphrase and when i hit Test Connection I get the below error Stage 'com_streamsets_pipeline_lib_remote_RemoteConnectionVerifier_01' initialization error: java.lang.NullPointerException: Cannot invoke "net.schmizz.sshj.userauth.keyprovider.KeyProvider.getPublic()" because "this.kProv" is null (CONTAINER_0701) But alternatively if i input the same in the credentials tab of the pipeline and preview ,I am able to successfully connect to the sftp server and read the file there . Problem is when i create the same via a connection Kindly help me to resolve this issue .
I am attempting to use Postman to query the runtime history of all jobs so that I can provide a list of the X slowest running jobs. I have been unable to configure Postman correct for this GET call, and would like to know from the hivemind what I am doing wrong here. Trying to use this API endpoint: https://{Control_Hub_URL}.streamsets.com/jobrunner/rest/v1/job/{jobId}/history Auth is set to āNo authā based upon another forum post I read that stated we should include the ID and key for the API credentials used in the header, though I have tried it with API Key and providing the credentials there, as well. I have read through the 14 questions and 4 conversations that return when searching here for āPostmanā and tried a few of the proffered solutions but without success. I have no parameters and the headers are where I have been trying to define API credentials. Note these credentials are used by automation in the Control Hub so they are valid. I think my issue lies in what header names
I am using Data collector 5.8.1 . I am selected JDBC in my pipeline start event I am using this query in my start event: DECLARE @XYZWorkFlowID INT = (SELECT TOP 1 WorkFlowID FROM dbo.RefWorkFlow WHERE WorkFlowName = 'XYZ') INSERT INTO JobTracker(JobName,WorkFlowID,Campaign,LastExecutedTime,JobStatus)VALUES ('XYZ_ABC_Export',@XYZWorkFlowID ,'Dialer',GETDATE(),'InProgress') I need to get the identity value generated by JobTracker table and assign it to a āJobTrackerIdā pipeline parameter. I need to use the same parameter in the stop event jdbc to update JobTracker the table. I tried adding: ${JobTrackerId} = SELECT @@Identity I'm pretty sure this is the wrong approach. Can anyone guide me through the right one?
Docs and at least one community thread have suggested that the following expression should work in a stream selector conditional: ${record:exists('/ids') && length(record:value('/ids')) > 0} This returns: ELException: No function is mapped to the name "length". The field in question is a list of integers. What am I not understanding? Thanks
I have resource URL as āhttps://api.simpleng.com.au/v2/ActionSheets/SummaryForSite/3?data=bma&changesAfter=2024-11-01T00:00:00&pageNumber=1ā And response as :{ "page": 1, "ofPages": 3, "content": [ ] } Where I want to get all records in Page 1,2 and 3.Despite using pagination I am not able to get the records from all the pages and get only from 1st page. I am using Pagination with PageNumber and using ${StartAt} variable.Refer below Screenshots
While i am working with a table that had no Primary Key and the total number of records were also huge, so i thought of a basic SQL concept that ā To Uniquely Identify a row some times we use Multiple columns ā.To use the same in incremental mode in JDBC Query Consumer, I thought of using multiple columns as offset, but i have gone nowhere. Can anybody have any thoughts on this. Thank you.
Hello everybody. I'm doing an exercise on streamsets and when creating a pipeline it throws this error. VALIDATION_0096 - This pipeline was created in version 6.1.0 and is not compatible with current version 6.0.0. How to fix it? I'm using the 30-day trial version of streamsets. Thank you very much.
Hello, I am trying to establish a connection from StreamSets to a Redis database on IBM Cloud. This instance requires the use of a Certificate Authority (CA) for authentication and secure communication, but I haven't found a way to properly configure it in StreamSets. I have attempted the following without success: Configuring a Truststore: I created a Truststore and imported the CA certificate using keytool. I updated the StreamSets configuration (sdc.properties), including the https.truststore.path property, to reference the Truststore. Passing parameters in the connection URI: I tried different URI formats, including adding the certificate to the connection string, but the connection still fails. I would appreciate any guidance on the correct way to configure StreamSets to trust the Redis certificate and establish a secure connection.
Dear Community, I hope this message finds you well. I am reaching out to seek your help on an error getting in validation of Mongodb oplog origin stage. Your support would be greatly appreciated. Validation Error: [ MONGODB_04 - Collection isn't tailable because 'oplog.rs' is not a capped collection. : configBean.mongoConfig.collection ] Other detail/info: > Stage Library: MongoDB Java driver 3.12.0 > I tried with another capped collection 'oplog.test' created in development database other than local. But getting the same error. > I checked the older post and found same error is mentioned, however solution is not there. Thank you in advance for your time and assistance. Best regards,Kamakhya
Become a leader!
4149 points
3570 points
2500 points
Already have an account? Login
No account yet? Create an account
Enter your E-mail address. We'll send you an e-mail with instructions to reset your password.
Sorry, we're still checking this file's contents to make sure it's safe to download. Please try again in a few minutes.
Sorry, our virus scanner detected that this file isn't safe to download.
