Wenlong Lyu created FLINK-4406:
--
Summary: Implement job master registration at resource manager
Key: FLINK-4406
URL: https://issues.apache.org/jira/browse/FLINK-4406
Project: Flink
Issue Type: S
Wenlong Lyu created FLINK-4414:
--
Summary: Remove restriction on RpcService.getAddress
Key: FLINK-4414
URL: https://issues.apache.org/jira/browse/FLINK-4414
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu reassigned FLINK-4406:
--
Assignee: Wenlong Lyu
> Implement job master registration at resource manager
> ---
Wenlong Lyu created FLINK-4443:
--
Summary: Add support in RpcCompletenessTest for inheritance of
RpcGateway and RpcEndpoint
Key: FLINK-4443
URL: https://issues.apache.org/jira/browse/FLINK-4443
Project: F
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu closed FLINK-4375.
--
Resolution: Invalid
> Introduce rpc protocols implemented by job manager
> -
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15447770#comment-15447770
]
Wenlong Lyu commented on FLINK-4375:
the definition will be split into special interac
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-4406:
---
Assignee: Kurt Young (was: Wenlong Lyu)
> Implement job master registration at resource manager
> ---
[
https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906815#comment-15906815
]
Wenlong Lyu commented on FLINK-6018:
I think we should just throw an exception since a
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925592#comment-15925592
]
Wenlong Lyu commented on FLINK-5756:
In RocksDB , the merge operation is processed in
Wenlong Lyu created FLINK-6162:
--
Summary: Fix bug in ByteArrayOutputStreamWithPos#setPosition
Key: FLINK-6162
URL: https://issues.apache.org/jira/browse/FLINK-6162
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952094#comment-15952094
]
Wenlong Lyu edited comment on FLINK-5989 at 4/1/17 7:10 AM:
hi
[
https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952094#comment-15952094
]
Wenlong Lyu commented on FLINK-5989:
hi, [~rmetzger], have you ever try add a module l
Wenlong Lyu created FLINK-5284:
--
Summary: Make output of bucketing sink compatible with other
processing framework like mapreduce
Key: FLINK-5284
URL: https://issues.apache.org/jira/browse/FLINK-5284
Pro
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350396#comment-15350396
]
Wenlong Lyu commented on FLINK-2144:
we also consider increment agg for sliding window
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350396#comment-15350396
]
Wenlong Lyu edited comment on FLINK-2144 at 6/27/16 7:57 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15354715#comment-15354715
]
Wenlong Lyu commented on FLINK-2144:
our solution is mostly based on this paper:
http
[
https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15391849#comment-15391849
]
Wenlong Lyu commented on FLINK-4256:
hi, Stephan, we have implemented similar solution
[
https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15391849#comment-15391849
]
Wenlong Lyu edited comment on FLINK-4256 at 7/25/16 1:14 PM:
-
Wenlong Lyu created FLINK-4271:
--
Summary: There is no way to set parallelism of operators such as
map and window produced by
Key: FLINK-4271
URL: https://issues.apache.org/jira/browse/FLINK-4271
Project
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-4271:
---
Summary: There is no way to set parallelism of operators produced by
CoGroupedStreams (was: There is
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15397140#comment-15397140
]
Wenlong Lyu commented on FLINK-4271:
I think the solution can be better. Not only the
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15397140#comment-15397140
]
Wenlong Lyu edited comment on FLINK-4271 at 7/28/16 7:05 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-4344:
---
Description:
This is the parent issue for the efforts to implement the {{JobManager}}
changes based o
Wenlong Lyu created FLINK-4375:
--
Summary: defined rpc protocols provided by job manager
Key: FLINK-4375
URL: https://issues.apache.org/jira/browse/FLINK-4375
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-4375:
---
Summary: define rpc protocols provided by job manager (was: defined rpc
protocols provided by job man
Wenlong Lyu created FLINK-4376:
--
Summary: implement job manager init procedure
Key: FLINK-4376
URL: https://issues.apache.org/jira/browse/FLINK-4376
Project: Flink
Issue Type: Sub-task
Wenlong Lyu created FLINK-4378:
--
Summary: Enable RollingSink to custom HDFS client configuration
Key: FLINK-4378
URL: https://issues.apache.org/jira/browse/FLINK-4378
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-4375:
---
Summary: Introduce rpc protocols implemented by job manager (was:
Introduce rpc protocols provided by
[
https://issues.apache.org/jira/browse/FLINK-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu reassigned FLINK-6298:
--
Assignee: Wenlong Lyu
> Local execution is not setting RuntimeContext for RichOutputFormat
> --
[
https://issues.apache.org/jira/browse/FLINK-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967343#comment-15967343
]
Wenlong Lyu commented on FLINK-6298:
It is a bug in all execution environenment, I thi
Wenlong Lyu created FLINK-5815:
--
Summary: Add resource files configuration for Yarn Mode
Key: FLINK-5815
URL: https://issues.apache.org/jira/browse/FLINK-5815
Project: Flink
Issue Type: Improvem
Wenlong Lyu created FLINK-5817:
--
Summary: Fix test concurrent execution failure by test dir
conflicts.
Key: FLINK-5817
URL: https://issues.apache.org/jira/browse/FLINK-5817
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869704#comment-15869704
]
Wenlong Lyu commented on FLINK-5817:
ok, It seems good, I will try it instead of addin
[
https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871461#comment-15871461
]
Wenlong Lyu commented on FLINK-5817:
[~shijinkui] I think the reason why you want to c
[
https://issues.apache.org/jira/browse/FLINK-5815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15874104#comment-15874104
]
Wenlong Lyu commented on FLINK-5815:
Hi, till, we have finished an implementation. I
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu closed FLINK-4378.
--
fixed
> Enable RollingSink to custom HDFS client configuration
> --
[
https://issues.apache.org/jira/browse/FLINK-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu closed FLINK-4443.
--
fixed
> Add support in RpcCompletenessTest for inheritance of RpcGateway and
> RpcEndpoint
> -
Wenlong Lyu created FLINK-5989:
--
Summary: Protobuf in akka needs to be shaded
Key: FLINK-5989
URL: https://issues.apache.org/jira/browse/FLINK-5989
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15900651#comment-15900651
]
Wenlong Lyu commented on FLINK-5989:
[~mxm] I found that you change the dependency on
Wenlong Lyu created FLINK-5749:
--
Summary: Unset HADOOP_HOME and HADOOP_CONF_DIR from system
environment when building flink
Key: FLINK-5749
URL: https://issues.apache.org/jira/browse/FLINK-5749
Project:
[
https://issues.apache.org/jira/browse/FLINK-5749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-5749:
---
Summary: unset HADOOP_HOME and HADOOP_CONF_DIR to avoid env in build
machine failing the UT and IT
Wenlong Lyu created FLINK-16864:
---
Summary: Add idle metrics for Task
Key: FLINK-16864
URL: https://issues.apache.org/jira/browse/FLINK-16864
Project: Flink
Issue Type: Improvement
Com
Wenlong Lyu created FLINK-17012:
---
Summary: Expose cost of task initialization
Key: FLINK-17012
URL: https://issues.apache.org/jira/browse/FLINK-17012
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-17012:
Summary: Expose stage of task initialization (was: Expose cost of task
initialization)
> Expose
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077193#comment-17077193
]
Wenlong Lyu commented on FLINK-17012:
-
[~chesnay] for debugging, logging maybe enoug
Wenlong Lyu created FLINK-17040:
---
Summary: SavepointWriterITCase broken
Key: FLINK-17040
URL: https://issues.apache.org/jira/browse/FLINK-17040
Project: Flink
Issue Type: Bug
Report
Wenlong Lyu created FLINK-21010:
---
Summary: Separete the implementation of StreamExecJoin
Key: FLINK-21010
URL: https://issues.apache.org/jira/browse/FLINK-21010
Project: Flink
Issue Type: Sub-t
Wenlong Lyu created FLINK-21011:
---
Summary: Separete the implementation of StreamExecJoin
Key: FLINK-21011
URL: https://issues.apache.org/jira/browse/FLINK-21011
Project: Flink
Issue Type: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-21011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu closed FLINK-21011.
---
Resolution: Duplicate
> Separete the implementation of StreamExecJoin
>
[
https://issues.apache.org/jira/browse/FLINK-21011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21011:
Summary: Separate the implementation of StreamExecIntervalJoin (was:
Separete the implementation
[
https://issues.apache.org/jira/browse/FLINK-21011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu reopened FLINK-21011:
-
> Separate the implementation of StreamExecIntervalJoin
> --
[
https://issues.apache.org/jira/browse/FLINK-5815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu closed FLINK-5815.
--
Resolution: Abandoned
> Add resource files configuration for Yarn Mode
> --
Wenlong Lyu created FLINK-8200:
--
Summary: RocksDBAsyncSnapshotTest should use temp fold instead of
fold with fixed name
Key: FLINK-8200
URL: https://issues.apache.org/jira/browse/FLINK-8200
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu reassigned FLINK-8200:
--
Assignee: Wenlong Lyu
> RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixe
Wenlong Lyu created FLINK-8201:
--
Summary: YarnResourceManagerTest causes license checking failure
Key: FLINK-8201
URL: https://issues.apache.org/jira/browse/FLINK-8201
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu reassigned FLINK-8201:
--
Assignee: Wenlong Lyu
> YarnResourceManagerTest causes license checking failure
> -
[
https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018086#comment-17018086
]
Wenlong Lyu commented on FLINK-15635:
-
hi, [~twalthr], I would like to share some mo
[
https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018617#comment-17018617
]
Wenlong Lyu edited comment on FLINK-15635 at 1/18/20 3:40 PM:
[
https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018617#comment-17018617
]
Wenlong Lyu commented on FLINK-15635:
-
[~twalthr] thanks for the explanation. I came
[
https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180209#comment-17180209
]
Wenlong Lyu commented on FLINK-12351:
-
Hi, [~jark][~trohrmann] I think we may need t
[
https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181081#comment-17181081
]
Wenlong Lyu commented on FLINK-12351:
-
[~pnowojski] As I known, it is easy to get wh
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089260#comment-17089260
]
Wenlong Lyu commented on FLINK-17012:
-
[~pnowojski] I think whether the task is read
[
https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089350#comment-17089350
]
Wenlong Lyu commented on FLINK-17313:
-
hi, all, the ticket is trying to fix the bug
[
https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089382#comment-17089382
]
Wenlong Lyu commented on FLINK-17313:
-
[~dwysakowicz] I think it is not necessary th
[
https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089472#comment-17089472
]
Wenlong Lyu commented on FLINK-17313:
-
[~dwysakowicz] Regarding LEGACY DECIMAL, I th
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091088#comment-17091088
]
Wenlong Lyu commented on FLINK-17012:
-
I have come up the same question about init t
Wenlong Lyu created FLINK-17386:
---
Summary: Exception in HadoopSecurityContextFactory.createContext
while no shaded-hadoop-lib provided.
Key: FLINK-17386
URL: https://issues.apache.org/jira/browse/FLINK-17386
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-17386:
Description:
java.io.IOException: Process execution failed due error. Error
output:java.lang.NoCl
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094097#comment-17094097
]
Wenlong Lyu commented on FLINK-17386:
-
hi [~rongr], I don't want shaded-hadoop-lib i
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094218#comment-17094218
]
Wenlong Lyu commented on FLINK-17386:
-
yes, you are right about the use case. We are
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094235#comment-17094235
]
Wenlong Lyu commented on FLINK-17386:
-
[~rongr] I run a quick test by copy the state
[
https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096232#comment-17096232
]
Wenlong Lyu commented on FLINK-17386:
-
[~rongr] I have verified the patch, it works.
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079409#comment-17079409
]
Wenlong Lyu commented on FLINK-17012:
-
[~chesnay] I think it is not a good choice to
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082008#comment-17082008
]
Wenlong Lyu commented on FLINK-17012:
-
[~chesnay] If the state is a TaskExecutor-loc
Wenlong Lyu created FLINK-17109:
---
Summary: FlinkPipelineTranslationUtil#getJobGraph doesn't consider
Jars and Classpaths in configuration.
Key: FLINK-17109
URL: https://issues.apache.org/jira/browse/FLINK-17109
Wenlong Lyu created FLINK-17110:
---
Summary: Make StreamExecutionEnvironment#configure also affects
configuration
Key: FLINK-17110
URL: https://issues.apache.org/jira/browse/FLINK-17110
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083070#comment-17083070
]
Wenlong Lyu commented on FLINK-17110:
-
[~aljoscha] I mean configuration in StreamExe
[
https://issues.apache.org/jira/browse/FLINK-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083313#comment-17083313
]
Wenlong Lyu commented on FLINK-17139:
-
in 1.10 the compile for each dml is eager:
S
Wenlong Lyu created FLINK-17141:
---
Summary: Name of SQL Operator is too long
Key: FLINK-17141
URL: https://issues.apache.org/jira/browse/FLINK-17141
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-17110:
Summary: Make StreamExecutionEnvironment#configure also affects
StreamExecutionEnvironment#configu
[
https://issues.apache.org/jira/browse/FLINK-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083957#comment-17083957
]
Wenlong Lyu commented on FLINK-17110:
-
hi, [~aljoscha][~kkl0u] Do you have any more
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084135#comment-17084135
]
Wenlong Lyu commented on FLINK-17012:
-
Treating initialization as part of deploying
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084135#comment-17084135
]
Wenlong Lyu edited comment on FLINK-17012 at 4/15/20, 2:37 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087435#comment-17087435
]
Wenlong Lyu commented on FLINK-17012:
-
hi, [~sewen] thanks for the explanation. but
Wenlong Lyu created FLINK-16279:
---
Summary: Per job Yarn application leak in normal execution mode.
Key: FLINK-16279
URL: https://issues.apache.org/jira/browse/FLINK-16279
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-16279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-16279:
Description:
I run a job in yarn per job mode using {{env.executeAsync}}, the job failed but
the
Wenlong Lyu created FLINK-21870:
---
Summary: RelDataType of TableFunction different in local and CI
Key: FLINK-21870
URL: https://issues.apache.org/jira/browse/FLINK-21870
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-21785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21785:
Affects Version/s: 1.13.0
> Support StreamExecCorrelate json serde
> -
[
https://issues.apache.org/jira/browse/FLINK-21785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21785:
Component/s: Table SQL / Planner
> Support StreamExecCorrelate json serde
> --
[
https://issues.apache.org/jira/browse/FLINK-21785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21785:
Fix Version/s: 1.13.0
> Support StreamExecCorrelate json serde
> -
[
https://issues.apache.org/jira/browse/FLINK-21785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21785:
Affects Version/s: (was: 1.13.0)
> Support StreamExecCorrelate json serde
> --
[
https://issues.apache.org/jira/browse/FLINK-21813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21813:
Component/s: Table SQL / Planner
> Support StreamExecOverAggregate json ser/de
> -
[
https://issues.apache.org/jira/browse/FLINK-21816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21816:
Fix Version/s: 1.13.0
> Support StreamExecMatch json ser/de
> ---
[
https://issues.apache.org/jira/browse/FLINK-21813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21813:
Fix Version/s: 1.13.0
> Support StreamExecOverAggregate json ser/de
>
[
https://issues.apache.org/jira/browse/FLINK-21816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-21816:
Component/s: Table SQL / Planner
> Support StreamExecMatch json ser/de
> -
Wenlong Lyu created FLINK-22020:
---
Summary: Reflections ClassNotFound when trying to deserialize a
json plan in deployment envrionment
Key: FLINK-22020
URL: https://issues.apache.org/jira/browse/FLINK-22020
[
https://issues.apache.org/jira/browse/FLINK-22020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-22020:
Attachment: error_log.png
> Reflections ClassNotFound when trying to deserialize a json plan in
>
[
https://issues.apache.org/jira/browse/FLINK-22020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-22020:
Description: after some investigation, I found that it is because we can
don't include org.reflect
[
https://issues.apache.org/jira/browse/FLINK-23159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373308#comment-17373308
]
Wenlong Lyu commented on FLINK-23159:
-
[~gaoyunhaii] Thanks for reporting the issue,
[
https://issues.apache.org/jira/browse/FLINK-23385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382009#comment-17382009
]
Wenlong Lyu commented on FLINK-23385:
-
hi, [~twalthr] I think the root cause of the
1 - 100 of 238 matches
Mail list logo
