Hey Jae, Also, this should work:
System.getenv(ShellCommandConfig.ENV_CONTAINER_ID).toInt This is actually how SamzaContainer gets its containerId variable. BTW, I've opened: https://issues.apache.org/jira/browse/SAMZA-586 To track exposing SamzaContainerContext. Cheers, Chris