Contribute to Open Source. Search issue labels to find the right project for you!

Bubble up private code gen methods to make integration easier (see Data Hub).

marklogic/entity-services

Some functions required for extraction are currently included as private functions with code-generated modules. It would be more convenient to work with entity services from the data hub perspective were these functions part of the es:module.

Propose removing two functions from instance converter and two functions from version translator.

instance:init-source => es:init-source instance:add-attachments => es:attatchments translator:init-source => es:init-translation-source translator:copy-attachments => es:copy-attachments

also to add es:init-instance which replaces some inline code currently in the codegen modules.

Updated 23/06/2017 22:03 1 Comments

Verify compliance to the new official subscriptions spec

sangria-graphql/sangria

From what I saw so far, it ’s compliant, except that sangria allows to specify multiple subscription fields.

A validation rule for this: https://github.com/graphql/graphql-js/pull/882

https://github.com/graphql/graphql-js/issues/897 https://github.com/graphql/graphql-js/pull/868 https://github.com/graphql/graphql-js/pull/887 https://github.com/graphql/graphql-js/pull/888 https://github.com/graphql/graphql-js/pull/870

Updated 16/06/2017 20:59

HLS memcpy : multiple issues addressed to Xilinx

open-power/snap

Working this issue with Xilinx on a basic example. Waiting for feedback from them (Sergei)

The “basic” definition of our ports is done as follow:

pragma HLS INTERFACE m_axi port=din_gmem bundle=host_mem offset=slave depth=512

and this gives by default 16 access per burst which means 1KB read or write per burst while AXI limit is 4KB.

Adding the max_read_burst to 32 works ok (some rare case of timing issue during routing of the chip),

pragma HLS INTERFACE m_axi port=din_gmem bundle=host_mem offset=slave depth=512 \

max_read_burst_length=32 max_write_burst_length= 32

Trying the max_read_burst to 64 seems ok on synthesis and simulation but doesn’t work on real card (freeze/no answer) This limits our transfer bandwidth

Updated 23/06/2017 08:49 3 Comments

Better way to override `@Model` and `@Routable` constructor?

sakuraapi/api

See “Class Decorators” here: https://www.typescriptlang.org/docs/handbook/decorators.html ``` function classDecorator<T extends {new(…args:any[]):{}}>(constructor:T) { return class extends constructor { newProperty = “new property”; hello = “override”; } }

@classDecorator class Greeter { property = “property”; hello: string; constructor(m: string) { this.hello = m; } }

