Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix index push down #697

Merged
merged 8 commits into from May 8, 2019
Merged
Changes from 1 commit
Commits
File filter...
Filter file types
Jump to…
Jump to file or symbol
Failed to load files and symbols.

Always

Just for now

fix concurrent

  • Loading branch information...
birdstorm committed May 8, 2019
commit 4b4b3db55e4e4193f682cc64b478fefab8998348
@@ -261,7 +261,7 @@ case class RegionTaskExec(child: SparkPlan,
taskCount += 1
val task = new Callable[util.Iterator[TiRow]] {
override def call(): util.Iterator[TiRow] =
CoprocessIterator.getRowIterator(dagRequest, tasks, session)
CoprocessIterator.getRowIterator(dagRequest.copy(), tasks, session)
}
completionService.submit(task)
}
@@ -111,6 +111,15 @@ public TypedKey next() {

@Override
public String toString() {
This conversation was marked as resolved by birdstorm

This comment has been minimized.

Copy link
@zhexuany

zhexuany May 8, 2019

Member

We can use protobuf‘s TextFormat

This comment has been minimized.

Copy link
@birdstorm

birdstorm May 8, 2019

Author Member

done

return KeyUtils.formatBytesUTF8(value);
try {
CodecDataInput cdi = new CodecDataInput(value);
Object val = type.decode(cdi);
if (val instanceof byte[]) {
return KeyUtils.formatBytes(value);
}
return val.toString();
} catch (Exception e) {
return "raw value:" + KeyUtils.formatBytesUTF8(value);
}
}
}
ProTip! Use n and p to navigate between commits in a pull request.
You can’t perform that action at this time.