Apache project meetup in ShangHai Sep 21st

Hi, We would like to hold a meetup in ShangHai Sep 21st by inviting some Apache members ( Craig Russell, Justin Mclean, Willem Jiang）and some apache projects committers in China like we did last year. We hold this meetup can help Apache projects to know each other in China. As there are lot of Ap

Re:RE: what is the measure sink recoreds method used for

Thanks , Lionel . 1. If the result records can only be sink into hdfs filesystem, that means griffin has strong dependence on hdfs, and other system like s3 can not get the result records . 2. Could the metrics and records be sink into one components like ElasticSearch or Mongo ? 3. Why shou

Re:RE: what is the measure sink recoreds method used for

At 2019-08-20 21:24:37, "Lionel, Liu" wrote: >Hi, > >The sinkRecords method is not implemented in these kinds of sinks. You should >notice that there are two kinds of sink methods in trait Sink, sinkRecords >method persist the mismatched records of original data set, which is in large

[jira] [Work logged] (GRIFFIN-281) Add custom sink testcase

[ https://issues.apache.org/jira/browse/GRIFFIN-281?focusedWorklogId=297924&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-297924 ] ASF GitHub Bot logged work on GRIFFIN-281: -- Author: ASF GitHub Bot

[GitHub] [griffin] guoyuepeng commented on issue #524: [GRIFFIN-281] Add custom sink testcase

guoyuepeng commented on issue #524: [GRIFFIN-281] Add custom sink testcase URL: https://github.com/apache/griffin/pull/524#issuecomment-523045458 LGTM This is an automated message from the Apache Git Service. To respond to the

[jira] [Resolved] (GRIFFIN-271) Before 0.6.0 milestone release, We need to check and trim current codes against apache griffin dev guide

[ https://issues.apache.org/jira/browse/GRIFFIN-271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] William Guo resolved GRIFFIN-271. - Resolution: Fixed Issue resolved by pull request 522 [https://github.com/apache/griffin/pull/522

[jira] [Work logged] (GRIFFIN-271) Before 0.6.0 milestone release, We need to check and trim current codes against apache griffin dev guide

[ https://issues.apache.org/jira/browse/GRIFFIN-271?focusedWorklogId=297895&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-297895 ] ASF GitHub Bot logged work on GRIFFIN-271: -- Author: ASF GitHub Bot

[GitHub] [griffin] asfgit closed pull request #522: [GRIFFIN-271] Before 0.6.0 milestone release, We need to check and tr…

asfgit closed pull request #522: [GRIFFIN-271] Before 0.6.0 milestone release, We need to check and tr… URL: https://github.com/apache/griffin/pull/522 This is an automated message from the Apache Git Service. To respond to

[jira] [Work logged] (GRIFFIN-271) Before 0.6.0 milestone release, We need to check and trim current codes against apache griffin dev guide

[ https://issues.apache.org/jira/browse/GRIFFIN-271?focusedWorklogId=297894&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-297894 ] ASF GitHub Bot logged work on GRIFFIN-271: -- Author: ASF GitHub Bot

[GitHub] [griffin] guoyuepeng commented on issue #522: [GRIFFIN-271] Before 0.6.0 milestone release, We need to check and tr…

guoyuepeng commented on issue #522: [GRIFFIN-271] Before 0.6.0 milestone release, We need to check and tr… URL: https://github.com/apache/griffin/pull/522#issuecomment-523027565 LGTM This is an automated message from the Apac

RE: what is the measure sink recoreds method used for

Hi, The sinkRecords method is not implemented in these kinds of sinks. You should notice that there are two kinds of sink methods in trait Sink, sinkRecords method persist the mismatched records of original data set, which is in large size, and sinkMetrics method persist the metric of a measure

[jira] [Updated] (GRIFFIN-281) Add custom sink testcase

[ https://issues.apache.org/jira/browse/GRIFFIN-281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wan kun updated GRIFFIN-281: Summary: Add custom sink testcase (was: Add custom sink test) > Add custom sink testcase > --

[jira] [Work logged] (GRIFFIN-281) Add custom sink test

[ https://issues.apache.org/jira/browse/GRIFFIN-281?focusedWorklogId=297661&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-297661 ] ASF GitHub Bot logged work on GRIFFIN-281: -- Author: ASF GitHub Bot

[GitHub] [griffin] wankunde opened a new pull request #524: [GRIFFIN-281] Add custom sink test

wankunde opened a new pull request #524: [GRIFFIN-281] Add custom sink test URL: https://github.com/apache/griffin/pull/524 Add custom sink test. I also have two question: 1. In `ConsoleSink`,`ElasticSearchSink`,`MongoSink` , the `sinkRecords` method doesn't really sink records ?

[jira] [Created] (GRIFFIN-281) Add custom sink test

wan kun created GRIFFIN-281: --- Summary: Add custom sink test Key: GRIFFIN-281 URL: https://issues.apache.org/jira/browse/GRIFFIN-281 Project: Griffin Issue Type: Task Reporter: wan kun