You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/10/30 22:55:00 UTC
[jira] [Updated] (SAMZA-1475) The latest branch of hello-samza
should pass compilation
[ https://issues.apache.org/jira/browse/SAMZA-1475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dong Lin updated SAMZA-1475:
----------------------------
Description:
The latest branch of hello-samza could not compile due to the following error:
{code}
$ ./gradlew jar
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=512m; support was removed in 8.0
:compileJava
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewFilterApp.java:75: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
.partitionBy(kv -> kv.value.userId, kv -> kv.value, "pageview")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:110: error: no suitable method found for partitionBy((pv)->pv.pageId,(pv)->pv,KVSerde<String,PageView>,String)
.partitionBy(pv -> pv.pageId, pv -> pv, KVSerde.of(stringSerde, pageViewSerde), "pageview")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super PageView,? extends K#1>,Function<? super PageView,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(actual and formal argument lists differ in length))
method MessageStream.<K#2,V#2>partitionBy(Function<? super PageView,? extends K#2>,Function<? super PageView,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:111: error: invalid method reference
.map(KV::getValue);
^
non-static method getValue() cannot be referenced from a static context
where V is a type-variable:
V extends Object declared in class KV
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:115: error: no suitable method found for partitionBy(AdClick::getPageId,(ac)->ac,KVSerde<String,AdClick>,String)
.partitionBy(AdClick::getPageId, ac -> ac, KVSerde.of(stringSerde, adClickSerde), "adclick")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super AdClick,? extends K#1>,Function<? super AdClick,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(actual and formal argument lists differ in length))
method MessageStream.<K#2,V#2>partitionBy(Function<? super AdClick,? extends K#2>,Function<? super AdClick,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:115: error: invalid method reference
.partitionBy(AdClick::getPageId, ac -> ac, KVSerde.of(stringSerde, adClickSerde), "adclick")
^
non-static method getPageId() cannot be referenced from a static context
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:116: error: invalid method reference
.map(KV::getValue);
^
non-static method getValue() cannot be referenced from a static context
where V is a type-variable:
V extends Object declared in class KV
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:119: error: method join in interface MessageStream<M> cannot be applied to given types;
.join(repartitionedAdClicks, pageViewAdClickJoinFunction,
^
required: MessageStream<OM>,JoinFunction<? extends K,? super PageView,? super OM,? extends JM>,Serde<K>,Serde<PageView>,Serde<OM>,Duration
found: MessageStream<AdClick>,JoinFunction<String,PageView,AdClick,JoinResult>,StringSerde,JsonSerdeV2<PageView>,JsonSerdeV2<AdClick>,Duration,String
reason: cannot infer type-variable(s) K,OM,JM
(actual and formal argument lists differ in length)
where OM,K,JM,M are type-variables:
OM extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
K extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
JM extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
M extends Object declared in interface MessageStream
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/TumblingPageViewCounterApp.java:87: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
.partitionBy(kv -> kv.value.userId, kv -> kv.value, "userId")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/TumblingPageViewCounterApp.java:89: error: cannot find symbol
kv -> kv.key, Duration.ofSeconds(5), () -> 0, (m, prevCount) -> prevCount + 1,
^
symbol: variable key
location: variable kv of type Object
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewSessionizerApp.java:90: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
.partitionBy(kv -> kv.value.userId, kv -> kv.value, "pageview")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java:115: error: method window in interface MessageStream<M> cannot be applied to given types;
.window(Windows.tumblingWindow(Duration.ofSeconds(10), WikipediaStats::new,
^
required: Window<Map<String,Object>,K,WV>
found: Window<Map<String,Object>,Void,WikipediaStats>,String
reason: cannot infer type-variable(s) K,WV
(actual and formal argument lists differ in length)
where K,WV,M are type-variables:
K extends Object declared in method <K,WV>window(Window<M,K,WV>)
WV extends Object declared in method <K,WV>window(Window<M,K,WV>)
M extends Object declared in interface MessageStream
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
11 errors
:compileJava FAILED
{code}
was:
The latest branch of hello-samza could not compile due to the following error:
```
$ ./gradlew jar
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=512m; support was removed in 8.0
:compileJava
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewFilterApp.java:75: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
.partitionBy(kv -> kv.value.userId, kv -> kv.value, "pageview")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:110: error: no suitable method found for partitionBy((pv)->pv.pageId,(pv)->pv,KVSerde<String,PageView>,String)
.partitionBy(pv -> pv.pageId, pv -> pv, KVSerde.of(stringSerde, pageViewSerde), "pageview")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super PageView,? extends K#1>,Function<? super PageView,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(actual and formal argument lists differ in length))
method MessageStream.<K#2,V#2>partitionBy(Function<? super PageView,? extends K#2>,Function<? super PageView,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:111: error: invalid method reference
.map(KV::getValue);
^
non-static method getValue() cannot be referenced from a static context
where V is a type-variable:
V extends Object declared in class KV
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:115: error: no suitable method found for partitionBy(AdClick::getPageId,(ac)->ac,KVSerde<String,AdClick>,String)
.partitionBy(AdClick::getPageId, ac -> ac, KVSerde.of(stringSerde, adClickSerde), "adclick")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super AdClick,? extends K#1>,Function<? super AdClick,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(actual and formal argument lists differ in length))
method MessageStream.<K#2,V#2>partitionBy(Function<? super AdClick,? extends K#2>,Function<? super AdClick,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:115: error: invalid method reference
.partitionBy(AdClick::getPageId, ac -> ac, KVSerde.of(stringSerde, adClickSerde), "adclick")
^
non-static method getPageId() cannot be referenced from a static context
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:116: error: invalid method reference
.map(KV::getValue);
^
non-static method getValue() cannot be referenced from a static context
where V is a type-variable:
V extends Object declared in class KV
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:119: error: method join in interface MessageStream<M> cannot be applied to given types;
.join(repartitionedAdClicks, pageViewAdClickJoinFunction,
^
required: MessageStream<OM>,JoinFunction<? extends K,? super PageView,? super OM,? extends JM>,Serde<K>,Serde<PageView>,Serde<OM>,Duration
found: MessageStream<AdClick>,JoinFunction<String,PageView,AdClick,JoinResult>,StringSerde,JsonSerdeV2<PageView>,JsonSerdeV2<AdClick>,Duration,String
reason: cannot infer type-variable(s) K,OM,JM
(actual and formal argument lists differ in length)
where OM,K,JM,M are type-variables:
OM extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
K extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
JM extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
M extends Object declared in interface MessageStream
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/TumblingPageViewCounterApp.java:87: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
.partitionBy(kv -> kv.value.userId, kv -> kv.value, "userId")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/TumblingPageViewCounterApp.java:89: error: cannot find symbol
kv -> kv.key, Duration.ofSeconds(5), () -> 0, (m, prevCount) -> prevCount + 1,
^
symbol: variable key
location: variable kv of type Object
/home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewSessionizerApp.java:90: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
.partitionBy(kv -> kv.value.userId, kv -> kv.value, "pageview")
^
method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
(cannot infer type-variable(s) K#1,V#1
(argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
(cannot infer type-variable(s) K#2,V#2
(actual and formal argument lists differ in length))
where K#1,V#1,M,K#2,V#2 are type-variables:
K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
M extends Object declared in interface MessageStream
K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
/home/dolin/research/hello-samza/src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java:115: error: method window in interface MessageStream<M> cannot be applied to given types;
.window(Windows.tumblingWindow(Duration.ofSeconds(10), WikipediaStats::new,
^
required: Window<Map<String,Object>,K,WV>
found: Window<Map<String,Object>,Void,WikipediaStats>,String
reason: cannot infer type-variable(s) K,WV
(actual and formal argument lists differ in length)
where K,WV,M are type-variables:
K extends Object declared in method <K,WV>window(Window<M,K,WV>)
WV extends Object declared in method <K,WV>window(Window<M,K,WV>)
M extends Object declared in interface MessageStream
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
11 errors
:compileJava FAILED
```
> The latest branch of hello-samza should pass compilation
> --------------------------------------------------------
>
> Key: SAMZA-1475
> URL: https://issues.apache.org/jira/browse/SAMZA-1475
> Project: Samza
> Issue Type: Bug
> Reporter: Dong Lin
>
> The latest branch of hello-samza could not compile due to the following error:
> {code}
> $ ./gradlew jar
> Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
> Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=512m; support was removed in 8.0
> :compileJava
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewFilterApp.java:75: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
> .partitionBy(kv -> kv.value.userId, kv -> kv.value, "pageview")
> ^
> method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
> (cannot infer type-variable(s) K#1,V#1
> (argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
> method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
> (cannot infer type-variable(s) K#2,V#2
> (actual and formal argument lists differ in length))
> where K#1,V#1,M,K#2,V#2 are type-variables:
> K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> M extends Object declared in interface MessageStream
> K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:110: error: no suitable method found for partitionBy((pv)->pv.pageId,(pv)->pv,KVSerde<String,PageView>,String)
> .partitionBy(pv -> pv.pageId, pv -> pv, KVSerde.of(stringSerde, pageViewSerde), "pageview")
> ^
> method MessageStream.<K#1,V#1>partitionBy(Function<? super PageView,? extends K#1>,Function<? super PageView,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
> (cannot infer type-variable(s) K#1,V#1
> (actual and formal argument lists differ in length))
> method MessageStream.<K#2,V#2>partitionBy(Function<? super PageView,? extends K#2>,Function<? super PageView,? extends V#2>) is not applicable
> (cannot infer type-variable(s) K#2,V#2
> (actual and formal argument lists differ in length))
> where K#1,V#1,M,K#2,V#2 are type-variables:
> K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> M extends Object declared in interface MessageStream
> K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:111: error: invalid method reference
> .map(KV::getValue);
> ^
> non-static method getValue() cannot be referenced from a static context
> where V is a type-variable:
> V extends Object declared in class KV
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:115: error: no suitable method found for partitionBy(AdClick::getPageId,(ac)->ac,KVSerde<String,AdClick>,String)
> .partitionBy(AdClick::getPageId, ac -> ac, KVSerde.of(stringSerde, adClickSerde), "adclick")
> ^
> method MessageStream.<K#1,V#1>partitionBy(Function<? super AdClick,? extends K#1>,Function<? super AdClick,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
> (cannot infer type-variable(s) K#1,V#1
> (actual and formal argument lists differ in length))
> method MessageStream.<K#2,V#2>partitionBy(Function<? super AdClick,? extends K#2>,Function<? super AdClick,? extends V#2>) is not applicable
> (cannot infer type-variable(s) K#2,V#2
> (actual and formal argument lists differ in length))
> where K#1,V#1,M,K#2,V#2 are type-variables:
> K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> M extends Object declared in interface MessageStream
> K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:115: error: invalid method reference
> .partitionBy(AdClick::getPageId, ac -> ac, KVSerde.of(stringSerde, adClickSerde), "adclick")
> ^
> non-static method getPageId() cannot be referenced from a static context
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:116: error: invalid method reference
> .map(KV::getValue);
> ^
> non-static method getValue() cannot be referenced from a static context
> where V is a type-variable:
> V extends Object declared in class KV
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java:119: error: method join in interface MessageStream<M> cannot be applied to given types;
> .join(repartitionedAdClicks, pageViewAdClickJoinFunction,
> ^
> required: MessageStream<OM>,JoinFunction<? extends K,? super PageView,? super OM,? extends JM>,Serde<K>,Serde<PageView>,Serde<OM>,Duration
> found: MessageStream<AdClick>,JoinFunction<String,PageView,AdClick,JoinResult>,StringSerde,JsonSerdeV2<PageView>,JsonSerdeV2<AdClick>,Duration,String
> reason: cannot infer type-variable(s) K,OM,JM
> (actual and formal argument lists differ in length)
> where OM,K,JM,M are type-variables:
> OM extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
> K extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
> JM extends Object declared in method <K,OM,JM>join(MessageStream<OM>,JoinFunction<? extends K,? super M,? super OM,? extends JM>,Serde<K>,Serde<M>,Serde<OM>,Duration)
> M extends Object declared in interface MessageStream
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/TumblingPageViewCounterApp.java:87: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
> .partitionBy(kv -> kv.value.userId, kv -> kv.value, "userId")
> ^
> method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
> (cannot infer type-variable(s) K#1,V#1
> (argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
> method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
> (cannot infer type-variable(s) K#2,V#2
> (actual and formal argument lists differ in length))
> where K#1,V#1,M,K#2,V#2 are type-variables:
> K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> M extends Object declared in interface MessageStream
> K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/TumblingPageViewCounterApp.java:89: error: cannot find symbol
> kv -> kv.key, Duration.ofSeconds(5), () -> 0, (m, prevCount) -> prevCount + 1,
> ^
> symbol: variable key
> location: variable kv of type Object
> /home/dolin/research/hello-samza/src/main/java/samza/examples/cookbook/PageViewSessionizerApp.java:90: error: no suitable method found for partitionBy((kv)->kv.v[...]serId,(kv)->kv.value,String)
> .partitionBy(kv -> kv.value.userId, kv -> kv.value, "pageview")
> ^
> method MessageStream.<K#1,V#1>partitionBy(Function<? super KV<String,PageView>,? extends K#1>,Function<? super KV<String,PageView>,? extends V#1>,KVSerde<K#1,V#1>) is not applicable
> (cannot infer type-variable(s) K#1,V#1
> (argument mismatch; String cannot be converted to KVSerde<K#1,V#1>))
> method MessageStream.<K#2,V#2>partitionBy(Function<? super KV<String,PageView>,? extends K#2>,Function<? super KV<String,PageView>,? extends V#2>) is not applicable
> (cannot infer type-variable(s) K#2,V#2
> (actual and formal argument lists differ in length))
> where K#1,V#1,M,K#2,V#2 are type-variables:
> K#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> V#1 extends Object declared in method <K#1,V#1>partitionBy(Function<? super M,? extends K#1>,Function<? super M,? extends V#1>,KVSerde<K#1,V#1>)
> M extends Object declared in interface MessageStream
> K#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> V#2 extends Object declared in method <K#2,V#2>partitionBy(Function<? super M,? extends K#2>,Function<? super M,? extends V#2>)
> /home/dolin/research/hello-samza/src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java:115: error: method window in interface MessageStream<M> cannot be applied to given types;
> .window(Windows.tumblingWindow(Duration.ofSeconds(10), WikipediaStats::new,
> ^
> required: Window<Map<String,Object>,K,WV>
> found: Window<Map<String,Object>,Void,WikipediaStats>,String
> reason: cannot infer type-variable(s) K,WV
> (actual and formal argument lists differ in length)
> where K,WV,M are type-variables:
> K extends Object declared in method <K,WV>window(Window<M,K,WV>)
> WV extends Object declared in method <K,WV>window(Window<M,K,WV>)
> M extends Object declared in interface MessageStream
> Note: Some input files use unchecked or unsafe operations.
> Note: Recompile with -Xlint:unchecked for details.
> 11 errors
> :compileJava FAILED
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)