You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nemo.apache.org by ta...@apache.org on 2019/08/14 09:08:26 UTC
[incubator-nemo] branch serverless-optimize created (now 3462928)
This is an automated email from the ASF dual-hosted git repository.
taegeonum pushed a change to branch serverless-optimize
in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git.
at 3462928 kafka optimize
This branch includes the following new commits:
new fb6ddc6 nexmark
new 66de21f dd
new 92c6bd3 nexmark fix
new 10c8cbd fix script
new d4c224c Merge branch 'Nemo-279' into 247-unbounded-nexmark
new 69f161e Merge branch 'Nemo-279' into 247-unbounded-nexmark
new 31cbc83 Merge branch '247-unbounded-mr' into 247-unbounded-nexmark
new fc407e9 set window
new 21bae85 fix script
new 9a0b341 fix parsing
new 71ac442 Merge branch '247-unbounded-nexmark' into 247-unbounded-nexmark-sls
new cd73c8c broadcast windowed value
new d551e0a impl..
new a0e84c6 Merge branch 'master' of https://github.com/apache/incubator-nemo into 247-unbounded-nexmark-sls
new 4a024c3 done: upload main/side input to s3
new bfa69d0 done: upload main/side input to s3
new 8a63da3 lambda
new 967aa71 serverless deserialize
new fe2e2d9 nemo serverless
new 8b3a850 flush multithread
new 7c1136d flush fix
new 3802f98 fix concurrent map
new adcbfd9 rm log
new dc20f66 fix
new d3bc3f8 Merge branch 'master' of https://github.com/apache/incubator-nemo into 247-unbounded-nexmark-sls
new e0e6a84 add netty leak log
new 6d8c09a delete unncessary files
new 10722e9 fix
new f5f4ff5 complete
new 01f4c03 rm file in lambda
new 9290861 delete key
new aa2e69e origin
new db0d126 merge jyk branch
new dfe8083 0.2 snapshot
new eede9f9 0.2 snapshot
new 433d7b9 fix driver option
new 6697c71 fix
new 3efbb20 enable sls
new 33a053b operator20 -> operator22
new 6a6028c fix
new 186cc80 fix
new 964c845 fix side input output
new 278373c multiple async client
new f7b2a9c logging
new c78691d fix cli size
new 1dc79c8 fix num
new 97df641 Merge branch '247-unbounded-nexmark-sls-origin' of github.com:taegeonum/incubator-nemo into 247-unbounded-nexmark-sls-origin
new 2d7e4f2 add warmer
new 1c3c068 Merge branch '247-unbounded-nexmark-sls-origin' of github.com:taegeonum/incubator-nemo into 247-unbounded-nexmark-sls-origin
new 977b47c aws async -> aws client
new f7128e1 Merge branch '247-unbounded-nexmark-sls-origin' of github.com:taegeonum/incubator-nemo into 247-unbounded-nexmark-sls-origin
new d448ccf Merge branch '259-sideinput' of https://github.com/johnyangk/incubator-nemo into 247-unbounded-nexmark-sls-origin
new f0fddaf merge jyk
new 18bbb06 warmer fix
new fdd377b Merge branch '247-unbounded-nexmark-sls-origin' of github.com:taegeonum/incubator-nemo into 247-unbounded-nexmark-sls-origin
new c215433 Merge branch '247-unbounded-nexmark-sls-origin' of github.com:taegeonum/incubator-nemo into 247-unbounded-nexmark-sls-origin
new d4290c8 fix max client
new 167fa8f Merge branch '247-unbounded-nexmark-sls-origin' of github.com:taegeonum/incubator-nemo into 247-unbounded-nexmark-sls-origin
new dfdd60a side input lambda
new a2c9a8a Merge branch 'master' of https://github.com/apache/incubator-nemo into 247-unbounded-nexmark-sls-origin
new 2080b74 Merge branch 'master' of https://github.com/apache/incubator-nemo into 247-unbounded-nexmark-sls-origin
new 925336f logging fix
new 7835f8e fix fanout
new b93b820 late data
new caf9d3f Merge branch 'drop-data' into 247-unbounded-nexmark-sls-origin
new 4447cac allowed lateness
new d219b78 nemo 282
new f3cd3a2 Merge branch 'Nemo-282' into 247-unbounded-nexmark-sls-origin
new 19638cb disable compression
new 9331059 logging
new 8514db5 comment out
new 03d3ea6 comment out
new 82b78d3 fix inmemory side input reader map
new 5637218 unbounded source revert
new 1628034 fix window access map
new d5d0c1b compression enable
new ad68349 logging fix
new 83b2729a fix logic
new 4f43afe warmer invocation
new 7eeadb1 fix periodic flush
new 4410dfa inmemory
new f8c55a7 fix
new c1d2ba3 inmemory
new 73eb1a1 logging
new ec262be fix filename
new b9a5495 fix server side channel handler
new 6610ee3 add logging
new df43b94 adr
new b664b44 logging
new 97293d1 coder fix
new dd8501a logging
new 94dc1c8 logging
new 9d41d90 logging
new 3f12125 fix
new 9d8f0a4 bug fix
new 05e08e5 fix
new d9754df logging
new 06bb8a8 close obj
new cb578be loggingg
new 7f3bf52 log
new 7049138 fix bug
new c9a479c rm logging
new ceaf10d fix sending byte
new 0d2e171 Merge branch 'Nemo-293' into 247-sls-inmemory
new 4d7cd3b Merge branch 'Nemo-293' into 247-sls-inmemory
new 0654f2a in-memory
new d9206b7 warmer fix
new 5229583 logging
new c562e86 lambda async inmemory
new 23dcc00 no wait all handshakes
new 5e9e953 Merge branch 'master' of https://github.com/apache/incubator-nemo into 247-sls-inmemory
new 07c52ce Merge branch 'Nemo-293' into 247-sls-inmemory
new 3360381 synchronized
new d78cd38 Merge branch 'master' of https://github.com/apache/incubator-nemo into 247-sls-inmemory
new a4fe1fa Merge branch 'master' of https://github.com/apache/incubator-nemo into 247-sls-inmemory
new a32142d lazy init
new ae23c9f add log
new f8fce01 write and flush
new 65bc6f0 Merge branch 'Nemo-309' into 247-sls-inmemory
new eb3bfa8 flush at watermark
new 211a30b Merge branch 'Nemo-309' into 247-sls-inmemory
new 9c99a9e logging
new 31987e3 lo0g
new c6392e6 log
new 5778d96 log
new aea2679 logging
new 3cec2f3 log
new f03ad17 fix ped
new fb165c3 fix script
new f50ee6c query8 logging
new a9eca42 gc
new 103296d fix gbkw
new e5d909b number of key logging
new d4a4b94 rm unused keys
new 9ffead2 logging
new 537abaa log
new 425ad7a fix trigger
new 18c77d8 rm key
new 3b73444 log:
new e40cb73 fix gbkw timer internal
new 9afbfc8 rm log
new d6443c6 fix bug
new dfc8f36 rm log
new 9e468b4 element-wise processing
new b5e22c6 log
new bbc7ca8 element wise flush
new f42b080 netty flush fix
new 8fdbfa4 add ser file
new bdd0e5e send ir vertex
new efa9d96 fix
new 0346794 query8 serverless
new 2776944 address fixgs
new 2dffba1 fix
new d987f3a disable serialized file
new 7323712 disable query8
new 58dc48b fix bug
new c4b7fbd warmup
new 51a7fcb warmup
new 7d3ca18 fix handler
new efcb77a warmer count fix
new a453d6a add query8
new df3ae05 watermark logging
new e8f6cbe warmup
new 6fd591a rm warmer
new 0881066 warmup fix
new 786aaa4 logging
new 6b2a778 fix
new a337157 fix netty handler
new f161c3f buffer -> ioBuffer
new 9d98d68 addr
new 63e5fd8 refactoring gbk lambda emitter
new 46dbf4b buffer batch
new c8d4a51 Add logging
new 6e6fb2b refactor
new 812e3e5 fix
new f80d07b rm warmer
new b3a9512 fix
new 7f59f96 fix
new c9c0892 fix
new 8c3725a fix
new 672d5c6 fix
new cca81c4 fix gbk
new f19427d fix period
new a4816fe Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new ec0a59b fix
new f077fbf Merge branch 'after-hos-refactor' of https://github.com/taegeonum/incubator-nemo into after-hos-refactor
new c76480c logging pushback
new 6014623 serialize vertices
new ee53aca fix
new 4c15b42 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 8d11b03 vertex submit
new 79f7679 fix
new ad24bf6 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 4538fac fix
new 582b74d logging
new ac88fed Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new df79b23 logging
new ba1167e Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 556abab add pending queue
new 9d6426f Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new d437149 fix
new d826f58 fix addr
new 34e923a Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 4112457 fix pending
new 808e6e4 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 94a6932 fix
new b7aca1e Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 93a6d8a logging
new 4be704f MMerge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 0a30537 log
new bfe73c7 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 90508fd fix
new b8116e0 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 4092c50 rm log
new a692694 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 9458e06 refactor for vm
new 45bdcd3 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new bc0056c fix bug
new c10b13b Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 1862301 refactoring for vm
new dd0cd89 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 4b14153 fix
new ee457bd address
new 82a5ceb Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 22e1a2b vm
new d311a54 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 454ff1b fix address
new bb6676e Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 05ef119 log
new 9bf9f95 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 7bc3cee fix
new 061cc23 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new eb221c5 fix pom
new 84385cc rm pushback logg
new 3664ec2 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new b05e4f7 rm gbkw log
new 5565577 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 11df234 logging:
new ac13e5b Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 48682e9 bug fix
new 44d0f0e Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 48b8a5c offloading handler
new 3349f54 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 3d23977 fix bug
new 43c9a56 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 923afef rm logs
new 58a22ef fix address
new 972e6e8 Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new d956cd1 fix pa
new 4973141 fix
new 7152ead add start/stop vm
new 327320a Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 92b94ae Merge branch 'after-hos-refactor' of github.com:taegeonum/incubator-nemo into after-hos-refactor
new 56ab2fa fix destroy
new d4f3970 Merge branch 'after-hos-refactor' of https://github.com/taegeonum/incubator-nemo into after-hos-refactor
new f6fd317 handle restart exception
new bf7f6b7 fix bug
new 2f24ccd fix ready vm
new 2d4089e rm pool
new 7ea9816 constants
new f9f137a element wise flush
new 52b1d88 fix lambda offloading requester
new 4699f48 fix
new fce0896 loggig
new 632b576 logging
new 964a7dd synchronized
new c51141e rm sync
new f99f952 push back log
new 65a221d logging fix
new 65f16c9 refactoring
new c4fd515 fix dependency
new 84bb5b9 Revert "fix dependency"
new ebf5e7d Revert "Revert "fix dependency""
new 9ee8d29 refactoring
new 6df363d fix sh
new 864549f fix pom
new 9d1702d fix pom
new d541f71 warmer in master
new b63fa4a fix script
new a7f21e3 Merge branch 'serverless-general' of github.com:taegeonum/incubator-nemo into serverless-general
new 6a0727d fix address
new 4b354a3 fix constants
new 7735396 Merge branch 'serverless-general' of github.com:taegeonum/incubator-nemo into serverless-general
new 2109c64 fix netutil
new 57a4d8a Merge branch 'serverless-general' of https://github.com/taegeonum/incubator-nemo into serverless-general
new 99b0d5d Addrr
new f4c4a84 inet socket addr
new 18783df disable serverless warmer
new 1fd19e1 logging
new 167acd6 fix
new 545546c logging
new 974b6cd 20332
new 473faaa fix
new 450f9b9 warmer in master
new 517f636 fix lambda worker connection
new b92a13b refactoring task executor
new 8cd8d3b log
new 2535528 support join
new 8b2bdf9 rm unused import
new c7df232 fix push back
new 955b35c fix bug
new 1671331 fix bug
new 0ba4b83 add bytebuf.release()
new ad410cc fix exernal class loader
new 7d424c2 logging
new 49a3cd3 log
new 2d385d8 fix bug
new f4cf373 rm logging
new 9689565 fix bug
new 088a2a5 log
new 861cb68 parallelism
new ec4779e log
new 1b1444a fix push back transform
new c0ac3bc extra request
new 377d9f4 logging
new 1d8088d fix extra request logic
new 717f825 logging
new a2911c3 rm write and flush
new 4213b27 more logging
new 7289cb3 logging
new e41ea95 pipelining data transfer
new 39e3653 fix
new 28c2cbd no direct flush
new 6232335 fix constnats
new d0ff291 rm
new f5e03ab fix
new 605a206 fix
new c95c296 refactoring
new 1eed91e fix format
new c79c00e fix pushback offloading
new 1df130d worker init buffer retain
new 13eca46 fix
new 8df4d03 logging
new a9a1728 fix sls executor service
new 1fa731b write ordinal
new e27b064 fix result
new 0dbe513 logging
new db8452b output emit
new 981fbde result logging
new d4142e0 rm logging
new eabc609 fix log
new 2c38af6 log
new abf4e23 rm pending request in offloading factory and preparing for speculative execution (global id)
new 37fb5a5 speculative exection
new 3cc69ea fix output emission
new 67f1843 fix shutdown logig
new 07642cf logging
new 8f7be6e rm logging
new 09a1961 log
new c5f5fe4 rm result map
new 66a92b1 loggingg
new 90dddad pushback fix
new 7b7446e fix push back offloading
new a8442ec rm ready state
new 8b0e159 log
new fa5ef0e optional fix
new 6891754 fix result map clear bug in finishOffloading
new 98fa2df period
new 6fc7a65 logging output latency
new 4d4626b more logging
new 2b1cf15 fix
new 7481a3d more logging
new 6b56cc7 serialize fix
new d99dd6f fix transient
new db27346 fix bug
new cc6a5cd data ordinal add
new 166d6cc direct buff -> heap buffer
new f25bd1a log
new 7938d6e speculative execution
new 745794b fix bytebuf bug
new 571d8ce fix bug
new c635471 speculative fix
new c0e6f33 comment out
new 8ef6f43 speuclative bug fix
new aa787a3 emittable fix
new 74d2a73 logging
new 313d8b3 logging fix
new e7c9afd fix retain
new 7619de8 scheduler log
new a17c6e3 scheduler log
new 3bb0541 print exception
new f3bf055 fix error
new 27d4fa8 fix speculative execution (reject execution if the work is done)
new 28f29ca fix
new e276dff more logging
new ea49c39 fix
new bed7b49 finish offloading
new b3fa0ad remove rejected output
new 438e1b2 speculative execution optimization
new b76c7e1 fix speculative
new 7e2ec0d sync bytebuf
new 13cff04 Revert "sync bytebuf"
new 39cb71e exception handling
new 52f375d ioBuffer -> buffer
new 5ef047d wo speculative
new 6f7a016 more logging
new c7235a2 add exception
new 12407e6 Revert "ioBuffer -> buffer"
new d63df8f sls general logging
new 56486e7 more logging
new 2a79bf2 speculative execution fix
new 41b4a3d Merge branch 'serverless-general-wo-speculative' of github.com:taegeonum/incubator-nemo into serverless-general-wo-speculative
new 22a7062 bug fix
new dd2d9f0 Merge branch 'serverless-general-wo-speculative' of github.com:taegeonum/incubator-nemo into serverless-general-wo-speculative
new abbeea0 logging
new a8dd525 Merge branch 'serverless-general-wo-speculative' of github.com:taegeonum/incubator-nemo into serverless-general-wo-speculative
new 2756201 fix log
new 5311d96 decoupling serverless module
new 1c4ad0a add nexmark
new 172440c rm unnecessary
new 9a9a781 Merge branch 'decouple-serverless' into serverless-general
new c26cbc4 rm no element
new fd56ddd offloading false
new a0a0fbb fix pushback
new dd17583 fix
new b666488 Revert "fix"
new d9e7abd Revert "rm no element"
new c621867 nexmark 2.7.0-snapshot
new c516d9b fix pom
new 754f678 add gcp pom
new 2fddccb rm gcp pom
new 89f8583 Revert "rm gcp pom"
new 22e6486 cpu bottleneck detection
new f1c1e46 fix event handler
new 8f1c857 logging prcoessed events
new 6f55fb6 logging prcoessed events
new a20a4ae fix cpu bottleneck handler
new f8fed16 start/stop offloading skeleton code
new 5a592b0 input fluctuation detection
new a3f8284 fix
new 2108a6f fix cpu bottleneck detection
new fa8a4f9 comment
new 36f0e7e automatic offloading checkpoint... rm data type write
new 30dffde fix offloading event coder
new 75e3591 fix offloading event coder
new 3727ad4 fix
new 3e250e9 fix encoder
new 2685979 fix
new cb6dbd7 fix
new 70d0924 fix
new 0344bd7 fix
new 5a3e4ea logging..
new 3d598f0 add sdk
new fe34c6e set context class loader
new e368f9c use composite
new 71ace5e add writer index
new c0c7e11 fix
new 57758f7 logging encode/decode byte
new fb4dd7c fix cached pool worker init buf
new a7733d7 more logging
new c8e6fec rm windowaccessmap
new 3772170 log
new bca6df1 new pushbackdofn
new dc9bd6a new pushbackdofn
new f703da3 offloading bytebuf
new 94e1117 revert to beam 2.6.0
new 92557e1 fix pom
new 8246f4a initial commit for offloading stateless transform
new 1840095 add offloading result event
new 3ec5b4a add offloading true
new 3a59a76 add logging
new 1b29e06 log
new 3246b6f fix encoder
new efc2cf1 more logging
new 62b21b2 add nemo-beam-runner
new bd911c9 skip sink
new 2b83693 logging
new 2f7a786 logging and fix
new 32fbd7d output emit logging
new b3ecbe6 mv file
new 9302453 remove logging
new 3d4f100 flush to sls
new d4e896b flush fix
new 9e288aa rm logging and fix
new b097c5f logging
new b30dfee shutdown thread
new c04a068 operator bursty disable
new 5177ae2 add configuration for offloading
new e598367 create evalconf
new 88c4164 fix
new 0d7d70e use evalConf for poolSize and flushBytes
new 7650b3e fix
new 9a9a55b fix
new 0ec9c31 rm log
new 79e6998 rm log
new 88d705a bottleneck detection parameter conf
new 3942df6 logging enable/disble lambda
new 016c047 add offloading debug
new eb7a508 fix
new 6be1b0e offloading request after 10 sec
new f1305d8 Add Timestamp Value to NemoEvent for Input Tracking
new b4658c9 metric collector implementation
new 55455a2 rm logging
new 5bee178 latency logging fix
new 0988de4 latency logging fix
new a0d99ed latency logging fix
new 04ef8f7 Timestampvalue for offloading
new 610ab7c fix
new 012f686 add script
new 734db94 fix pom
new 9ba3f9e fix dependency
new 8b21e67 fix dependency
new 810b2f9 Automatic offloading for general query DAG
new d40e090 Refactoring packages
new cf41b1f rm logging
new 6d95df6 merge
new 97d6109 Merge branch 'serverless-general' of github.com:taegeonum/incubator-nemo into serverless-general
new d5db1ad fix
new 07d107b Merge branch 'master' of https://github.com/apache/incubator-nemo into merge-from-master
new 5a11b3c logging
new 78b049f fix unbounded source readable
new 42a3d36 rm nemo-client dependency from nemo-beam-compiler-frontend
new e1b02f9 rm unnecessary files
new f55b258 latency logging
new dbb72b8 fix logging
new ec2ec1c rm unnecessary variables
new 9b6a7b9 Support multi-stage offloading (output writer)
new 338b2e2 Handling offloading event in one thread
new 5aedf29 gradle and rm shaded nexmark
new 6860bd5 nexmark shaded
new 2a65741 Support input watermarks of multiple sources
new 7fd4110 [Logging latencies for multiple stages]
new d2f363e Merge branch 'master' of https://github.com/apache/incubator-nemo into serverless-general
new da38ae5 fix
new 07a561b Merge branch 'serverless-general' of github.com:taegeonum/incubator-nemo into serverless-general
new 6ebcec7 rm logging
new c378052 Merge branch 'serverless-general' of github.com:taegeonum/incubator-nemo into serverless-general
new 450b07a rm logging
new c046f7c Merge branch 'serverless-general' of https://github.com/taegeonum/incubator-nemo into serverless-general
new c1b4f6f bottleneck detection fix
new 0e9fc77 latency monitoring fix
new ef5827f logging
new 95adfa9 [Fix bugs ]
new a0105fe [Support kafka source and remove uber jar by adding small dependent jar files]
new 4241b7a add lib
new c7a7eec [Enable kafka dynamic partitioning]
new 0373d9b [Taks source split]
new 78cc921 [Fix bug and offloading logic]
new eef95d3 [Source merge]
new 5e12f33 [Support Yarn]
new 599c8f4 [Pipe reverse connection]
new 0db4c50 [Preparing multi-stage lambda.. remove protobuf and move classes]
new fda7a65 dynamic task source addition
new 326ffb1 preparing for multi-stage
new 486560e log
new 8901aab fix
new 5adc5a6 Add avro
new 72b5a00 fix
new f61c393 rm sink
new fcc4311 fi
new 6db5878 fix
new 488550c fix
new 2588590 log
new f463ab7 log
new 593a2f3 log
new b8b978f rm log
new ade6384 fix
new 0bfd5da fix
new a3f535b add taskIndexMaster
new 19ae068 fix
new 57d59ea log
new 565d622 log
new ed4620a fix
new c1e02d1 fix
new fd24917 fix
new 4f362e4 fix
new 31352c4 log
new 327be6c log
new 9be5c30 fix
new 2446664 fix
new 01ba1d5 cpu 100 debugging
new 5279ca9 netty flush fix
new a443746 pipe container null point exception fix
new 3cb00db gbkw batched trigger
new efb666e fix rm key
new db97780 fix lambda flush
new 54823b7 offload debuging fix
new bf35a3a log
new 58c4622 fix
new 3dec247 context stop/restart
new 1138f8a rm offloadingdebug in taskexecutor
new 1bed909 context stop fix
new ab63a55 context stop fix
new 74e96b9 log
new 29f5716 fix context stop
new 04b0799 rm restart
new e839b4d context restart message
new 3be55aa fix
new 2fc7746 restart fix
new 747599d rm logs
new 77e6bbb [Fix cpu modeling with cpuTime and offload only for stateless]
new 49a3804 [Local communication]
new 584922b [Streaming combiner]
new 5af95fa latency logging
new 8687a56 add start slack time
new 40ffc6c fix
new 3c0c671 Deoffloading fix
new 7a6eaec break
new f8e71ca logging
new a82ddfa channel exception logging
new 58503f7 special case
new 4e46801 cpu load
new de2dd2c fix offloading algorithm
new 1cd0376 deoffload slack time
new 3007244 slack time
new 78d07de fix constants
new dbeab29 fix constants
new 045ea0b fix logic
new 6210869 handshake and gbk fix
new d276d7f watermark logging and dynamic input watermark setting fix
new 8175151 log
new 6ce34cf logging
new cde6408 fix output writer
new e079c4a Stream remote input context
new 7885796 gbk
new fef7047 fix bug
new e4bf390 fix bug
new 72afa00 add finished
new b6ce73b [Offloading mechanism refactoring]
new 85873fd fix
new 78bd9a2 fix
new 3b57f49 iterator add/remove fix
new bcd207d lessen watermark check
new 68db6a5 watermark fix
new 2be29fd slacktime
new dd4d236 more logging
new 42574b0 enable late data
new b20edd7 validation
new 6609231 fix
new 13f188c bug fix
new a2d592c fix
new 413acf7 local iput context atomic boolean
new 450b469 fix dynamic input watermark
new aee4925 fix dynamic input watermark
new d6c60ca bug fixed
new b35bd3a enable drop data
new 47ef399 fix constant
new 12fb7fb force close
new 266fe2f fix null..
new c627cb2 rm log
new d9ccc82 fix offloading logic-
new 2fbfda6 fix
new 4067c84 gbk partial flush fix
new 083c316 handle init watermark
new 91285f6 reset watermark
new 3e65c54 flush fix
new 6c5d951 snapshot vertex
new eaec342 prepare gbk
new 4e9abe0 null byte fix
new 60ce88e value fix
new 35ff8d7 log
new ab3c87d force close
new cd699bd offloading logic fix
new 8e1aeda vm offloading
new 6ae0e29 logging and fix
new 9689d8d fix
new 488bbdb fix lambda offloading worker factory
new 6c158fd fix pom
new 4f28737 fix
new 7daf8d1 multiple vms
new 59c36d8 multiple vms fix
new 8a67ad3 fix
new a193128 vm
new fee1cad fix logic
new ef1f760 vm round robin
new 6b9778a 5 vms
new 2c056a4 seep task offloader
new e19e74c offloading fix
new eb806d0 offloading middle stateless
new 78ddc36 offloading result fix
new 1dcb526 logging
new 4435b96 restart middle
new 1128fdf fix middle
new 3074473 fix
new 68abf39 rm logging
new 0f2461e fix values
new 40c0282 fix
new 9f125c3 fix value
new 0434331 consider deoffloading
new 8840b14 slac time
new b0a3c50 observed window
new 6de8aae heartbeat
new ef53f51 fix
new e70644d deoffloading fix
new 375401c heartbeat fix
new d86a44b normalize
new 1478491 rm log
new 44ab710 logging fix
new a0f8b84 fix
new 9b9660e fix cpu sum
new a789245 logging
new adfa7a2 running tsak in cpu time order
new 3652021 rm logging
new c3fc93f offload only stateless
new 17e4164 poly 2
new a9a9a65 val
new 2add4c9 fix
new abba3ae fix curr cpu time sum
new 32c3bf7 fix iterator bug
new bfd9ab6 fix val
new bd929a9 nemo fix
new c220da7 Fix
new 7fe8fb6 fix
new d02ba82 force close fix
new 5933519 tiny tasks
new 889e188 executor threads
new f453168 sleep
new 5d8d1a4 implementing vm scaling..
new ec3ec69 implementing vm scaling..
new 7126a0e debugging
new da3491e logging and fix address
new e4118ff logging
new 24b29a4 data id
new 18f1ec5 downstream transform fix
new b717f8c fix
new 19777d5 fix
new 8b96ac8 logging
new 8fe71c4 fix downstream transform
new e127952 remote test
new 0f41b00 fix for remote executor
new 9206643 fix
new 06ff968 log
new 68be93b downstreamTaskOffloader getEvent immediately
new 809af91 writeAndFlush
new 160e866 [VM scaleout checkpoint]
new 0e208e2 Implement VM scale in
new ac5eb97 fix offloadpending
new fc883c6 disable sendToServerless
new ddaaa41 shared channel close
new 3388a91 shared channel close
new 547ec36 fix and logging
new cfd07a8 logging
new 95d0711 logging
new 7cc0513 channel close
new e0ded04 getandincrement
new 6959d9c remote byte output context ack
new 37766b2 [VM scalin checkpoint]
new a74ae51 Merge branch 'serverless-general-upstream-tasks' into serverless-general-tiny-tasks
new 72817f8 refactoring checkpoint
new ee0a176 try to remove local
new 8d56644 offloading
new 8f7d63f fix compile error
new b0c5d27 serilaization issue
new 543ff18 serilaization issue
new 7cfcc19 logging
new e3b7510 logging
new ba787b3 isReady
new 33fd48f null pointer exception fixed
new 468c8bc logging
new bdce885 print ordinal
new e962f63 byte array logging
new 41af9e0 byte array logging
new 166565f byte array logging
new 5e91628 byte array logging
new 866e237 fix offloadingTask encode
new 30c0d6f fix offloadingTask encode
new 271d0fa fix offloadingTask encode
new 8c7142f fix offloadingTask encode
new cc5ca98 fix offloadingTask encode
new ebe91d7 logging
new 5948aa7 stage ser fix
new efc1c2a logging
new 180cb29 fix offloadingTask encode
new 8da820a do not close
new 62ef481 logging
new a84084e check readable bytes
new d408d1b fix pair
new eeda5da rm byte logging
new 2e7d6d5 rm byte logging
new 5dc47d0 rm logging
new 76eeff7 logging
new 3bf8589 remote input and output context handling fix
new 910321c logging
new dbbdafa input output context fix
new 974cd45 scaling in
new 7787f2f fix and logging:
new 6dbe1f2 logging
new 722e45d checkpoint fix
new 02f6371 just add data fetcher
new 2872cc5 logging
new c1b9e8f logging
new e137b14 logging
new 6662480 logging
new fc4a5a8 logging
new bc99427 logging
new fb376e4 fix
new e378526 input context logging
new 92e1dde disable dataframe end
new 5e4d205 delete VM
new 6280c7e vm request fix
new 55759b0 disable onContextExpire in lambda
new 0f37f34 stage1 scaleout
new 0e4956c disable deoff
new 88b5238 check available fetchers
new ecc2a31 logging
new ce02ef3 logging
new c053ea0 logging
new 46016c7 exception logging
new db353db add logging
new b0fedf7 add logging
new 41d6c10 fix bug
new 5a3bd18 fix
new a06ade5 getInpuContext in LambdaContextManager
new 6a3bd2f byte output context channel flush
new 654adf1 element logging
new 6346e86 logging
new 2b915ff logging
new 3eebeaa blockingqueue logging
new 77426c0 fix
new 3eb6652 synchronized isEmpty
new 558b8d9 fix parentTaskDataFetcher
new 0862902 rm logging
new 7cc5b9d [stage1 stageout]
new b847056 vm scalin
new 1d183bd vm scalin
new 7cd12f9 fix task deletion
new e9fee1b logging
new 1d43ddb add finish
new b8c8486 ack logging
new f98b565 fix
new 4efcd70 fix pair
new 07d13bf fix
new 07fabe3 delete task
new 72771c7 multiple task stop
new adad67c stage0
new 66fb8f8 stage0
new c635c93 debugging
new 05984ded transfer index
new 87061a5 disable vertex6 split
new 4f8bbcb schedule at fixed rate
new eedc31b rm worker
new 2c2fc0b vm requester fix
new 018e338 start fix
new 15df7b9 logging
new de7f0af logging ts
new c206b64 logging ts
new d0a983e logging ts
new af5d741 logging
new 1dc9bce log
new 2dc667d set input timestampe for gbk partial and final
new 43d9500 transient
new c9275e1 state scaleout
new 8647437 logging
new 31e18de comparator
new 27f4618 fix combining state coder
new 015b0f6 nullable state fix
new e994610 combining state logging
new 2363d83 logging
new 7bf12e6 accum coder
new 2fef767 fix accum coder
new 888592d logging
new bf2f5c7 state decode
new 4c7460a state stringify
new 378df6b state scaling in
new 67cd07e fix error
new c2bf7e4 gbk final logging
new 028675a more logging
new d83b5e7 more logging
new aaffa83 logging
new 0933f33 hashcode
new d43eeb1 hashcode
new 9145327 logging
new a95e43b set staet fix
new c9ffc63 state map
new a40e058 encoding fix
new 2938718 partial flush remove
new 1b0f7d0 rm log
new f483aa0 offload stage0
new 1ae5846 Remove flush
new 89821c0 schedule fixed rate
new 6b36f2c relay server ...
new de67b77 flush fixgs
new 3601757 Merge branch 'serverless-general-state-scaleout' into serverless-general-relay
new 1d9e0db relay server (upstream)
new e5edb65 decode fix
new e114056 fix decode
new 3ffb12b fix
new c117932 ack fix
new 03f5280 checkpoint mark coder
new 1f67fe7 state map coder fix
new 55822b6 coder fix
new 7849ff3 logging
new 78f4bcc logging
new e669ee9 logging
new e84111b fix relay control encoder
new 831593f fix relay control encoder
new 8224b56 debugging
new 054b542 byteTransferMsg wrapping
new 75cc63b fix
new 6ebca4a skip control message
new 186bb3a logging
new 51f60e9 logging
new ac70924 channel flush
new b53519b logging
new 49d7947 global transfer index
new 0687894 global index
new 23ade9b fix
new 210be2c logging
new 6e07487 logging
new 1658268 logging
new 07dd32a logging
new 770d366 fix relay coding
new 77bab97 fix relay coding
new e2ad578 fix relay decoder
new 17c38aa fix
new 2a52fd9 while loop
new c2a542b logging
new a11d639 fix logic
new 5c461e2 ack from downstream
new 2d62f1c deoffloading stage0
new 03db96a deoff off
new 3f505d2 do not throw duplicate context
new f54ddf8 Scaling in second stage
new 8a59760 resetting context manager for input context
new 62040c6 input context relay server
new 767a5ad fix
new 254c5e0 disable wrong executor id
new d4d8120 logging fix
new 9f374dd more logging
new b7723ac more logging
new c2fe44c more logging
new 64145da pending bytes
new 014e4ee executorId
new 3a6691b refactoring..
new 5186eb3 refactorig
new 1710ccc set is relay server and logging
new bb46a8b isDone fix
new a9d7bb5 rm countdown latch in lambda remote byte
new 5d78da5 upstream off deoff
new c50841b complex off and deoff
new 9b9c4c4 deoff fix
new fedb37b waiting for ack
new 1dbefa2 send message fix
new 63fd5ee setting input output context
new 017643b setting vm -> sf
new c8a38ed concurrent exception in finish fixed
new 79f2443 more logging
new 396b57b pendingCnt fix
new 4dce0ba fix to bytetomessagedecoder
new 146900d source vertex data fetcher stop fix
new 39a4c9d get logging sourcevertexdatafetcher
new 960ae2a logging
new 571128c hasSource
new 65498dc fix hasSource
new 82706c2 source data fetcher restart
new af25c20 output writer close order changed
new 1879439 complex offloading
new d452824 task relay test
new 809690c pipe init logging
new 2d75d66 logging id bytes
new 7d760e3 Revert "logging id bytes"
new 26f07c4 Revert "Revert "logging id bytes""
new 8e24db3 global scheduling..
new 5043d56 byte logging
new f3b7421 more bytes logging
new 6d47be5 ..
new 24a5257 fixing
new 0fd2bd1 offloading done
new dd6159f Merge branch 'serverless-general-relay' into serverless-general-global-scheduling
new 6487597 taskdone fix
new dbb5af0 stage id
new a870d5a query5 stage1
new 0a19cfe stage 0
new b0d63ec disable logging
new 1193258 worker heartbeat
new 33f26f0 cpu load fix
new 8512b39 just single stage
new 0521b49 logging for q5
new eec470c rm log
new d6ec8fe offload stage0
new 56ad8d8 lambda byte output context relay dst
new 5ce04ae fix slot
new fabbef5 bis available
new abc8a69 logging
new 88de8f8 more logging
new 88f8003 more logging
new 52026a5 logging
new 27a717b logging
new 49be69f more logging
new 34acbee logging
new 64a0696 logging
new c177e05 use atomic counter for queue
new 5c6409f gs
new a880edc disable loggin lambdainput
new 13e6cd8 closable blocking queue fix
new f0dcc6f array blocking -> concurrent liked
new 6e4d6aa reuse array dequeue
new 93bd059 fix
new 1abb3c6 logging
new 4cd695b concurrent linked queue
new fd0e0ca decoder logging
new e26359a Rm bis
new fc43c63 closable queue use atomic integer
new 8dfb0b6 timer internal trigger fix
new ce2d16b fix
new 9d8b876 rm logging
new db40945 deoffloading signal
new a675411 deoffloading signal
new 1a8e92b ack fix
new 800e189 break
new f72267e fix output context
new 0154b78 oflfoading
new c315406 logging gbkf
new a9424c8 partial logging
new 283f637 logging watermark
new bb9e330 fix
new f39d51f logging
new 0ca0930 logging watermark
new 2c7f2c2 logging and concurrent queue
new f7dde3c watermark logging
new af2b5c3 fix watermark
new 41b9805 profiling cpu time and load
new 1701c4c disable logging
new bf6bc43 more logging
new 5dbd1c1 prepare service
new c57feb9 offloading status in master with atomic integer
new fcda344 lambda layer lib added
new bcc6146 task offloading
new aca8449 Merge branch 'serverless-general-lambda-layer' into serverless-general-0530-unpredictable
new 9b34c2b add taskSLot conf
new fbd8991 rm google collect
new b25659a fix
new 11c3b74 logging channel
new 122f371 fix
new cd42f97 logging
new e38b973 logging
new 810f989 sync invoke
new 706bcbe fix weired lambda behavior
new bfde0be debugging
new 5fc2524 use nemo event handler, rm log, lambda.close non blocking
new 5a3517a rm jars
new 5b214f2 rm thread sleep
new 796fb1e q5 test
new 89ba6f0 warmer fix
new e9ed43c logging disable
new 72828ee fix logic
new 179f586 more logging
new 8f502f9 offloading executor shutting down
new d388600 offloading test
new 0171afa channel closed handling wo exception
new 73c7a56 channel closed fix
new 77787e0 heartbeat logging
new b394392 multiple off
new 7685e42 offloading some part
new 5c55f1d fix
new 0d13f15 scheduling worker in workermanager
new 5530ed7 offload time heartbeat after 10 seconds
new 1e049af offload time heartbeat after 10 seconds
new 79381ae target offload fix
new 4a77a85 asynchronous offloading
new d60b2b3 fix error
new 75d8063 fix prepare cnt
new 63cae0c worker ready prepare
new c3c3ad2 fix heartbeat
new e9336f6 worker init fix
new 7291d89 q5 offload test
new e9effbf logging
new 89e37a2 lambda handler executorservice
new 739e5e6 stage-based offloading
new f60135c fix logging
new c8909fe fix logging
new cf767be log
new d4fec75 stage0
new b4bd80e more logging
new feabbfd more logging
new 039fc8a fix
new b646af6 ser fix
new d0f0bdf ser fix
new d404d4d logging
new a93cc8f change ser order
new 23f00b1 cached pool
new 7da1fdb process cpu -> system cpu
new 2d49089 fix val
new 4947f3c task offloading fix
new bc87ff8 task offloading fix
new ea40622 fix val
new 2a084e0 multiplicative offloading
new e65648b multiple
new aab85c1 window increase
new d492d78 multiplicative percentage
new 6a5b90c rm slack time in multiplicative and concurrent add/rm tasks in offloading executor
new d9534f0 logging rm in gbkFinal
new 0e1ce9f executor service fixed thread:
new d5ea9c4 stage scheduling
new 468e181 cached tp
new fc44eeb message id logging
new d5ee133 thread sleep 1000
new d548a64 pick fixed
new 3aa2528 rm logging
new cc6b7a9 peek blocking
new 39e15ec logging
new 61597a5 log
new e8a15b7 fix pending rm
new 475cf5b offloading handler fix
new 20eba24 fix policy
new a4ab4d7 add stepwise offloading
new b4ccfac fix policy
new b8d8717 fix policy
new 68b7a86 more logging, executor service in event handler
new 0656460 logging
new 8e5c935 logging
new 648a471 more logging
new e8c0dd0 disable state encoding
new 2f0ed97 null fix
new 489b467 more logging
new 4e429bb print
new 37cad72 print
new efa4e9d executor thread exception fixed
new ebd0e24 offloading handler fix
new bef0d8c fix
new 6a0f2d9 unbounded source start fix
new b2e15a7 readable fix
new 5e74cf3 increase slack time
new 6d5d321 offloading event handler thread pool
new 2ee1886 logging
new 9d65213 50 sec
new c8ec34f decoding time logging
new bc11a98 enable task encoding
new 54f7abd executor fixed thread pool
new 8276602 rm logging
new 905a7ea rm log messages
new 3162a17 fix thread sleep in streaming sched
new 69fcf0c rm logging
new 9ee4ee8 rm map encoding of task
new f7ae543 encoding decoding time logging
new b3384e4 70s
new 9604e33 stepwise stage1
new f975820 taskid
new 7274dda filter stage1
new 62971ca stage1
new bf9157d stage1
new 68244e2 duplicate input context
new f5835ff serialization fix
new aa907cc null pointer exception fix
new ef40191 input context logging
new 6416de2 input reader stop fix
new e2c2c89 fix input fetcher stop and check offloaded executor
new a2d900a fix
new 6891e35 off deoff
new af3f737 set grpc
new 097f621 add script
new 305b8d5 logging
new 92a5283 add
new b8bf5f6 Merge branch 'serverless-general-0607-serialization' of github.com:taegeonum/incubator-nemo into serverless-general-0607-serialization
new 5e5500e logging
new 025840e miMerge branch 'serverless-general-0607-serialization' of github.com:taegeonum/incubator-nemo into serverless-general-0607-serialization
new 8f38ed1 miMerge branch 'serverless-general-0607-serialization' of github.com:taegeonum/incubator-nemo into serverless-general-0607-serialization
new 28d11a0 logging
new 35d60a7 logging
new ccf318c Merge branch 'serverless-general-0607-serialization' of https://github.com/taegeonum/incubator-nemo into serverless-general-0607-serialization
new 6a503b4 logging
new b7532ca fix bug
new df47dac sync
new 862f9d8 slack time
new e5ff0d9 off deoff
new eb82928 off deoff
new e76574e logging
new e24cae6 concurrent rm fix
new 0741312 more logging
new 44d60f5 fix null pointer
new 520a9f1 byte output context fix
new eb7a773 rm log
new 4588884 inmemory state coder optimize
new be58390 fix
new 8113ba3 logging
new c74c6a2 fix coder
new f251b95 logging
new d10d789 log
new b50e780 coder fix
new 236c926 watermark coder optimize
new 6544145 coder fix
new 829cc04 offloading after 200
new 4c491e8 fix
new 0642d22 offloading after 400
new 738e2fc offloading bug fix
new 3347448 coder optimize
new fd6cc63 off deoff
new fca3212 fix
new c2db9ea policy fix
new df44c66 taskOffloadingManager bug fix
new 75f0c10 logging
new a3fc8fe fix bug
new 2993091 logging
new 7cbba07 fix concurrent mod
new cccef0e multiple stage off deoff
new 6657f81 threshold based policy
new 4b5b593 state remove after timer triggered
new b69fedc rm log
new 9e7022a task execution time average
new 2ae7a8e watermark logging
new 8155fd7 fix log
new 2043bf4 logging watermark
new f529a85 more logging watermark
new 588025a more logging
new 88ad56c more logging
new 52634ef watermark emit fix
new 44c7b23 watermark emit fix
new 63b4b55 log
new ce4ccfb log
new a15ac3b logging
new 7376b30 logging
new 6a43140 disable logging in dynamicWatermarkAManger, gbkpartial and final
new 5de37fe revert prevWatermarkHold
new 1675581 fix encoding
new 555d1ec gbk final watermark logging
new f9060c1 input watermark logging
new a9eeceb input watermark logging
new 9ec6f5c gbk partial watermark emit logging
new 8f01d4f logging and all fetcher set
new 6dca9a0 input watermark fix
new a74c97c rm timer key
new e1fa2e5 threshold based logic fixed
new 574f817 disable logging
new 0e64fa2 fix threshold based offloading offloadPending.contains
new 3edd9cd scaleout latency test
new a1aa626 disable stop vm
new 60afad5 create channel req
new fc70ccc create channel req
new b30ab70 disable closing running worker for test
new 49fa283 rm no such element exception
new 0450870 empty element in unbounded readable
new 55f76bb optimize readable
new 3a08049 disable offloading and vm request
new 5b4f5cf polling time 100 ms
new 7361d1c enable offloading
new cba3099 polling time 50 ms
new dca2448 offloading q5 multistage
new e9902ee watermark progress
new 178bc9e fix compile error
new 7f03468 prev watermark offloading
new f2b3190 keyandwatermarkmap logging
new 43a7c11 watermark progress fix
new 317d4f6 fix taskoffloader debugging
new e551198 deoffloading fix
new 7a1bd81 logging
new cb1655c logging
new ffbe980 debugging
new eb461b3 restart and setting context sync
new 8d9e42c restart and setting context sync
new 9dab754 global watermark trigger
new fe3b73e global watermark trigger
new 1513c06 optimize executorThread
new 4e05adc optimize executorthread
new 4855a58 optimize executor thread and polling time
new 38e4a6f fix compile error
new 741b3c8 rm polling time in task executor
new e488331 rm log
new c0da030 fix source readable
new 634c0f4 Revert "fix source readable"
new 177f09f watermark trigger fix
new 51ca4a5 gbk partial transform watermark logging
new 9f42b0c concurrent linked queue
new ef2714d multiInputWatermarkManager fix
new 470fab1 logging
new 57eb032 logging
new f555c9f lambda parent task datafetcher iterator bug fix
new e62f6e3 while
new c6e76f8 rm logging
new b83bb93 rm byteInputContext after stop
new a5f7f9a fix bug
new 0e24caa clear byte input contexts after stop
new bf17f88 separate scale out and in when downstream operator moves
new 15a157b thread per stage
new 475bd5a unbounded source readable fix
new 26515ca processed cnt logging
new d617679 system cpu -> process cpu
new f9be4ee implement static offloading policy (signaling from file)
new ce11420 logging thp (implement thp event)
new e89abef logging thp latency
new 2df3c66 static off deoff fix
new 47e9e7f thp latency logging in source vertex fetcher
new 280b206 thp latency logging in source vertex fetcher
new 99d9e12 static offloading per stage
new 8a7c417 static offloading per stage
new 5ad28f3 deoffload bug fix
new 54046d9 rm watermark logging
new ab925fa static off deoff logging
new ff3e77f logging taskId for offloading
new a7fc2bf logging taskid
new 7ce7b77 add tid logging for pending
new ffe27f4 gbk partial final emit watermark
new 308acab disable offloading check cache
new 842c20a disable offloading check cache
new 2e23857 disable offloading check cache
new 921f292 restarting signal fix
new 85d64cb fix bug
new 4879e10 directly send pending ack
new 67679bf executor thread 2
new a5c2b37 kafka polling
new 36aadab Revert "kafka polling"
new 41218c6 check whether tasks have data or not
new 891073a nullpointerexception fix
new eb64da8 source vertex data fetcher isFinished
new d356c4a rm partial combiner
new 9407902 fix scheduling
new 7af7669 operator metric logging diabled
new cf12d6a logging
new 2988a01 logging
new b315af5 rm logging
new e13a23a worker logging:
new d2346c0 logging
new d1c95c3 more logging
new 020ca6e Removing channel when inactive in RelaySErver
new d8b98bd Rm logging
new 6277bd2 logging
new acba2fb fix relay server decoder and logging
new bb710cd fix formatting
new ff18073 logging
new 84e0144 relay decoder logging
new b82dd4f relay server pending fix
new 03f9259 rm logging relay server
new c6771ee multi-stage offloadint at a time
new 7b82d55 logging
new a01ca82 fix offload cnt set
new 9d235e7 byte output context null pointer exception fix
new eef8f12 relay server decoder key
new d32ddc8 logging
new 2bf1905 Channel flusher
new f16afe2 Output writer flusher channel
new ecf461c grpc version up
new de0d458 rm groupbyKeyAndWindowDoFn
new dc585cf set main input coder
new 038c841 adhoc
new 280cd1b inmemory internal fix
new 65373fb parameterize offload number
new d3d71ae logging
new 75149d9 logging
new ca3e040 policy fix
new 8a6f909 [Implement master scaling decision]
new 2a0cfd4 Implement multivm relay server
new ecbfa32 fix
new 9c48fcd fix
new 43f4be1 fix
new e016bc2 divide
new 165a784 logging
new 7725d9f fix
new 067e9b9 sync
new 9b1adec logging ncs
new 4339c29 global message send fix
new dccbc57 logging
new 38d788e logging
new 50de936 logging
new a4103af outputWriter close future
new f146ea5 logging
new 54d900b lgoging
new 0cd165c register task fix
new 2bd5094 logging
new 34e433d ncs message context fix
new be66d50 fix bug
new 8467c86 fix
new bf4de78 Revert "fix"
new 3fe53b6 logging
new 981b955 logging relay server
new 5a5085b task executor id map fix
new 881f200 log
new 8c45276 Register task fix
new 012a592 fix
new 040eb2b possible order problem
new d6ee2f3 possible order problem
new 393ad77 logging lib path
new 7e93750 logging lib path
new c075168 add jvm process for verbos class logging
new fc6cb22 log class path
new 4e3d2e2 logging executorAddressMap
new 897ece2 logging
new 7b21804 relay server decoder
new 0966849 logging relay control message encoding
new e332327 logging
new b9a759f task register fix
new 9752d75 logging executorId
new d5558d6 remote relay server
new 9c4726e remote relay server
new b2adbaf lgoging
new ec22ab6 set remote relay channel when scaling out
new b7bd3d6 add local address
new f88b9c6 relay server length field
new 19601ef relay server encoder ifx
new dc2345e relay server encoder ifx
new d870cab flush fix
new 253534b add offExecutorThreadNum
new 9f898f0 local tiny worker task scheduling fix
new 567d313 fixed codes in ec2
new e39e212 Merge branch 'serverless-relay-server-task-register' into serverless-local-tiny-worker
new 5204710 fix null pointer exception
new ec3a41a fix arrayindex error
new b52a842 Remove logging
new f305733 fix compile error
new 8f15e41 GlobalExecutorAddressMap and remove logging
new 3d30fca rm executor address map put
new cd63d97 fix nullpointer excep
new 0721496 rm logging
new b4f3813 cached thread pool
new 554debe logging
new d3433d7 Rescheduling
new b1554aa rescheduling
new 79a0f89 logging
new 22c7c61 logging
new e8a429e task offloading ready signal
new 6503458 fix check order
new 784587e fix output pending done
new 420c86e vm offloading
new b83d734 vm scaling in multiple nodes
new 7e8860a fix vm scaling
new a7897e0 vm 16
new 499f8da fix error
new 26e847f vm 18
new 7330277 task location management in master
new 61566e6 disable global sync in offloading
new c622eb0 scaling in
new 4487544 fix bug in tiny task worker
new e02b952 disable stage2 offloading in query5
new 1ec65cf fix bug
new dab9a88 fix bug
new 5ae0e19 job scaler fix
new b499185 query5 move fix
new f234ab5 Add thread throttleling
new 5a04f55 inject
new e2b3072 query5 stage2 offloading disable
new 0e21f2e throttle
new 72c7c6a throttle
new f44cf7b throttle
new 8df412f throttle
new a51e30d throttle
new ecc2377 rendevous server impl
new 01f1a71 task registering and sending data fix
new f22595c offloading executor blocking fix
new 24f75a1 logging
new 3583e23 encoder fix
new 4029f0d log
new c2d8d02 fix rendevous client channel initializer null
new 2bac95c output context completableFuture asyncc
new 17ac1ca Fix thread num in relay server
new a6df3fa query5 job scaling stage 3
new a2883bd query5 job scaling stage 3 disable
new ed56dd0 optimize relay server
new 78cff4f retain
new 83201c3 retain
new ac3f565 throttle in offloading executor
new d606a88 no throttleing in offloading executor
new 025a00f vm scaling
new c11e2dc log
new c8ace91 logging
new 81a498d cached poll
new 714f2c3 disable global sync
new dc5ab15 rm logging
new 9f5bcb0 cpu
new d188bf8 vm 22
new 7a01a59 task number based offloading
new 3462928 kafka optimize
The 1449 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.