[
https://issues.apache.org/jira/browse/FLINK-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453599#comment-16453599
]
Renkai Ge commented on FLINK-7851:
--
[~till.rohrmann] Is there an alternative way that use
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417058#comment-16417058
]
Renkai Ge commented on FLINK-2540:
--
[~uce] As far as I can see,there is no reason that th
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge reopened FLINK-2540:
--
It seems that this issue was not fixed at all.It is closed since some
github/Jira sync bugs occured.
I sti
[
https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714849#comment-15714849
]
Renkai Ge commented on FLINK-5108:
--
I think it could be ready in this weekend,sorry for t
[
https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15704795#comment-15704795
]
Renkai Ge commented on FLINK-5108:
--
I want to work for this.
> Remove ClientShutdownHook
[
https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge reassigned FLINK-5108:
Assignee: Renkai Ge
> Remove ClientShutdownHook during job execution
>
[
https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692944#comment-15692944
]
Renkai Ge commented on FLINK-5128:
--
I want to work for this.
> Get Kafka partitions in F
[
https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge reassigned FLINK-5128:
Assignee: Renkai Ge
> Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set
> ---
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15678716#comment-15678716
]
Renkai Ge edited comment on FLINK-5031 at 11/19/16 6:29 AM:
[~
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15678716#comment-15678716
]
Renkai Ge commented on FLINK-5031:
--
[~fhueske]The second split was not ignored, it was un
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675265#comment-15675265
]
Renkai Ge commented on FLINK-4587:
--
Yes,solved in the way described
Stephan Ewen (JIRA)
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666015#comment-15666015
]
Renkai Ge commented on FLINK-5031:
--
I want to work on this issue
> Consecutive DataStrea
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge reassigned FLINK-5031:
Assignee: Renkai Ge
> Consecutive DataStream.split() ignored
>
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15619663#comment-15619663
]
Renkai Ge commented on FLINK-4883:
--
I tried to implement it in module flink-scala and fli
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15611756#comment-15611756
]
Renkai Ge commented on FLINK-4883:
--
How about to extend the method
org.apache.flink.stre
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607635#comment-15607635
]
Renkai Ge commented on FLINK-4883:
--
I found a way to distinguish normal scala instances a
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15604147#comment-15604147
]
Renkai Ge commented on FLINK-4883:
--
I tried to use object to extend UDF, but I haven't go
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15600886#comment-15600886
]
Renkai Ge commented on FLINK-4883:
--
I want to work on this issue.
> Prevent UDFs impleme
[
https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509539#comment-15509539
]
Renkai Ge commented on FLINK-1605:
--
Hi [~rmetzger],
Could you help take a view at this is
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge updated FLINK-4587:
-
Component/s: Build System
> Yet another java.lang.NoSuchFieldError: INSTANCE
> ---
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15502441#comment-15502441
]
Renkai Ge edited comment on FLINK-4587 at 9/19/16 9:18 AM:
---
logs
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15502715#comment-15502715
]
Renkai Ge commented on FLINK-4587:
--
The released binary at https://flink.apache.org/downl
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge updated FLINK-4587:
-
Attachment: diff in mvn clean package.png
logs when execute mvn between root directory and flink-dist dire
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15502373#comment-15502373
]
Renkai Ge commented on FLINK-4587:
--
When I execute {code}mvn clean install -DskipTests{co
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15502120#comment-15502120
]
Renkai Ge commented on FLINK-4587:
--
the
{code}lib/flink-dist_2.10-1.2-SNAPSHOT.jar{code}
[
https://issues.apache.org/jira/browse/FLINK-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15500799#comment-15500799
]
Renkai Ge commented on FLINK-3373:
--
[~StephanEwen]
This issue seems reproduced in Flink 1
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge updated FLINK-4587:
-
Attachment: flink-explore-src.zip
> Yet another java.lang.NoSuchFieldError: INSTANCE
> ---
Renkai Ge created FLINK-4587:
Summary: Yet another java.lang.NoSuchFieldError: INSTANCE
Key: FLINK-4587
URL: https://issues.apache.org/jira/browse/FLINK-4587
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452069#comment-15452069
]
Renkai Ge commented on FLINK-4532:
--
[~StephanEwen] So should I close this issue and creat
[
https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450946#comment-15450946
]
Renkai Ge edited comment on FLINK-4532 at 8/31/16 3:33 AM:
---
[~St
[
https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450946#comment-15450946
]
Renkai Ge commented on FLINK-4532:
--
[~StephanEwen]
Yes, I think your proposal is actually
Renkai Ge created FLINK-4532:
Summary: Allow independent metrics reporter for tasks
Key: FLINK-4532
URL: https://issues.apache.org/jira/browse/FLINK-4532
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430310#comment-15430310
]
Renkai Ge edited comment on FLINK-2118 at 8/22/16 8:40 AM:
---
[~fh
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430310#comment-15430310
]
Renkai Ge commented on FLINK-2118:
--
[~fhueske][~aljoscha]
operations end with '=' have s
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15427903#comment-15427903
]
Renkai Ge commented on FLINK-2118:
--
I want to help solving this issue but I'm not sure wh
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15427893#comment-15427893
]
Renkai Ge commented on FLINK-2118:
--
[~sahitya.pavurala] ! have a higher precedence than &
Renkai Ge created FLINK-4428:
Summary: Method map/flatMapWithState may need a eviction policy
Key: FLINK-4428
URL: https://issues.apache.org/jira/browse/FLINK-4428
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425768#comment-15425768
]
Renkai Ge commented on FLINK-4282:
--
Hi, [~aljoscha]. I changed the code as your last prop
[
https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge updated FLINK-4409:
-
Description:
It seems all classes in jsr305-1.3.9.jar can be found in
flink-shaded-hadoop2-1.1.1.jar,too.
Renkai Ge created FLINK-4409:
Summary: class conflict between jsr305-1.3.9.jar and
flink-shaded-hadoop2-1.1.1.jar
Key: FLINK-4409
URL: https://issues.apache.org/jira/browse/FLINK-4409
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420137#comment-15420137
]
Renkai Ge commented on FLINK-4282:
--
[~aljoscha]I use two mod just want to prevent someone
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419763#comment-15419763
]
Renkai Ge commented on FLINK-4282:
--
Thanks,[~aljoscha].It's a brilliant idea,but the resu
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416602#comment-15416602
]
Renkai Ge commented on FLINK-4282:
--
I have the same opinion with [~aljoscha],the offset p
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416556#comment-15416556
]
Renkai Ge commented on FLINK-4282:
--
If there is no proper solution to this issue now,I wa
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge updated FLINK-4252:
-
Description:
I'm trying the table apis.
I got some errors like this
My code is in the attachments
Renkai Ge created FLINK-4252:
Summary: Table program cannot be compiled
Key: FLINK-4252
URL: https://issues.apache.org/jira/browse/FLINK-4252
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge updated FLINK-4252:
-
Attachment: TestMain.scala
> Table program cannot be compiled
>
>
>
47 matches
Mail list logo
