● Manage the team to build search and recommendation components which make real time, personalized decisions on each of the content requests from Grab massive user base, and serve as the foundation for enhancing user experience that increase the conversion rate(CVR) and revenue. ● Lead the team to build real time ML features and metrics with streaming SQL and send to the feature store to serve for the ML ranking models● Guide the team to build search indexes on ElasticSearch with CDC which serve as the source for the search and recommendation● Build observability tools and feedback loop to measure and improve the quality of search results and content data, and provide data-driven insights● Grow the team from 3 to 8 people in a year and settle down agile methodology for the team● Mentor the team to be highly productive and self-driven

● Build real time streaming platform including managed data ingestion system and stream processing service for other teams to use that can support different real time business use cases.● Develop stream processing framework in Golang to support real time processing logic such as map, filter, aggregation and join. The framework is inspired by Google dataflow and Apache Beam.● Manage and maintain Kubernetes cluster (AWS EKS)to execute real time processing pipeline leveraged by stream processing framework.● Support Apache Flink as part of the stream platform, execute Flink application in Kubernetes clusters and develop CI/CD tools to deploy the Flink application in Kubernetes with Operator.● Develop real time SQL interface on top of Flink SQL that user can do real time processing by submit and execute SQL like query with yaml file.

● Manage and maintain high available and stable Kafka clusters on AWS to serve billions of real time events per day.● Develop Stream SDK and schema registry with Golang and Protobuf to read and write to Kafka cluster in low latency and no data loss.● Manage and maintain a high efficient distributed key-value store (ScyllaDB) to support stateful stream processing.● Develop a GRPC service in Golang to serve read query from users to ScyllaDB.

● Build a distributed web system which provides restful service and analytic tool for hotels to process and analysis inventory data between hotels and Expedia.● Utilize Kafka as distributed message queue to support asynchronous connection which can improve response time and throughput.● Build data streaming pipeline by Kafka and Sparking Streaming to aggregate the inventory data for hotels to analysis their connectivity.● Utilize Spring Boot and Netflix Hystrix to control latency and fault tolerance when interact with external services and support event driven reactive programming.● Improving continuous integration and continuous delivery maturity by utilizing Docker to deploy on AWS Container Service and support micro service architecture.

 Worked directly with the chief architect and senior developers on innovative solutions for migrating customer data between versions of the IBM security products Designed and built extractors, loaders and a JSON template format, using LDAP, JNDI and RESTful web services with JAX-RS Used an agile scrum project management methodology. Created epics, stories, story-point estimates and proposed sprint release milestones