1
从升级后出现错误“冲突类型ID [type1 ='行',type2 ='行',typeId = 113114]” Apache Ignite 2.0至2.1(.Net)。升级后我没有更改任何代码,所以想知道如何创建和使用动态二进制对象的期望改变了?我看着AddType方法。也许它应该返回而不是抛出,也许该方法的名称是误导性的,它应该是GetOrAddType?Apache Ignite 2.1:从2.0升级后出现“冲突类型ID”错误
堆栈跟踪:
at Apache.Ignite.Core.Impl.Binary.Marshaller.ThrowConflictingTypeError(Object type1, Object type2, Int32 typeId)
at Apache.Ignite.Core.Impl.Binary.Marshaller.AddType(Type type, Int32 typeId, String typeName, Boolean userType, Boolean keepDeserialized, IBinaryNameMapper nameMapper, IBinaryIdMapper idMapper, IBinarySerializerInternal serializer, String affKeyFieldName, Boolean isEnum)
at Apache.Ignite.Core.Impl.Binary.Marshaller.AddUserType(BinaryTypeConfiguration typeCfg, TypeResolver typeResolver)
at Apache.Ignite.Core.Impl.Binary.Marshaller.GetDescriptor(Boolean userType, Int32 typeId, Boolean requiresType, String typeName, Type knownType)
at Apache.Ignite.Core.Impl.Binary.Marshaller.GetDescriptor(String typeName)
at Apache.Ignite.Core.Impl.Binary.Binary.GetBuilder(String typeName)
at MyCompany.DataFabric.Core.CacheManagers.Table.RowCacheManager.BuildRow(Int64 rowNumber, String row, Boolean setColumnFields) in C:\Users\me\Documents\GitLab\Platform\Core\CacheManagers\Table\RowCacheManager.cs:line 140
at MyCompany.DataFabric.Core.CacheManagers.Table.RowCacheManager.<>c__DisplayClass26_1.<WriteAsync>b__1(KeyValuePair`2 r) in C:\Users\me\Documents\GitLab\Platform\Core\CacheManagers\Table\RowCacheManager.cs:line 128
at System.Threading.Tasks.Parallel.<>c__DisplayClass42_0`2.<PartitionerForEachWorker>b__1()
at System.Threading.Tasks.Task.InnerInvokeWithArg(Task childTask)
at System.Threading.Tasks.Task.<>c__DisplayClass176_0.<ExecuteSelfReplicating>b__0(Object)
这是我的代码如下所示:
public async Task WriteAsync(IEnumerable<string> rows, long startRowNum = 0) {
// Create the cache if it doesn't exist, yet
await this.GetOrCreateRowCache();
using (var ds = m_ignite.GetDataStreamer<string, object>(CacheName).WithKeepBinary<string, IBinaryObject>()) {
try {
ds.AllowOverwrite = true;
ds.Receiver = new RowStreamReceiver {
TableId = TableId
};
Parallel.ForEach(rows.Select((r, i) => new KeyValuePair<long, string>(i, r)), r => {
var rowNum = r.Key + startRowNum;
if (rowNum % 10000 == 0) {
Console.WriteLine($"Put [Row: {r.Key}, Thread: {Thread.CurrentThread.ManagedThreadId}]");
}
var pair = BuildRow(rowNum, r.Value, false);
// ReSharper disable once AccessToDisposedClosure
ds.AddData(pair);
});
} finally {
Console.WriteLine("Flushing");
ds.Flush();
}
}
}
public KeyValuePair<string, IBinaryObject> BuildRow(long rowNumber, string row, bool setColumnFields = true) {
var builder = m_ignite.GetBinary().GetBuilder(TypeName);
var rowId = row.GetHashString();
builder.SetField(PrimaryKeyName, rowId);
builder.SetField(RowNumberName, rowNumber);
builder.SetField(RawName, row);
if (setColumnFields) {
SetColumnFields(m_table, row, builder);
}
return new KeyValuePair<string, IBinaryObject>(rowId, builder.Build());
}