console.log(new Greeter(“world”)); `` Could this be used to get typing for injected methods without having to extendSakuraApiModel`?

Updated 04/06/2017 18:36

UnicodeEncodeError with Python 3.6

waf-project/waf
Setting top to                           : C:\Downloads\waf\demos\c 
Setting out to                           : C:\Downloads\waf\demos\c\build 
Checking for 'msvc' (C compiler)         : --- Logging error ---
Traceback (most recent call last):
  File "C:\Python36-32\lib\logging\__init__.py", line 994, in emit
    stream.write(msg)
  File "C:\Python36-32\lib\encodings\cp1252.py", line 19, in encode
    return codecs.charmap_encode(input,self.errors,encoding_table)[0]
UnicodeEncodeError: 'charmap' codec can't encode character '\ufffd' in position 900: character maps to <undefined>
Call stack:
  File "waf", line 164, in <module>
    from waflib import Scripting
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Scripting.py", line 122, in waf_entry_point
    run_commands()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Scripting.py", line 183, in run_commands
    ctx=run_command(cmd_name)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Scripting.py", line 174, in run_command
    ctx.execute()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 85, in execute
    super(ConfigurationContext,self).execute()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Context.py", line 88, in execute
    self.recurse([os.path.dirname(g_module.root_path)])
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Context.py", line 129, in recurse
    user_function(self)
  File "C:\Downloads\waf\demos\c\wscript", line 21, in configure
    conf.load('compiler_c gnu_dirs')
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 155, in load
    func(self)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\compiler_c.py", line 23, in configure
    conf.load(compiler)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 155, in load
    func(self)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\msvc.py", line 543, in configure
    conf.autodetect(True)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 177, in fun
    return f(*k,**kw)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\msvc.py", line 561, in autodetect
    compiler,version,path,includes,libdirs,cpu=conf.detect_msvc()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 177, in fun
    return f(*k,**kw)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\msvc.py", line 461, in detect_msvc
    return self.setup_msvc(self.get_msvc_versions())
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 177, in fun
    return f(*k,**kw)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\msvc.py", line 72, in setup_msvc
    cfg.evaluate()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\msvc.py", line 243, in evaluate
    vs=self.conf.get_msvc_version(self.compiler,self.version,self.bat_target,self.bat)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 177, in fun
    return f(*k,**kw)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\msvc.py", line 115, in get_msvc_version
    conf.cmd_and_log(cxx+['/help'],env=env)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Context.py", line 230, in cmd_and_log
    self.to_log('out: %s'%out)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Context.py", line 256, in to_log
    self.logger.info(msg)
Message: 'out:                          OPTIONS DU COMPILATEURÿC/C++\r\n\r\n\r\n                              -OPTIMISATION-\r\n\r\n/O1 r‚duire l\'espace                    /O2 augmenter la vitesse\r\n/Ob<n> expansion inline (n=0 par d‚faut)\r\n/Od d‚sactiver les optimisations (par d‚faut)\r\n/Og activer l\'optimisation globale      \r\n/Oi[-] activer les fonctions intrinsŠques\r\n/Os privil‚gier l\'espace du code        /Ot privil‚gier la vitesse du code\r\n/Ox optimisations maximales             \r\n/favor:<blend|AMD64|INTEL64|ATOM> s‚lectionner le processeur … optimiser, au choixÿ:\r\n    blend - combinaison d\'optimisations pour plusieurs processeursÿx64 diff‚rents\r\n    AMD64 - processeurs AMDÿ64ÿbits                                 \r\n    INTEL64 - processeurs d\'architecture Intel(R)64                  \r\n    ATOM - processeurs Intel(R) Atom(TM)                           \r\n\r\n                             -G\ufffdN\ufffdRATION DE CODE-\r\n\r\n/Gw[-] s‚parer les variables globales pour l\'\ufffdditeur de liens\r\n/GF activer le regroupement des chaŒnes en lecture seule\r\n/Gm[-] activer la r‚g‚n‚ration minimale \r\n/Gy[-] s‚parer les fonctions pour l\'\ufffdditeur de liens\r\n/GS[-] activer les v‚rifications de la s‚curit‚\r\n/GR[-] activer C++ RTTI                 \r\n/GX[-] activer C++ EH (identique … /EHsc)\r\n/guard:cf[-] activer CFG (protection du flux de contr“le)\r\n/EHs activer C++ EH (sans exception SEH)\r\n/EHa activer C++ EH (avec exceptions SEH)\r\n/EHc extern " C" a pour valeur par d‚faut nothrow\r\n/EHr g‚nŠre toujours des contr“les d\'arrˆt de runtime noexcept\r\n/fp:<except[-]|fast|precise|strict> choisir le modŠle de virgule flottante :\r\n    except[-] - prendre en consid‚ration les exceptions de virgule flottante lors de la g‚n‚ration du code\r\n    fast - modŠle de virgule flottanteÿ®ÿrapideÿ¯ÿ; les r‚sultats sont moins pr‚visibles\r\n    precise - modŠle de virgule flottante ®ÿpr‚ciseÿ¯ÿ; les r‚sultats sont pr‚visibles\r\n    strict - modŠle de virgule flottante ®ÿstricteÿ¯ (implique /fp:except)\r\n/Qfast_transcendentals g‚n‚rer des intrinsŠques FP inline mˆme avec /fp:except\r\n/Qpar[-] activer la g‚n‚ration de code parallŠle\r\n/Qpar-report:1 diagnostic du parall‚liseur automatique ; indiquer les boucles parall‚lis‚es\r\n/Qpar-report:2 diagnostic du parall‚liseur automatique ; indiquer les boucles non parall‚lis‚es\r\n/Qvec-report:1 diagnostic du vectoriseur automatique ; indiquer les boucles vectoris‚es\r\n/Qvec-report:2 diagnostic du vectoriseur automatique ; indiquer les boucles non vectoris‚es\r\n/GL[-] activer la g‚n‚ration du code durant l\'‚dition des liens\r\n/volatile:< iso|ms> choisir le modŠle de volatileÿ:\r\n    iso - Les s‚mantiques acquire/release ne sont pas garanties sur les accŠs volatiles\r\n    ms - Les s‚mantiques acquire/release sont garanties sur les accŠs volatiles\r\n/GA optimiser pour les applications Windows\r\n/Ge forcer le contr“le de pile pour toutes les fonctions\r\n/Gs[num] contr“ler les appels de contr“le de pile\r\n/Gh activer l\'appel de la fonction _penter\r\n/GH activer l\'appel de la fonction _pexit\r\n/GT g‚n‚rer les accŠs TLS … fibres s‚curis‚es\r\n/RTC1 Activer les contr“les rapides (/RTCsu)\r\n/RTCc Contr“les de la conversion des types les plus petits\r\n/RTCs Contr“les … l\'ex‚cution des frames de pile\r\n/RTCu Contr“les de l\'utilisation des variables locales non initialis‚es\r\n/clr[:option] compiler pour le Common Language Runtime, o— option correspond …ÿ:\r\n    pure - produire un fichier de sortie IL uniquement (pas de code ex‚cutable natif)\r\n    safe - produire un fichier de sortie v‚rifiable IL uniquement\r\n    initialAppDomain - activer le comportement AppDomain initial de VisualÿC++ÿ2002\r\n    noAssembly - ne pas produire d\'assembly\r\n    nostdlib - ignorer le r‚pertoire \\clr par d‚faut\r\n/homeparams forcer l\'‚criture dans la pile des paramŠtres pass‚s dans les registres\r\n/GZ Activer les contr“les de pile (/RTCs)\r\n/arch:AVX autoriser l\'utilisation des instructions disponibles avec les UC compatibles AVX\r\n/arch:AVX2 autoriser l\'utilisation des instructions disponibles avec les UC compatibles AVX2\r\n/Gv convention d\'appel __vectorcall     \r\n\r\n                              -FICHIERS DE SORTIE-\r\n\r\n/Fa[fichier] nommer le fichier du listing assembleur\r\n/FA[scu] configurer le listing assembleur\r\n/Fd[fichier] nommer le fichier .PDB     \r\n/Fe<fichier> nommer le fichier ex‚cutable\r\n/Fm[fichier] nommer le fichier de mappage\r\n/Fo<fichier> nommer le fichier objet    \r\n/Fp<fichier> nommer le fichier d\'en-tˆte pr‚compil‚\r\n/Fr[fichier] nommer le fichier browser source\r\n/FR[fichier] nommer le fichier .SBR ‚tendu\r\n/Fi[fichier] nommer le fichier pr‚trait‚/Fdÿ: <fichier> nommer le fichier .PDB\r\n/Feÿ: <fichier> nommer le fichier ex‚cutable\r\n/Fmÿ: <fichier> nommer le fichier de mappage\r\n/Foÿ: <fichier> nommer le fichier objet /Fpÿ: <fichier> nommer le fichier .PCH\r\n/FRÿ: <fichier> nommer le fichier .SBR ‚tendu\r\n/Fiÿ: <fichier> nommer le fichier pr‚trait‚\r\n/doc[fichier] traiter les commentaires de documentation XML et nommer ‚ventuellement le fichier .xdc\r\n\r\n                              -PR\ufffdPROCESSEUR-\r\n\r\n/AI<r‚p> ajouter au chemin de recherche des assemblys\r\n/FU<fichier> utilisation forc‚e d\'un assembly/module \r\n/C ne pas supprimer les commentaires    /D<nom>{=|#}<texte> d‚finir une macro\r\n/E pr‚traiter dans stdout               /EP pr‚traiter dans stdout, sans #line\r\n/P pr‚traiter dans un fichier           \r\n/Fx fusionner le code inject‚ dans un fichier\r\n/FI<fichier> nommer le fichier Include forc‚\r\n/U<nom> supprimer la macro pr‚d‚finie   \r\n/u supprimer toutes les macros pr‚d‚finies\r\n/I<r‚p> ajouter au chemin de recherche Include\r\n/X ignorer les "places standard"        \r\n\r\n                                -LANGUE-\r\n\r\n/Zi activer les informations de d‚bogage\r\n/Z7 activer les informations de d‚bogage … l\'ancien format\r\n/Zp[n] compresser les structures … la limite n-octet\r\n/Za d‚sactiver les extensions           /Ze activer les extensions (par d‚faut)\r\n/Zl omettre le nom de bibliothŠque par d‚faut dans .OBJ\r\n/Zs v‚rifier la syntaxe uniquement      /vd{0|1|2} d‚sactiver/activer vtordisp\r\n/vm<x> type des pointeurs vers les membres\r\n/Zc:arg1[,arg2] conformit‚ au langageÿC++, o— les arguments peuvent ˆtreÿ:\r\n  forScope[-]           appliquer la norme C++ pour les rŠgles de port‚e\r\n  wchar_t[-]            wchar_t est le type natif et non un typedef\r\n  auto[-]               appliquer la nouvelle signification C++ standard pour auto\r\n  trigraphs[-]          activer les trigraphes (d‚sactiv‚s par d‚faut)\r\n  rvalueCast[-]         appliquer les rŠgles de conversion de type explicite standard C++\r\n  strictStrings[-]      d‚sactiver la conversion de litt‚ral\r\n                        de chaŒne en [char|wchar_t]* (d‚sactiv‚e par d‚faut)\r\n  implicitNoexcept[-]   activer noexcept implicite sur les fonctions obligatoires\r\n  threadSafeInit[-]     permet l\'initialisation statique locale thread-safe\r\n  inline[-]             supprimer la fonction ou les donn‚es non r‚f‚renc‚es s\'il est\r\n                        COMDAT ou a une liaison interne uniquement (d‚sactiv‚ par d‚faut)\r\n  sizedDealloc[-]       activer les fonctions de d‚sallocation \r\n                        dimensionn‚es globales C++14 (activ‚ par d‚faut)\r\n  throwingNew[-]        suppose de nouvelles lev‚es d\'exception de l\'op‚rateur en cas d\'‚chec (d‚sactiv‚ par d‚faut)\r\n  referenceBinding[-]   une variable temporaire ne sera pas li‚e … une r‚f‚rence Ivalue\r\n                        non const (d‚sactiv‚ par d‚faut)\r\n/ZH:SHA_256             utiliser SHA256 pour le checksum de fichier dans les informations de d‚bogage (exp‚rimental)\r\n\r\n/Zo[-] g‚n‚rer des informations de d‚bogage plus d‚taill‚es pour le code optimis‚ (activ‚ par d‚faut)\r\n/ZW activer les extensions de langage WinRT\r\n/constexpr:depth<N>     utiliser <N> comme limite de profondeur de r‚cursivit‚\r\n                        pour constexpr (par d‚fautÿ: 512)\r\n/constexpr:backtrace<N> afficher <N>ÿ‚valuations constexpr\r\n                        dans les diagnostics (par d‚fautÿ: 10)\r\n/constexpr:steps<N>     arrˆter l\'‚valuation constexpr aprŠs\r\n                        <N>ÿ‚tapes (par d‚fautÿ: 100000)\r\n/ZI activer les inform. de d‚bogage de l\'op‚r. Modifier & Continuer\r\n/openmp activer les extensions de langageÿOpenMP 2.0\r\n\r\n                              -DIVERS-\r\n\r\n@<fichier> fichier r‚ponse des options  /?, /help afficher ce message d\'aide\r\n/bigobj g‚n‚rer un format d\'objet ‚tendu\r\n/c compiler uniquement, pas d\'‚dition des liens\r\n/errorReport:option Signaler les erreurs internes du compilateur … Microsoft\r\n    none - ne pas envoyer le rapport                \r\n    prompt - inviter … envoyer imm‚diatement le rapport\r\n    queue - lors de la prochaine ouverture de session d\'un administrateur, inviter … envoyer le rapport (par d‚faut)\r\n    send - envoyer le rapport automatiquement         \r\n/FC utiliser des chemins complets dans les diagnostics\r\n/H<num> longueur maximale du nom externe\r\n/J type de caractŠre par d‚faut non sign‚\r\n/MP[n] utiliser jusqu\'… \'n\' processus pour la compilation\r\n/nologo supprimer le message de copyright\r\n/sdl activer des avertissements et des fonctionnalit‚s de s‚curit‚ suppl‚mentaires\r\n/showIncludes afficher les noms de fichiers Include\r\n/Tc<fichier source> compiler le fichier comme .c\r\n/Tp<fichier source> compiler le fichier comme .cpp\r\n/TC compiler tous les fichiers comme .c \r\n/TP compiler tous les fichiers comme .cpp\r\n/V<string> d‚finir la chaŒne de version /w d‚sactiver tous les avertissements\r\n/wd<n> d‚sactiver l\'avertissement n     \r\n/we<n> traiter l\'avertissement n comme une erreur\r\n/wo<n> ‚mettre l\'avertissement n une fois\r\n/w<l><n> d‚finir le niveau d\'avertissement 1-4 pour n\r\n/W<n> d‚finir le niveau d\'avertissement (par d‚faut n=1)\r\n/Wall activer tous les avertissements   \r\n/WL activer les diagnostics sur une ligne\r\n/WX traiter les avertissements comme des erreurs\r\n/Yc[fichier] cr‚er un fichier .PCH      \r\n/Yd placer les informations de d‚bogage dans chaque .OBJ\r\n/Yl[sym] injecter la r‚f‚rence .PCH pour la bibliothŠque de d‚bogage\r\n/Yu[fichier] utiliser le fichier .PCH   /Y- d‚sactiver toutes les options PCH\r\n/Zm<n> m‚moire max. allou‚e (% de la valeur par d‚faut)\r\n/FS utilisation forc‚e de MSPDBSRV.EXE  \r\n/await pour activer l\'extension des fonctions pouvant ˆtre reprises\r\n/Wv:xx[.yy[.zzzzz]] d‚sactiver les avertissements introduits aprŠs la version xx.yy.zzzzz\r\n/source-charset:<nom_iana>|.nnnn d‚finit le jeu de caractŠres source\r\n/execution-charset:<nom_iana>|.nnnn d‚finit le jeu de caractŠres d\'ex‚cution\r\n/utf-8 d‚finit le jeu de caractŠres source et d\'ex‚cution … UTF-8\r\n/validate-charset[-] valide les fichiers UTF-8 uniquement pour les caractŠres conformes\r\n/diagnostics:<arguments,...> contr“le le format des messages de diagnosticÿ:\r\n             classicÿ-ÿconserve le format ant‚rieur\r\n             column[-]ÿ-ÿaffiche les informations sur la colonne\r\n             caret[-]ÿ-ÿaffiche la colonne et la ligne de code source indiqu‚e\r\n/permissiveÿ-ÿd‚finit le mode de conformit‚ standard (ensemble de fonctionnalit‚s susceptible de changer)\r\n/std:<c++14|c++latest> version C++ standard\r\n    c++14ÿ-ÿISO/IEC 14882:2014 (par d‚faut)\r\n    c++latestÿ-ÿdernier projet de norme (ensemble de fonctionnalit‚s susceptible de changer)\r\n\r\n                                -\ufffdDITION DES LIENS-\r\n\r\n/LD Cr‚er une .DLL                      \r\n/LDd Cr‚er une bibliothŠque .DLL de d‚bogage\r\n/LN Cr‚er un .netmodule                 /F<num> d‚finir la taille de la pile\r\n/link [options et bibliothŠques de l\'\ufffdditeur de liens]\r\n/MD lier avec MSVCRT.LIB                /MT lier avec LIBCMT.LIB\r\n/MDd lier avec la bibliothŠque de d‚bogage MSVCRTD.LIB\r\n/MTd lier avec la bibliothŠque de d‚bogage LIBCMTD.LIB\r\n\r\n                              -ANALYSE DU CODE-\r\n\r\n/analyze[-] Activer l\'analyse native    \r\n/analyze:quiet[-] Aucun avertissement sur la console\r\n/analyze:log<nom> Avertissements sur le fichier\r\n/analyze:autolog Enregistrer le journal sur *.pftlog\r\n/analyze:autolog:ext<ext> Enregistrer le journal sur *.<ext>\r\n/analyze:autolog- Pas de fichier journal/analyze:WX- Avertissements r‚cup‚rables\r\n/analyze:stacksize<num> Frame de pile maximal\r\n/analyze:max_paths<num> Chemins d\'accŠs maximum\r\n/analyze:only Analyse, pas de g‚n‚ration de code\r\n\r\n'
Arguments: ()
--- Logging error ---
Traceback (most recent call last):
  File "C:\Python36-32\lib\logging\__init__.py", line 994, in emit
    stream.write(msg)
  File "C:\Python36-32\lib\encodings\cp1252.py", line 19, in encode
    return codecs.charmap_encode(input,self.errors,encoding_table)[0]
UnicodeEncodeError: 'charmap' codec can't encode character '\ufffd' in position 900: character maps to <undefined>
Call stack:
  File "waf", line 164, in <module>
    from waflib import Scripting
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Scripting.py", line 122, in waf_entry_point
    run_commands()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Scripting.py", line 183, in run_commands
    ctx=run_command(cmd_name)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Scripting.py", line 174, in run_command
    ctx.execute()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 85, in execute
    super(ConfigurationContext,self).execute()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Context.py", line 88, in execute
    self.recurse([os.path.dirname(g_module.root_path)])
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Context.py", line 129, in recurse
    user_function(self)
  File "C:\Downloads\waf\demos\c\wscript", line 21, in configure
    conf.load('compiler_c gnu_dirs')
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 155, in load
    func(self)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\compiler_c.py", line 23, in configure
    conf.load(compiler)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 155, in load
    func(self)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\msvc.py", line 544, in configure
    conf.find_msvc()
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Configure.py", line 177, in fun
    return f(*k,**kw)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Tools\msvc.py", line 596, in find_msvc
    if not conf.cmd_and_log(cxx+['/nologo','/help'],env=env):
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Context.py", line 230, in cmd_and_log
    self.to_log('out: %s'%out)
  File "C:\Downloads\waf\demos\c\waf3-1.9.11-59ca33296ff5d605ccbbc39b041b19fd\waflib\Context.py", line 256, in to_log
    self.logger.info(msg)
Message: 'out:                          OPTIONS DU COMPILATEURÿC/C++\r\n\r\n\r\n                              -OPTIMISATION-\r\n\r\n/O1 r‚duire l\'espace                    /O2 augmenter la vitesse\r\n/Ob<n> expansion inline (n=0 par d‚faut)\r\n/Od d‚sactiver les optimisations (par d‚faut)\r\n/Og activer l\'optimisation globale      \r\n/Oi[-] activer les fonctions intrinsŠques\r\n/Os privil‚gier l\'espace du code        /Ot privil‚gier la vitesse du code\r\n/Ox optimisations maximales             \r\n/favor:<blend|AMD64|INTEL64|ATOM> s‚lectionner le processeur … optimiser, au choixÿ:\r\n    blend - combinaison d\'optimisations pour plusieurs processeursÿx64 diff‚rents\r\n    AMD64 - processeurs AMDÿ64ÿbits                                 \r\n    INTEL64 - processeurs d\'architecture Intel(R)64                  \r\n    ATOM - processeurs Intel(R) Atom(TM)                           \r\n\r\n                             -G\ufffdN\ufffdRATION DE CODE-\r\n\r\n/Gw[-] s‚parer les variables globales pour l\'\ufffdditeur de liens\r\n/GF activer le regroupement des chaŒnes en lecture seule\r\n/Gm[-] activer la r‚g‚n‚ration minimale \r\n/Gy[-] s‚parer les fonctions pour l\'\ufffdditeur de liens\r\n/GS[-] activer les v‚rifications de la s‚curit‚\r\n/GR[-] activer C++ RTTI                 \r\n/GX[-] activer C++ EH (identique … /EHsc)\r\n/guard:cf[-] activer CFG (protection du flux de contr“le)\r\n/EHs activer C++ EH (sans exception SEH)\r\n/EHa activer C++ EH (avec exceptions SEH)\r\n/EHc extern " C" a pour valeur par d‚faut nothrow\r\n/EHr g‚nŠre toujours des contr“les d\'arrˆt de runtime noexcept\r\n/fp:<except[-]|fast|precise|strict> choisir le modŠle de virgule flottante :\r\n    except[-] - prendre en consid‚ration les exceptions de virgule flottante lors de la g‚n‚ration du code\r\n    fast - modŠle de virgule flottanteÿ®ÿrapideÿ¯ÿ; les r‚sultats sont moins pr‚visibles\r\n    precise - modŠle de virgule flottante ®ÿpr‚ciseÿ¯ÿ; les r‚sultats sont pr‚visibles\r\n    strict - modŠle de virgule flottante ®ÿstricteÿ¯ (implique /fp:except)\r\n/Qfast_transcendentals g‚n‚rer des intrinsŠques FP inline mˆme avec /fp:except\r\n/Qpar[-] activer la g‚n‚ration de code parallŠle\r\n/Qpar-report:1 diagnostic du parall‚liseur automatique ; indiquer les boucles parall‚lis‚es\r\n/Qpar-report:2 diagnostic du parall‚liseur automatique ; indiquer les boucles non parall‚lis‚es\r\n/Qvec-report:1 diagnostic du vectoriseur automatique ; indiquer les boucles vectoris‚es\r\n/Qvec-report:2 diagnostic du vectoriseur automatique ; indiquer les boucles non vectoris‚es\r\n/GL[-] activer la g‚n‚ration du code durant l\'‚dition des liens\r\n/volatile:< iso|ms> choisir le modŠle de volatileÿ:\r\n    iso - Les s‚mantiques acquire/release ne sont pas garanties sur les accŠs volatiles\r\n    ms - Les s‚mantiques acquire/release sont garanties sur les accŠs volatiles\r\n/GA optimiser pour les applications Windows\r\n/Ge forcer le contr“le de pile pour toutes les fonctions\r\n/Gs[num] contr“ler les appels de contr“le de pile\r\n/Gh activer l\'appel de la fonction _penter\r\n/GH activer l\'appel de la fonction _pexit\r\n/GT g‚n‚rer les accŠs TLS … fibres s‚curis‚es\r\n/RTC1 Activer les contr“les rapides (/RTCsu)\r\n/RTCc Contr“les de la conversion des types les plus petits\r\n/RTCs Contr“les … l\'ex‚cution des frames de pile\r\n/RTCu Contr“les de l\'utilisation des variables locales non initialis‚es\r\n/clr[:option] compiler pour le Common Language Runtime, o— option correspond …ÿ:\r\n    pure - produire un fichier de sortie IL uniquement (pas de code ex‚cutable natif)\r\n    safe - produire un fichier de sortie v‚rifiable IL uniquement\r\n    initialAppDomain - activer le comportement AppDomain initial de VisualÿC++ÿ2002\r\n    noAssembly - ne pas produire d\'assembly\r\n    nostdlib - ignorer le r‚pertoire \\clr par d‚faut\r\n/homeparams forcer l\'‚criture dans la pile des paramŠtres pass‚s dans les registres\r\n/GZ Activer les contr“les de pile (/RTCs)\r\n/arch:AVX autoriser l\'utilisation des instructions disponibles avec les UC compatibles AVX\r\n/arch:AVX2 autoriser l\'utilisation des instructions disponibles avec les UC compatibles AVX2\r\n/Gv convention d\'appel __vectorcall     \r\n\r\n                              -FICHIERS DE SORTIE-\r\n\r\n/Fa[fichier] nommer le fichier du listing assembleur\r\n/FA[scu] configurer le listing assembleur\r\n/Fd[fichier] nommer le fichier .PDB     \r\n/Fe<fichier> nommer le fichier ex‚cutable\r\n/Fm[fichier] nommer le fichier de mappage\r\n/Fo<fichier> nommer le fichier objet    \r\n/Fp<fichier> nommer le fichier d\'en-tˆte pr‚compil‚\r\n/Fr[fichier] nommer le fichier browser source\r\n/FR[fichier] nommer le fichier .SBR ‚tendu\r\n/Fi[fichier] nommer le fichier pr‚trait‚/Fdÿ: <fichier> nommer le fichier .PDB\r\n/Feÿ: <fichier> nommer le fichier ex‚cutable\r\n/Fmÿ: <fichier> nommer le fichier de mappage\r\n/Foÿ: <fichier> nommer le fichier objet /Fpÿ: <fichier> nommer le fichier .PCH\r\n/FRÿ: <fichier> nommer le fichier .SBR ‚tendu\r\n/Fiÿ: <fichier> nommer le fichier pr‚trait‚\r\n/doc[fichier] traiter les commentaires de documentation XML et nommer ‚ventuellement le fichier .xdc\r\n\r\n                              -PR\ufffdPROCESSEUR-\r\n\r\n/AI<r‚p> ajouter au chemin de recherche des assemblys\r\n/FU<fichier> utilisation forc‚e d\'un assembly/module \r\n/C ne pas supprimer les commentaires    /D<nom>{=|#}<texte> d‚finir une macro\r\n/E pr‚traiter dans stdout               /EP pr‚traiter dans stdout, sans #line\r\n/P pr‚traiter dans un fichier           \r\n/Fx fusionner le code inject‚ dans un fichier\r\n/FI<fichier> nommer le fichier Include forc‚\r\n/U<nom> supprimer la macro pr‚d‚finie   \r\n/u supprimer toutes les macros pr‚d‚finies\r\n/I<r‚p> ajouter au chemin de recherche Include\r\n/X ignorer les "places standard"        \r\n\r\n                                -LANGUE-\r\n\r\n/Zi activer les informations de d‚bogage\r\n/Z7 activer les informations de d‚bogage … l\'ancien format\r\n/Zp[n] compresser les structures … la limite n-octet\r\n/Za d‚sactiver les extensions           /Ze activer les extensions (par d‚faut)\r\n/Zl omettre le nom de bibliothŠque par d‚faut dans .OBJ\r\n/Zs v‚rifier la syntaxe uniquement      /vd{0|1|2} d‚sactiver/activer vtordisp\r\n/vm<x> type des pointeurs vers les membres\r\n/Zc:arg1[,arg2] conformit‚ au langageÿC++, o— les arguments peuvent ˆtreÿ:\r\n  forScope[-]           appliquer la norme C++ pour les rŠgles de port‚e\r\n  wchar_t[-]            wchar_t est le type natif et non un typedef\r\n  auto[-]               appliquer la nouvelle signification C++ standard pour auto\r\n  trigraphs[-]          activer les trigraphes (d‚sactiv‚s par d‚faut)\r\n  rvalueCast[-]         appliquer les rŠgles de conversion de type explicite standard C++\r\n  strictStrings[-]      d‚sactiver la conversion de litt‚ral\r\n                        de chaŒne en [char|wchar_t]* (d‚sactiv‚e par d‚faut)\r\n  implicitNoexcept[-]   activer noexcept implicite sur les fonctions obligatoires\r\n  threadSafeInit[-]     permet l\'initialisation statique locale thread-safe\r\n  inline[-]             supprimer la fonction ou les donn‚es non r‚f‚renc‚es s\'il est\r\n                        COMDAT ou a une liaison interne uniquement (d‚sactiv‚ par d‚faut)\r\n  sizedDealloc[-]       activer les fonctions de d‚sallocation \r\n                        dimensionn‚es globales C++14 (activ‚ par d‚faut)\r\n  throwingNew[-]        suppose de nouvelles lev‚es d\'exception de l\'op‚rateur en cas d\'‚chec (d‚sactiv‚ par d‚faut)\r\n  referenceBinding[-]   une variable temporaire ne sera pas li‚e … une r‚f‚rence Ivalue\r\n                        non const (d‚sactiv‚ par d‚faut)\r\n/ZH:SHA_256             utiliser SHA256 pour le checksum de fichier dans les informations de d‚bogage (exp‚rimental)\r\n\r\n/Zo[-] g‚n‚rer des informations de d‚bogage plus d‚taill‚es pour le code optimis‚ (activ‚ par d‚faut)\r\n/ZW activer les extensions de langage WinRT\r\n/constexpr:depth<N>     utiliser <N> comme limite de profondeur de r‚cursivit‚\r\n                        pour constexpr (par d‚fautÿ: 512)\r\n/constexpr:backtrace<N> afficher <N>ÿ‚valuations constexpr\r\n                        dans les diagnostics (par d‚fautÿ: 10)\r\n/constexpr:steps<N>     arrˆter l\'‚valuation constexpr aprŠs\r\n                        <N>ÿ‚tapes (par d‚fautÿ: 100000)\r\n/ZI activer les inform. de d‚bogage de l\'op‚r. Modifier & Continuer\r\n/openmp activer les extensions de langageÿOpenMP 2.0\r\n\r\n                              -DIVERS-\r\n\r\n@<fichier> fichier r‚ponse des options  /?, /help afficher ce message d\'aide\r\n/bigobj g‚n‚rer un format d\'objet ‚tendu\r\n/c compiler uniquement, pas d\'‚dition des liens\r\n/errorReport:option Signaler les erreurs internes du compilateur … Microsoft\r\n    none - ne pas envoyer le rapport                \r\n    prompt - inviter … envoyer imm‚diatement le rapport\r\n    queue - lors de la prochaine ouverture de session d\'un administrateur, inviter … envoyer le rapport (par d‚faut)\r\n    send - envoyer le rapport automatiquement         \r\n/FC utiliser des chemins complets dans les diagnostics\r\n/H<num> longueur maximale du nom externe\r\n/J type de caractŠre par d‚faut non sign‚\r\n/MP[n] utiliser jusqu\'… \'n\' processus pour la compilation\r\n/nologo supprimer le message de copyright\r\n/sdl activer des avertissements et des fonctionnalit‚s de s‚curit‚ suppl‚mentaires\r\n/showIncludes afficher les noms de fichiers Include\r\n/Tc<fichier source> compiler le fichier comme .c\r\n/Tp<fichier source> compiler le fichier comme .cpp\r\n/TC compiler tous les fichiers comme .c \r\n/TP compiler tous les fichiers comme .cpp\r\n/V<string> d‚finir la chaŒne de version /w d‚sactiver tous les avertissements\r\n/wd<n> d‚sactiver l\'avertissement n     \r\n/we<n> traiter l\'avertissement n comme une erreur\r\n/wo<n> ‚mettre l\'avertissement n une fois\r\n/w<l><n> d‚finir le niveau d\'avertissement 1-4 pour n\r\n/W<n> d‚finir le niveau d\'avertissement (par d‚faut n=1)\r\n/Wall activer tous les avertissements   \r\n/WL activer les diagnostics sur une ligne\r\n/WX traiter les avertissements comme des erreurs\r\n/Yc[fichier] cr‚er un fichier .PCH      \r\n/Yd placer les informations de d‚bogage dans chaque .OBJ\r\n/Yl[sym] injecter la r‚f‚rence .PCH pour la bibliothŠque de d‚bogage\r\n/Yu[fichier] utiliser le fichier .PCH   /Y- d‚sactiver toutes les options PCH\r\n/Zm<n> m‚moire max. allou‚e (% de la valeur par d‚faut)\r\n/FS utilisation forc‚e de MSPDBSRV.EXE  \r\n/await pour activer l\'extension des fonctions pouvant ˆtre reprises\r\n/Wv:xx[.yy[.zzzzz]] d‚sactiver les avertissements introduits aprŠs la version xx.yy.zzzzz\r\n/source-charset:<nom_iana>|.nnnn d‚finit le jeu de caractŠres source\r\n/execution-charset:<nom_iana>|.nnnn d‚finit le jeu de caractŠres d\'ex‚cution\r\n/utf-8 d‚finit le jeu de caractŠres source et d\'ex‚cution … UTF-8\r\n/validate-charset[-] valide les fichiers UTF-8 uniquement pour les caractŠres conformes\r\n/diagnostics:<arguments,...> contr“le le format des messages de diagnosticÿ:\r\n             classicÿ-ÿconserve le format ant‚rieur\r\n             column[-]ÿ-ÿaffiche les informations sur la colonne\r\n             caret[-]ÿ-ÿaffiche la colonne et la ligne de code source indiqu‚e\r\n/permissiveÿ-ÿd‚finit le mode de conformit‚ standard (ensemble de fonctionnalit‚s susceptible de changer)\r\n/std:<c++14|c++latest> version C++ standard\r\n    c++14ÿ-ÿISO/IEC 14882:2014 (par d‚faut)\r\n    c++latestÿ-ÿdernier projet de norme (ensemble de fonctionnalit‚s susceptible de changer)\r\n\r\n                                -\ufffdDITION DES LIENS-\r\n\r\n/LD Cr‚er une .DLL                      \r\n/LDd Cr‚er une bibliothŠque .DLL de d‚bogage\r\n/LN Cr‚er un .netmodule                 /F<num> d‚finir la taille de la pile\r\n/link [options et bibliothŠques de l\'\ufffdditeur de liens]\r\n/MD lier avec MSVCRT.LIB                /MT lier avec LIBCMT.LIB\r\n/MDd lier avec la bibliothŠque de d‚bogage MSVCRTD.LIB\r\n/MTd lier avec la bibliothŠque de d‚bogage LIBCMTD.LIB\r\n\r\n                              -ANALYSE DU CODE-\r\n\r\n/analyze[-] Activer l\'analyse native    \r\n/analyze:quiet[-] Aucun avertissement sur la console\r\n/analyze:log<nom> Avertissements sur le fichier\r\n/analyze:autolog Enregistrer le journal sur *.pftlog\r\n/analyze:autolog:ext<ext> Enregistrer le journal sur *.<ext>\r\n/analyze:autolog- Pas de fichier journal/analyze:WX- Avertissements r‚cup‚rables\r\n/analyze:stacksize<num> Frame de pile maximal\r\n/analyze:max_paths<num> Chemins d\'accŠs maximum\r\n/analyze:only Analyse, pas de g‚n‚ration de code\r\n\r\n'
Arguments: ()
C:\Program Files (x86)\Microsoft Visual Studio\2017\Community\VC\Tools\MSVC\14.10.25017\bin\HostX64\x64\CL.exe 
Checking for code snippet                : yes 
Checking for code snippet                : yes 
(... then everything looks fine ...)
Waf: Leaving directory `C:\Downloads\waf\demos\c\build'
'build' finished successfully (2.547s)

It may be the same kind of problem as the one fixed here #1965 related to the console’s encoding setting.

Updated 18/06/2017 22:49 15 Comments

