Skip to content

Fix metadata inconsistency during the autoscaling#19065

Draft
Fly-Style wants to merge 1 commit intoapache:masterfrom
Fly-Style:fix/pending-autoscaling
Draft

Fix metadata inconsistency during the autoscaling#19065
Fly-Style wants to merge 1 commit intoapache:masterfrom
Fly-Style:fix/pending-autoscaling

Conversation

@Fly-Style
Copy link
Contributor

@Fly-Style Fly-Style commented Feb 27, 2026

Work in progress

@Fly-Style Fly-Style marked this pull request as draft February 27, 2026 18:26
{
EasyMock.expect(spec.getId()).andReturn(SUPERVISOR).anyTimes();
EasyMock.expect(spec.getSupervisorStateManagerConfig()).andReturn(supervisorConfig).anyTimes();
EasyMock.expect(spec.getDataSchema()).andReturn(getDataSchema(DATASOURCE)).anyTimes();

Check notice

Code scanning / CodeQL

Deprecated method or constructor invocation Note test

Invoking
SeekableStreamSupervisorSpec.getDataSchema
should be avoided because it has been deprecated.
@Override
protected int getTaskGroupIdForPartition(String partition)
{
return Integer.parseInt(partition) % spec.getIoConfig().getTaskCount();

Check notice

Code scanning / CodeQL

Missing catch of NumberFormatException Note test

Potential uncaught 'java.lang.NumberFormatException'.
Signed-off-by: Sasha Syrotenko <alexander.syrotenko@imply.io>
@Fly-Style Fly-Style force-pushed the fix/pending-autoscaling branch from 1f3347a to 642a187 Compare February 27, 2026 22:35
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant