YufeiLiu created FLINK-26800:
Summary: write small data file using share write buffer manager
Key: FLINK-26800
URL: https://issues.apache.org/jira/browse/FLINK-26800
Project: Flink
Issue Type: Bu
YufeiLiu created FLINK-23008:
Summary: Upload file not exist when submit job use RestClient
Key: FLINK-23008
URL: https://issues.apache.org/jira/browse/FLINK-23008
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277082#comment-17277082
]
YufeiLiu commented on FLINK-21208:
--
[~hxbks2ks] I still have a question, I haven't use
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275661#comment-17275661
]
YufeiLiu edited comment on FLINK-21208 at 1/30/21, 4:01 PM:
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275661#comment-17275661
]
YufeiLiu commented on FLINK-21208:
--
I've made some discoveries, I found beam has a conf
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-21208:
-
Comment: was deleted
(was: I found that have start more than one beam worker, and seems share the
same
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275546#comment-17275546
]
YufeiLiu edited comment on FLINK-21208 at 1/30/21, 10:25 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275546#comment-17275546
]
YufeiLiu commented on FLINK-21208:
--
I've found that beam worker wasn't exit after job f
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-21208:
-
Affects Version/s: 1.12.1
> pyarrow exception when using window with pandas udaf
> -
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-21208:
-
Issue Type: Bug (was: Improvement)
> pyarrow exception when using window with pandas udaf
> ---
YufeiLiu created FLINK-21208:
Summary: pyarrow exception when using window with pandas udaf
Key: FLINK-21208
URL: https://issues.apache.org/jira/browse/FLINK-21208
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251604#comment-17251604
]
YufeiLiu commented on FLINK-18983:
--
Hi [~ym] We already have a fix in our internal bran
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250910#comment-17250910
]
YufeiLiu commented on FLINK-18983:
--
[~ym] Thanks for you response.
I'm using {{StreamFi
[
https://issues.apache.org/jira/browse/FLINK-20496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-20496:
-
Comment: was deleted
(was: What do you think about this, and I'd like to take this ticket if it's
neces
[
https://issues.apache.org/jira/browse/FLINK-20496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1725#comment-1725
]
YufeiLiu commented on FLINK-20496:
--
What do you think about this, and I'd like to take
[
https://issues.apache.org/jira/browse/FLINK-20496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1726#comment-1726
]
YufeiLiu commented on FLINK-20496:
--
What do you think about this, and I'd like to take
[
https://issues.apache.org/jira/browse/FLINK-20496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-20496:
-
Description:
When using RocksDBStateBackend and enabling
{{state.backend.rocksdb.memory.managed}} and
YufeiLiu created FLINK-20496:
Summary: RocksDB partitioned index filter option
Key: FLINK-20496
URL: https://issues.apache.org/jira/browse/FLINK-20496
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239547#comment-17239547
]
YufeiLiu commented on FLINK-20375:
--
+1 for this.
I think it's necessary to provide a wa
[
https://issues.apache.org/jira/browse/FLINK-15940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu closed FLINK-15940.
Resolution: Won't Fix
> Flink TupleSerializer and CaseClassSerializer shoud support serialize and
> deser
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-18983:
-
Description:
If a operator throw a exception, it will break process loop and dispose all
operator. But
YufeiLiu created FLINK-19322:
Summary: Specified parallelism in create table operation
Key: FLINK-19322
URL: https://issues.apache.org/jira/browse/FLINK-19322
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-18983:
-
Description:
If a operator throw a exception, it will break process loop and dispose all
operator. But
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-18983:
-
Description:
If a operator throw a exception, it will break process loop and dispose all
operator. But
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu closed FLINK-18983.
Resolution: Not A Bug
> Job doesn't changed to failed if close function has blocked
>
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu reopened FLINK-18983:
--
> Job doesn't changed to failed if close function has blocked
> --
YufeiLiu created FLINK-18983:
Summary: Job doesn't changed to failed if close function has
blocked
Key: FLINK-18983
URL: https://issues.apache.org/jira/browse/FLINK-18983
Project: Flink
Issue Ty
YufeiLiu created FLINK-18234:
Summary: Implicit type conversion in join condition
Key: FLINK-18234
URL: https://issues.apache.org/jira/browse/FLINK-18234
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-18212:
-
Description:
Throw exception
{code}
Caused by: scala.MatchError: (CONCAT(_UTF-16LE'Hello',
$2),_UTF-1
YufeiLiu created FLINK-18212:
Summary: Init lookup join failed when use udf on lookup table
Key: FLINK-18212
URL: https://issues.apache.org/jira/browse/FLINK-18212
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-18179:
-
Description:
When execute sql like this, will throw expection
"org.apache.flink.table.planner.codegen.
YufeiLiu created FLINK-18179:
Summary: Apply AggregateProjectPullUpConstantsRule after
WindowPropertiesRules
Key: FLINK-18179
URL: https://issues.apache.org/jira/browse/FLINK-18179
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126599#comment-17126599
]
YufeiLiu commented on FLINK-18070:
--
I still didn't get it, could you give me a example
[
https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125952#comment-17125952
]
YufeiLiu commented on FLINK-18070:
--
[~libenchao]
process time have already been materi
[
https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125587#comment-17125587
]
YufeiLiu commented on FLINK-18070:
--
[~libenchao] I feel uncertain about why we need "_m
[
https://issues.apache.org/jira/browse/FLINK-18111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-18111:
-
Description:
When execute sql like this will throw exception
"org.apache.calcite.sql.validate.SqlValida
YufeiLiu created FLINK-18111:
Summary: LATERAL query failed when use create view syntax
Key: FLINK-18111
URL: https://issues.apache.org/jira/browse/FLINK-18111
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124894#comment-17124894
]
YufeiLiu commented on FLINK-18070:
--
[~libenchao] Sure, I'd love to contribute. Please a
YufeiLiu created FLINK-18070:
Summary: Time attribute been materialized after sub graph optimize
Key: FLINK-18070
URL: https://issues.apache.org/jira/browse/FLINK-18070
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074517#comment-17074517
]
YufeiLiu commented on FLINK-16938:
--
Hi [~jark], but at this point, convert DataStream t
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074397#comment-17074397
]
YufeiLiu edited comment on FLINK-16938 at 4/3/20, 8:33 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074397#comment-17074397
]
YufeiLiu edited comment on FLINK-16938 at 4/3/20, 8:26 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074397#comment-17074397
]
YufeiLiu commented on FLINK-16938:
--
Hi [~jark], I think timestamp doesn't have timezon
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074255#comment-17074255
]
YufeiLiu commented on FLINK-16938:
--
It wasn't I want to use SqlTimestamp, because of bl
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073683#comment-17073683
]
YufeiLiu edited comment on FLINK-16938 at 4/2/20, 12:41 PM:
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073683#comment-17073683
]
YufeiLiu commented on FLINK-16938:
--
[~jark] Sorry I didn't describe clearly. That code
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073511#comment-17073511
]
YufeiLiu commented on FLINK-16938:
--
org.apache.flink.table.api.ValidationException: Fie
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073504#comment-17073504
]
YufeiLiu commented on FLINK-16938:
--
[~jark] Here is the test demo. I know use {{Instant
[
https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073461#comment-17073461
]
YufeiLiu commented on FLINK-16938:
--
cc [~jark]
> SqlTimestamp has lag when convert lo
YufeiLiu created FLINK-16938:
Summary: SqlTimestamp has lag when convert long to Timestamp
Key: FLINK-16938
URL: https://issues.apache.org/jira/browse/FLINK-16938
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-16599:
-
Description:
{code:sql}
CREATE TABLE source {
origin STRING,
col1 AS FUN_1(origin),
col2 AS FUN_2(
YufeiLiu created FLINK-16599:
Summary: Throw Unknown identifier when having nested computed
column
Key: FLINK-16599
URL: https://issues.apache.org/jira/browse/FLINK-16599
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-16526:
-
Comment: was deleted
(was: [~jark] -Hi, I tried cherrypick to my branch, but UT
{{testKeywordsWithWater
[
https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464
]
YufeiLiu edited comment on FLINK-16526 at 3/13/20, 7:29 AM:
[
https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464
]
YufeiLiu edited comment on FLINK-16526 at 3/13/20, 7:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464
]
YufeiLiu edited comment on FLINK-16526 at 3/13/20, 7:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464
]
YufeiLiu edited comment on FLINK-16526 at 3/13/20, 6:53 AM:
[
https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464
]
YufeiLiu edited comment on FLINK-16526 at 3/13/20, 6:53 AM:
[
https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464
]
YufeiLiu commented on FLINK-16526:
--
[~jark] Hi, I tried cherrypick to my branch, but UT
YufeiLiu created FLINK-16526:
Summary: Escape character doesn't work for computed column
Key: FLINK-16526
URL: https://issues.apache.org/jira/browse/FLINK-16526
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17047581#comment-17047581
]
YufeiLiu commented on FLINK-15832:
--
Hi, [~chesnay]
I have the same issue, and disable
[
https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046515#comment-17046515
]
YufeiLiu commented on FLINK-16215:
--
[~xintongsong] LGTM. I think can handle almost all
[
https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046335#comment-17046335
]
YufeiLiu commented on FLINK-16215:
--
[~xintongsong] I'm thinking about to reuse the slot
[
https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046195#comment-17046195
]
YufeiLiu commented on FLINK-16215:
--
[~xintongsong]
This sounds good. We can do some act
[
https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045565#comment-17045565
]
YufeiLiu edited comment on FLINK-16215 at 2/26/20 2:12 PM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045565#comment-17045565
]
YufeiLiu edited comment on FLINK-16215 at 2/26/20 2:08 PM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045565#comment-17045565
]
YufeiLiu commented on FLINK-16215:
--
[~xintongsong] I understand your concern, so we can
YufeiLiu created FLINK-16215:
Summary: Start redundant TaskExecutor when JM failed
Key: FLINK-16215
URL: https://issues.apache.org/jira/browse/FLINK-16215
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039932#comment-17039932
]
YufeiLiu commented on FLINK-15959:
--
[~xintongsong] Sorry, I was wrong about that, it wo
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039875#comment-17039875
]
YufeiLiu commented on FLINK-15959:
--
[~xintongsong] I'm worried about the uncertainty, l
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039149#comment-17039149
]
YufeiLiu commented on FLINK-15959:
--
[~xintongsong] Hi, I've got a problem and I need so
YufeiLiu created FLINK-16145:
Summary: ScheduledUnit toString method throw NPE when Execution is
null
Key: FLINK-16145
URL: https://issues.apache.org/jira/browse/FLINK-16145
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038072#comment-17038072
]
YufeiLiu commented on FLINK-15959:
--
[~xintongsong]Got it, check total Executors less th
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038071#comment-17038071
]
YufeiLiu commented on FLINK-15959:
--
[~xintongsong] Got it, check total Executors less t
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Comment: was deleted
(was: [~xintongsong] Got it, check total Executors less than maximum before
startN
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17037773#comment-17037773
]
YufeiLiu commented on FLINK-15959:
--
[~karmagyz] Thanks for your suggestion, I did ignor
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17037130#comment-17037130
]
YufeiLiu commented on FLINK-15959:
--
I've made some modification of description accordin
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Comment: was deleted
(was: I've made some modification of description according to the comments,
please
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17037120#comment-17037120
]
YufeiLiu edited comment on FLINK-15959 at 2/14/20 5:25 PM:
---
I'
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17037127#comment-17037127
]
YufeiLiu commented on FLINK-15959:
--
I've made some modification of description accordin
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Comment: was deleted
(was: I've made some modification of description according to the comments,
please
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17037120#comment-17037120
]
YufeiLiu commented on FLINK-15959:
--
I've made some modification of description accordin
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Description:
Flink removed `-n` option after FLIP-6, change to ResourceManager start a new
worker when
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Issue Type: Improvement (was: New Feature)
> Add min/max number of slots configuration to limit total n
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Description:
Flink removed `-n` option after FLIP-6, change to ResourceManager start a new
worker when
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Description:
Flink removed `-n` option after FLIP-6, change to ResourceManager start a new
worker when
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034238#comment-17034238
]
YufeiLiu edited comment on FLINK-15959 at 2/11/20 8:33 AM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034238#comment-17034238
]
YufeiLiu commented on FLINK-15959:
--
[~sewen] I also feel like it's a backwards when I p
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034218#comment-17034218
]
YufeiLiu commented on FLINK-15959:
--
Hi [~xintongsong]
Thanks for your suggestions. It d
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Description:
Flink removed `-n` option after FLIP-6, change to ResourceManager start a new
worker when
YufeiLiu created FLINK-15959:
Summary: Add TaskExecutor number option in FlinkYarnSessionCli
Key: FLINK-15959
URL: https://issues.apache.org/jira/browse/FLINK-15959
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Description:
Flink removed `-n` option after FLIP-6, change to ResourceManager start a new
worker when
[
https://issues.apache.org/jira/browse/FLINK-15940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15940:
-
Description:
It's allready support copy NULL value in
[FLINK-14642|https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-15940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15940:
-
Description:
It's allready support copy NULL value in
[FLINK-14642|https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-15940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15940:
-
Description:
It's allready support copy NULL value in
[FLINK-14642|https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-15940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15940:
-
Description:
It's allready support copy NULL value in
[FLINK-14642|https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-15940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15940:
-
Description:
It's allready support copy NULL value in
[FLINK-14642|https://issues.apache.org/jira/brows
YufeiLiu created FLINK-15940:
Summary: Flink TupleSerializer and CaseClassSerializer shoud
support serialize and deserialize NULL value
Key: FLINK-15940
URL: https://issues.apache.org/jira/browse/FLINK-15940
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031591#comment-17031591
]
YufeiLiu commented on FLINK-12122:
--
[~trohrmann]I think should not start execution befo
[
https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019322#comment-17019322
]
YufeiLiu commented on FLINK-14642:
--
[~victor-wong] Didn't support `serialize` and `dese
1 - 100 of 120 matches
Mail list logo