I got an IllegalStateException error using the Data Movement SDK

marklogic/java-client-api

This happened after running for over a day.

Here is the error:

27-May-2017 12:27:49.622 SEVERE [http-nio-8080-exec-39] org.apache.catalina.core.StandardWrapperValve.invoke Servlet.service() for servlet [HarvestJDBCDataServlet] in context with path [/easymetahub] threw exception [java.lang.IllegalStateException: This instance has been stopped] with root cause
 java.lang.IllegalStateException: This instance has been stopped
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.requireNotStopped(WriteBatcherImpl.java:347)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.add(WriteBatcherImpl.java:283)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.add(WriteBatcherImpl.java:267)
    at com.easymetahub.HarvestJDBCData.doRoot(HarvestJDBCData.java:485)
    at com.easymetahub.HarvestJDBCData.doSomething(HarvestJDBCData.java:224)
    at com.easymetahub.HarvestJDBCData.processBatchSegment(HarvestJDBCData.java:120)
    at com.easymetahub.HarvestJDBCDataServlet.doPost(HarvestJDBCDataServlet.java:33)
    at com.easymetahub.HarvestJDBCDataServlet.doGet(HarvestJDBCDataServlet.java:45)
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:622)
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:729)
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:232)
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165)
    at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165)
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199)
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:105)
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:506)
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140)
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:79)
    at org.apache.catalina.valves.AbstractAccessLogValve.invoke(AbstractAccessLogValve.java:620)
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87)
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
    at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:1078)
    at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
    at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:760)
    at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.run(NioEndpoint.java:1524)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
    at java.lang.Thread.run(Thread.java:745)
Updated 05/06/2017 18:26 7 Comments

HLS: address bits lost when using hls memcpy to copy only one 512bits word

open-power/snap

Today I found a bug maybe in Vivado HLS If using ``` memcpy(buf, (snap_membus *t) (din_gmem + (input_address >> ADDR_RIGHT_SHIFT)), BPERDW);

//ADDR_RIGHT_SHIFT = 6 //BPERDW = 64 to transfer only 1 BPERDW, HLS synthesis result shows: signal p_s_reg_151 : STD_LOGIC_VECTOR (63 downto 0); … tmp_2_fu_240_p4 <= p_s_reg_151(37 downto 6); ```

p_s_reg_151 (63 downto 0) has the correct full width address, but I don’t know why tmp_2_fu_240_p4 will cut higher bits and send the address to m_axi_host_mem_ARADDR, and finally go to ah_cea.

Simulation on bb x86 server happen to pass, because higher bits (higher than bit37) are zero accidently. When running on Power server, higher bits lost will cause PSL bad context error and timeout.
(Last time I thought it was because SNAP hadn’t developed the part of ah_cch stuff and didn’t know it is because of bad address. )

The confusing part is: If use this memcpy statement to copy more than 1 word, since it goes to a burst and may be handled by some different logic, the address is tranferred correctly. Most of our SNAP example cases are copying data block, so we didn’t see the problem in hls_memcopy, hls_hashjoin, hls_intersect, and even the first part of code of hls_bfs.

I remember in the very beginning, there are functions “read/write_single_word….” Are they from Xilinx guys? They are necessary. We need them come back. And they can perform properly on the address bits.

Updated 22/06/2017 15:30 4 Comments

Flr708 709

LigaData/Kamanja

Jira Tasks - https://ligadata.atlassian.net/browse/FLR-708 and https://ligadata.atlassian.net/browse/FLR-709

Updated 25/06/2017 05:58 1 Comments

SPARQLManagerTest testConstrainingQueries asserts on tuples size.

marklogic/java-client-api

Able to reproduce this issue locally. Tested on Windows build on develop branch with 10.0-20170504 server build. Here is the stack trace from QA nightly regression server run and Http wire trace from Windows Laptop run:

<testcase classname="com.marklogic.client.test.SPARQLManagerTest" name="testConstrainingQueries" time="0.576">
    <failure message="expected:&lt;1&gt; but was:&lt;2&gt;" type="java.lang.AssertionError">java.lang.AssertionError: expected:&lt;1&gt; but was:&lt;2&gt;
    at org.junit.Assert.fail(Assert.java:88)
    at org.junit.Assert.failNotEquals(Assert.java:834)
    at org.junit.Assert.assertEquals(Assert.java:645)
    at org.junit.Assert.assertEquals(Assert.java:631)
    at com.marklogic.client.test.SPARQLManagerTest.testConstrainingQueries(SPARQLManagerTest.java:234)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)
    at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)
    at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)
    at org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)
    at org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)
    at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:115)
    at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)
</failure>

