[jira] [Commented] (SAMZA-969) allow empty serde for SystemStream for SystemConsumer

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

[jira] [Commented] (SAMZA-969) allow empty serde for SystemStream for SystemConsumer

[ https://issues.apache.org/jira/browse/SAMZA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15337214#comment-15337214 ] Yi Pan (Data Infrastructure) commented on SAMZA-969: +1. Merged and submitted. Thanks!

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

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-727: --- Attachment: SAMZA-727-9.patch Fixed some license and checkstyle issues

[jira] [Updated] (SAMZA-855) Upgrade Samza's Kafka client version to 0.9.0.0

[ https://issues.apache.org/jira/browse/SAMZA-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-855: --- Assignee: Robert Crim > Upgrade Samza's Kafka client version to

[jira] [Commented] (SAMZA-957) Avoid unnecessary KV Store flushes (part 3)

[ https://issues.apache.org/jira/browse/SAMZA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15319620#comment-15319620 ] Yi Pan (Data Infrastructure) commented on SAMZA-957: Merged and submitted. Thanks! >

[jira] [Commented] (SAMZA-855) Upgrade Samza's Kafka client version to 0.9.0.0

[ https://issues.apache.org/jira/browse/SAMZA-855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15318884#comment-15318884 ] Yi Pan (Data Infrastructure) commented on SAMZA-855: [~rjc...@gmail.com], glad that you

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

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-727: --- Attachment: SAMZA-727.7.patch [~capricornius], I have updated the

[jira] [Commented] (SAMZA-680) Invert the JobCoordinator and AM logic

[ https://issues.apache.org/jira/browse/SAMZA-680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15313147#comment-15313147 ] Yi Pan (Data Infrastructure) commented on SAMZA-680: Merged and submitted. Thanks! >

[jira] [Created] (SAMZA-955) Upgrade RocksDB JNI to 4.5.1

Yi Pan (Data Infrastructure) created SAMZA-955: -- Summary: Upgrade RocksDB JNI to 4.5.1 Key: SAMZA-955 URL: https://issues.apache.org/jira/browse/SAMZA-955 Project: Samza Issue

[jira] [Commented] (SAMZA-870) RocksDBException: Invalid argument: Compression type Snappy is not linked with the binary

[ https://issues.apache.org/jira/browse/SAMZA-870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304941#comment-15304941 ] Yi Pan (Data Infrastructure) commented on SAMZA-870: [~staslos], thanks for confirming!

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

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15302985#comment-15302985 ] Yi Pan (Data Infrastructure) commented on SAMZA-727: [~capricornius], Thanks a lot! I

[jira] [Commented] (SAMZA-951) Improve event loop timing metrics

[ https://issues.apache.org/jira/browse/SAMZA-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15299227#comment-15299227 ] Yi Pan (Data Infrastructure) commented on SAMZA-951: Merged and submitted. Thanks! >

[jira] [Commented] (SAMZA-949) KafkaCheckpointManager should not try forever for non-recoverable checkpoint deserialization failures

[ https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298927#comment-15298927 ] Yi Pan (Data Infrastructure) commented on SAMZA-949: [~TaoFeng], it is related but

[jira] [Commented] (SAMZA-870) RocksDBException: Invalid argument: Compression type Snappy is not linked with the binary

[ https://issues.apache.org/jira/browse/SAMZA-870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15292156#comment-15292156 ] Yi Pan (Data Infrastructure) commented on SAMZA-870: Jose and [~edi_b...@yahoo.com], I

[jira] [Commented] (SAMZA-950) Add backward-compatible KafkaSystemProducer constructor for Java clients

[ https://issues.apache.org/jira/browse/SAMZA-950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15292115#comment-15292115 ] Yi Pan (Data Infrastructure) commented on SAMZA-950: [~jmakes], merged and submitted.

[jira] [Created] (SAMZA-949) KafkaCheckpointManager should not try forever for non-recoverable checkpoint deserialization failures

Yi Pan (Data Infrastructure) created SAMZA-949: -- Summary: KafkaCheckpointManager should not try forever for non-recoverable checkpoint deserialization failures Key: SAMZA-949 URL:

[jira] [Commented] (SAMZA-948) CoordinatorStreamSystemConsumer is not threadsafe.

[ https://issues.apache.org/jira/browse/SAMZA-948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282226#comment-15282226 ] Yi Pan (Data Infrastructure) commented on SAMZA-948: Merged and submitted. Thanks! >

[jira] [Commented] (SAMZA-852) Better logging when system can not be created

[ https://issues.apache.org/jira/browse/SAMZA-852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15281846#comment-15281846 ] Yi Pan (Data Infrastructure) commented on SAMZA-852: +1. Merged and submitted. Thanks!

[jira] [Commented] (SAMZA-947) TaskAssignmentManager registration exception when partition count changes.

[ https://issues.apache.org/jira/browse/SAMZA-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15281601#comment-15281601 ] Yi Pan (Data Infrastructure) commented on SAMZA-947: +1. Merged and submitted. Thanks!

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

[ https://issues.apache.org/jira/browse/SAMZA-929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15261290#comment-15261290 ] Yi Pan (Data Infrastructure) commented on SAMZA-929: Hi, [~capricornius], if you have

[jira] [Updated] (SAMZA-937) Correct URL to Coda's metrics library

[ https://issues.apache.org/jira/browse/SAMZA-937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-937: --- Assignee: Robin Tweedie > Correct URL to Coda's metrics library >

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

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

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

[ https://issues.apache.org/jira/browse/SAMZA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258759#comment-15258759 ] Yi Pan (Data Infrastructure) commented on SAMZA-727: Nevermind, I found the

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

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

[jira] [Updated] (SAMZA-944) Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser

[ https://issues.apache.org/jira/browse/SAMZA-944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-944: --- Affects Version/s: 0.10.0 > Broadcast stream is not added properly in

[jira] [Updated] (SAMZA-944) Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser

[ https://issues.apache.org/jira/browse/SAMZA-944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-944: --- Fix Version/s: 0.10.1 > Broadcast stream is not added properly in the

[jira] [Created] (SAMZA-942) Document the core set of metrics Samza generate

Yi Pan (Data Infrastructure) created SAMZA-942: -- Summary: Document the core set of metrics Samza generate Key: SAMZA-942 URL: https://issues.apache.org/jira/browse/SAMZA-942 Project:

[jira] [Created] (SAMZA-941) fix the bug containsValue method in MapConfig

Yi Pan (Data Infrastructure) created SAMZA-941: -- Summary: fix the bug containsValue method in MapConfig Key: SAMZA-941 URL: https://issues.apache.org/jira/browse/SAMZA-941 Project: Samza

[jira] [Commented] (SAMZA-911) Abandon producer retry after a certain # of errors

[ https://issues.apache.org/jira/browse/SAMZA-911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15251291#comment-15251291 ] Yi Pan (Data Infrastructure) commented on SAMZA-911: [~jagadish1...@gmail.com], added

[jira] [Updated] (SAMZA-911) Abandon producer retry after a certain # of errors

[ https://issues.apache.org/jira/browse/SAMZA-911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-911: --- Fix Version/s: 0.10.1 > Abandon producer retry after a certain # of

[jira] [Updated] (SAMZA-938) KV-store API changes should be backward compatible to 0.10

[ https://issues.apache.org/jira/browse/SAMZA-938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-938: --- Affects Version/s: 0.10.1 > KV-store API changes should be backward

[jira] [Created] (SAMZA-938) KV-store API changes should be backward compatible to 0.10

Yi Pan (Data Infrastructure) created SAMZA-938: -- Summary: KV-store API changes should be backward compatible to 0.10 Key: SAMZA-938 URL: https://issues.apache.org/jira/browse/SAMZA-938

[jira] [Updated] (SAMZA-924) Add disk space monitoring

[ https://issues.apache.org/jira/browse/SAMZA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-924: --- Fix Version/s: 0.10.1 > Add disk space monitoring >

[jira] [Updated] (SAMZA-920) BrokerProxy.abdicateAll can get stuck on adding and removing the same partitions infinitely

[ https://issues.apache.org/jira/browse/SAMZA-920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-920: --- Fix Version/s: 0.10.1 > BrokerProxy.abdicateAll can get stuck on

[jira] [Updated] (SAMZA-920) BrokerProxy.abdicateAll can get stuck on adding and removing the same partitions infinitely

[ https://issues.apache.org/jira/browse/SAMZA-920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-920: --- Assignee: Ivan Simoneko > BrokerProxy.abdicateAll can get stuck on

[jira] [Commented] (SAMZA-906) Host Affinity - Minimize task reassignment when container count changes

[ https://issues.apache.org/jira/browse/SAMZA-906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15225374#comment-15225374 ] Yi Pan (Data Infrastructure) commented on SAMZA-906: Thanks! Merged and committed. >

[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

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

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

[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:

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

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

[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=15222130#comment-15222130 ] Yi Pan (Data Infrastructure) commented on SAMZA-921: Hi, [~jmaes], yeah, your

[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=15220319#comment-15220319 ] Yi Pan (Data Infrastructure) commented on SAMZA-925: [~cpsoman], this may be something

[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=15220302#comment-15220302 ] Yi Pan (Data Infrastructure) commented on SAMZA-348: Hi, [~alex.buck10], I have created

[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

[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

[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] [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=15212351#comment-15212351 ] Yi Pan (Data Infrastructure) commented on SAMZA-913: Merged and submitted. Thanks! >

[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

[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=1527#comment-1527 ] Yi Pan (Data Infrastructure) commented on SAMZA-914: Ah... sorry I forgot that. It is

[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=15211072#comment-15211072 ] Yi Pan (Data Infrastructure) commented on SAMZA-914: The initial draft of operator

[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] [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] [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-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] [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=15210698#comment-15210698 ] Yi Pan (Data Infrastructure) commented on SAMZA-907: Got +1 on RB. Merged and

[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

[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=15209045#comment-15209045 ] Yi Pan (Data Infrastructure) commented on SAMZA-907: RB:

[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=15209051#comment-15209051 ] Yi Pan (Data Infrastructure) commented on SAMZA-908: Merged and submitted to samza-sql

[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=15207575#comment-15207575 ] Yi Pan (Data Infrastructure) commented on SAMZA-908: The patch is simple. Hence,

[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=15207573#comment-15207573 ] Yi Pan (Data Infrastructure) commented on SAMZA-908: RB available:

[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=15207565#comment-15207565 ] Yi Pan (Data Infrastructure) commented on SAMZA-893: [~jmaes], thanks for splitting the

[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

[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-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:

[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=15183374#comment-15183374 ] Yi Pan (Data Infrastructure) commented on SAMZA-813: [~amitra123], I added one comment

[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=15181426#comment-15181426 ] Yi Pan (Data Infrastructure) commented on SAMZA-205: [~yatessb], sorry to chime in

[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=15181413#comment-15181413 ] Yi Pan (Data Infrastructure) commented on SAMZA-854: [~navina], is there any specific

[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=15181405#comment-15181405 ] Yi Pan (Data Infrastructure) commented on SAMZA-881: Hi, [~jagadish1...@gmail.com], the

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

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

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

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

[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=15180577#comment-15180577 ] Yi Pan (Data Infrastructure) commented on SAMZA-863: [~xinyu], thanks for the design

[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=15180442#comment-15180442 ] Yi Pan (Data Infrastructure) commented on SAMZA-884: Got +1 on RB. Merged and

[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

[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=15180226#comment-15180226 ] Yi Pan (Data Infrastructure) commented on SAMZA-882: [~jarradk], thanks for your input.

[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=15176690#comment-15176690 ] Yi Pan (Data Infrastructure) commented on SAMZA-813: Hi, [~amitra123], thanks! I will

[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=15176663#comment-15176663 ] Yi Pan (Data Infrastructure) commented on SAMZA-884: Hm... sorry I missed that. This

[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-878) upgrade Jackson to 1.9.13

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

[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

[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=15157367#comment-15157367 ] Yi Pan (Data Infrastructure) commented on SAMZA-609: [~naveenatceg], is this fixed w/

[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-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=15154604#comment-15154604 ] Yi Pan (Data Infrastructure) commented on SAMZA-872: +1. Merged and submitted both

[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=15154574#comment-15154574 ] Yi Pan (Data Infrastructure) commented on SAMZA-864: [~boryas], thanks! I took the

[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

[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=15154517#comment-15154517 ] Yi Pan (Data Infrastructure) commented on SAMZA-689: Hi, revisiting this one now and it

[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=15153079#comment-15153079 ] Yi Pan (Data Infrastructure) commented on SAMZA-876: Hi, [~edi_b...@yahoo.com], since

[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

[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=15152903#comment-15152903 ] Yi Pan (Data Infrastructure) commented on SAMZA-872: Thanks a lot [~banecogic]. Could

[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=15152845#comment-15152845 ] Yi Pan (Data Infrastructure) commented on SAMZA-873: +1. Merged and submitted. Thanks!

[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

[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) >

[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] [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=15152725#comment-15152725 ] Yi Pan (Data Infrastructure) commented on SAMZA-873: Cool! I will take a look asap.

[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=15152687#comment-15152687 ] Yi Pan (Data Infrastructure) commented on SAMZA-873: [~nico...@movio.co], could you

[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=15149969#comment-15149969 ] Yi Pan (Data Infrastructure) commented on SAMZA-864: Also, I noticed that you have

[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=15149942#comment-15149942 ] Yi Pan (Data Infrastructure) commented on SAMZA-864: Thanks, [~boryas]. I applied the

[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=15145609#comment-15145609 ] Yi Pan (Data Infrastructure) commented on SAMZA-836: Finally got it to work! The

[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=15145658#comment-15145658 ] Yi Pan (Data Infrastructure) commented on SAMZA-836: The issue is reported to RocksDb

<    1   2   3   4   5   6   7   8   >