[jira] [Commented] (SAMZA-861) move KV storage api into samza-api package

[ https://issues.apache.org/jira/browse/SAMZA-861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131203#comment-15131203 ] Yi Pan (Data Infrastructure) commented on SAMZA-861: Hi, [~boryas], I t

[jira] [Commented] (SAMZA-813) Add Seek functionality to KeyValueStoreIterator

[ https://issues.apache.org/jira/browse/SAMZA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15131226#comment-15131226 ] Yi Pan (Data Infrastructure) commented on SAMZA-813: Hi, [~amitra123],

[jira] [Commented] (SAMZA-727) Support for Kerberos

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132723#comment-15132723 ] Yi Pan (Data Infrastructure) commented on SAMZA-727: [~ste...@apache.or

[jira] [Commented] (SAMZA-762) java arrays not usable as keys anymore

[ https://issues.apache.org/jira/browse/SAMZA-762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132764#comment-15132764 ] Yi Pan (Data Infrastructure) commented on SAMZA-762: Noting that SAMZA-

[jira] [Commented] (SAMZA-762) java arrays not usable as keys anymore

[ https://issues.apache.org/jira/browse/SAMZA-762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132767#comment-15132767 ] Yi Pan (Data Infrastructure) commented on SAMZA-762: SAMZA-839 address

[jira] [Assigned] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-836: -- Assignee: Yi Pan (Data Infrastructure) > 0.10.0 :samza-kv-rocksd

[jira] [Commented] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137410#comment-15137410 ] Yi Pan (Data Infrastructure) commented on SAMZA-836: Hi, [~edi_b...@yah

[jira] [Commented] (SAMZA-861) move KV storage api into samza-api package

[ https://issues.apache.org/jira/browse/SAMZA-861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137496#comment-15137496 ] Yi Pan (Data Infrastructure) commented on SAMZA-861: Hi, [~boryas], tha

[jira] [Commented] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15137530#comment-15137530 ] Yi Pan (Data Infrastructure) commented on SAMZA-836: Hi, [~edi_b...@yah

[jira] [Commented] (SAMZA-436) Update RocksDB KV's putAll to use write batch

[ https://issues.apache.org/jira/browse/SAMZA-436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139982#comment-15139982 ] Yi Pan (Data Infrastructure) commented on SAMZA-436: Hi, [~a.bircakovic

[jira] [Commented] (SAMZA-851) Hello-samza doesn't work on CDH

[ https://issues.apache.org/jira/browse/SAMZA-851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140316#comment-15140316 ] Yi Pan (Data Infrastructure) commented on SAMZA-851: [~staslos], I have

[jira] [Commented] (SAMZA-851) Hello-samza doesn't work on CDH

[ https://issues.apache.org/jira/browse/SAMZA-851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140335#comment-15140335 ] Yi Pan (Data Infrastructure) commented on SAMZA-851: Added RB for docum

[jira] [Updated] (SAMZA-851) Hello-samza doesn't work on CDH

[ https://issues.apache.org/jira/browse/SAMZA-851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-851: --- Attachment: SAMZA-851-0-doc.patch > Hello-samza doesn't work on CDH > -

[jira] [Commented] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

[ https://issues.apache.org/jira/browse/SAMZA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140416#comment-15140416 ] Yi Pan (Data Infrastructure) commented on SAMZA-864: +1 on the patch. T

[jira] [Commented] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

[ https://issues.apache.org/jira/browse/SAMZA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140420#comment-15140420 ] Yi Pan (Data Infrastructure) commented on SAMZA-864: [~boryas], is the

[jira] [Created] (SAMZA-871) Implement heart-beat mechanism between JobCoordinator and all running containers

Yi Pan (Data Infrastructure) created SAMZA-871: -- Summary: Implement heart-beat mechanism between JobCoordinator and all running containers Key: SAMZA-871 URL: https://issues.apache.org/jira/browse/SAM

[jira] [Assigned] (SAMZA-802) KafkaSystemAdmin needs to handle empty topic offsets

[ https://issues.apache.org/jira/browse/SAMZA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-802: -- Assignee: Yi Pan (Data Infrastructure) (was: Aleksandar Pejakovi

[jira] [Commented] (SAMZA-802) KafkaSystemAdmin needs to handle empty topic offsets

[ https://issues.apache.org/jira/browse/SAMZA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143168#comment-15143168 ] Yi Pan (Data Infrastructure) commented on SAMZA-802: [~a.pejakovic], if

[jira] [Commented] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143588#comment-15143588 ] Yi Pan (Data Infrastructure) commented on SAMZA-836: Just to update: -

[jira] [Updated] (SAMZA-851) Hello-samza doesn't work on CDH

[ https://issues.apache.org/jira/browse/SAMZA-851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-851: --- Attachment: SAMZA-851-master-pom.patch SAMZA-851-latest-

[jira] [Updated] (SAMZA-851) Hello-samza doesn't work on CDH

[ https://issues.apache.org/jira/browse/SAMZA-851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-851: --- Attachment: SAMZA-851-doc-0.10.0.patch > Hello-samza doesn't work on CD

[jira] [Commented] (SAMZA-200) Explore using MySQL changelog as input stream

[ https://issues.apache.org/jira/browse/SAMZA-200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144969#comment-15144969 ] Yi Pan (Data Infrastructure) commented on SAMZA-200: [~rukshan.vidura..

[jira] [Updated] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-836: --- Attachment: SAMZA-836-0.patch > 0.10.0 :samza-kv-rocksdb_2.10:test fail

[jira] [Commented] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15145609#comment-15145609 ] Yi Pan (Data Infrastructure) commented on SAMZA-836: Finally got it to

[jira] [Commented] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15145658#comment-15145658 ] Yi Pan (Data Infrastructure) commented on SAMZA-836: The issue is repor

[jira] [Updated] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-836: --- Fix Version/s: 0.10.1 > 0.10.0 :samza-kv-rocksdb_2.10:test fails >

[jira] [Commented] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

[ https://issues.apache.org/jira/browse/SAMZA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15145678#comment-15145678 ] Yi Pan (Data Infrastructure) commented on SAMZA-836: Got +1s from RB. M

[jira] [Commented] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

[ https://issues.apache.org/jira/browse/SAMZA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15149942#comment-15149942 ] Yi Pan (Data Infrastructure) commented on SAMZA-864: Thanks, [~boryas].

[jira] [Commented] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

[ https://issues.apache.org/jira/browse/SAMZA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15149969#comment-15149969 ] Yi Pan (Data Infrastructure) commented on SAMZA-864: Also, I noticed th

[jira] [Assigned] (SAMZA-776) building instructions have bad URL - http instead of https

[ https://issues.apache.org/jira/browse/SAMZA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-776: -- Assignee: Yi Pan (Data Infrastructure) > building instructions h

[jira] [Updated] (SAMZA-785) StreamAppender doesn't check for system Serde

[ https://issues.apache.org/jira/browse/SAMZA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-785: --- Assignee: Venkat Nannapaneni > StreamAppender doesn't check for system

[jira] [Updated] (SAMZA-776) building instructions have bad URL - http instead of https

[ https://issues.apache.org/jira/browse/SAMZA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-776: --- Assignee: Edi Bice (was: Yi Pan (Data Infrastructure)) > building inst

[jira] [Commented] (SAMZA-873) Avoid unnecessary flushes in CachedStore

[ https://issues.apache.org/jira/browse/SAMZA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152687#comment-15152687 ] Yi Pan (Data Infrastructure) commented on SAMZA-873: [~nico...@movio.co

[jira] [Updated] (SAMZA-873) Avoid unnecessary flushes in CachedStore

[ https://issues.apache.org/jira/browse/SAMZA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-873: --- Assignee: Nicolas Maquet > Avoid unnecessary flushes in CachedStore > -

[jira] [Commented] (SAMZA-873) Avoid unnecessary flushes in CachedStore

[ https://issues.apache.org/jira/browse/SAMZA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152725#comment-15152725 ] Yi Pan (Data Infrastructure) commented on SAMZA-873: Cool! I will take

[jira] [Updated] (SAMZA-776) building instructions have bad URL - http instead of https

[ https://issues.apache.org/jira/browse/SAMZA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-776: --- Assignee: Aleksandar Bircakovic (was: Yi Pan (Data Infrastructure)) >

[jira] [Assigned] (SAMZA-776) building instructions have bad URL - http instead of https

[ https://issues.apache.org/jira/browse/SAMZA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-776: -- Assignee: Yi Pan (Data Infrastructure) (was: Edi Bice) > buildi

[jira] [Updated] (SAMZA-872) Remove unsafe log4j DailyRollingFileAppender from docs and hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-872: --- Assignee: Branislav Cogic > Remove unsafe log4j DailyRollingFileAppende

[jira] [Commented] (SAMZA-873) Avoid unnecessary flushes in CachedStore

[ https://issues.apache.org/jira/browse/SAMZA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152845#comment-15152845 ] Yi Pan (Data Infrastructure) commented on SAMZA-873: +1. Merged and sub

[jira] [Commented] (SAMZA-872) Remove unsafe log4j DailyRollingFileAppender from docs and hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152903#comment-15152903 ] Yi Pan (Data Infrastructure) commented on SAMZA-872: Thanks a lot [~ban

[jira] [Updated] (SAMZA-876) Implemented AvroDataFileHdfsWriter and exposed several RocksDb config

[ https://issues.apache.org/jira/browse/SAMZA-876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-876: --- Assignee: Edi Bice (was: Navina Ramesh) > Implemented AvroDataFileHdfs

[jira] [Commented] (SAMZA-876) Implemented AvroDataFileHdfsWriter and exposed several RocksDb config

[ https://issues.apache.org/jira/browse/SAMZA-876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153079#comment-15153079 ] Yi Pan (Data Infrastructure) commented on SAMZA-876: Hi, [~edi_b...@yah

[jira] [Commented] (SAMZA-689) When Kafka has topic auto-creation turned on, checkpoint topics may be created w/ wrong partition numbers

[ https://issues.apache.org/jira/browse/SAMZA-689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15154517#comment-15154517 ] Yi Pan (Data Infrastructure) commented on SAMZA-689: Hi, revisiting thi

[jira] [Resolved] (SAMZA-689) When Kafka has topic auto-creation turned on, checkpoint topics may be created w/ wrong partition numbers

[ https://issues.apache.org/jira/browse/SAMZA-689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-689. Resolution: Won't Fix > When Kafka has topic auto-creation turned on,

[jira] [Commented] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

[ https://issues.apache.org/jira/browse/SAMZA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15154574#comment-15154574 ] Yi Pan (Data Infrastructure) commented on SAMZA-864: [~boryas], thanks!

[jira] [Commented] (SAMZA-872) Remove unsafe log4j DailyRollingFileAppender from docs and hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15154604#comment-15154604 ] Yi Pan (Data Infrastructure) commented on SAMZA-872: +1. Merged and su

[jira] [Resolved] (SAMZA-872) Remove unsafe log4j DailyRollingFileAppender from docs and hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-872. Resolution: Fixed Fix Version/s: 0.10.1 > Remove unsafe log4j

[jira] [Commented] (SAMZA-609) Properties not encoded properly

[ https://issues.apache.org/jira/browse/SAMZA-609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157367#comment-15157367 ] Yi Pan (Data Infrastructure) commented on SAMZA-609: [~naveenatceg], is

[jira] [Created] (SAMZA-880) Moving to github/pull-request for code review and check-in

Yi Pan (Data Infrastructure) created SAMZA-880: -- Summary: Moving to github/pull-request for code review and check-in Key: SAMZA-880 URL: https://issues.apache.org/jira/browse/SAMZA-880 Pro

[jira] [Commented] (SAMZA-878) upgrade Jackson to 1.9.13

[ https://issues.apache.org/jira/browse/SAMZA-878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172639#comment-15172639 ] Yi Pan (Data Infrastructure) commented on SAMZA-878: Hi, guys, I apolog

[jira] [Resolved] (SAMZA-878) upgrade Jackson to 1.9.13

[ https://issues.apache.org/jira/browse/SAMZA-878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-878. Resolution: Fixed Assignee: Yi Pan (Data Infrastructure)

[jira] [Commented] (SAMZA-876) Implemented AvroDataFileHdfsWriter

[ https://issues.apache.org/jira/browse/SAMZA-876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176434#comment-15176434 ] Yi Pan (Data Infrastructure) commented on SAMZA-876: [~edi_b...@yahoo.c

[jira] [Commented] (SAMZA-884) Upgrade Jackson to 1.9.13 in hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176663#comment-15176663 ] Yi Pan (Data Infrastructure) commented on SAMZA-884: Hm... sorry I miss

[jira] [Commented] (SAMZA-813) Add Seek functionality to KeyValueStoreIterator

[ https://issues.apache.org/jira/browse/SAMZA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176690#comment-15176690 ] Yi Pan (Data Infrastructure) commented on SAMZA-813: Hi, [~amitra123],

[jira] [Commented] (SAMZA-876) Implemented AvroDataFileHdfsWriter

[ https://issues.apache.org/jira/browse/SAMZA-876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15179474#comment-15179474 ] Yi Pan (Data Infrastructure) commented on SAMZA-876: Merged and submitt

[jira] [Commented] (SAMZA-882) Detect partition count changes in input streams

[ https://issues.apache.org/jira/browse/SAMZA-882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15180226#comment-15180226 ] Yi Pan (Data Infrastructure) commented on SAMZA-882: [~jarradk], thanks

[jira] [Commented] (SAMZA-884) Upgrade Jackson to 1.9.13 in hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15180310#comment-15180310 ] Yi Pan (Data Infrastructure) commented on SAMZA-884: RB here: https://r

[jira] [Updated] (SAMZA-884) Upgrade Jackson to 1.9.13 in hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-884: --- Attachment: SAMZA-884-0.patch > Upgrade Jackson to 1.9.13 in hello-samz

[jira] [Commented] (SAMZA-727) Support for Kerberos

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15180430#comment-15180430 ] Yi Pan (Data Infrastructure) commented on SAMZA-727: [~capricornius], c

[jira] [Commented] (SAMZA-884) Upgrade Jackson to 1.9.13 in hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15180442#comment-15180442 ] Yi Pan (Data Infrastructure) commented on SAMZA-884: Got +1 on RB. Merg

[jira] [Commented] (SAMZA-863) Support multi-threading in samza tasks

[ https://issues.apache.org/jira/browse/SAMZA-863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15180577#comment-15180577 ] Yi Pan (Data Infrastructure) commented on SAMZA-863: [~xinyu], thanks f

[jira] [Commented] (SAMZA-727) Support for Kerberos

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15180637#comment-15180637 ] Yi Pan (Data Infrastructure) commented on SAMZA-727: [~steve_l], thanks

[jira] [Commented] (SAMZA-727) Support for Kerberos

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15181373#comment-15181373 ] Yi Pan (Data Infrastructure) commented on SAMZA-727: Hi, [~steve_l], ju

[jira] [Commented] (SAMZA-881) Re-think the Samza Job Coordinator

[ https://issues.apache.org/jira/browse/SAMZA-881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15181405#comment-15181405 ] Yi Pan (Data Infrastructure) commented on SAMZA-881: Hi, [~jagadish1...

[jira] [Commented] (SAMZA-854) Upgrade Zookeeper dependency to 3.4.3

[ https://issues.apache.org/jira/browse/SAMZA-854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15181413#comment-15181413 ] Yi Pan (Data Infrastructure) commented on SAMZA-854: [~navina], is ther

[jira] [Commented] (SAMZA-205) Bring Hello Samza in as an integration test

[ https://issues.apache.org/jira/browse/SAMZA-205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15181426#comment-15181426 ] Yi Pan (Data Infrastructure) commented on SAMZA-205: [~yatessb], sorry

[jira] [Commented] (SAMZA-813) Add Seek functionality to KeyValueStoreIterator

[ https://issues.apache.org/jira/browse/SAMZA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15183374#comment-15183374 ] Yi Pan (Data Infrastructure) commented on SAMZA-813: [~amitra123], I ad

[jira] [Commented] (SAMZA-813) Add Seek functionality to KeyValueStoreIterator

[ https://issues.apache.org/jira/browse/SAMZA-813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188357#comment-15188357 ] Yi Pan (Data Infrastructure) commented on SAMZA-813: Merged and submitt

[jira] [Commented] (SAMZA-882) Detect partition count changes in input streams

[ https://issues.apache.org/jira/browse/SAMZA-882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194406#comment-15194406 ] Yi Pan (Data Infrastructure) commented on SAMZA-882: [~navina], I have

[jira] [Created] (SAMZA-907) Make samza-sql-core and samza-sql-calcite as optionally compiled modules w/ JDK8

Yi Pan (Data Infrastructure) created SAMZA-907: -- Summary: Make samza-sql-core and samza-sql-calcite as optionally compiled modules w/ JDK8 Key: SAMZA-907 URL: https://issues.apache.org/jira/browse/SAM

[jira] [Created] (SAMZA-908) Fix dependency issues in samza-sql-calcite

Yi Pan (Data Infrastructure) created SAMZA-908: -- Summary: Fix dependency issues in samza-sql-calcite Key: SAMZA-908 URL: https://issues.apache.org/jira/browse/SAMZA-908 Project: Samza

[jira] [Created] (SAMZA-909) Merge samza-sql branch to master

Yi Pan (Data Infrastructure) created SAMZA-909: -- Summary: Merge samza-sql branch to master Key: SAMZA-909 URL: https://issues.apache.org/jira/browse/SAMZA-909 Project: Samza Issu

[jira] [Commented] (SAMZA-893) Fix a bug with host affinity request expiration introduced in SAMZA-867

[ https://issues.apache.org/jira/browse/SAMZA-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207565#comment-15207565 ] Yi Pan (Data Infrastructure) commented on SAMZA-893: [~jmaes], thanks f

[jira] [Commented] (SAMZA-908) Fix dependency issues in samza-sql-calcite

[ https://issues.apache.org/jira/browse/SAMZA-908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207573#comment-15207573 ] Yi Pan (Data Infrastructure) commented on SAMZA-908: RB available: http

[jira] [Commented] (SAMZA-908) Fix dependency issues in samza-sql-calcite

[ https://issues.apache.org/jira/browse/SAMZA-908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207575#comment-15207575 ] Yi Pan (Data Infrastructure) commented on SAMZA-908: The patch is simpl

[jira] [Updated] (SAMZA-908) Fix dependency issues in samza-sql-calcite

[ https://issues.apache.org/jira/browse/SAMZA-908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-908: --- Component/s: sql > Fix dependency issues in samza-sql-calcite > ---

[jira] [Commented] (SAMZA-908) Fix dependency issues in samza-sql-calcite

[ https://issues.apache.org/jira/browse/SAMZA-908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15209051#comment-15209051 ] Yi Pan (Data Infrastructure) commented on SAMZA-908: Merged and submitt

[jira] [Commented] (SAMZA-907) Make samza-sql-core and samza-sql-calcite as optionally compiled modules w/ JDK8

[ https://issues.apache.org/jira/browse/SAMZA-907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15209045#comment-15209045 ] Yi Pan (Data Infrastructure) commented on SAMZA-907: RB: https://review

[jira] [Updated] (SAMZA-907) Make samza-sql-core and samza-sql-calcite as optionally compiled modules w/ JDK8

[ https://issues.apache.org/jira/browse/SAMZA-907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-907: --- Attachment: SAMZA-907-0.patch > Make samza-sql-core and samza-sql-calci

[jira] [Commented] (SAMZA-907) Make samza-sql-core and samza-sql-calcite as optionally compiled modules w/ JDK8

[ https://issues.apache.org/jira/browse/SAMZA-907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15210698#comment-15210698 ] Yi Pan (Data Infrastructure) commented on SAMZA-907: Got +1 on RB. Merg

[jira] [Created] (SAMZA-914) Implement a composable operator APIs for direct programming in Java

Yi Pan (Data Infrastructure) created SAMZA-914: -- Summary: Implement a composable operator APIs for direct programming in Java Key: SAMZA-914 URL: https://issues.apache.org/jira/browse/SAMZA-914

[jira] [Created] (SAMZA-915) Design and implement operator programming APIs to support linear pipeline

Yi Pan (Data Infrastructure) created SAMZA-915: -- Summary: Design and implement operator programming APIs to support linear pipeline Key: SAMZA-915 URL: https://issues.apache.org/jira/browse/SAMZA-915

[jira] [Updated] (SAMZA-914) Implement a composable operator APIs for direct programming of DAG in Java

[ https://issues.apache.org/jira/browse/SAMZA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-914: --- Summary: Implement a composable operator APIs for direct programming of

[jira] [Created] (SAMZA-916) Design and implement operator programing APIs to support split and join

Yi Pan (Data Infrastructure) created SAMZA-916: -- Summary: Design and implement operator programing APIs to support split and join Key: SAMZA-916 URL: https://issues.apache.org/jira/browse/SAMZA-916

[jira] [Assigned] (SAMZA-914) Implement a composable operator APIs for direct programming of DAG in Java

[ https://issues.apache.org/jira/browse/SAMZA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-914: -- Assignee: Yi Pan (Data Infrastructure) > Implement a composable

[jira] [Commented] (SAMZA-914) Implement a composable operator APIs for direct programming of DAG in Java

[ https://issues.apache.org/jira/browse/SAMZA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15211072#comment-15211072 ] Yi Pan (Data Infrastructure) commented on SAMZA-914: The initial draft

[jira] [Commented] (SAMZA-914) Implement a composable operator APIs for direct programming of DAG in Java

[ https://issues.apache.org/jira/browse/SAMZA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1527#comment-1527 ] Yi Pan (Data Infrastructure) commented on SAMZA-914: Ah... sorry I forg

[jira] [Updated] (SAMZA-914) Implement a composable operator APIs for direct programming of DAG in Java

[ https://issues.apache.org/jira/browse/SAMZA-914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-914: --- Description: In the process of design/refining the physical operator la

[jira] [Commented] (SAMZA-913) CoordinatorStreamSystemConsumer drops messages when they are considered equivalent

[ https://issues.apache.org/jira/browse/SAMZA-913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15212351#comment-15212351 ] Yi Pan (Data Infrastructure) commented on SAMZA-913: Merged and submitt

[jira] [Updated] (SAMZA-886) Investigate 'relax locality' to improve Host Affinity

[ https://issues.apache.org/jira/browse/SAMZA-886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-886: --- Attachment: (was: 50_pct_match.log) > Investigate 'relax locality'

[jira] [Created] (SAMZA-925) Explicit restart containers to pick up dynamic JobModel changes

Yi Pan (Data Infrastructure) created SAMZA-925: -- Summary: Explicit restart containers to pick up dynamic JobModel changes Key: SAMZA-925 URL: https://issues.apache.org/jira/browse/SAMZA-925

[jira] [Assigned] (SAMZA-925) Explicit restart containers to pick up dynamic JobModel changes

[ https://issues.apache.org/jira/browse/SAMZA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-925: -- Assignee: Yi Pan (Data Infrastructure) > Explicit restart contai

[jira] [Updated] (SAMZA-925) Explicit restart containers to pick up dynamic JobModel changes

[ https://issues.apache.org/jira/browse/SAMZA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-925: --- Assignee: Alex Buck (was: Yi Pan (Data Infrastructure)) > Explicit res

[jira] [Commented] (SAMZA-348) Configure Samza jobs through a stream

[ https://issues.apache.org/jira/browse/SAMZA-348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15220302#comment-15220302 ] Yi Pan (Data Infrastructure) commented on SAMZA-348: Hi, [~alex.buck10]

[jira] [Commented] (SAMZA-925) Explicit restart containers to pick up dynamic JobModel changes

[ https://issues.apache.org/jira/browse/SAMZA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15220319#comment-15220319 ] Yi Pan (Data Infrastructure) commented on SAMZA-925: [~cpsoman], this m

[jira] [Commented] (SAMZA-921) Consolidate LocalityManager and TaskAssignmentManager

[ https://issues.apache.org/jira/browse/SAMZA-921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222130#comment-15222130 ] Yi Pan (Data Infrastructure) commented on SAMZA-921: Hi, [~jmaes], yeah

[jira] [Commented] (SAMZA-727) Support for Kerberos

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224526#comment-15224526 ] Yi Pan (Data Infrastructure) commented on SAMZA-727: [~steve_l], thanks

[jira] [Created] (SAMZA-929) Support AM restart in Kerberos secured YARN after the original token in launch context expires

Yi Pan (Data Infrastructure) created SAMZA-929: -- Summary: Support AM restart in Kerberos secured YARN after the original token in launch context expires Key: SAMZA-929 URL: https://issues.apache.org/j

[jira] [Commented] (SAMZA-727) Support for Kerberos

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224539#comment-15224539 ] Yi Pan (Data Infrastructure) commented on SAMZA-727: Opened a JIRA to t

[jira] [Resolved] (SAMZA-919) Add milliseconds and thread name to log4j configs.

[ https://issues.apache.org/jira/browse/SAMZA-919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-919. Resolution: Fixed +1ed on RBs. Merged and submitted. Thanks! > Add

  1   2   3   4   5   6   7   8   9   10   >