Wire Trace: 10:55:45.824 [main] DEBUG c.m.client.impl.JerseyServices - Connecting to localhost at 8011 as rest-writer 10:55:46.183 [main] DEBUG c.m.client.impl.JerseyServices - Putting graphs 2017/05/05 10:55:46:315 PDT [DEBUG] ThreadSafeClientConnManager - Get connection: {}->http://localhost:8011, timeout = 0 2017/05/05 10:55:46:319 PDT [DEBUG] ConnPoolByRoute - [{}->http://localhost:8011] total kept alive: 0, total issued: 0, total allocated: 0 out of 200 2017/05/05 10:55:46:319 PDT [DEBUG] ConnPoolByRoute - No free connections [{}->http://localhost:8011][null] 2017/05/05 10:55:46:319 PDT [DEBUG] ConnPoolByRoute - Available capacity: 100 out of 100 [{}->http://localhost:8011][null] 2017/05/05 10:55:46:319 PDT [DEBUG] ConnPoolByRoute - Creating new connection [{}->http://localhost:8011] 2017/05/05 10:55:46:331 PDT [DEBUG] DefaultClientConnectionOperator - Connecting to localhost:8011 2017/05/05 10:55:46:348 PDT [DEBUG] RequestAddCookies - CookieSpec selected: ignoreCookies 2017/05/05 10:55:46:350 PDT [DEBUG] RequestAuthCache - Auth cache not set in the context 2017/05/05 10:55:46:350 PDT [DEBUG] RequestTargetAuthentication - Target auth state: UNCHALLENGED 2017/05/05 10:55:46:350 PDT [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED 2017/05/05 10:55:46:350 PDT [DEBUG] DefaultHttpClient - Attempt 1 to execute request 2017/05/05 10:55:46:351 PDT [DEBUG] DefaultClientConnection - Sending request: HEAD /v1/ping HTTP/1.1 2017/05/05 10:55:46:351 PDT [DEBUG] wire - >> "HEAD /v1/ping HTTP/1.1[\r][\n]" 2017/05/05 10:55:46:352 PDT [DEBUG] wire - >> "Host: localhost:8011[\r][\n]" 2017/05/05 10:55:46:352 PDT [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:352 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:353 PDT [DEBUG] wire - << "HTTP/1.1 401 Unauthorized[\r][\n]" 2017/05/05 10:55:46:354 PDT [DEBUG] wire - << "Server: MarkLogic[\r][\n]" 2017/05/05 10:55:46:354 PDT [DEBUG] wire - << "WWW-Authenticate: Digest realm="public", qop="auth", nonce="8ff3995ac607275a97c77723d20c1f15", opaque="1a0feacf356abab0"[\r][\n]" 2017/05/05 10:55:46:354 PDT [DEBUG] wire - << "Content-Type: application/json; charset=utf-8[\r][\n]" 2017/05/05 10:55:46:354 PDT [DEBUG] wire - << "Content-Length: 0[\r][\n]" 2017/05/05 10:55:46:354 PDT [DEBUG] wire - << "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:355 PDT [DEBUG] wire - << "Keep-Alive: timeout=5[\r][\n]" 2017/05/05 10:55:46:355 PDT [DEBUG] wire - << "[\r][\n]" 2017/05/05 10:55:46:355 PDT [DEBUG] DefaultClientConnection - Receiving response: HTTP/1.1 401 Unauthorized 2017/05/05 10:55:46:359 PDT [DEBUG] DefaultHttpClient - Connection can be kept alive for 5000 MILLISECONDS 2017/05/05 10:55:46:359 PDT [DEBUG] DefaultHttpClient - Authentication required 2017/05/05 10:55:46:359 PDT [DEBUG] DefaultHttpClient - localhost:8011 requested authentication 2017/05/05 10:55:46:360 PDT [DEBUG] TargetAuthenticationStrategy - Authentication schemes in the order of preference: [Negotiate, Kerberos, NTLM, Digest, Basic] 2017/05/05 10:55:46:360 PDT [DEBUG] TargetAuthenticationStrategy - Challenge for Negotiate authentication scheme not available 2017/05/05 10:55:46:360 PDT [DEBUG] TargetAuthenticationStrategy - Challenge for Kerberos authentication scheme not available 2017/05/05 10:55:46:360 PDT [DEBUG] TargetAuthenticationStrategy - Challenge for NTLM authentication scheme not available 2017/05/05 10:55:46:364 PDT [DEBUG] TargetAuthenticationStrategy - Challenge for Basic authentication scheme not available 2017/05/05 10:55:46:364 PDT [DEBUG] ThreadSafeClientConnManager - Released connection is reusable. 2017/05/05 10:55:46:365 PDT [DEBUG] ConnPoolByRoute - Releasing connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:365 PDT [DEBUG] ConnPoolByRoute - Pooling connection [{}->http://localhost:8011][null]; keep alive for 5000 MILLISECONDS 2017/05/05 10:55:46:365 PDT [DEBUG] ConnPoolByRoute - Notifying no-one, there are no waiting threads 2017/05/05 10:55:46:581 PDT [DEBUG] ThreadSafeClientConnManager - Get connection: {}->http://localhost:8011, timeout = 0 2017/05/05 10:55:46:581 PDT [DEBUG] ConnPoolByRoute - [{}->http://localhost:8011] total kept alive: 1, total issued: 0, total allocated: 1 out of 200 2017/05/05 10:55:46:581 PDT [DEBUG] ConnPoolByRoute - Getting free connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:581 PDT [DEBUG] DefaultHttpClient - Stale connection check 2017/05/05 10:55:46:583 PDT [DEBUG] RequestAddCookies - CookieSpec selected: ignoreCookies 2017/05/05 10:55:46:583 PDT [DEBUG] RequestAuthCache - Auth cache not set in the context 2017/05/05 10:55:46:583 PDT [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED 2017/05/05 10:55:46:583 PDT [DEBUG] DefaultHttpClient - Attempt 1 to execute request 2017/05/05 10:55:46:583 PDT [DEBUG] DefaultClientConnection - Sending request: HEAD /v1/ping HTTP/1.1 2017/05/05 10:55:46:583 PDT [DEBUG] wire - >> "HEAD /v1/ping HTTP/1.1[\r][\n]" 2017/05/05 10:55:46:583 PDT [DEBUG] wire - >> "Authorization: Digest username="rest-writer",realm="public",nonce="8ff3995ac607275a97c77723d20c1f15",opaque="1a0feacf356abab0",qop=auth,uri="/v1/ping",cnonce="702467b5",nc=00000001,response="3ea86272e2346bfb2f78d1a856118341"[\r][\n]" 2017/05/05 10:55:46:583 PDT [DEBUG] wire - >> "Host: localhost:8011[\r][\n]" 2017/05/05 10:55:46:584 PDT [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:584 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:591 PDT [DEBUG] wire - << "HTTP/1.1 204 No Content[\r][\n]" 2017/05/05 10:55:46:592 PDT [DEBUG] wire - << "Server: MarkLogic[\r][\n]" 2017/05/05 10:55:46:592 PDT [DEBUG] wire - << "Content-Length: 0[\r][\n]" 2017/05/05 10:55:46:592 PDT [DEBUG] wire - << "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:593 PDT [DEBUG] wire - << "Keep-Alive: timeout=5[\r][\n]" 2017/05/05 10:55:46:593 PDT [DEBUG] wire - << "[\r][\n]" 2017/05/05 10:55:46:593 PDT [DEBUG] DefaultClientConnection - Receiving response: HTTP/1.1 204 No Content 2017/05/05 10:55:46:593 PDT [DEBUG] DefaultHttpClient - Connection can be kept alive for 5000 MILLISECONDS 2017/05/05 10:55:46:593 PDT [DEBUG] ThreadSafeClientConnManager - Released connection is reusable. 2017/05/05 10:55:46:593 PDT [DEBUG] ConnPoolByRoute - Releasing connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:593 PDT [DEBUG] ConnPoolByRoute - Pooling connection [{}->http://localhost:8011][null]; keep alive for 5000 MILLISECONDS 2017/05/05 10:55:46:593 PDT [DEBUG] ConnPoolByRoute - Notifying no-one, there are no waiting threads 2017/05/05 10:55:46:599 PDT [DEBUG] ThreadSafeClientConnManager - Get connection: {}->http://localhost:8011, timeout = 0 2017/05/05 10:55:46:599 PDT [DEBUG] ConnPoolByRoute - [{}->http://localhost:8011] total kept alive: 1, total issued: 0, total allocated: 1 out of 200 2017/05/05 10:55:46:599 PDT [DEBUG] ConnPoolByRoute - Getting free connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:599 PDT [DEBUG] DefaultHttpClient - Stale connection check 2017/05/05 10:55:46:601 PDT [DEBUG] RequestAddCookies - CookieSpec selected: ignoreCookies 2017/05/05 10:55:46:601 PDT [DEBUG] RequestAuthCache - Auth cache not set in the context 2017/05/05 10:55:46:601 PDT [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED 2017/05/05 10:55:46:601 PDT [DEBUG] DefaultHttpClient - Attempt 1 to execute request 2017/05/05 10:55:46:602 PDT [DEBUG] DefaultClientConnection - Sending request: PUT /v1/graphs?graph=http://marklogic.com/java/SPARQLManagerTest HTTP/1.1 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "PUT /v1/graphs?graph=http://marklogic.com/java/SPARQLManagerTest HTTP/1.1[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "Content-Type: application/n-triples[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "ML-Agent-ID: java[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "Authorization: Digest username="rest-writer",realm="public",nonce="8ff3995ac607275a97c77723d20c1f15",opaque="1a0feacf356abab0",qop=auth,uri="/v1/graphs",cnonce="ba61d2f2",nc=00000002,response="8c2c35586178ba57c03e75cdd9739066"[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "Transfer-Encoding: chunked[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "Host: localhost:8011[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "91[\r][\n]" 2017/05/05 10:55:46:602 PDT [DEBUG] wire - >> "<http://example.org/s1> <http://example.org/p1> <http://example.org/o1>.[\n]" 2017/05/05 10:55:46:603 PDT [DEBUG] wire - >> "<http://example.org/s2> <http://example.org/p2> <http://example.org/o2>." 2017/05/05 10:55:46:603 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:603 PDT [DEBUG] wire - >> "0[\r][\n]" 2017/05/05 10:55:46:603 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:611 PDT [DEBUG] wire - << "HTTP/1.1 201 Created[\r][\n]" 2017/05/05 10:55:46:612 PDT [DEBUG] wire - << "Location: [\r][\n]" 2017/05/05 10:55:46:612 PDT [DEBUG] wire - << "Server: MarkLogic[\r][\n]" 2017/05/05 10:55:46:612 PDT [DEBUG] wire - << "Content-Type: text/plain; charset=UTF-8[\r][\n]" 2017/05/05 10:55:46:612 PDT [DEBUG] wire - << "Content-Length: 33[\r][\n]" 2017/05/05 10:55:46:612 PDT [DEBUG] wire - << "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:612 PDT [DEBUG] wire - << "Keep-Alive: timeout=5[\r][\n]" 2017/05/05 10:55:46:612 PDT [DEBUG] wire - << "[\r][\n]" 2017/05/05 10:55:46:612 PDT [DEBUG] DefaultClientConnection - Receiving response: HTTP/1.1 201 Created 2017/05/05 10:55:46:613 PDT [DEBUG] DefaultHttpClient - Connection can be kept alive for 5000 MILLISECONDS 2017/05/05 10:55:46:615 PDT [DEBUG] wire - << "/triplestore/63b7860eb421b599.xml" 2017/05/05 10:55:46:620 PDT [DEBUG] ThreadSafeClientConnManager - Released connection is reusable. 2017/05/05 10:55:46:620 PDT [DEBUG] ConnPoolByRoute - Releasing connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:620 PDT [DEBUG] ConnPoolByRoute - Pooling connection [{}->http://localhost:8011][null]; keep alive for 5000 MILLISECONDS 2017/05/05 10:55:46:620 PDT [DEBUG] ConnPoolByRoute - Notifying no-one, there are no waiting threads 10:55:46.625 [main] DEBUG c.m.client.impl.JerseyServices - Putting graphs 2017/05/05 10:55:46:626 PDT [DEBUG] ThreadSafeClientConnManager - Get connection: {}->http://localhost:8011, timeout = 0 2017/05/05 10:55:46:626 PDT [DEBUG] ConnPoolByRoute - [{}->http://localhost:8011] total kept alive: 1, total issued: 0, total allocated: 1 out of 200 2017/05/05 10:55:46:626 PDT [DEBUG] ConnPoolByRoute - Getting free connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:626 PDT [DEBUG] DefaultHttpClient - Stale connection check 2017/05/05 10:55:46:627 PDT [DEBUG] RequestAddCookies - CookieSpec selected: ignoreCookies 2017/05/05 10:55:46:627 PDT [DEBUG] RequestAuthCache - Auth cache not set in the context 2017/05/05 10:55:46:627 PDT [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED 2017/05/05 10:55:46:627 PDT [DEBUG] DefaultHttpClient - Attempt 1 to execute request 2017/05/05 10:55:46:627 PDT [DEBUG] DefaultClientConnection - Sending request: PUT /v1/graphs?graph=SPARQLManagerTest.testConstrainingQueries HTTP/1.1 2017/05/05 10:55:46:627 PDT [DEBUG] wire - >> "PUT /v1/graphs?graph=SPARQLManagerTest.testConstrainingQueries HTTP/1.1[\r][\n]" 2017/05/05 10:55:46:627 PDT [DEBUG] wire - >> "Content-Type: application/n-triples[\r][\n]" 2017/05/05 10:55:46:627 PDT [DEBUG] wire - >> "ML-Agent-ID: java[\r][\n]" 2017/05/05 10:55:46:627 PDT [DEBUG] wire - >> "Authorization: Digest username="rest-writer",realm="public",nonce="8ff3995ac607275a97c77723d20c1f15",opaque="1a0feacf356abab0",qop=auth,uri="/v1/graphs",cnonce="0c65a878",nc=00000003,response="b1484a71e4caff9d07676502bed570ec"[\r][\n]" 2017/05/05 10:55:46:627 PDT [DEBUG] wire - >> "Transfer-Encoding: chunked[\r][\n]" 2017/05/05 10:55:46:628 PDT [DEBUG] wire - >> "Host: localhost:8011[\r][\n]" 2017/05/05 10:55:46:628 PDT [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:628 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:628 PDT [DEBUG] wire - >> "38[\r][\n]" 2017/05/05 10:55:46:628 PDT [DEBUG] wire - >> "<http://example.org/s1> <http://example.org/p1> 'test1'." 2017/05/05 10:55:46:628 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:628 PDT [DEBUG] wire - >> "0[\r][\n]" 2017/05/05 10:55:46:628 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:635 PDT [DEBUG] wire - << "HTTP/1.1 204 Updated[\r][\n]" 2017/05/05 10:55:46:635 PDT [DEBUG] wire - << "Server: MarkLogic[\r][\n]" 2017/05/05 10:55:46:635 PDT [DEBUG] wire - << "Content-Length: 0[\r][\n]" 2017/05/05 10:55:46:635 PDT [DEBUG] wire - << "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:635 PDT [DEBUG] wire - << "Keep-Alive: timeout=5[\r][\n]" 2017/05/05 10:55:46:635 PDT [DEBUG] wire - << "[\r][\n]" 2017/05/05 10:55:46:635 PDT [DEBUG] DefaultClientConnection - Receiving response: HTTP/1.1 204 Updated 2017/05/05 10:55:46:636 PDT [DEBUG] DefaultHttpClient - Connection can be kept alive for 5000 MILLISECONDS 2017/05/05 10:55:46:636 PDT [DEBUG] ThreadSafeClientConnManager - Released connection is reusable. 2017/05/05 10:55:46:636 PDT [DEBUG] ConnPoolByRoute - Releasing connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:636 PDT [DEBUG] ConnPoolByRoute - Pooling connection [{}->http://localhost:8011][null]; keep alive for 5000 MILLISECONDS 2017/05/05 10:55:46:636 PDT [DEBUG] ConnPoolByRoute - Notifying no-one, there are no waiting threads 10:55:46.657 [main] INFO c.m.client.impl.DocumentManagerImpl - Writing content for SPARQLManagerTest.testConstrainingQueries/embededTriple.xml 10:55:46.658 [main] DEBUG c.m.client.impl.JerseyServices - Sending SPARQLManagerTest.testConstrainingQueries/embededTriple.xml multipart document in transaction null 2017/05/05 10:55:46:661 PDT [DEBUG] ThreadSafeClientConnManager - Get connection: {}->http://localhost:8011, timeout = 0 2017/05/05 10:55:46:661 PDT [DEBUG] ConnPoolByRoute - [{}->http://localhost:8011] total kept alive: 1, total issued: 0, total allocated: 1 out of 200 2017/05/05 10:55:46:661 PDT [DEBUG] ConnPoolByRoute - Getting free connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:661 PDT [DEBUG] DefaultHttpClient - Stale connection check 2017/05/05 10:55:46:663 PDT [DEBUG] RequestAddCookies - CookieSpec selected: ignoreCookies 2017/05/05 10:55:46:663 PDT [DEBUG] RequestAuthCache - Auth cache not set in the context 2017/05/05 10:55:46:663 PDT [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED 2017/05/05 10:55:46:663 PDT [DEBUG] DefaultHttpClient - Attempt 1 to execute request 2017/05/05 10:55:46:663 PDT [DEBUG] DefaultClientConnection - Sending request: PUT /v1/documents?category=content&category=metadata&uri=SPARQLManagerTest.testConstrainingQueries/embededTriple.xml HTTP/1.1 2017/05/05 10:55:46:663 PDT [DEBUG] wire - >> "PUT /v1/documents?category=content&category=metadata&uri=SPARQLManagerTest.testConstrainingQueries/embededTriple.xml HTTP/1.1[\r][\n]" 2017/05/05 10:55:46:663 PDT [DEBUG] wire - >> "ML-Agent-ID: java[\r][\n]" 2017/05/05 10:55:46:663 PDT [DEBUG] wire - >> "Content-Type: multipart/mixed; boundary=Boundary_1_417797183_1494006946659[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "Authorization: Digest username="rest-writer",realm="public",nonce="8ff3995ac607275a97c77723d20c1f15",opaque="1a0feacf356abab0",qop=auth,uri="/v1/documents",cnonce="8243bc2d",nc=00000004,response="e208dd7da59f7854f8f07900cea66a4d"[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "Transfer-Encoding: chunked[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "Host: localhost:8011[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "47[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "--Boundary_1_417797183_1494006946659[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "Content-Type: application/xml[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:664 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "111[\r][\n]" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "<?xml version='1.0' encoding='utf-8'?><rapi:metadata xmlns:rapi="http://marklogic.com/rest-api" xmlns:prop="http://marklogic.com/xdmp/property"><rapi:collections><rapi:collection>SPARQLManagerTest.testConstrainingQueries</rapi:collection></rapi:collections></rapi:metadata>" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "49[\r][\n]" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "--Boundary_1_417797183_1494006946659[\r][\n]" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "Content-Type: application/xml[\r][\n]" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:698 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:699 PDT [DEBUG] wire - >> "161[\r][\n]" 2017/05/05 10:55:46:699 PDT [DEBUG] wire - >> "<xml><test2>testValue</test2><sem:triples xmlns:sem='http://marklogic.com/semantics'><sem:triple><sem:subject>http://example.org/s2</sem:subject><sem:predicate>http://example.org/p2</sem:predicate><sem:object datatype='http://www.w3.org/2001/XMLSchema#string'>test2</sem:object></sem:triple></sem:triples></xml>[\r][\n]" 2017/05/05 10:55:46:699 PDT [DEBUG] wire - >> "--Boundary_1_417797183_1494006946659--[\r][\n]" 2017/05/05 10:55:46:699 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:699 PDT [DEBUG] wire - >> "0[\r][\n]" 2017/05/05 10:55:46:699 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:701 PDT [DEBUG] wire - << "HTTP/1.1 204 Content Updated[\r][\n]" 2017/05/05 10:55:46:701 PDT [DEBUG] wire - << "Server: MarkLogic[\r][\n]" 2017/05/05 10:55:46:701 PDT [DEBUG] wire - << "Content-Length: 0[\r][\n]" 2017/05/05 10:55:46:701 PDT [DEBUG] wire - << "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:701 PDT [DEBUG] wire - << "Keep-Alive: timeout=5[\r][\n]" 2017/05/05 10:55:46:701 PDT [DEBUG] wire - << "[\r][\n]" 2017/05/05 10:55:46:701 PDT [DEBUG] DefaultClientConnection - Receiving response: HTTP/1.1 204 Content Updated 2017/05/05 10:55:46:701 PDT [DEBUG] DefaultHttpClient - Connection can be kept alive for 5000 MILLISECONDS 2017/05/05 10:55:46:701 PDT [DEBUG] ThreadSafeClientConnManager - Released connection is reusable. 2017/05/05 10:55:46:701 PDT [DEBUG] ConnPoolByRoute - Releasing connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:702 PDT [DEBUG] ConnPoolByRoute - Pooling connection [{}->http://localhost:8011][null]; keep alive for 5000 MILLISECONDS 2017/05/05 10:55:46:702 PDT [DEBUG] ConnPoolByRoute - Notifying no-one, there are no waiting threads 10:55:46.711 [main] DEBUG c.m.client.impl.JerseyServices - Posting /graphs/sparql 2017/05/05 10:55:46:713 PDT [DEBUG] ThreadSafeClientConnManager - Get connection: {}->http://localhost:8011, timeout = 0 2017/05/05 10:55:46:713 PDT [DEBUG] ConnPoolByRoute - [{}->http://localhost:8011] total kept alive: 1, total issued: 0, total allocated: 1 out of 200 2017/05/05 10:55:46:713 PDT [DEBUG] ConnPoolByRoute - Getting free connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:713 PDT [DEBUG] DefaultHttpClient - Stale connection check 2017/05/05 10:55:46:714 PDT [DEBUG] RequestAddCookies - CookieSpec selected: ignoreCookies 2017/05/05 10:55:46:714 PDT [DEBUG] RequestAuthCache - Auth cache not set in the context 2017/05/05 10:55:46:714 PDT [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED 2017/05/05 10:55:46:714 PDT [DEBUG] DefaultHttpClient - Attempt 1 to execute request 2017/05/05 10:55:46:714 PDT [DEBUG] DefaultClientConnection - Sending request: POST /v1/graphs/sparql?default-rulesets=exclude&collection=SPARQLManagerTest.testConstrainingQueries HTTP/1.1 2017/05/05 10:55:46:714 PDT [DEBUG] wire - >> "POST /v1/graphs/sparql?default-rulesets=exclude&collection=SPARQLManagerTest.testConstrainingQueries HTTP/1.1[\r][\n]" 2017/05/05 10:55:46:714 PDT [DEBUG] wire - >> "Content-Type: application/xml[\r][\n]" 2017/05/05 10:55:46:714 PDT [DEBUG] wire - >> "Accept: application/json[\r][\n]" 2017/05/05 10:55:46:714 PDT [DEBUG] wire - >> "ML-Agent-ID: java[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "Authorization: Digest username="rest-writer",realm="public",nonce="8ff3995ac607275a97c77723d20c1f15",opaque="1a0feacf356abab0",qop=auth,uri="/v1/graphs/sparql",cnonce="163de452",nc=00000005,response="9f4f607b15cf6fc8e7fa22e349cb86d8"[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "Transfer-Encoding: chunked[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "Host: localhost:8011[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "b2[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "<?xml version='1.0' encoding='UTF-8'?><search xmlns="http://marklogic.com/appservices/search"><qtext>test1</qtext><sparql>select ?s ?p ?o { ?s ?p ?o } limit 100</sparql></search>" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "0[\r][\n]" 2017/05/05 10:55:46:715 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "HTTP/1.1 200 OK[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "Content-type: application/json; charset=UTF-8[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "ML-Effective-Timestamp: 14940069467011536[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "Server: MarkLogic[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "Content-Length: 199[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "Keep-Alive: timeout=5[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "[\r][\n]" 2017/05/05 10:55:46:723 PDT [DEBUG] DefaultClientConnection - Receiving response: HTTP/1.1 200 OK 2017/05/05 10:55:46:723 PDT [DEBUG] DefaultHttpClient - Connection can be kept alive for 5000 MILLISECONDS 2017/05/05 10:55:46:723 PDT [DEBUG] wire - << "{"head":{"vars":["s","p","o"]},"results":{"bindings":[{"s":{"type":"uri","value":"http://example.org/s1"},"p":{"type":"uri","value":"http://example.org/p1"},"o":{"type":"literal","value":"test1"}}]}}" 2017/05/05 10:55:46:744 PDT [DEBUG] ThreadSafeClientConnManager - Released connection is reusable. 2017/05/05 10:55:46:744 PDT [DEBUG] ConnPoolByRoute - Releasing connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:744 PDT [DEBUG] ConnPoolByRoute - Pooling connection [{}->http://localhost:8011][null]; keep alive for 5000 MILLISECONDS 2017/05/05 10:55:46:744 PDT [DEBUG] ConnPoolByRoute - Notifying no-one, there are no waiting threads 10:55:46.762 [main] DEBUG c.m.client.impl.JerseyServices - Posting /graphs/sparql 2017/05/05 10:55:46:763 PDT [DEBUG] ThreadSafeClientConnManager - Get connection: {}->http://localhost:8011, timeout = 0 2017/05/05 10:55:46:763 PDT [DEBUG] ConnPoolByRoute - [{}->http://localhost:8011] total kept alive: 1, total issued: 0, total allocated: 1 out of 200 2017/05/05 10:55:46:763 PDT [DEBUG] ConnPoolByRoute - Getting free connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:763 PDT [DEBUG] DefaultHttpClient - Stale connection check 2017/05/05 10:55:46:764 PDT [DEBUG] RequestAddCookies - CookieSpec selected: ignoreCookies 2017/05/05 10:55:46:764 PDT [DEBUG] RequestAuthCache - Auth cache not set in the context 2017/05/05 10:55:46:764 PDT [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED 2017/05/05 10:55:46:764 PDT [DEBUG] DefaultHttpClient - Attempt 1 to execute request 2017/05/05 10:55:46:764 PDT [DEBUG] DefaultClientConnection - Sending request: POST /v1/graphs/sparql?default-rulesets=exclude&collection=SPARQLManagerTest.testConstrainingQueries HTTP/1.1 2017/05/05 10:55:46:764 PDT [DEBUG] wire - >> "POST /v1/graphs/sparql?default-rulesets=exclude&collection=SPARQLManagerTest.testConstrainingQueries HTTP/1.1[\r][\n]" 2017/05/05 10:55:46:764 PDT [DEBUG] wire - >> "Content-Type: application/xml[\r][\n]" 2017/05/05 10:55:46:764 PDT [DEBUG] wire - >> "Accept: application/json[\r][\n]" 2017/05/05 10:55:46:764 PDT [DEBUG] wire - >> "ML-Agent-ID: java[\r][\n]" 2017/05/05 10:55:46:764 PDT [DEBUG] wire - >> "Authorization: Digest username="rest-writer",realm="public",nonce="8ff3995ac607275a97c77723d20c1f15",opaque="1a0feacf356abab0",qop=auth,uri="/v1/graphs/sparql",cnonce="6acb5ff8",nc=00000006,response="f91f0b721156e19742eecbfcdc426f8b"[\r][\n]" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "Transfer-Encoding: chunked[\r][\n]" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "Host: localhost:8011[\r][\n]" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "214[\r][\n]" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "<?xml version='1.0' encoding='UTF-8'?><search xmlns="http://marklogic.com/appservices/search"><sparql>select ?s ?p ?o { ?s ?p ?o } limit 100</sparql><query xmlns="http://marklogic.com/appservices/search" xmlns:search="http://marklogic.com/appservices/search" xmlns:xs="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><and-query><term-query><text>test2</text></term-query><value-query type="string"><element ns="" name="test2"/><text>testValue</text></value-query></and-query></query></search>" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "0[\r][\n]" 2017/05/05 10:55:46:765 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:772 PDT [DEBUG] wire - << "HTTP/1.1 200 OK[\r][\n]" 2017/05/05 10:55:46:772 PDT [DEBUG] wire - << "Content-type: application/json; charset=UTF-8[\r][\n]" 2017/05/05 10:55:46:772 PDT [DEBUG] wire - << "ML-Effective-Timestamp: 14940069467011536[\r][\n]" 2017/05/05 10:55:46:772 PDT [DEBUG] wire - << "Server: MarkLogic[\r][\n]" 2017/05/05 10:55:46:772 PDT [DEBUG] wire - << "Content-Length: 342[\r][\n]" 2017/05/05 10:55:46:772 PDT [DEBUG] wire - << "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:772 PDT [DEBUG] wire - << "Keep-Alive: timeout=5[\r][\n]" 2017/05/05 10:55:46:772 PDT [DEBUG] wire - << "[\r][\n]" 2017/05/05 10:55:46:773 PDT [DEBUG] DefaultClientConnection - Receiving response: HTTP/1.1 200 OK 2017/05/05 10:55:46:773 PDT [DEBUG] DefaultHttpClient - Connection can be kept alive for 5000 MILLISECONDS 2017/05/05 10:55:46:773 PDT [DEBUG] wire - << "{"head":{"vars":["s","p","o"]},"results":{"bindings":[{"s":{"type":"uri","value":"http://example.org/s1"},"p":{"type":"uri","value":"http://example.org/p1"},"o":{"type":"literal","value":"test1"}},{"s":{"type":"uri","value":"http://example.org/s2"},"p":{"type":"uri","value":"http://example.org/p2"},"o":{"type":"literal","value":"test2"}}]}}" 2017/05/05 10:55:46:774 PDT [DEBUG] ThreadSafeClientConnManager - Released connection is reusable. 2017/05/05 10:55:46:774 PDT [DEBUG] ConnPoolByRoute - Releasing connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:774 PDT [DEBUG] ConnPoolByRoute - Pooling connection [{}->http://localhost:8011][null]; keep alive for 5000 MILLISECONDS 2017/05/05 10:55:46:774 PDT [DEBUG] ConnPoolByRoute - Notifying no-one, there are no waiting threads 10:55:46.781 [main] DEBUG c.m.client.impl.JerseyServices - Deleting graphs 2017/05/05 10:55:46:783 PDT [DEBUG] ThreadSafeClientConnManager - Get connection: {}->http://localhost:8011, timeout = 0 2017/05/05 10:55:46:783 PDT [DEBUG] ConnPoolByRoute - [{}->http://localhost:8011] total kept alive: 1, total issued: 0, total allocated: 1 out of 200 2017/05/05 10:55:46:783 PDT [DEBUG] ConnPoolByRoute - Getting free connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:783 PDT [DEBUG] DefaultHttpClient - Stale connection check 2017/05/05 10:55:46:784 PDT [DEBUG] RequestAddCookies - CookieSpec selected: ignoreCookies 2017/05/05 10:55:46:784 PDT [DEBUG] RequestAuthCache - Auth cache not set in the context 2017/05/05 10:55:46:784 PDT [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED 2017/05/05 10:55:46:784 PDT [DEBUG] DefaultHttpClient - Attempt 1 to execute request 2017/05/05 10:55:46:784 PDT [DEBUG] DefaultClientConnection - Sending request: DELETE /v1/graphs?graph=http://marklogic.com/java/SPARQLManagerTest HTTP/1.1 2017/05/05 10:55:46:784 PDT [DEBUG] wire - >> "DELETE /v1/graphs?graph=http://marklogic.com/java/SPARQLManagerTest HTTP/1.1[\r][\n]" 2017/05/05 10:55:46:784 PDT [DEBUG] wire - >> "ML-Agent-ID: java[\r][\n]" 2017/05/05 10:55:46:784 PDT [DEBUG] wire - >> "Authorization: Digest username="rest-writer",realm="public",nonce="8ff3995ac607275a97c77723d20c1f15",opaque="1a0feacf356abab0",qop=auth,uri="/v1/graphs",cnonce="f43e4aa4",nc=00000007,response="fd3defccd442cbd458a8aa0c9629f381"[\r][\n]" 2017/05/05 10:55:46:784 PDT [DEBUG] wire - >> "Host: localhost:8011[\r][\n]" 2017/05/05 10:55:46:784 PDT [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:784 PDT [DEBUG] wire - >> "[\r][\n]" 2017/05/05 10:55:46:787 PDT [DEBUG] wire - << "HTTP/1.1 204 Updated[\r][\n]" 2017/05/05 10:55:46:787 PDT [DEBUG] wire - << "Server: MarkLogic[\r][\n]" 2017/05/05 10:55:46:787 PDT [DEBUG] wire - << "Content-Length: 0[\r][\n]" 2017/05/05 10:55:46:787 PDT [DEBUG] wire - << "Connection: Keep-Alive[\r][\n]" 2017/05/05 10:55:46:787 PDT [DEBUG] wire - << "Keep-Alive: timeout=5[\r][\n]" 2017/05/05 10:55:46:787 PDT [DEBUG] wire - << "[\r][\n]" 2017/05/05 10:55:46:787 PDT [DEBUG] DefaultClientConnection - Receiving response: HTTP/1.1 204 Updated 2017/05/05 10:55:46:788 PDT [DEBUG] DefaultHttpClient - Connection can be kept alive for 5000 MILLISECONDS 2017/05/05 10:55:46:788 PDT [DEBUG] ThreadSafeClientConnManager - Released connection is reusable. 2017/05/05 10:55:46:788 PDT [DEBUG] ConnPoolByRoute - Releasing connection [{}->http://localhost:8011][null] 2017/05/05 10:55:46:788 PDT [DEBUG] ConnPoolByRoute - Pooling connection [{}->http://localhost:8011][null]; keep alive for 5000 MILLISECONDS 2017/05/05 10:55:46:788 PDT [DEBUG] ConnPoolByRoute - Notifying no-one, there are no waiting threads

Updated 05/06/2017 20:28

Stress test client throws XDMP-DOCBADCHAR for nquad on content load.

marklogic/java-client-api

Running the Java/REST stress test with 9.0-2 throws exception at document write with nquad type. ``` 2017-04-28 10:16:33 (Thread=45) ERROR writing graph /BVQHLJIHXIQVOAAK/2017328101524236/15/05triples-utf16.nt with mimetype application/n-triples without transaction 2017-04-28 10:16:33 (Thread=45) com.marklogic.client.FailedRequestException: Local message: failed to apply resource at graphs: Internal Server Error. Server Message: XDMP-DOCBADCHAR: xdmp:nquad($body, $options) – Unexpected character found: ‘�’ (0xfffd) at :1:0 . See the MarkLogic server error log for further detail. com.marklogic.client.FailedRequestException: Local message: failed to apply resource at graphs: Internal Server Error. Server Message: XDMP-DOCBADCHAR: xdmp:nquad($body, $options) – Unexpected character found: ‘�’ (0xfffd) at :1:0 . See the MarkLogic server error log for further detail. at com.marklogic.client.impl.JerseyServices.checkStatus(JerseyServices.java:4311) at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3218) at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3171) at com.marklogic.client.impl.JerseyServices.mergeGraph(JerseyServices.java:5053) at com.marklogic.client.impl.GraphManagerImpl.merge(GraphManagerImpl.java:203) at test.stress.JavaAPISession.mergeGraph(JavaAPISession.java:671) at test.stress.SemanticGraphLoadTester.putDocument(SemanticGraphLoadTester.java:22) at test.stress.RestLoadTester.loadContentFromDir(RestLoadTester.java:188) at test.stress.RestLoadTester.runTest(RestLoadTester.java:278) at test.stress.StressTest.run(StressTest.java:378) 2017-04-28 10:16:33 (Thread=45) Test took: 69298ms

```

Updated 17/05/2017 16:31

ES example nomenclature (minor)

marklogic/entity-services

Hi - when going through the examples I got tripped up after generating the instance converter when the example nomenclature changed from person-0.0.1.* to person-1.0.0 and sometimes person-3.0.0.

Here is what I see on: http://docs-ea.marklogic.com/guide/entity-services/codegen

  • version translator uses person-1.0.0 to person-1.0.0.
  • TDE starts with person-1.0.0 but the full sample code goes back to person-0.0.1.
  • schema uses person-1.0.0
  • database config uses person-3.0.0
  • search options start with person-0.0.1 but go uses person-1.0.0 in the full code

I get that these are all technically correct - but it would be good to standardize and be consistent especially since the entire framework relies on file name consistency as you from one step to another.

Also - maybe just one . version? person-0.1? :)

Thanks,

Matt

Updated 28/04/2017 22:39 6 Comments

DaaS only allows the user to query for containers. Messages are not tracked.

LigaData/Kamanja

After successfully processing messages from the Hello World and Medical sample applications, I attempted to query for msg1, outmsg1 and beneficiary messages, all of which failed: ``` WilMac:Kamanja-1.5.3_2.11 william$ curl -k -XGET https://localhost:8081/data/outmsg1 The requested resource could not be found.WilMac:Kamanja-1.5.3_2.11 william$

WilMac:Kamanja-1.5.3_2.11 william$ curl -k -XGET https://localhost:8081/data/msg1 The requested resource could not be found.

WilMac:Kamanja-1.5.3_2.11 william$ curl -k -XGET https://localhost:8081/data/beneficiary The requested resource could not be found. ```

Then I ran curl -k -XGET https://localhost:8081/data and it returned the following json: { "status": "success", "statusCode": "0", "statusDescription": "Containers in DaaS API", "resultCount": 1, "result": [{ "envcontext": { "name": "envcontext", "fullContainerName": "system.envcontext", "attributes": [], "attributeGroups": {}, "key": null }, "envcodes": { "name": "envcodes", "fullContainerName": "com.ligadata.kamanja.samples.containers.envcodes", "attributes": [{ "name": "icd9code", "typeStr": "string" }, { "name": "icd9description", "typeStr": "string" }], "attributeGroups": {}, "key": ["icd9code"] }, "context": { "name": "context", "fullContainerName": "system.context", "attributes": [], "attributeGroups": {}, "key": null }, "coughcodes": { "name": "coughcodes", "fullContainerName": "com.ligadata.kamanja.samples.containers.coughcodes", "attributes": [{ "name": "icd9code", "typeStr": "string" }, { "name": "icd9description", "typeStr": "string" }], "attributeGroups": {}, "key": ["icd9code"] }, "containerinterface": { "name": "containerinterface", "fullContainerName": "system.containerinterface", "attributes": [], "attributeGroups": {}, "key": null }, "smokecodes": { "name": "smokecodes", "fullContainerName": "com.ligadata.kamanja.samples.containers.smokecodes", "attributes": [{ "name": "icd9code", "typeStr": "string" }, { "name": "icd9description", "typeStr": "string" }], "attributeGroups": {}, "key": ["icd9code"] }, "dyspnoeacodes": { "name": "dyspnoeacodes", "fullContainerName": "com.ligadata.kamanja.samples.containers.dyspnoeacodes", "attributes": [{ "name": "icd9code", "typeStr": "string" }, { "name": "icd9description", "typeStr": "string" }], "attributeGroups": {}, "key": ["icd9code"] }, "messageinterface": { "name": "messageinterface", "fullContainerName": "system.messageinterface", "attributes": [], "attributeGroups": {}, "key": null }, "sputumcodes": { "name": "sputumcodes", "fullContainerName": "com.ligadata.kamanja.samples.containers.sputumcodes", "attributes": [{ "name": "icd9code", "typeStr": "string" }, { "name": "icd9description", "typeStr": "string" }], "attributeGroups": {}, "key": ["icd9code"] }, "kamanjamodelevent": { "name": "kamanjamodelevent", "fullContainerName": "com.ligadata.kamanjabase.kamanjamodelevent", "attributes": [{ "name": "modelid", "typeStr": "long" }, { "name": "elapsedtimeinms", "typeStr": "float" }, { "name": "eventepochtime", "typeStr": "long" }, { "name": "isresultproduced", "typeStr": "boolean" }, { "name": "producedmessages", "typeStr": "arrayoflong" }, { "name": "error", "typeStr": "string" }], "attributeGroups": {}, "key": null } }] } Listed in this structure are all internal messages and the containers for the medical app. However, there is no mention of any messages for either application.

Updated 05/04/2017 18:00 1 Comments

Discrepancy in behavior when one of the node is shutdown

marklogic/java-client-api

From https://github.com/marklogic/data-movement/issues/59

@srinathgit: Scenario 1 :

Three node cluster, having a forest on each node. Make one of the forest disabled Start the job Stop the node on which the aforementioned forest resides when insert is happening

Documents are written to the host. The host that has forest disabled routes the document to other hosts where forest is available. When the node having the disabled forest is brought down, the batch to be written to the host having disabled forest are marked as failure. The database goes to unavailable state immediately and no more inserts take place until the node is brought back up.

Scenario 2:

Three node cluster, having a forest on each node. Make one of the forest offline Start the job Stop the node on which the aforementioned forest resides when insert is happening

Documents are written to the host. The host that has forest offline routes the document to other hosts where forest is available. When the node having the offline forest is brought down, the batches of document to be written to the host having offline forest are marked as failure while documents are written to the other nodes. This continues for a period of roughly 90 seconds after the node is brought down. After that no more inserts take place until the node is brought back up. Hence a lot more batches fail during the interim period. 1. This may be due to the behavior of server. I just want to confirm if this is expected. 2. Also in either case, the DMSDK application indefinitely hangs (it was alive for atleast 20 minutes when I checked) with stack trace of main thread is provided below waiting for a response from the server.

Name: main
State: RUNNABLE
Total blocked: 0  Total waited: 22

Stack trace: 
java.net.SocketInputStream.socketRead0(Native Method)
java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
java.net.SocketInputStream.read(SocketInputStream.java:170)
java.net.SocketInputStream.read(SocketInputStream.java:141)
org.apache.http.impl.io.AbstractSessionInputBuffer.fillBuffer(AbstractSessionInputBuffer.java:149)
org.apache.http.impl.io.SocketInputBuffer.fillBuffer(SocketInputBuffer.java:110)
org.apache.http.impl.io.AbstractSessionInputBuffer.readLine(AbstractSessionInputBuffer.java:260)
org.apache.http.impl.conn.LoggingSessionInputBuffer.readLine(LoggingSessionInputBuffer.java:115)
org.apache.http.impl.conn.DefaultResponseParser.parseHead(DefaultResponseParser.java:98)
org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:252)
org.apache.http.impl.AbstractHttpClientConnection.receiveResponseHeader(AbstractHttpClientConnection.java:281)
org.apache.http.impl.conn.DefaultClientConnection.receiveResponseHeader(DefaultClientConnection.java:247)
org.apache.http.impl.conn.AbstractClientConnAdapter.receiveResponseHeader(AbstractClientConnAdapter.java:219)
org.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:298)
org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:125)
org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
com.sun.jersey.api.client.Client.handle(Client.java:648)
com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:4338)
com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3564)
com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3677)
com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:564)
com.marklogic.datamovement.impl.WriteHostBatcherImpl.flushBatch(WriteHostBatcherImpl.java:164)
   - locked com.marklogic.datamovement.impl.WriteHostBatcherImpl@4a4a492
com.marklogic.datamovement.impl.WriteHostBatcherImpl.add(WriteHostBatcherImpl.java:105)
   - locked com.marklogic.datamovement.impl.BatchWriteSet@767e8f3c
com.marklogic.datamovement.impl.WriteHostBatcherImpl.add(WriteHostBatcherImpl.java:89)
com.marklogic.datamovement.functionaltests.WriteHostBatcherTest.testDisableDBDuringInsert(WriteHostBatcherTest.java:1684)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
org.junit.runners.ParentRunner.run(ParentRunner.java:309)
org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192) 
Updated 17/05/2017 16:31

Publish a nightly build to our maven server

marklogic/java-client-api

From https://github.com/marklogic/data-movement/issues/112

@jmakeig has requested a periodic build of java-client-api in our maven server to simplify his development of sample code for the EA releases. @popzip would like the same. The build should end with -SNAPSHOT in keeping with non-release builds. We can publish only the nightly build and not any previous nightly builds.

Updated 28/03/2017 23:02

Denormalized sub-entities

marklogic/entity-services

When putting entity instances into documents, one always chooses one to be the root, and others to embed or denormalize into the document structure.

Entity Services in MarkLogic 9 does not provide this vocabulary, but repeated use of the code generation indicates that it could be automated significantly with this extra concept.

  1. Entry point of a module is known.
  2. Expectations of whether a reference property contains an embedded instance or a reference to an external one.
  3. Refinement of extraction template to require less customization.
Updated 09/06/2017 17:49 3 Comments

Handling NPE withBlackList and withWhiteList methods

marklogic/java-client-api

Handling NPE withBlackList and withWhiteList methods

Test:

@Test
    public void testWhiteList() throws Exception{
        Assume.assumeTrue(hostNames.length > 1);

        final String query1 = "fn:count(fn:doc())";

        try{
            DocumentMetadataHandle meta6 = new DocumentMetadataHandle().withCollections("NoHost").withQuality(0);

            Assert.assertTrue(dbClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 0);

            WriteBatcher ihb2 =  dmManager.newWriteBatcher();

            FilteredForestConfiguration forestConfig = new FilteredForestConfiguration(dmManager.readForestConfig())
                            .withBlackList(null);
}

Exception:

java.lang.NullPointerException
    at com.marklogic.client.datamovement.FilteredForestConfiguration.withBlackList(FilteredForestConfiguration.java:172)
    at com.marklogic.client.datamovement.functionaltests.WriteHostBatcherTest.testWhiteList(WriteHostBatcherTest.java:2651)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
Updated 17/05/2017 16:31

Final touches on SDK for Release Candidate 1

RestComm/restcomm-ios-sdk

I quickly copied this from Android SDK, so many of them will have to change:

Review all aspects of the SDK and make sure it is GA quality. Some things to check: - API is in good shape - CI/CD facilities are complete and 100% functional from Travis CI - UI/Integration/Unit testing are complete with 100% passing tests, also automated testing in real devices (using external service like Amazon farm) would be great. - Interoperability testing between all SDKs would be a plus, but not sure if it can be realized yet, as the rest of the SDKs might not yet be ready. - Documentation is up to date and with some improvements so that it is easier to read (also all documentation should reside in this repo, not Restcomm-Connect): - Reference Documentation - Quick start guide - User guide for Olympus - Olympus App and Hello World sample app both functional. Olympus should be verified by UI tests, but not sure about Hello World -maybe we could introduce a rudimentary set of UI tests for this as well. - Libraries in RC should all be release type and as lightweight as possible - All dependencies are stored in Sonatype and visible to public. The repository should have no local dependencies.

Also do a round of very thorough testing: - Do some more testing on Notifications functionality + integrations with Android Contacts + Calls as they aren’t tested enough as far as I know - Test UI/UX aspects to fix any left overs that might have slipped our attention. - Manually test interoperability in various types of calls within Android Olympus: - Video -> Video - Video -> Audio - Audio -> Video - Audio -> Audio - Manually test interoperability between Android, iOS and Web Olympus

Updated 26/06/2017 18:15

Flr 294

LigaData/Kamanja

Used the class MetadataAPISerialization for generating Json corresponding GetAll API functions. For adapters, Json result will look something like as shown below

“Adapters”: [ { “Adapter”: { “Name”: “MedicalInput”, “TypeString”: “Input”, “ClassName”: “com.ligadata.kafkaInputOutputAdapters_v10.KamanjaKafkaConsumer$”, “JarName”: “kamanjakafkaadapters_0_10_2.11-1.6.1.jar”, “DependencyJars”: [ “kafka-clients-0.10.0.1.jar”, “KamanjaInternalDeps_2.11-1.6.1.jar”, “ExtDependencyLibs_2.11-1.6.1.jar”, “ExtDependencyLibs2_2.11-1.6.1.jar” ], “AdapterSpecificCfg”: “{\"HostList\”:\“localhost:9092\”,\“TopicName\”:\“medicalinput\”}“, "TenantId”: “tenant1”, “FullAdapterConfig”: “{\"TenantId\”:\“tenant1\”,\“DependencyJars\”:[\“kafka-clients-0.10.0.1.jar\”,\“KamanjaInternalDeps_2.11-1.6.1.jar\”,\“ExtDependencyLibs_2.11-1.6.1.jar\”,\“ExtDependencyLibs2_2.11-1.6.1.jar\”],\“ClassName\”:\“com.ligadata.kafkaInputOutputAdapters_v10.KamanjaKafkaConsumer$\”,\“Name\”:\“MedicalInput\”,\“AdapterSpecificCfg\”:{\“HostList\”:\“localhost:9092\”,\“TopicName\”:\“medicalinput\”},\“TypeString\”:\“Input\”,\“JarName\”:\“kamanjakafkaadapters_0_10_2.11-1.6.1.jar\”}“ } }, { "Adapter”: { “Name”: “Storage_1”, “TypeString”: “Storage”, “ClassName”: “”, “JarName”: “”, “DependencyJars”: [], “AdapterSpecificCfg”: “”, “TenantId”: “tenant1”, “FullAdapterConfig”: “{\"TenantId\”:\“tenant1\”,\“Location\”:\“/media/home3/installKamanja161/Kamanja-1.6.1_2.11/storage/tenant1_storage_1\”,\“Name\”:\“Storage_1\”,\“portnumber\”:\“9100\”,\“StoreType\”:\“h2db\”,\“TypeString\”:\“Storage\”,\“connectionMode\”:\“embedded\”,\“SchemaName\”:\“testdata\”,\“user\”:\“test\”,\“password\”:\“test\”}“ } },

Updated 25/06/2017 05:55

The example query-builder.js not completing

marklogic/node-client-api

When running all the examples at once, as described in the README, or when running query-builder.js alone, execution dies near the end of query-builder.js: mwooldri$ node examples/query-builder.js Query documents with the Query Builder Mayotte at /countries/mf.json Seychelles at /countries/se.json Morocco at /countries/mo.json Burkina Faso at /countries/uv.json Algeria at /countries/ag.json Djibouti at /countries/dj.json Cote d'Ivoire at /countries/iv.json Mauritania at /countries/mr.json Guinea at /countries/gv.json Mali at /countries/ml.json mwooldri$ It should end like this: ... Mali at /countries/ml.json Niger at /countries/ng.json done mwooldri$ All other examples complete successfully when run by themselves.

When query-builder.js is edited to use a promise instead of a stream (similar to how query-by-example.js uses a promise), the script completes successfully. So it appears to be an issue with streams in query-builder.js.

I’m running Node.js v6.5.0 and npm v3.10.3.

Updated 21/06/2017 16:22 5 Comments

Npc weg porten

combak/ShatteredWorld

relativ hat getestet..mit dem Dislocation Amulett kann mann Spieler die schleichen, Npc, Tiere und alle Monster porten.

Npc finden den weg in ihre Dimenson nie wieder.. bitte Amulett deaktivieren oder oder oder

Updated 15/05/2017 06:47 8 Comments

Loading document fails when used with a MetaData object with property set

marklogic/java-client-api

Loading document fails when used with a MetaData object with property set. If “.withProperty("docMeta-1”, “true”).withQuality(1)“ is removed from DocumentMetadataHandle object, the documents are written fine.

    @Test
    public void addWithMetadata() throws Exception{

        final String query1 = "fn:count(fn:doc())";

        try{
            DocumentMetadataHandle meta6 = new DocumentMetadataHandle()
                     .withCollections("Sample Collection 1").withProperty("docMeta-1", "true").withQuality(1);
            meta6.setFormat(Format.XML);
            Assert.assertTrue(dbClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 0);

            Thread.currentThread().sleep(5000L);

            DatabaseClient dbClient = DatabaseClientFactory.newClient(host, port, user, password, Authentication.DIGEST);
            DataMovementManager dmManager = dbClient.newDataMovementManager();

            WriteBatcher ihb2 =  dmManager.newWriteBatcher();
            ihb2.withBatchSize(50).withThreadCount(1);

            ihb2.onBatchSuccess(
                    batch -> {
                        }
                    )
                    .onBatchFailure(
                      (batch, throwable) -> {
                          throwable.printStackTrace();

                      }
            );
            for (int j =0 ;j < 1000; j++){
                String uri ="/local/string-"+ j;
                ihb2.addAs(uri , meta6,jsonNode);
            }


            ihb2.flushAndWait();

            Assert.assertTrue(dbClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 1000);

        }
        catch(Exception e){
            e.printStackTrace();
        }
    }

Log:



16:32:32.839 [main] DEBUG c.m.client.impl.JerseyServices - Connecting to localhost at 8000 as admin
16:32:33.535 [main] DEBUG c.m.client.impl.JerseyServices - Getting forestinfo as application/json
16:32:33.878 [main] DEBUG c.m.client.impl.JerseyServices - Posting eval
16:32:39.001 [main] DEBUG c.m.client.impl.JerseyServices - Connecting to localhost at 8000 as admin
16:32:39.251 [main] DEBUG c.m.client.impl.JerseyServices - Getting forestinfo as application/json
16:32:39.278 [main] INFO  c.m.c.d.impl.WriteBatcherImpl - (withForestConfig) Using [localhost] hosts with forests for "WriteHostBatcher"
16:32:39.283 [main] INFO  c.m.c.d.impl.WriteBatcherImpl - Adding DatabaseClient on port 8000 for host "localhost" to the rotation
16:32:39.325 [main] INFO  c.m.c.d.impl.WriteBatcherImpl - threadCount=1
16:32:39.325 [main] INFO  c.m.c.d.impl.WriteBatcherImpl - batchSize=50
16:32:39.412 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:39.413 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:39.419 [main] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:39.420 [main] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:43.731 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:43.731 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:43.733 [main] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:43.734 [main] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 19 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 43 more
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 19 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 43 more
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 19 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 43 more
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 19 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 43 more
16:32:43.746 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
16:32:43.748 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:43.748 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:43.756 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
16:32:43.758 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:43.758 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:43.767 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
16:32:43.769 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:43.770 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:43.783 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
16:32:43.785 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:43.786 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:44.198 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:44.199 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:44.753 [main] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.marklogic.client.FailedRequestException: Local message: failed to apply resource at documents: Bad Request. Server Message: XDMP-DOCSTARTTAGCHAR: xdmp:get-request-part-body("xml") -- Unexpected character "&quot;" in start tag at  line 1
com.marklogic.client.FailedRequestException: Local message: failed to apply resource at documents: Bad Request. Server Message: XDMP-DOCSTARTTAGCHAR: xdmp:get-request-part-body("xml") -- Unexpected character "&quot;" in start tag at  line 1
    at com.marklogic.client.impl.JerseyServices.checkStatus(JerseyServices.java:4243)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3257)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy.rejectedExecution(ThreadPoolExecutor.java:2022)
    at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
    at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
    at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:112)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.add(WriteBatcherImpl.java:292)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.addAs(WriteBatcherImpl.java:320)
    at com.marklogic.client.datamovement.functionaltests.WriteHostBatcherTest.addWithMetadata(WriteHostBatcherTest.java:2458)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
16:32:44.756 [main] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:44.756 [main] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:44.768 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:44.768 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
com.marklogic.client.FailedRequestException: Local message: failed to apply resource at documents: Bad Request. Server Message: XDMP-DOCSTARTTAGCHAR: xdmp:get-request-part-body("xml") -- Unexpected character "&quot;" in start tag at  line 1
16:32:44.852 [main] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.marklogic.client.FailedRequestException: Local message: failed to apply resource at documents: Bad Request. Server Message: XDMP-DOCSTARTTAGCHAR: xdmp:get-request-part-body("xml") -- Unexpected character "&quot;" in start tag at  line 1
16:32:44.854 [main] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:44.854 [main] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
    at com.marklogic.client.impl.JerseyServices.checkStatus(JerseyServices.java:4243)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3257)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy.rejectedExecution(ThreadPoolExecutor.java:2022)
    at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
    at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
    at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:112)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.add(WriteBatcherImpl.java:292)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.addAs(WriteBatcherImpl.java:320)
    at com.marklogic.client.datamovement.functionaltests.WriteHostBatcherTest.addWithMetadata(WriteHostBatcherTest.java:2458)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
com.marklogic.client.FailedRequestException: Local message: failed to apply resource at documents: Bad Request. Server Message: XDMP-DOCSTARTTAGCHAR: xdmp:get-request-part-body("xml") -- Unexpected character "&quot;" in start tag at  line 1
    at com.marklogic.client.impl.JerseyServices.checkStatus(JerseyServices.java:4243)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3257)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
16:32:44.859 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.marklogic.client.FailedRequestException: Local message: failed to apply resource at documents: Bad Request. Server Message: XDMP-DOCSTARTTAGCHAR: xdmp:get-request-part-body("xml") -- Unexpected character "&quot;" in start tag at  line 1
16:32:44.860 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:44.860 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 19 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 43 more
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy.rejectedExecution(ThreadPoolExecutor.java:2022)
    at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
    at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
    at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:112)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.add(WriteBatcherImpl.java:292)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.addAs(WriteBatcherImpl.java:320)
    at com.marklogic.client.datamovement.functionaltests.WriteHostBatcherTest.addWithMetadata(WriteHostBatcherTest.java:2458)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 50 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 74 more
16:32:44.887 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
16:32:44.888 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:44.888 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:44.899 [main] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
16:32:44.900 [main] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:44.901 [main] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:44.936 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 19 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 43 more
16:32:44.937 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:44.937 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:45.127 [main] INFO  c.m.c.d.impl.WriteBatcherImpl - flushing 0 queued docs
16:32:45.129 [pool-3-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:45.130 [pool-3-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:45.160 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:45.160 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:539)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.lambda$5(WriteBatcherImpl.java:658)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 22 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 46 more
16:32:45.169 [pool-3-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
16:32:45.170 [pool-3-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:45.170 [pool-3-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to output non-whitespace characters outside main element tree (in prolog or epilog)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to output non-whitespace characters outside main element tree (in prolog or epilog)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 19 more
Caused by: javax.xml.stream.XMLStreamException: Trying to output non-whitespace characters outside main element tree (in prolog or epilog)
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.BaseStreamWriter.reportNwfStructure(BaseStreamWriter.java:1593)
    at com.ctc.wstx.sw.BaseStreamWriter.writeCharacters(BaseStreamWriter.java:420)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:902)
    ... 43 more
com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:184)
    at com.marklogic.client.impl.DigestChallengeFilter.handle(DigestChallengeFilter.java:34)
    at com.sun.jersey.api.client.filter.HTTPDigestAuthFilter.handle(HTTPDigestAuthFilter.java:493)
    at com.sun.jersey.api.client.Client.handle(Client.java:648)
    at com.sun.jersey.api.client.WebResource.handle(WebResource.java:680)
    at com.sun.jersey.api.client.WebResource.access$200(WebResource.java:74)
    at com.sun.jersey.api.client.WebResource$Builder.post(WebResource.java:568)
    at com.marklogic.client.impl.JerseyServices.doPost(JerseyServices.java:3940)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3227)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:904)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:270)
    at com.marklogic.client.impl.ValueConverter.convertFromJava(ValueConverter.java:87)
    at com.marklogic.client.io.DocumentMetadataHandle.sendPropertiesImpl(DocumentMetadataHandle.java:873)
    at com.marklogic.client.io.DocumentMetadataHandle.sendMetadataImpl(DocumentMetadataHandle.java:776)
    at com.marklogic.client.io.DocumentMetadataHandle.write(DocumentMetadataHandle.java:559)
    at com.marklogic.client.impl.StreamingOutputImpl.write(StreamingOutputImpl.java:48)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:71)
    at com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:57)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:218)
    at com.sun.jersey.multipart.impl.MultiPartWriter.writeTo(MultiPartWriter.java:71)
    at com.sun.jersey.api.client.RequestWriter$RequestEntityWriterImpl.writeRequestEntity(RequestWriter.java:231)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler$2.writeTo(ApacheHttpClient4Handler.java:262)
    at org.apache.http.entity.HttpEntityWrapper.writeTo(HttpEntityWrapper.java:96)
    at org.apache.http.impl.client.EntityEnclosingRequestWrapper$EntityWrapper.writeTo(EntityEnclosingRequestWrapper.java:108)
    at org.apache.http.impl.entity.EntitySerializer.serialize(EntitySerializer.java:120)
    at org.apache.http.impl.AbstractHttpClientConnection.sendRequestEntity(AbstractHttpClientConnection.java:263)
    at org.apache.http.impl.conn.AbstractClientConnAdapter.sendRequestEntity(AbstractClientConnAdapter.java:227)
    at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:255)
    at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)
    at org.apache.http.impl.client.DefaultRequestDirector.tryExecute(DefaultRequestDirector.java:633)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:454)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:820)
    at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:776)
    at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:170)
    ... 19 more
