Skip to content

Adding new bulk processor for elasticsearch implementation#95

Merged
dlamoris merged 4 commits intodevelopfrom
feature/elasticBulkProcessor
Sep 18, 2020
Merged

Adding new bulk processor for elasticsearch implementation#95
dlamoris merged 4 commits intodevelopfrom
feature/elasticBulkProcessor

Conversation

@HuiJun
Copy link
Collaborator

@HuiJun HuiJun commented Sep 3, 2020

No description provided.

jacksonVersion=2.10.3
log4jVersion=2.13.1
elasticVersion=7.1.1
elasticVersion=7.9.0
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

is there a 7.7.x version? the highest on aws right now is 7.7 and the client are forward but not backwards compatible

public CommitsResponse updateTwcRevisionID(String projectId, String commitId, String revisionId) {
CommitsResponse commitsResponse = new CommitsResponse();
if (revisionId.isEmpty() || revisionId.isBlank()) {
if (revisionId.isEmpty()) {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

should check for null first also

}

@Override
public void afterBulk(long executionId, BulkRequest request, BulkResponse response) {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

should log any failures for now


public abstract class BaseElasticDAOImpl<E extends Map<String, Object>> {

private final Logger logger = LogManager.getLogger(getClass());
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

use slf4j LoggerFactory.getLogger(getClass())

project(':jupyter'),
project(':permissions'),
project(':webhooks'),
project(':twc'),
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

take out ldap too

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

done

@HuiJun HuiJun requested a review from dlamoris September 18, 2020 21:41
public CommitsResponse updateTwcRevisionID(String projectId, String commitId, String revisionId) {
CommitsResponse commitsResponse = new CommitsResponse();
if (revisionId.isEmpty() || revisionId.isBlank()) {
if (revisionId != null && revisionId.isEmpty()) {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

should be == null ||

@dlamoris dlamoris merged commit 15616de into develop Sep 18, 2020
@dlamoris dlamoris deleted the feature/elasticBulkProcessor branch September 23, 2020 17:49
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants