[
https://issues.apache.org/jira/browse/FLINK-32480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754403#comment-17754403
]
Kezhu Wang commented on FLINK-32480:
Flink never provide such a guarantee. The "Expe
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503954#comment-17503954
]
Kezhu Wang commented on FLINK-21564:
[~pedrosbs] [~renqs] I think it has been fixed
[
https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-12491:
---
Fix Version/s: 1.14.0
> Incorrect documentation for directory path separators of CoreOptions.TMP_DIR
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21564:
---
Fix Version/s: 1.14.0
> CommonTestUtils.waitUntilCondition could fail with condition meets before
>
[
https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-12491:
---
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Incorrect documentati
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-11409:
---
Fix Version/s: 2.0.0
> Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces
> --
[
https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329916#comment-17329916
]
Kezhu Wang commented on FLINK-12491:
I guess it is still valid.
> Incorrect documen
[
https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21317:
---
Fix Version/s: 1.13.1
1.14.0
> Downstream keyed state not work after FlinkKafkaSh
[
https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329911#comment-17329911
]
Kezhu Wang commented on FLINK-21317:
[~flink-jira-bot] Still valid. I will update fi
[
https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329910#comment-17329910
]
Kezhu Wang commented on FLINK-21578:
Still valid. I will update fix version to 1.14
[
https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21578:
---
Fix Version/s: 1.14.0
> Closeable Sink Committer/GlobalCommitter were created to function in onestep
[
https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21578:
---
Labels: (was: stale-major)
> Closeable Sink Committer/GlobalCommitter were created to function in
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21564:
---
Labels: pull-request-available (was: pull-request-available stale-assigned)
> CommonTestUtils.waitU
[
https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-22345:
---
Attachment: (was: image.png)
> CoordinatorEventsExactlyOnceITCase hangs on azure
> -
[
https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-22345:
---
Attachment: image.png
> CoordinatorEventsExactlyOnceITCase hangs on azure
>
[
https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319367#comment-17319367
]
Kezhu Wang commented on FLINK-21996:
bq. We cannot trigger checkpoints while we are
[
https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319358#comment-17319358
]
Kezhu Wang commented on FLINK-21996:
[~sewen] Taking no source tasks into account, t
[
https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318962#comment-17318962
]
Kezhu Wang commented on FLINK-18071:
Sure, I will take a look at. Thanks for deliver
[
https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318585#comment-17318585
]
Kezhu Wang edited comment on FLINK-21996 at 4/10/21, 8:11 PM:
[
https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318585#comment-17318585
]
Kezhu Wang commented on FLINK-21996:
Is there any design guarantee for no source ope
[
https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316150#comment-17316150
]
Kezhu Wang commented on FLINK-21386:
Hi [~dwysakowicz], I could give it a try.
> Fr
[
https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314987#comment-17314987
]
Kezhu Wang commented on FLINK-18071:
Hi all, I pushed a [poc
branch|https://github
[
https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314074#comment-17314074
]
Kezhu Wang commented on FLINK-18071:
Hi all, I dug and thought some time about this.
Kezhu Wang created FLINK-22108:
--
Summary: Ephemeral socket address was checkpointed to state and
restored back in CollectSinkOperatorCoordinator
Key: FLINK-22108
URL: https://issues.apache.org/jira/browse/FLINK-22108
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310387#comment-17310387
]
Kezhu Wang commented on FLINK-21990:
A {{disableChaining}} in between failed source
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310372#comment-17310372
]
Kezhu Wang commented on FLINK-21990:
Ideally, this should be fixed in
[1.12.2|https
[
https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307891#comment-17307891
]
Kezhu Wang commented on FLINK-21821:
Good catch [~pnowojski]. But this would also ri
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307580#comment-17307580
]
Kezhu Wang commented on FLINK-20329:
Another case:
https://dev.azure.com/apache-fli
[
https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang closed FLINK-21821.
--
Resolution: Not A Problem
> Clean up Task/StreamTask cancellation and remove unnecessary concurrency
[
https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307117#comment-17307117
]
Kezhu Wang commented on FLINK-21578:
bq. Make createCommitter return non-optional ob
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307116#comment-17307116
]
Kezhu Wang commented on FLINK-21133:
[~sewen] [~becket_qin] Good news!
> FLIP-27 So
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307100#comment-17307100
]
Kezhu Wang commented on FLINK-21133:
[~trohrmann] [~pnowojski] [~becket_qin] [~sewen
[
https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307087#comment-17307087
]
Kezhu Wang commented on FLINK-21386:
Hi [~chesnay] could I take over this ?
> FromE
[
https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307086#comment-17307086
]
Kezhu Wang commented on FLINK-21317:
Hi [~ym] [~pnowojski], anyone is working on thi
[
https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307079#comment-17307079
]
Kezhu Wang commented on FLINK-21817:
+1 for gradual procedure.
{quote} But we may ev
[
https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307050#comment-17307050
]
Kezhu Wang commented on FLINK-21821:
I am going to close this ticket as there is no
[
https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307040#comment-17307040
]
Kezhu Wang commented on FLINK-21467:
I also think it is part of FLIP-147 [~pnowojski
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306896#comment-17306896
]
Kezhu Wang commented on FLINK-21564:
A small improvement is still a good. I will ope
[
https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306807#comment-17306807
]
Kezhu Wang commented on FLINK-21626:
[~roman_khachatryan] Thanks, I will.
> Conside
[
https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306805#comment-17306805
]
Kezhu Wang commented on FLINK-21817:
I guess we four are probably talking about two
[
https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306227#comment-17306227
]
Kezhu Wang commented on FLINK-21467:
Hi [~pnowojski], here are my imaginative paths
[
https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305690#comment-17305690
]
Kezhu Wang edited comment on FLINK-21821 at 3/21/21, 2:42 PM:
[
https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305690#comment-17305690
]
Kezhu Wang commented on FLINK-21821:
Thanks for more context [~pnowojski]. After clo
[
https://issues.apache.org/jira/browse/FLINK-21798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303080#comment-17303080
]
Kezhu Wang commented on FLINK-21798:
[~xintongsong] You are right. It is always a go
[
https://issues.apache.org/jira/browse/FLINK-21798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303047#comment-17303047
]
Kezhu Wang commented on FLINK-21798:
Inspired by [pr-15246|https://github.com/apache
[
https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302745#comment-17302745
]
Kezhu Wang commented on FLINK-21728:
[~dwysakowicz] [~pnowojski] Good catch!
But I
Kezhu Wang created FLINK-21821:
--
Summary: StreamTask.cancelables was closed concurrent between task
canceler and task thread
Key: FLINK-21821
URL: https://issues.apache.org/jira/browse/FLINK-21821
Projec
[
https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302442#comment-17302442
]
Kezhu Wang commented on FLINK-21728:
I guess so.
There are actually two cases:
1.
Kezhu Wang created FLINK-21817:
--
Summary: FLIP-27 Source might break subtask and split assignment
upon rescale
Key: FLINK-21817
URL: https://issues.apache.org/jira/browse/FLINK-21817
Project: Flink
Kezhu Wang created FLINK-21806:
--
Summary: ContinuousEventTimeTrigger should register its first
timer base on current watermark
Key: FLINK-21806
URL: https://issues.apache.org/jira/browse/FLINK-21806
Proj
[
https://issues.apache.org/jira/browse/FLINK-11408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302181#comment-17302181
]
Kezhu Wang commented on FLINK-11408:
I think it is same as FLINK-5717 and similar to
[
https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301856#comment-17301856
]
Kezhu Wang commented on FLINK-21728:
[~dwysakowicz] You are right. That is not possi
[
https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301506#comment-17301506
]
Kezhu Wang commented on FLINK-21753:
[~nicholasjiang] Only that two branches need th
[
https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301504#comment-17301504
]
Kezhu Wang commented on FLINK-21419:
[~xintongsong] Thanks for the backgrounds and e
[
https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301408#comment-17301408
]
Kezhu Wang commented on FLINK-21419:
Glad to see, we all lean to fail concurrent fre
[
https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301395#comment-17301395
]
Kezhu Wang commented on FLINK-21753:
HI [~xintongsong], I am interesting in fix for
[
https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301166#comment-17301166
]
Kezhu Wang commented on FLINK-21728:
After hundred rounds in my local environment, I
[
https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301066#comment-17301066
]
Kezhu Wang commented on FLINK-21467:
Hi [~pnowojski], I guess it depends on various
[
https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21626:
---
Fix Version/s: 1.13.0
> Consider shaping newly introduced RuntimeContext.getJobId to return JobID
>
[
https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300887#comment-17300887
]
Kezhu Wang commented on FLINK-21578:
[~gaoyunhaii] Not exactly. The problem is inter
[
https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300846#comment-17300846
]
Kezhu Wang commented on FLINK-21753:
It is a good direction, master does not have th
Kezhu Wang created FLINK-21753:
--
Summary: Cycle references between memory manager and gc cleaner
action
Key: FLINK-21753
URL: https://issues.apache.org/jira/browse/FLINK-21753
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300222#comment-17300222
]
Kezhu Wang commented on FLINK-21419:
# detecting concurrent frees: To detect and gua
[
https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300149#comment-17300149
]
Kezhu Wang commented on FLINK-21419:
>From all my experiences, native resources shou
[
https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300138#comment-17300138
]
Kezhu Wang commented on FLINK-21419:
Hi [~xintongsong] & [~nicholasjiang], I think t
[
https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299989#comment-17299989
]
Kezhu Wang commented on FLINK-21419:
Coming from FLINK-21728, given the severity of
[
https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299749#comment-17299749
]
Kezhu Wang commented on FLINK-21728:
[~dwysakowicz] Installing {{openjdk-8-dbg}} giv
[
https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299284#comment-17299284
]
Kezhu Wang commented on FLINK-21578:
Hi [~gaoyunhaii], in current situation there is
[
https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298744#comment-17298744
]
Kezhu Wang commented on FLINK-21317:
Hi [~ym], you are right,
`KeyGroupRangeAssignm
[
https://issues.apache.org/jira/browse/FLINK-21635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296011#comment-17296011
]
Kezhu Wang commented on FLINK-21635:
I think we could go through `Nullable` first to
[
https://issues.apache.org/jira/browse/FLINK-21635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295979#comment-17295979
]
Kezhu Wang commented on FLINK-21635:
[~jark] Thank you for inspiration. I thought a
Kezhu Wang created FLINK-21635:
--
Summary: Driver name is optional for DriverManager.getConnection
but a must in JdbcConnectionOptions
Key: FLINK-21635
URL: https://issues.apache.org/jira/browse/FLINK-21635
Kezhu Wang created FLINK-21626:
--
Summary: Consider shaping newly introduced RuntimeContext.getJobId
to return JobID with no Optional wrapper
Key: FLINK-21626
URL: https://issues.apache.org/jira/browse/FLINK-21626
[
https://issues.apache.org/jira/browse/FLINK-21522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295736#comment-17295736
]
Kezhu Wang commented on FLINK-21522:
Hi for all watchers and subscribers, the report
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295040#comment-17295040
]
Kezhu Wang commented on FLINK-21564:
[~nicholasjiang] Not about simplification, but
[
https://issues.apache.org/jira/browse/FLINK-21581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294977#comment-17294977
]
Kezhu Wang commented on FLINK-21581:
[~roman_khachatryan] [~chesnay] Sorry for borin
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294959#comment-17294959
]
Kezhu Wang commented on FLINK-21564:
[~nicholasjiang] I guess the procedure you draw
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294510#comment-17294510
]
Kezhu Wang commented on FLINK-21564:
Hi [~nicholasjiang], I would prefer following d
Kezhu Wang created FLINK-21578:
--
Summary: Closeable Sink Committer/GlobalCommitter were created to
function in onestep during job graph composition
Key: FLINK-21578
URL: https://issues.apache.org/jira/browse/FLINK-21
[
https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294216#comment-17294216
]
Kezhu Wang commented on FLINK-17510:
https://dev.azure.com/apache-flink/apache-flink
Kezhu Wang created FLINK-21564:
--
Summary: CommonTestUtils.waitUntilCondition could fail with
condition meets before
Key: FLINK-21564
URL: https://issues.apache.org/jira/browse/FLINK-21564
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292839#comment-17292839
]
Kezhu Wang commented on FLINK-21386:
[~chesnay] It works for function also, I have v
[
https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292765#comment-17292765
]
Kezhu Wang commented on FLINK-21386:
[~chesnay] Combination of #1 and #3 could solv
[
https://issues.apache.org/jira/browse/FLINK-21025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292359#comment-17292359
]
Kezhu Wang commented on FLINK-21025:
Another instance
https://dev.azure.com/apache-
Kezhu Wang created FLINK-21522:
--
Summary: Iterative stream could not work with stop-with-savepoint
Key: FLINK-21522
URL: https://issues.apache.org/jira/browse/FLINK-21522
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292316#comment-17292316
]
Kezhu Wang commented on FLINK-21467:
Hi [~pnowojski], I think the "non deterministic
[
https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292152#comment-17292152
]
Kezhu Wang commented on FLINK-21386:
I think implementing {{OutputTypeConfigurable}}
[
https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291751#comment-17291751
]
Kezhu Wang commented on FLINK-20658:
[~jark] Sorry for so late response. I confirmed
[
https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290781#comment-17290781
]
Kezhu Wang commented on FLINK-21467:
Hi [~pnowojski], I see the possibility. But I t
Kezhu Wang created FLINK-21467:
--
Summary: Document possible recommended usage of
Bounded{One/Multi}Input.endInput and emphasize that they could be called
multiple times
Key: FLINK-21467
URL: https://issues.apache.or
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288477#comment-17288477
]
Kezhu Wang commented on FLINK-21133:
[~trohrmann] Great summarization!
About user-c
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287735#comment-17287735
]
Kezhu Wang commented on FLINK-21133:
[~becket_qin] [~pnowojski] [~sewen] Thanks all
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285319#comment-17285319
]
Kezhu Wang edited comment on FLINK-21133 at 2/16/21, 4:21 PM:
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285319#comment-17285319
]
Kezhu Wang commented on FLINK-21133:
{quote}But this assumption doesn't hold with th
[
https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285250#comment-17285250
]
Kezhu Wang commented on FLINK-21317:
[~pnowojski] Yeh, I could prepare a fix if my p
[
https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285207#comment-17285207
]
Kezhu Wang commented on FLINK-21133:
{quote}I think what stop-with-savepoint should
[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284169#comment-17284169
]
Kezhu Wang commented on FLINK-21214:
Another instance:
https://dev.azure.com/apache
[
https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283726#comment-17283726
]
Kezhu Wang commented on FLINK-20580:
{quote}
If we want to support null values, then
[
https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283680#comment-17283680
]
Kezhu Wang commented on FLINK-20580:
I am kind of prefer third option.
If we allow
[
https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283659#comment-17283659
]
Kezhu Wang commented on FLINK-20580:
Hi [~trohrmann], after digging a bit, I think w
1 - 100 of 195 matches
Mail list logo