Caused by: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
    at com.ctc.wstx.sw.BaseStreamWriter.throwOutputError(BaseStreamWriter.java:1564)
    at com.ctc.wstx.sw.RepairingNsStreamWriter.writeAttribute(RepairingNsStreamWriter.java:124)
    at com.marklogic.client.io.DocumentMetadataHandle$ValueSerializer.process(DocumentMetadataHandle.java:900)
    ... 43 more
16:32:45.178 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to output non-whitespace characters outside main element tree (in prolog or epilog)
16:32:45.179 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Posting documents
16:32:45.180 [pool-1-thread-1] DEBUG c.m.client.impl.JerseyServices - Sending multipart for /v1/documents
16:32:45.183 [pool-1-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.sun.jersey.api.client.ClientHandlerException: com.marklogic.client.MarkLogicIOException: javax.xml.stream.XMLStreamException: Trying to write an attribute when there is no open start element.
com.marklogic.client.FailedRequestException: Local message: failed to apply resource at documents: Bad Request. Server Message: XDMP-DOCSTARTTAGCHAR: xdmp:get-request-part-body("xml") -- Unexpected character "&quot;" in start tag at  line 1
    at com.marklogic.client.impl.JerseyServices.checkStatus(JerseyServices.java:4243)
    at com.marklogic.client.impl.JerseyServices.postResource(JerseyServices.java:3257)
    at com.marklogic.client.impl.JerseyServices.postBulkDocuments(JerseyServices.java:3345)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:619)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.impl.DocumentManagerImpl.write(DocumentManagerImpl.java:611)
    at com.marklogic.client.impl.GenericDocumentImpl.write(GenericDocumentImpl.java:1)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl$BatchWriter.run(WriteBatcherImpl.java:1032)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at com.marklogic.client.datamovement.impl.WriteBatcherImpl.lambda$5(WriteBatcherImpl.java:658)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
16:32:45.223 [pool-3-thread-1] WARN  c.m.c.d.impl.WriteBatcherImpl - Error writing batch: com.marklogic.client.FailedRequestException: Local message: failed to apply resource at documents: Bad Request. Server Message: XDMP-DOCSTARTTAGCHAR: xdmp:get-request-part-body("xml") -- Unexpected character "&quot;" in start tag at  line 1
16:32:45.224 [main] DEBUG c.m.client.impl.JerseyServices - Posting eval
S is true
WriteHostBatcher-1
Updated 17/04/2017 20:40 7 Comments

Issue1357 161

LigaData/Kamanja

I have addressed the issue 1.5.1 and somehow it didn’t make it to later versions. I have merged the changes into 1.6.1 branch and done some unit-testing. Let me know If I need to improve the messages further.

Updated 25/06/2017 06:28

Issue1123

LigaData/Kamanja

For Java/Scala Models, The package name specified within the model code should match the nameSpace of modelName. Otherwise, fail the Add/Update Model operations

Updated 25/06/2017 06:28

Move MERRA profile generation to... somewhere

Applied-GeoSolutions/gips

The current non-working MERRA driver has a function that retrieves a single column of atmospheric properties that are used by MODTRAN for the landsat wtemp product.

This function has a pydap dependency. MERRA driver no longer uses pydap driver because implementing EarthData authentication was proving to be difficult.

See #142

Updated 08/05/2017 18:00 1 Comments

EvalTest fails in develop branch.

marklogic/java-client-api

The following test fails in the nightly regression run in the EA4 server build. I don’t see this test failing on Jenkins environment, where the server build used is 9.0 trunk.

<testsuite tests="6" failures="1" name="com.marklogic.client.test.EvalTest" time="4.448" errors="0" skipped="0">
...
...

<testcase classname="com.marklogic.client.test.EvalTest" name="test_582_need_privilege" time="0.006">
    <failure message="a FailedRequestException should have been thrown since rest_admin doesn't have eval privileges" type="java.lang.AssertionError">java.lang.AssertionError: a FailedRequestException should have been thrown since rest_admin doesn't have eval privileges
    at org.junit.Assert.fail(Assert.java:88)
    at com.marklogic.client.test.EvalTest.test_582_need_privilege(EvalTest.java:463)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)
    at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)
    at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)
    at org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)
    at org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)
    at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:115)
    at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)
</failure>
Updated 15/06/2017 00:57 7 Comments

How to make sure the uniqueness of indexes

strongloop/loopback

Bug or feature request

  • [X] Bug
  • [X ] Feature request

Description of feature (or steps to reproduce if bug)

The following is my model description. "indexes": { "ackId_deviceId_index": { "keys": { "ackId": 1, "deviceId": 1 }, "options": { "unique": true } } }, "validations": [], And when I insert duplicated ackId join with deviceId loopback doesn’t raise error for me.

Updated 13/04/2017 06:17 5 Comments

Job not getting stopped when number of available hosts < 'minHosts' property

marklogic/java-client-api

This issue was observed with a specific forest configuration described below: A. This test was run on a 3 node cluster (rh7v-intel64-90-test-4/5/6.marklogic.com) with a forest (WriteBatcher-1,2,3) on each of the node which are associated with a db. ‘WriteBatcher-1’ is not configured for failover. ‘WriteBatcher-3’ is configured to fail over to host ‘rh7v-intel64-90-test-5.marklogic.com’. ‘WriteBatcher-2’ is configured to fail over to host ‘rh7v-intel64-90-test-4.marklogic.com’

  1. Now when ‘ihb2’ WB job is getting executed,nodes rh7v-intel64-90-test-6.marklogic.com is first stopped .

21:16:24.885 [main] ERROR c.m.c.d.HostAvailabilityListener - ERROR: host unavailable “rh7v-intel64-90-test-6.marklogic.com”, black-listing it for PT15S The forest fails over to ‘rh7v-intel64-90-test-5.marklogic.com’. The writing of document to db resumes once the failover is complete.

  1. Now ‘rh7v-intel64-90-test-5.marklogic.com’ is stopped. It gets blacklisted 21:17:02.508 [main] ERROR c.m.c.d.HostAvailabilityListener - ERROR: host unavailable “rh7v-intel64-90-test-5”, black-listing it for PT15S

  2. After that, the job is stopped as available hosts < minHosts

21:17:02.772 [pool-1-thread-1] ERROR c.m.c.d.HostAvailabilityListener - Encountered [com.sun.jersey.api.client.ClientHandlerException: org.apache.http.NoHttpResponseException: The target server failed to respond] on host “rh7v-intel64-90-test-5.marklogic.com” but black-listing it would drop job below minHosts (2), so stopping job “unnamed”.

  1. After that , retrying of failed batches keeps running infinitely

21:17:02.550 [main] WARN c.m.c.d.HostAvailabilityListener - Retrying failed batch: 132, results so far: 2640, uris: [/local/ABC-2620, /local/ABC-2621, /local/ABC-2622, /local/ABC-2623, /local/ABC-2624, /local/ABC-2625, /local/ABC-2626, /local/ABC-2627, /local/ABC-2628, /local/ABC-2629, /local/ABC-2630, /local/ABC-2631, /local/ABC-2632, /local/ABC-2633, /local/ABC-2634, /local/ABC-2635, /local/ABC-2636, /local/ABC-2637, /local/ABC-2638, /local/ABC-2639]

  1. The client process was killed after sometime and the client logs and stack trace have been attached. Client log Stack trace

Test:

@Test
public void testFailOver() throws Exception{
    try{
        final String query1 = "fn:count(fn:doc())";

        final AtomicInteger successCount = new AtomicInteger(0);

        final MutableBoolean failState = new MutableBoolean(false);
        final AtomicInteger failCount = new AtomicInteger(0);

        WriteBatcher ihb2 =  dmManager.newWriteBatcher();
        ihb2.withBatchSize(20);
        //ihb2.withThreadCount(120);


        ihb2.setBatchFailureListeners(
                  new HostAvailabilityListener(dmManager)
                    .withSuspendTimeForHostUnavailable(Duration.ofSeconds(15))
                    .withMinHosts(2)
                );  
        ihb2.onBatchSuccess(
               batch -> {

                    successCount.addAndGet(batch.getItems().length);
                    System.out.println("Success Host: "+ batch.getClient().getHost());
                    System.out.println("Success batch number: "+ batch.getJobBatchNumber());
                     System.out.println("Success Job writes so far: "+ batch.getJobWritesSoFar());
                  }
                )
                .onBatchFailure(
                  (batch, throwable) -> {
                      System.out.println("Failed batch number: "+ batch.getJobBatchNumber());
                      /*try{
                          System.out.println("Retrying batch: "+ batch.getJobBatchNumber());
                          ihb2.retry(batch);
                      }
                     catch(Exception e){
                         System.out.println("Retry of batch "+ batch.getJobBatchNumber()+ " failed");
                         e.printStackTrace();
                     }*/

                      throwable.printStackTrace();
                      failState.setTrue();
                      failCount.addAndGet(batch.getItems().length);
                  });


        dmManager.startJob(ihb2);    

        for (int j =0 ;j < 20000; j++){
            String uri ="/local/ABC-"+ j;
            ihb2.add(uri, stringHandle);
        }


        ihb2.flushAndWait();


        System.out.println("Fail : "+failCount.intValue());
        System.out.println("Success : "+successCount.intValue());
        System.out.println("Count : "+ dbClient.newServerEval().xquery(query1).eval().next().getNumber().intValue());

        Assert.assertTrue(dbClient.newServerEval().xquery(query1).eval().next().getNumber().intValue()==20000);

    }
    catch(Exception e){
        e.printStackTrace();
    }
}
Updated 17/05/2017 16:31 8 Comments

Job hangs when available hosts < min hosts instead of terminating

marklogic/java-client-api
  1. This test was run on a 3 node cluster (rh7v-intel64-90-test-4/5/6.marklogic.com) with a forest (ApplyTransform1,2,3) on each of the node associated with a db.
  2. Now when ‘batcher ’ QB job is getting executed,nodes rh7v-intel64-90-test-5/6.marklogic.com are stopped one after the other. new HostAvailabilityListener(dmManager) .withSuspendTimeForHostUnavailable(Duration.ofSeconds(15)) .withMinHosts(2)

C.From the log, it can be seen that rh7v-intel64-90-test-6.marklogic.com is black listed but once rh7v-intel64-90-test-5.marklogic.com is stopped , it is not black listed. D. Instead,the process hangs forever. The stack trace and client logs are attached.

Client log jstack.txt

    @Test
    public void xQueryMasstransformReplace() throws Exception{

        WriteBatcher ihb2 =  dmManager.newWriteBatcher();
        ihb2.withBatchSize(27).withThreadCount(10);
        ihb2.onBatchSuccess(
                batch -> {


                }
                )
        .onBatchFailure(
                (batch, throwable) -> {
                    throwable.printStackTrace();
                });

        dmManager.startJob(ihb2);

        for (int j =0 ;j < 2000; j++){
            String uri ="/local/string-"+ j;
            ihb2.add(uri, meta2, stringHandle);
        }

        ihb2.flushAndWait();

        ServerTransform transform = new ServerTransform("add-attr-xquery-transform");
        transform.put("name", "Lang");
        transform.put("value", "English");

        AtomicInteger skipped = new AtomicInteger(0);
        AtomicInteger success = new AtomicInteger(0);
        AtomicInteger failure = new AtomicInteger(0);

        ApplyTransformListener listener = new ApplyTransformListener()
                .withTransform(transform)
                .withApplyResult(ApplyResult.REPLACE)
                .onSuccess(batch -> {
                    success.addAndGet(batch.getItems().length);
                }). 
                onBatchFailure((batch, throwable) -> {
                    failure.addAndGet(batch.getItems().length);
                    throwable.printStackTrace();
                }).onSkipped(batch -> {
                    skipped.addAndGet(batch.getItems().length);

                });

        QueryBatcher batcher = dmManager.newQueryBatcher(new StructuredQueryBuilder().collection("XmlTransform"))
                .onUrisReady(listener).withBatchSize(7);
        batcher.setQueryFailureListeners(
                  new HostAvailabilityListener(dmManager)
                    .withSuspendTimeForHostUnavailable(Duration.ofSeconds(15))
                    .withMinHosts(2)
                );  
        JobTicket ticket = dmManager.startJob( batcher );
        batcher.awaitCompletion();
        dmManager.stopJob(ticket);
        System.out.println("Success "+ success.intValue());
        System.out.println("Failure "+failure.intValue());
        String uris[] = new String[2000];
        for(int i =0;i<2000;i++){
            uris[i] = "/local/string-"+ i;
        }
        int count=0;
        DocumentPage page = dbClient.newDocumentManager().read(uris);
        DOMHandle dh = new DOMHandle();
        while(page.hasNext()){
            DocumentRecord rec = page.next();
            rec.getContent(dh);
            assertTrue("Element has attribure ? :",dh.get().getElementsByTagName("foo").item(0).hasAttributes());
            assertEquals("Attribute value should be English","English",dh.get().getElementsByTagName("foo").item(0).getAttributes().item(0).getNodeValue());
            count++;
        }

        assertEquals("document count", 2000,count); 
        assertEquals("document count", 2000,success.intValue()); 
        assertEquals("document count", 0,skipped.intValue()); 
    }
Updated 17/05/2017 16:31 4 Comments

Tests fail if a go-ipfs daemon is already running

ipfs/go-ipfs

Version information:

Current master: https://github.com/ipfs/go-ipfs/commit/a542dea5d

Type:

Bug

Priority:

P1

Description:

If an ipfs daemon is active TEST_NO_FUSE=1 make test fails like this ( tested only under the same user account, not sure what happens if the daemon runs under a dedicated/separate user but still occupies the usual ports )

Updated 08/05/2017 01:29 1 Comments

HostAvailabilityListener with QueryBatcher results in incorrect behavior

marklogic/java-client-api
  1. The test used here is the same as reference in #568 . It queries all documents in collection “Replace Snapshot”, applies transform on them and then finally deletes the document in a single QueryBatcher instance.
  2. This test was run on a 3 node cluster (rh7v-intel64-90-test-4/5/6.marklogic.com) with a forest (ApplyTransform1,2,3) on each of the node associated with a db.
  3. The forest on node rh7v-intel64-90-test-6.marklogic.com has been configured for shared disk failover to failover host rh7v-intel64-90-test-4.marklogic.com.
  4. Now when ‘batcher ’ QB job is getting executed,node rh7v-intel64-90-test-6.marklogic.com is stopped.
  5. After 30 seconds, the forest fails over to rh7v-intel64-90-test-4.marklogic.com and db once again becomes available
  6. But from the logs, it can be seen that the document with uri “/local/snapshot-0” has not been deleted from the db (it was confirmed that the document was available using QConsole as well).

Client log

Test:

java.lang.AssertionError
    at org.junit.Assert.fail(Assert.java:86)
    at org.junit.Assert.assertTrue(Assert.java:41)
    at org.junit.Assert.assertFalse(Assert.java:64)
    at org.junit.Assert.assertFalse(Assert.java:74)
    at com.marklogic.client.datamovement.functionaltests.ApplyTransformTest.jsMasstransformReplaceDelete(ApplyTransformTest.java:669)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
Updated 17/05/2017 16:31 1 Comments

Process hang with QueryBatcher during forest failover

marklogic/java-client-api
  1. The following test is performed on 3 node cluster with a db associated with 3 forests. 18:07:20.277 [main] INFO c.m.c.d.impl.WriteBatcherImpl - (withForestConfig) Using [rh7v-intel64-90-test-5.marklogic.com, rh7v-intel64-90-test-6.marklogic.com, rh7v-intel64-90-test-4.marklogic.com] hosts with forests for "ApplyTransform" 18:07:20.807 [main] INFO c.m.c.d.impl.WriteBatcherImpl - Adding DatabaseClient on port 8000 for host "rh7v-intel64-90-test-5.marklogic.com" to the rotation 18:07:20.807 [main] DEBUG c.m.client.impl.JerseyServices - Connecting to rh7v-intel64-90-test-6.marklogic.com at 8000 as admin 18:07:21.166 [main] INFO c.m.c.d.impl.WriteBatcherImpl - Adding DatabaseClient on port 8000 for host "rh7v-intel64-90-test-6.marklogic.com" to the rotation 18:07:21.166 [main] INFO c.m.c.d.impl.WriteBatcherImpl - Adding DatabaseClient on port 8000 for host "rh7v-intel64-90-test-4.marklogic.com" to the rotation
  2. When transformation is taking place, one of the host “rh7v-intel64-90-test-6.marklogic.com” is stopped 21:40:26.896 [pool-1-thread-1] ERROR c.m.c.d.HostAvailabilityListener - ERROR: host unavailable "rh7v-intel64-90-test-6.smarklogic.com", black-listing it for PT50S Server Error log:
2016-11-27 18:10:24.170 Info: Stopping XDQPServerConnection, client=rh7v-intel64-90-test-6.marklogic.com, conn=172.18.132.40:7999-172.18.132.42:4380
  1. Before Forest failover occurs (which takes place in 30 seconds after node shutdown) , node “rh7v-intel64-90-test-6.marklogic.com” is restarted.

Error Log: 2016-11-27 18:10:38.135 Info: Starting XDQPClientConnection, server=rh7v-intel64-90-test-6.marklogic.com, conn=172.18.132.40:38312-172.18.132.42:7999 2016-11-27 18:10:38.138 Info: Starting XDQPClientConnection, server=rh7v-intel64-90-test-6.marklogic.com, conn=172.18.132.40:38314-172.18.132.42:7999 2016-11-27 18:10:38.139 Debug: Retrying AppRequestTask::handleEvalLocked apply-transform.xqy 4333219226342543433 Update 11 because XDMP-XDQPDISC: XDQP connection disconnected, server=rh7v-intel64-90-test-6.marklogic.com 2016-11-27 18:10:38.142 Info: Starting domestic XDQPServerConnection, client=rh7v-intel64-90-test-6.marklogic.com, conn=172.18.132.40:7999-172.18.132.42:4388 2016-11-27 18:10:42.942 Info: Mounted forest ApplyTransform-3 remotely on rh7v-intel64-90-test-6.marklogic.com 2016-11-27 18:10:45.494 Info: Database ApplyTransform is online with 3 forests D. After 15 seconds, elapse, the following message is seen in the client log.

18:10:44.378 [pool-3-thread-1] INFO  c.m.c.d.HostAvailabilityListener - it's been PT15S since host rh7v-intel64-90-test-6.marklogic.com failed, opening communication to all server hosts [[rh7v-intel64-90-test-4.marklogic.com, rh7v-intel64-90-test-5.marklogic.com, rh7v-intel64-90-test-6.marklogic.com]]
18:10:44.378 [pool-3-thread-1] INFO  c.m.c.d.impl.QueryBatcherImpl - (withForestConfig) Using [rh7v-intel64-90-test-5.marklogic.com, rh7v-intel64-90-test-6.marklogic.com, rh7v-intel64-90-test-4.marklogic.com] hosts with forests for "ApplyTransform"
  1. Server is stopped again and now forest failover takes place Error log: 2016-11-27 18:10:48.319 Info: Stopping XDQPServerConnection, client=rh7v-intel64-90-test-6.marklogic.com, conn=172.18.132.40:7999-172.18.132.42:4398, requests=0, recvTics=0, sendTics=1, recvs=566, sends=517, recvBytes=87352, sendBytes=204140 2016-11-27 18:11:19.971 Info: Database ApplyTransform is offline 2016-11-27 18:11:19.974 Info: Unmounted forest ApplyTransform-3 because disconnected host 2016-11-27 18:11:19.982 Notice: Failing over forest ApplyTransform-3 because the host rh7v-intel64-90-test-6.marklogic.com has gone offline 2016-11-27 18:11:19.985 Info: Forest ApplyTransform-3 state changed from unmounted to mounted 2016-11-27 18:11:20.112 Info: Forest ApplyTransform-3 state changed from mounted to recovering 2016-11-27 18:11:20.118 Info: Forest ApplyTransform-3 state changed from recovering to open

  2. The client process has been hanging since 18:11:27.207 . The server was started later Error log: 2016-11-27 18:11:31.532 Info: Starting domestic XDQPServerConnection, client=rh7v-intel64-90-test-6.marklogic.com, conn=172.18.132.40:7999-172.18.132.42:4400

The entire client, server log file as well as stack trace taken at two different times are attached. exception.txt errorlog.txt jstack.txt jstack1.txt

I am guessing a similar scenario could occur with WriteBatcher as well during failover.

Test:

@Test
    public void xQueryMasstransformReplace() throws Exception{

        WriteBatcher ihb2 =  dmManager.newWriteBatcher();
        ihb2.withBatchSize(27).withThreadCount(10);
        ihb2.onBatchSuccess(
                batch -> {


                }
                )
        .onBatchFailure(
                (batch, throwable) -> {
                    throwable.printStackTrace();
                });

        dmManager.startJob(ihb2);

        for (int j =0 ;j < 2000; j++){
            String uri ="/local/string-"+ j;
            ihb2.add(uri, meta2, stringHandle);
        }

        ihb2.flushAndWait();

        ServerTransform transform = new ServerTransform("add-attr-xquery-transform");
        transform.put("name", "Lang");
        transform.put("value", "English");

        AtomicInteger skipped = new AtomicInteger(0);
        AtomicInteger success = new AtomicInteger(0);
        AtomicInteger failure = new AtomicInteger(0);

        ApplyTransformListener listener = new ApplyTransformListener()
                .withTransform(transform)
                .withApplyResult(ApplyResult.REPLACE)
                .onSuccess(batch -> {
                    success.addAndGet(batch.getItems().length);
                }). 
                onBatchFailure((batch, throwable) -> {
                    failure.addAndGet(batch.getItems().length);
                    throwable.printStackTrace();
                }).onSkipped(batch -> {
                    skipped.addAndGet(batch.getItems().length);

                });

        QueryBatcher batcher = dmManager.newQueryBatcher(new StructuredQueryBuilder().collection("XmlTransform"))
                .onUrisReady(listener).withBatchSize(7);
        batcher.setQueryFailureListeners(
                  new HostAvailabilityListener(dmManager)
                    .withSuspendTimeForHostUnavailable(Duration.ofSeconds(15))
                    .withMinHosts(2)
                );  
        JobTicket ticket = dmManager.startJob( batcher );
        batcher.awaitCompletion();
        dmManager.stopJob(ticket);
        System.out.println("Success "+ success.intValue());
        System.out.println("Failure "+failure.intValue());
        String uris[] = new String[2000];
        for(int i =0;i<2000;i++){
            uris[i] = "/local/string-"+ i;
        }
        int count=0;
        DocumentPage page = dbClient.newDocumentManager().read(uris);
        DOMHandle dh = new DOMHandle();
        while(page.hasNext()){
            DocumentRecord rec = page.next();
            rec.getContent(dh);
            assertTrue("Element has attribure ? :",dh.get().getElementsByTagName("foo").item(0).hasAttributes());
            assertEquals("Attribute value should be English","English",dh.get().getElementsByTagName("foo").item(0).getAttributes().item(0).getNodeValue());
            count++;
        }

        assertEquals("document count", 2000,count); 
        assertEquals("document count", 2000,success.intValue()); 
        assertEquals("document count", 0,skipped.intValue()); 
    }
Updated 17/05/2017 16:31 5 Comments

Need better 404 page

uboslinux/ubos-admin

Two use cases: * user moves app from example.com/foo to example.com/bar. Client accesses example.com/foo. * user updates the device. During the update, client accesses an app that’s currently unavailable. In both cases, nice page(s) should be shown. This probably should use some kind of “match” in the Apache config.

Updated 12/06/2017 04:48 2 Comments

Refactor iOS SDK part I

RestComm/restcomm-ios-sdk

Let’s document the steps for the first iteration of refactoring (let’s add as we think better about that): - [ ] Allow the stack to be restarted when the user changes from TLS to non-TLS for signaling. This will allow to properly address https://github.com/RestComm/restcomm-ios-sdk/issues/476 - [ ] Don’t forget, after refactoring is done, to re-enable the functionality that allow to modify TLS preference

Updated 26/06/2017 18:21 1 Comments

Error message for OPTIC-INVALARGS needs to be formatted correctly

marklogic/java-client-api

For a test that checks error messages when limit value is less than a positive value, the error message shows the limit variable name; prints the variable name (“length”) and the message twice.

For the above test in Java (given below):

Map<String, Object>[] literals1 = new HashMap[5];
Map<String, Object>[] literals2 = new HashMap[4];
...
...
Map<String, Object> row = new HashMap<>();          
row.put("rowId", 1); row.put("colorId", 1); row.put("desc", "ball");
literals1[0] = row; 
row = new HashMap<>();
row.put("rowId", 2); row.put("colorId", 2); row.put("desc", "square");
literals1[1] = row;
row = new HashMap<>();
row.put("rowId", 3); row.put("colorId", 1); row.put("desc", "box");
literals1[2] = row;        
row = new HashMap<>();
row.put("rowId", 4); row.put("colorId", 1); row.put("desc", "hoop");
literals1[3] = row;
row = new HashMap<>();
row.put("rowId", 5); row.put("colorId", 5); row.put("desc", "circle");
literals1[4] = row;             

row = new HashMap<>();          
row.put("colorId", 1); row.put("colorDesc", "red");
literals2[0] = row;
row = new HashMap<>();
row.put("colorId", 2); row.put("colorDesc", "blue");
literals2[1] = row;   
row = new HashMap<>();
row.put("colorId", 3); row.put("colorDesc", "black");
literals2[2] = row;        
row = new HashMap<>();
row.put("colorId", 4); row.put("colorDesc", "yellow");
literals2[3] = row;
...
// Create a new Plan.
RowManager rowMgr = client.newRowManager();
PlanBuilder p = rowMgr.newPlanBuilder();

// plans from literals
ModifyPlan plan1 = p.fromLiterals(literals1);
ModifyPlan plan2 = p.fromLiterals(literals2);
...
...
//limit with 0 length
ModifyPlan outputLimit = plan1.joinInner(plan2)
                                      .where(p.eq(p.col("colorId"), p.xs.intVal(1)))
                                      .limit(0)
                                      .select("rowId", "desc", "colorId", "colorDesc");
JacksonHandle jacksonHandle = new JacksonHandle();
jacksonHandle.setMimetype("application/json");
StringBuilder str = new StringBuilder();
try {
            rowMgr.resultDoc(outputLimit, jacksonHandle);
   }
catch(Exception ex) {
        str.append(ex.getMessage());
    }

The message is:

com.marklogic.client.FailedRequestException: Local message: failed to apply resource at rows: Bad Request. Server Message: OPTIC-INVALARGS: fn.error(null, 'OPTIC-INVALARGS', 'limit must be a positive number: '+length); -- Invalid arguments: limit must be a positive number: 0

The following text needs to be removed.

limit must be a positive number: '+length
Updated 10/05/2017 18:28 3 Comments

Assemble model descriptors from graph

marklogic/entity-services

As a data steward, I want to be able to organize my entities into descriptor docs as I see fit, for example, to group related entities into their own descriptor documents or separate entities into one descriptor per entity or to have just one descriptor doc for all entities. Each grouping should distill into the same entity type graph. Today, the downstream artifact generators assume one in-memory map structure that represents the entire type model. This is a direct mapping from a single descriptor doc that represents all entities. It should be possible to assemble the in-memory descriptors needed from code gen regardless of how the input entity definitions are grouped.

One implementation idea is to provide a function that would operate on the triples to assemble a map/object. Someone extending the model would also use this same technique to build custom in-memory representations of their extensions.

Some things to consider: - Versioning today is declared at the descriptor. Thus all entities declared in a single descriptor will have the same semver. I’d expect stewards to want to version entities at different rates. - (Now I can’t remember the other thing)

Updated 07/06/2017 21:38 4 Comments

Can't download via XModem on OSX using screen and minicom

emsec/ChameleonMini

Hi! I was trying to test the DOWNLOAD command and my cameleon waits for an XMODEM file transfer to start. I was using screen and “^a:exec !! lrx file” but it said that headers were garbled, then I tried minicom and presses ESC-Z and then R for receive and the XModem and a filename. It didn’t seem to work. Also I don’t understand the documentation here very well, does that command send the whole memory that’s been read from a card into a file? Can that same be done _on_card* and be stored internally? How? I’d like to clone a whole card.

Updated 05/04/2017 08:31 3 Comments

Stream ZipEntry reading of CompressedRDFReader

marklogic/marklogic-contentpump

CompressedRDFReader now buffers ZipEntrys in java heap to read in zipped file. Instead, it should stream the reading process, which is desired and preferrable. CompressedAggregateReader and CompressedDelimitedTextReader has done the same.

In an attempt to do the above job, I found that there is some class in CompressedRDFReader that closes the ZipInputStream in middle of a job. It is related to a java bug JDK-6539065. For CompressedAggregateReader, because I know it’s XMLStreamReader that closed the ZipInputStream in middle of a job, we can bypass the issue by overload ZipInputStream to disable the behavior. However, for CompressedRDFReader, I didn’t figure out who closed ZipInputStream.

You can refer to bug:39688 and bug:25918 for more info.

Please investigate. Thanks.

Updated 02/05/2017 16:29

Namespaces for enveloped entity instances

marklogic/entity-services

Generally it’s best practice to put all elements from a vocabulary in their own namespace to avoid conflicts and to allow easy and unambiguous discrimination from elements in other vocabularies (e.g. for schema validation). On the other hand, namespaces add complexity for just about everything downstream. What’s the cost-benefit? Should this be optional? If so, how do we determine the namespace URI and prefix?

Updated 11/05/2017 17:51 4 Comments

Referentially consistent export

marklogic/entity-services

Use the entity model to get a consistent subset of entities and their related entities that. For example, get me the 50 most recent customers, their related sales orders, products, etc. Handle cycles and, perhaps, truncate at some depth to avoid always getting the whole database. Export all reference data each time.

Updated 20/06/2017 17:09 6 Comments

Secure SIP setting update will fail if RCDevice has been previously initialized without certificates

RestComm/restcomm-ios-sdk

That happens because right now we need a Sofia restart to use updated certificates and at the time we update SIP settings via [RCDevice updateParams] this doesn’t happen.

I can see the following ways to go here: - Restart Sofia if there’s a secure settings in the parms and Sofia wasn’t initialized with security (not that good) - See if we can update Sofia’s configuration via nua_set_params() to avoid restarting - Always require certificates to be passed by the App, no matter if they actual use secure signaling or not

Updated 26/06/2017 17:15 1 Comments

Stress test with develop branch on 9.0 MarkLogic server reports error on Semantics' verifyLoaded

marklogic/java-client-api

With the standard MarkLogic Java/REST Client API stress test setup and run, we are seeing the following error in the Stress test client program’s log file.

2016-05-20 14:42:59 (Thread=33) ERROR (SemanticGraphLoadTester.verifyLoaded) found 0 loaded but should have found 1 of these URIs: [/SEITYXYCULKMIPUT/2016420144250157/5/0NorthwindData.xml]

The thread 33 was started with following:

