[GitHub] samza pull request #557: Pass full config to the IO resolver

GitHub user srinipunuru opened a pull request: https://github.com/apache/samza/pull/557 Pass full config to the IO resolver SQL IO Resolver needs full configs so that it can filter out the configs specific to the source that the SQL application is interested in. This change provide

[GitHub] samza pull request #555: SAMZA-1751: Refactored metrics for table API

Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/555 ---

Re: ClassNotFoundException when loading classes via Util#getObj

Hi, Tom, We have not had this Scala+Java+Clojure combination in LinkedIn test environment yet. Let's try to remove the variables one-by-one. Could you try a simple Java+Scala test app using InMemorySystemFactory and see whether it works? If yes, I would suggest that there is some classpath issue w

Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10

Hi, Debraj, For Samza 0.14.1, we have moved to Kafka 0.11.0.2. Please try to use the new Kafka version and let us know whether you have problem upgrading or not. Thanks a lot! -Yi On Fri, Jun 15, 2018 at 8:13 AM, Debraj Manna wrote: > Just to add everything is working fine with samza 0.12 . I

[GitHub] samza pull request #556: Table API: support table in low level API

GitHub user atoomula opened a pull request: https://github.com/apache/samza/pull/556 Table API: support table in low level API Code changes to support table in low level API. You can merge this pull request into a Git repository by running: $ git pull https://github.com/atoomul

Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10

Just to add everything is working fine with samza 0.12 . I am now trying to upgrade to latest samza 0.14.1 which is causing this issue. On Fri, Jun 15, 2018 at 8:14 PM, Debraj Manna wrote: > Hi > > I am trying to use samza 0.14.2 with Kafka Client 0.10.0 . I am getting > the below exception. Is

NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10

Hi I am trying to use samza 0.14.2 with Kafka Client 0.10.0 . I am getting the below exception. Is this related to https://issues.apache.org/jira/browse/SAMZA-1509. ? Is samza 0.14.2 not compatible with 0.10 Kafka ? 2018-06-15 13:47:29.228 [main] ZooKeeper [INFO] Session: 0x164031c68f3030a closed

[GitHub] samza pull request #555: Refactored metrics for table API

GitHub user weisong44 opened a pull request: https://github.com/apache/samza/pull/555 Refactored metrics for table API Refactored metrics for table API - Added TableMetricsUtil that encapsulates required parameters, maintains naming consistency and simplifies metrics creation A