2016-05-20 14:42:50 (Thread=33) ========
Starting test with uniqueURI = /SEITYXYCULKMIPUT/2016420144250157/5/
#
TestcaseID = semanticGraphs
ThreadID = 33
BinaryTest = false
JSONTest = false
InsertTime = false
NumberOfLoops = 5
MaxSleepTime = 1
LogOption = debug
WriteToScreen = true
LogFilename = auto
OutputFileName =
minRequestTimeLimit = 0
maxRequestTimeLimit = 0

numcreate = 1
checkInterval = 1000
loadDir = /space/HEAD/qa/testdata/semantics/
createModule = null
autoGenerate = true
multiStatement = false
batchSize = 1
rollback = false
generateQuery = null
numGenerated = 0
language = xquery

========
...
...
...

2016-05-20 14:42:50 (Thread=33) About to load 92 documents.

Test Env:

MarkLogic Server used: 9.0 nightly server MarkLogic Java Client API used: develop ( 4.0-SNAPSHOT )

All threads that handle 0Northwind.xml have this error message reported on the client side. There are no errors reported in the server logs (maybe due to log level set to notice).

Updated 17/04/2017 20:38

Properly integrate the iOS reachability inside Sofia SIP

RestComm/restcomm-ios-sdk

This is part of the umbrella issue: https://github.com/RestComm/restcomm-ios-sdk/issues/414

That way the networking change is handled internally and as a result affect us much less. We could expose events from the API that will notify the App that reachability has changed. Some pointers: - With the current Sofia SIP codebase this is possible for Mac but not iOS. The main difference is that Mac provides the SCDynamicStore API for that which doesn’t work in iOS (check https://github.com/RestComm/restcomm-ios-sdk/blob/master/dependencies/sources/sofia-sip/libsofia-sip-ua/su/su_os_nw.c#L228). iOS provides the Reachability API that we currently invoke from RCDevice. So the idea would be to integrate the Apple Reachability API in su_os_nw.c above. - To that end I think a great pointer is a chromium fix that seems to do exactly the same thing https://chromiumcodereview.appspot.com/10829453/ (Bug title is ‘Add iOS support to the NetworkChangeNotifier’)

Things to keep in mind (that have bitten us in the past): - It’s wise to not allow for reachability changes to be handled while the App is in the background (and on it’s way to suspended). I’ve seen that it might lead to unpredictable behavior as the handler code might be interrupted in the middle by iOS. What I have done in BETA4 is to ignore such events if the App is on the background by guarding with if ([UIApplication sharedApplication].applicationState != UIApplicationStateBackground) { all state changes. We should probably retain this logic throughout any refactoring.

Updated 23/06/2017 13:52 2 Comments

Need to introduce separate API for error reporting of SIP MESSAGEs

RestComm/restcomm-ios-sdk

This issues is pretty old and will probably be obsolete after we implement #577. Let’s keep it around for verification purposes:

Right now we only have didStopListeningForIncomingConnections in the Device level which assumes that the device also stopped listening for connections which isn’t the case. Notice that this API (i.e. didStopListeningForIncomingConnections) is how Twilio does error reporting for their TCDevice object (check https://www.twilio.com/docs/api/client/ios/TCDeviceDelegate#deviceDidStartListeningForIncomingConnections for more info), but if I recall correctly Twilio iOS SDK doesn’t support instant messages in that API like we do, hence they never needed to address this need.

That said I think the best way to go about it is to introduce this API: - (void)device:(RCDevice)device didReceiveTransientError:(NSError)error;

Which will be triggered for RCDevice errors that don’t cause the RCDevice to go offline. For now this is only needed for messages.

I know the name is a bit weird but I had to chose between: - Making it too generic like didReceiveError, which would make someone wonder why there are 2 separate APIs for RCDevice errors. - Another idea would be to make it only message related like didReceiveMessageError, which might be a bad choice since in the future we might find that we have other errors that don’t trigger the Device to go offline and which are not text message related - And finally something to show that the error isn’t that ‘hard’ to trigger the Device to go offline like didReceiveTransientError

Any other ideas are welcome!

Updated 26/06/2017 17:30

Sporadically media fails in a call to Restcomm

RestComm/restcomm-ios-sdk

It happens during call setup and not media is heard afterwards (scenario is a call to +1235)

Something to do with AVAudioSession it seems:

2016-02-17 17:33:49.665 restcomm-olympus[897:272435] connectionDidConnect
2016-02-17 17:33:54.957 restcomm-olympus[897:272597] 17:33:54.955 ERROR:     [Thread 0x0x17fe8530] 79: AudioSessionSetProperty posting message to kill mediaserverd (37)
2016-02-17 17:33:55.749 restcomm-olympus[897:272597] 17:33:55.749 ERROR:     [Thread 0x0x17fe8530] AVAudioSessionUtilities.h:111: GetProperty: AudioSessionGetProperty ('aiav') failed with error: '!siz'
2016-02-17 17:33:55.750 restcomm-olympus[897:272597] 17:33:55.750 ERROR:     [Thread 0x0x17fe8530] AVAudioSessionUtilities.h:124: GetProperty_DefaultToZero: AudioSessionGetProperty ('aiav') failed with error: '!siz'
2016-02-17 17:33:57.645 restcomm-olympus[897:272435] onVideoError: NSConcreteNotification 0x17e1c970 {name = AVCaptureSessionRuntimeErrorNotification; object = <AVCaptureSession: 0x17ed2bb0 [AVCaptureSessionPreset640x480]>
    <AVCaptureDeviceInput: 0x1c01e8a0 [Front Camera]> -> <AVCaptureVideoDataOutput: 0x17ed3820>; userInfo = {
    AVCaptureSessionErrorKey = "Error Domain=AVFoundationErrorDomain Code=-11819 \"Cannot Complete Action\" UserInfo=0x17ee73a0 {NSLocalizedRecoverySuggestion=Try again later., NSLocalizedDescription=Cannot Complete Action}";
}}

Full logs at:

https://gist.github.com/atsakiridis/8d18494479879d309b31

Updated 23/06/2017 13:51 2 Comments

Ambiguities concerning node.Links

ipfs/go-ipfs

Let nd contain links with names ["_", "_", "__", "___"] each with different hashes.

> nd.AddNodeLink("_", someNode)
> nd.LinkNames
["_", "_", "__", "___", "_"]  # will only get sorted when nd.Encoded()/nd.Marshal()/nd.Unmarshal() is called.
> nd.GetNodeLink("_")
# returns only the first "_", never the rest
> nd.UpdateNodeLink("_")
# all nodes with name "_" removed, leaving one "_"
> nd.AddNodeLink("_", someNode)
> nd.LinkNames
["__", "___", "_", "_"]
> nd.RemoveNodeLink("_")
> nd.LinkNames
["__", "___"]
Updated 08/05/2017 01:33 1 Comments

When changing from registrar-less to non registrar-less sporadically registration fails

RestComm/restcomm-ios-sdk

Scenario: - Launch iOS Olympus in registrar-less mode (with default values for settings) - Navigate to Settings and set a valid user for cloud.restcomm.com and also setup the domain to cloud.restcomm.com - Hit back to go to main screen

At that point the registration sometimes fails and you have to go back to settings and back again for it to take effect properly. Here are the logs in the first failure:

Jan 19 13:56:19  restcomm-olympus[63625] <Notice>: (RCDevice.m:95) [RCDevice initWithParams]
Jan 19 13:56:19  restcomm-olympus[63625] <Notice>: (SipManager.mm:289) [SipManager initWithDelegate]
Jan 19 13:56:19  restcomm-olympus[63625] <Notice>: (SipManager.mm:364) [SipManager eventLoop]
Jan 19 13:56:19  restcomm-olympus[63625] <Notice>: (ssc_sip.mm:231) Creating SIP stack -binding to: sip:192.168.2.3:*;transport=tcp
Jan 19 13:56:19  restcomm-olympus[63625] <Notice>: (RCDevice.m:375) [RCDevice checkNetworkStatus] Reachability update: 1
Jan 19 13:56:19  restcomm-olympus[63625] <Notice>: (RCDevice.m:321) [RCDevice sipManagerDidInitializedSignalling]
Jan 19 13:57:14  restcomm-olympus[63625] <Notice>: (RCDevice.m:282) [RCDevice updateParams]
Jan 19 13:57:14  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:1960) UA: un-REGISTER sip:ios-sdk@cloud.restcomm.com
Jan 19 13:57:14  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:1880) REGISTER sip:ios-sdk@cloud.restcomm.com - registering address to network
Jan 19 13:57:16  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:557) Unhandled event 'nua_i_outbound' (8): 101 NAT detected
Jan 19 13:57:16  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:1897) REGISTER: 407 Proxy Authentication required
Jan 19 13:57:16  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:635) Authenticating 'REGISTER' with 'Digest:"cloud.restcomm.com":ios-sdk:1234'
Jan 19 13:57:17  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:1897) REGISTER: 407 Proxy Authentication required
Jan 19 13:57:17  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:635) Authenticating 'REGISTER' with 'Digest:"cloud.restcomm.com":ios-sdk:1234'
Jan 19 13:57:17  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:1897) REGISTER: 904 Operation has no matching challenge 
Jan 19 13:57:17  restcomm-olympus[63625] <Error>: (ssc_sip.mm:1906) REGISTER failed: 904 Operation has no matching challenge 
Jan 19 13:57:17  restcomm-olympus[63625] <Notice>: (ssc_sip.mm:1909) Got failed REGISTER response but silencing it since another registration has been successfully handled afterwards
Jan 19 13:57:17  restcomm-olympus[63625] <Notice>: (RCDevice.m:329) [RCDevice didSignallingError: {
      "NSLocalizedDescription" : "Operation has no matching challenge "
    }]
Jan 19 13:57:17  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:1979) un-REGISTER: 407 Proxy Authentication required
Jan 19 13:57:17  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:635) Authenticating 'REGISTER' with 'Digest:"cloud.restcomm.com":ios-sdk:1234'
Jan 19 13:57:17  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:1979) un-REGISTER: 407 Proxy Authentication required
Jan 19 13:57:17  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:635) Authenticating 'REGISTER' with 'Digest:"cloud.restcomm.com":ios-sdk:1234'
Jan 19 13:57:17  restcomm-olympus[63625] <Debug>: (ssc_sip.mm:1979) un-REGISTER: 904 Operation has no matching challenge 

This is probably related to #331, that will refactor error handing

Updated 23/06/2017 13:51 1 Comments

Missing "read" dependency

marklogic/node-client-api

Examples/setup.js requires the npm “read” package, but this isn’t included in package.json.

$ node examples/setup.js 
module.js:338
    throw err;
          ^
Error: Cannot find module 'read'
    at Function.Module._resolveFilename (module.js:336:15)
    at Function.Module._load (module.js:278:25)
    at Module.require (module.js:365:17)
    at require (module.js:384:17)
    at Object.<anonymous> (/Users/dcassel/tmp/myproject/node_modules/marklogic/etc/test-setup-prompt.js:16:14)
    at Module._compile (module.js:460:26)
    at Object.Module._extensions..js (module.js:478:10)
    at Module.load (module.js:355:32)
    at Function.Module._load (module.js:310:12)
    at Module.require (module.js:365:17)
    at require (module.js:384:17)
    at Object.<anonymous> (/Users/dcassel/tmp/myproject/node_modules/marklogic/examples/setup.js:21:22)
    at Module._compile (module.js:460:26)
    at Object.Module._extensions..js (module.js:478:10)
    at Module.load (module.js:355:32)
    at Function.Module._load (module.js:310:12)
Updated 15/05/2017 21:02 5 Comments

an error without an error callback emits a spurious Bluebird error

marklogic/node-client-api

The spurious error is:

node_modules/bluebird/js/main/async.js:36 fn = function () { throw arg; };

The root error is still reported. In addition, the application should provide an error callback for better error reporting.

A quick search shows that the request module found a configure solution:

https://github.com/request/request-promise/commit/bc6080e501a406eb03ec779dd50458cde1bce7aa

But more investigation is needed.

Updated 15/05/2017 21:02

PojoLoadTester throws REST-INVALIDMIMETYPE during failover time period.

marklogic/java-client-api

2015-03-31 20:54:36 (Thread=391) ======== Starting test with uniqueURI = /KSPQKCFLYKKFZPRL/2015231205436623/4/

TestcaseID = pojoLoadTester ThreadID = 391 BinaryTest = false JSONTest = false InsertTime = false NumberOfLoops = 5 MaxSleepTime = 1 LogOption = debug WriteToScreen = true LogFilename = auto OutputFileName =

2015-03-31 20:54:36 (Thread=391) About to load 2501 documents. 2015-03-31 20:56:32 (Thread=391) About to load 2501 documents. 2015-03-31 20:58:53 (Thread=391) About to load 2501 documents.

21:00:00 <====== One of the D Node goes down.

Here is the stak trace from the thread 391.

2015-03-31 21:06:19 (Thread=391) com.marklogic.client.FailedRequestException: Local message: search failed: Unsupported Media Type. Server Message: REST-INVALIDMIMETYPE: (rest:INVALIDMIMETYPE) Content-Type must be one of: ‘text/xml’, ‘text/json’, ‘application/xml’, ‘application/json’, Received: text/plain com.marklogic.client.FailedRequestException: Local message: search failed: Unsupported Media Type. Server Message: REST-INVALIDMIMETYPE: (rest:INVALIDMIMETYPE) Content-Type must be one of: ‘text/xml’, ‘text/json’, ‘application/xml’, ‘application/json’, Received: text/plain at com.marklogic.client.impl.JerseyServices$JerseySearchRequest.getResponse(JerseyServices.java:2206) at com.marklogic.client.impl.JerseyServices.getBulkDocumentsImpl(JerseyServices.java:869) at com.marklogic.client.impl.JerseyServices.getBulkDocuments(JerseyServices.java:744) at com.marklogic.client.impl.DocumentManagerImpl.search(DocumentManagerImpl.java:500) at com.marklogic.client.impl.JSONDocumentImpl.search(JSONDocumentImpl.java:26) at com.marklogic.client.impl.PojoRepositoryImpl.search(PojoRepositoryImpl.java:340) at com.marklogic.client.impl.PojoRepositoryImpl.search(PojoRepositoryImpl.java:325) at test.stress.JavaAPISession.searchPojos(JavaAPISession.java:526) at test.stress.PojoLoadTester.verifyIntervalAfterIteration(PojoLoadTester.java:75) at test.stress.RestLoadTester.runTest(RestLoadTester.java:283) at test.stress.StressTest.run(StressTest.java:94) 2015-03-31 21:06:19 (Thread=391) Test took: 702600ms

Updated 17/04/2017 20:37 2 Comments

Add import hook for PIL.ImageTk.

pyinstaller/pyinstaller

Original date: 2014/03/27 Original reporter: *matttodaro AND gmail DOT COOM *

I’m getting an error when running my script in the console. I’ve traced it to the from PIL import ImageTk. Not sure how to fix this.

Traceback (most recent call last):
  File "<string>", line 26, in <module>
  File "/Library/Python/2.7/site-packages/PyInstaller/loader/pyi_importers.py", line 270, in load_module
    exec(bytecode, module.__dict__)
  File "/Users/matttodaro/Desktop/Board_Pitch/build/board_pitch_v3_copy copy/out00-PYZ.pyz/PIL.PngImagePlugin", line 40, in <module>
  File "/Library/Python/2.7/site-packages/PyInstaller/loader/pyi_importers.py", line 270, in load_module
    exec(bytecode, module.__dict__)
  File "/Users/matttodaro/Desktop/Board_Pitch/build/board_pitch_v3_copy copy/out00-PYZ.pyz/PIL.Image", line 44, in <module>
  File "/Library/Python/2.7/site-packages/PyInstaller/loader/pyi_importers.py", line 270, in load_module
    exec(bytecode, module.__dict__)
  File "/Users/matttodaro/Desktop/Board_Pitch/build/board_pitch_v3_copy copy/out00-PYZ.pyz/FixTk", line 74, in <module>
OSError: [Errno 20] Not a directory: '/var/folders/m2/xptcb98s4lj060skxt5j2x880000gn/T/_MEIyGdK4R/tcl'
Updated 28/05/2017 21:16 9 Comments

PyInstaller fails to load Werkzeug modules

pyinstaller/pyinstaller

Original date: 2012/09/04 Original reporter: torsten DOT landschoff AND dynamore DOT de

I am trying to deploy an application that uses Werkzeug but I am unable to get PyInstaller to include the werkzeug.* modules. Look at this example:

#!py
from werkzeug.exceptions import InternalServerError
print "Hello World!"

Obviously this works fine when called directly from Python. Using pyinstaller on test.py without any options gives an executable which acts like this:

torsten@sharokan:~/pyinstaller-test$ ~/workspace/pyinstaller-2.0/pyinstaller.py test.py
torsten@sharokan:~/pyinstaller-test$ ./dist/test/test 
Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "/home/torsten/workspace/pyinstaller-2.0/PyInstaller/loader/iu.py", line 409, in importHook
    raise ImportError("No module named %s" % fqname)
ImportError: No module named werkzeug.exceptions

I created a hook to make PyInstaller include the werkzeug submodules and placed it into the directory hookspath. I enabled that hook by modifying the generated test.spec to include

#!py
a = Analysis(['test.py'],
             pathex=['/home/torsten/pyinstaller-test'],
             hiddenimports=[],
             hookspath="hookspath")

But I noticed that this does not make a difference for the build result: The file logdict2.7.3.final.0-2.log is unchanged. In fact, the original version also contains the werkzeug.exceptions module (verified with ArchiveViewer.py).

Why this module can not be loaded is beyond me. I enabled the debug output of iu.py and will attach that file. Perhaps somebody with more insight into PyInstaller internals can go and fix the loader.

The only workaround I found was to replace the init.py in the werkzeug package to remove the lazy load feature by commenting out the last lines so that new_module is not written into sys.modules[“werkzeug”].

Updated 30/05/2017 06:28 6 Comments

exe shows msg "No Disk, There is no disk in the drive...." when drive is no longer available

pyinstaller/pyinstaller

Original date: 2011/06/16 Original reporter: *alarmz AND gmail DOT COOM *

step to reproduce 1. I have 3 hard disks driver. 2. I copy pyInstaller1.5 to Disk2 rather than Disk0 3. execute python Makespec.py -D F:\Myprogram\demo.py 4. execute python Build.py ..\demo\demo.spec 5. pyInstaller will make a exe file for me 6. I copy that file to client machine, and client machine have USB card reader, it have Disk2 already mount but no memory card inside. 7. When I execute the demo.exe in the client machine, it will show fallow message

“No Disk, There is no disk in the drive. Please insert a disk into drive \Device\Harddisk3\DR3” [cancel][Try Again][Continue]

under windows 2008, and show

“No Disk, Exception Processing Message” [cancel][TryAgain][Continue]

under windows XP sp3

Image

What happened instead

Execute binary program created by pyInstaller1.5 or trunk version under windows, will popup error message

“No Disk, There is no disk in the drive. Please insert a disk into drive \Device\Harddisk3\DR3” [cancel][Try Again][Continue]

Image

What you expect to happen

When copy pyInstaller program into Disk0 and rebuild the binary file, the error message just gone. this problem cost me a lot of time, hop pyInstaller develop team can take a look.

Updated 21/04/2017 15:43 7 Comments

Fork me on GitHub