flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce
PythonScalarFunctionRunner to handle the communication with Python worker for
Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552
## CI report:
* 852555dbd
flinkbot edited a comment on issue #7013: [FLINK-5601][Checkpointing] Watermark
checkpointing
URL: https://github.com/apache/flink/pull/7013#issuecomment-532533051
## CI report:
* c81a918723a3204483b152909c3fc93f16a23ce0 : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/bui
TisonKun created FLINK-14114:
Summary: Shift down ClusterClient#timeout to RestClusterClient
Key: FLINK-14114
URL: https://issues.apache.org/jira/browse/FLINK-14114
Project: Flink
Issue Type: Sub
[
https://issues.apache.org/jira/browse/FLINK-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932133#comment-16932133
]
TisonKun commented on FLINK-14070:
--
Hi [~zhuzh] did you start working on this thread? I
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932102#comment-16932102
]
vinoyang commented on FLINK-13987:
--
I have linked it to this issue a week ago, please s
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932103#comment-16932103
]
Jiayi Liao commented on FLINK-5601:
---
[~aljoscha] Any new idea for this issue? Theorati
tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep
hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with
@Deprecated annotation
URL: https://github.com/apache/flink/pull/9691#discussion_r325500227
##
File path:
flink-core/src/test/
tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep
hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with
@Deprecated annotation
URL: https://github.com/apache/flink/pull/9691#discussion_r325500646
##
File path:
flink-core/src/test/
tillrohrmann commented on a change in pull request #9691: [FLINK-13965] Keep
hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with
@Deprecated annotation
URL: https://github.com/apache/flink/pull/9691#discussion_r325500814
##
File path:
flink-core/src/main/
[
https://issues.apache.org/jira/browse/FLINK-13949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-13949.
---
Fix Version/s: 1.10.0
Resolution: Done
Done via 88a918bcb22808947537b34cb6d9dd396f08b
KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate
on-heap and off-heap managed memory pools
URL: https://github.com/apache/flink/pull/9693#discussion_r325475374
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate
on-heap and off-heap managed memory pools
URL: https://github.com/apache/flink/pull/9693#discussion_r325472245
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate
on-heap and off-heap managed memory pools
URL: https://github.com/apache/flink/pull/9693#discussion_r325473963
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
tillrohrmann closed pull request #9699: [FLINK-13949][rest]Delete deduplicating
JobVertexDetailsInfo.VertexTa…
URL: https://github.com/apache/flink/pull/9699
This is an automated message from the Apache Git Service.
To respo
KarmaGYZ commented on a change in pull request #9693: [FLINK-13984] Separate
on-heap and off-heap managed memory pools
URL: https://github.com/apache/flink/pull/9693#discussion_r325466726
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
flinkbot edited a comment on issue #7013: [FLINK-5601][Checkpointing] Watermark
checkpointing
URL: https://github.com/apache/flink/pull/7013#issuecomment-532533051
## CI report:
* c81a918723a3204483b152909c3fc93f16a23ce0 : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/bui
tillrohrmann commented on issue #9699: [FLINK-13949][rest]Delete deduplicating
JobVertexDetailsInfo.VertexTa…
URL: https://github.com/apache/flink/pull/9699#issuecomment-532537561
Thanks a lot. Merging this PR now.
This is an
[
https://issues.apache.org/jira/browse/FLINK-14069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-14069.
---
Resolution: Done
Done via
d3137b29c3837d34ab734b1182c15b32572e41ba
155179fb5a21afd1dd69e28a
tillrohrmann closed pull request #9686: [FLINK-14069] [core] Enable TimeUtils
for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686
This is an automated message from the Apache
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685
## CI report:
* bd2624914db1147588ea838ae542333c310290cc : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127790175)
[
https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932096#comment-16932096
]
Danny Chan commented on FLINK-11936:
[~walterddr], since CALCITE-3008 has not been r
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce
PythonScalarFunctionRunner to handle the communication with Python worker for
Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552
## CI report:
* 852555dbd
flinkbot commented on issue #7013: [FLINK-5601][Checkpointing] Watermark
checkpointing
URL: https://github.com/apache/flink/pull/7013#issuecomment-532533051
## CI report:
* c81a918723a3204483b152909c3fc93f16a23ce0 : UNKNOWN
---
WeiZhong94 commented on issue #9653: [FLINK-14014][python] Introduce
PythonScalarFunctionRunner to handle the communication with Python worker for
Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#issuecomment-532529973
@dianfu Thanks a lot for the update. LGTM
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce
PythonScalarFunctionRunner to handle the communication with Python worker for
Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552
## CI report:
* 852555dbd
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931971#comment-16931971
]
lining edited comment on FLINK-13987 at 9/18/19 5:42 AM:
-
I have
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932080#comment-16932080
]
lining commented on FLINK-13987:
Could you show your JIAR about it?
> add new logs api,
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931971#comment-16931971
]
lining edited comment on FLINK-13987 at 9/18/19 5:40 AM:
-
I hava
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931971#comment-16931971
]
lining edited comment on FLINK-13987 at 9/18/19 5:39 AM:
-
I hava
[
https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932076#comment-16932076
]
Kurt Young commented on FLINK-13656:
[~danny0405] Would you like to take this issue?
[
https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932074#comment-16932074
]
Kurt Young commented on FLINK-14092:
I think we should stick to FLINK-13656, I will
[
https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-14092.
--
Resolution: Duplicate
> Upgrade Calcite version to 1.21 for Flink SQL
> --
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932070#comment-16932070
]
Zhu Zhu edited comment on FLINK-14037 at 9/18/19 5:26 AM:
--
[~li
dianfu commented on issue #9653: [FLINK-14014][python] Introduce
PythonScalarFunctionRunner to handle the communication with Python worker for
Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#issuecomment-532524299
@WeiZhong94 Thanks for the review. Make sense
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932070#comment-16932070
]
Zhu Zhu commented on FLINK-14037:
-
[~liupengcheng] I mocked this case by creating 2 jars
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685
## CI report:
* bd2624914db1147588ea838ae542333c310290cc : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127790175)
[
https://issues.apache.org/jira/browse/FLINK-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932061#comment-16932061
]
TisonKun commented on FLINK-14093:
--
[~zhaoshijie] We cannot just introduce the workarou
[
https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932059#comment-16932059
]
TisonKun commented on FLINK-14111:
--
Yes I think it is a duplication of FLINK-10052. Cou
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685
## CI report:
* bd2624914db1147588ea838ae542333c310290cc : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127790175)
[
https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932058#comment-16932058
]
TisonKun edited comment on FLINK-14112 at 9/18/19 4:56 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932058#comment-16932058
]
TisonKun commented on FLINK-14112:
--
Hi [~aaronlevin] thanks for creating this JIRA. Gen
[
https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932053#comment-16932053
]
TisonKun commented on FLINK-14109:
--
Hi [~bremac] thanks for reporting this!
There are
[
https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932048#comment-16932048
]
Canbin Zheng commented on FLINK-14078:
--
Thanks [~ykt836] !
> Introduce more JDBCDi
flinkbot edited a comment on issue #8546: [FLINK-12621]. Use MiniCluster
instead of JobExecutor
URL: https://github.com/apache/flink/pull/8546#issuecomment-532503099
## CI report:
* d3beb329bc438c726b0906ab8c97e02c084409b7 : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/b
[
https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932043#comment-16932043
]
Danny Chan commented on FLINK-14092:
Thanks for the reminder [~twalthr], there indee
zhijiangW commented on a change in pull request #9483: [FLINK-13767][task]
Refactor StreamInputProcessor#processInput based on InputStatus
URL: https://github.com/apache/flink/pull/9483#discussion_r325477987
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streamin
[
https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-13708:
---
Comment: was deleted
(was: Do you have sample code to reproduce this issue ? Because I don't see
th
flinkbot edited a comment on issue #8546: [FLINK-12621]. Use MiniCluster
instead of JobExecutor
URL: https://github.com/apache/flink/pull/8546#issuecomment-532503099
## CI report:
* d3beb329bc438c726b0906ab8c97e02c084409b7 : PENDING
[Build](https://travis-ci.com/flink-ci/flink/b
zhijiangW edited a comment on issue #9646: [FLINK-14004][task] Define
SourceReader interface to verify the integration with StreamOneInputProcessor
URL: https://github.com/apache/flink/pull/9646#issuecomment-532503656
Sorry for missing the following comments. I agree with the general above
zhijiangW commented on issue #9646: [FLINK-14004][task] Define SourceReader
interface to verify the integration with StreamOneInputProcessor
URL: https://github.com/apache/flink/pull/9646#issuecomment-532503656
Sorry for missing the following comments. I agree with the general above
point
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932011#comment-16932011
]
Zijie Lu edited comment on FLINK-14099 at 9/18/19 3:30 AM:
---
Ma
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932012#comment-16932012
]
liupengcheng commented on FLINK-14037:
--
[~zhuzh] Can you share your test code? Do y
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932011#comment-16932011
]
Zijie Lu edited comment on FLINK-14099 at 9/18/19 3:30 AM:
---
Ma
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932011#comment-16932011
]
Zijie Lu commented on FLINK-14099:
--
Maybe we can add a parameter in the function timest
flinkbot commented on issue #8546: [FLINK-12621]. Use MiniCluster instead of
JobExecutor
URL: https://github.com/apache/flink/pull/8546#issuecomment-532503099
## CI report:
* d3beb329bc438c726b0906ab8c97e02c084409b7 : UNKNOWN
-
zhuzhurk edited a comment on issue #9688: [FLINK-13056] [runtime] Introduce
FastRestartPipelinedRegionStrategy which has better failover handling
performance at the cost of slower region building and more memory used
URL: https://github.com/apache/flink/pull/9688#issuecomment-532262379
> H
TisonKun commented on issue #8546: [FLINK-12621]. Use MiniCluster instead of
JobExecutor
URL: https://github.com/apache/flink/pull/8546#issuecomment-532500733
ref #9643 and
[FLINK-13961](https://issues.apache.org/jira/browse/FLINK-13961).
--
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932007#comment-16932007
]
Zijie Lu commented on FLINK-14099:
--
I agree with [~felixzheng], So does the rowtime fie
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932004#comment-16932004
]
vinoyang commented on FLINK-13987:
--
[~lining] Right, IMO, the existed implementation is
flinkbot edited a comment on issue #9025: [FLINK-13149][Web Frontend] support
configuration and update Angular to 8.0 version
URL: https://github.com/apache/flink/pull/9025#issuecomment-512173118
## CI report:
* e2ae53781367b527fd4d77a4a63ae3b8f354a810 : FAILURE
[Build](https://
[
https://issues.apache.org/jira/browse/FLINK-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jie TANG updated FLINK-13149:
-
Description:
The new web UI looks nice, but there are still some problems when I try to
integrate it in
[
https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932003#comment-16932003
]
Zijie Lu commented on FLINK-13746:
--
Is [Terror] logged in the $FLINK_DIR/log? In the t
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931999#comment-16931999
]
Canbin Zheng edited comment on FLINK-14099 at 9/18/19 3:09 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931999#comment-16931999
]
Canbin Zheng edited comment on FLINK-14099 at 9/18/19 3:08 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jie TANG updated FLINK-13149:
-
Description:
The new web UI looks nice, but there are still some problems when I try to
integrate it in
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931999#comment-16931999
]
Canbin Zheng commented on FLINK-14099:
--
+1. I think Computed column is a more gene
[
https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-14100:
--
Assignee: Canbin Zheng
> Introduce OracleDialect
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-14078:
--
Assignee: Canbin Zheng
> Introduce more JDBCDialect implementations
> ---
[
https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-14101:
--
Assignee: Canbin Zheng
> Introduce SqlServerDialect
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-14102:
--
Assignee: Canbin Zheng
> Introduce DB2Dialect
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931993#comment-16931993
]
Kurt Young commented on FLINK-14078:
Thanks [~felixzheng], I will assign these jiras
flinkbot edited a comment on issue #9025: [FLINK-13149][Web Frontend] support
configuration and update Angular to 8.0 version
URL: https://github.com/apache/flink/pull/9025#issuecomment-512173118
## CI report:
* e2ae53781367b527fd4d77a4a63ae3b8f354a810 : FAILURE
[Build](https://
WeiZhong94 commented on a change in pull request #9653: [FLINK-14014][python]
Introduce PythonScalarFunctionRunner to handle the communication with Python
worker for Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#discussion_r325458729
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931980#comment-16931980
]
Canbin Zheng commented on FLINK-14078:
--
Thanks for the quick response [~ykt836] !
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931977#comment-16931977
]
Zijie Lu commented on FLINK-14099:
--
I use a kafka connector and describe a schema as ro
jinglining edited a comment on issue #9699: [FLINK-13949][rest]Delete
deduplicating JobVertexDetailsInfo.VertexTa…
URL: https://github.com/apache/flink/pull/9699#issuecomment-532483390
> Thanks for this PR @jinglining. LGTM. Have you tried whether the web UI is
still displaying all subtask
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931971#comment-16931971
]
lining commented on FLINK-13987:
I hava disscussed with till about that pr. It has updat
[
https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
apus66 updated FLINK-13856:
---
Comment: was deleted
(was: Hi [~StephanEwen] Can you help me review the code and assign this task to
me? W
KurtYoung commented on a change in pull request #8468:
[FLINK-12399][table][table-planner] Fix FilterableTableSource does not change
after applyPredicate
URL: https://github.com/apache/flink/pull/8468#discussion_r325453512
##
File path:
flink-table/flink-table-planner/src/main/sca
[
https://issues.apache.org/jira/browse/FLINK-14096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931962#comment-16931962
]
TisonKun commented on FLINK-14096:
--
FYI
https://lists.apache.org/x/thread.html/e6536ad
jinglining commented on issue #9699: [FLINK-13949][rest]Delete deduplicating
JobVertexDetailsInfo.VertexTa…
URL: https://github.com/apache/flink/pull/9699#issuecomment-532483390
> Thanks for this PR @jinglining. LGTM. Have you tried whether the web UI is
still displaying all subtask execut
[
https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931960#comment-16931960
]
Kurt Young commented on FLINK-14078:
I think split into some subtasks is a good idea
[
https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931959#comment-16931959
]
Canbin Zheng commented on FLINK-14078:
--
[~ykt836] [~lzljs3620320] Yes, so there's
[
https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931955#comment-16931955
]
Jingsong Lee commented on FLINK-14078:
--
> Just want to clarify, does this only take
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931954#comment-16931954
]
Jingsong Lee commented on FLINK-14099:
--
The problem I've encountered is that I want
TisonKun created FLINK-14113:
Summary: Remove class JobWithJars
Key: FLINK-14113
URL: https://issues.apache.org/jira/browse/FLINK-14113
Project: Flink
Issue Type: Sub-task
Components: C
[
https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931944#comment-16931944
]
Kurt Young commented on FLINK-14078:
Just want to clarify, does this only take effec
[
https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931917#comment-16931917
]
Timo Walther commented on FLINK-14092:
--
[~danny0405] can you check if this is a dup
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931915#comment-16931915
]
Timo Walther commented on FLINK-14099:
--
Could you share a use case/example with us?
[
https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931901#comment-16931901
]
Elias Levy commented on FLINK-14111:
Probable related to FLINK-10052.
> Flink shou
Aaron Levin created FLINK-14112:
---
Summary: Removing zookeeper state should cause the task manager
and job managers to restart
Key: FLINK-14112
URL: https://issues.apache.org/jira/browse/FLINK-14112
Proj
Aaron Levin created FLINK-14111:
---
Summary: Flink should be robust to a non-leader Zookeeper host
going down
Key: FLINK-14111
URL: https://issues.apache.org/jira/browse/FLINK-14111
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aaron Levin updated FLINK-14110:
Description:
Suppose {{state.backend.rocksdb.localdir}} is configured as:
{noformat}
state.backend
Aaron Levin created FLINK-14110:
---
Summary: Deleting state.backend.rocksdb.localdir causes silent
failure
Key: FLINK-14110
URL: https://issues.apache.org/jira/browse/FLINK-14110
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brendan MacDonell updated FLINK-14109:
--
Description:
My team at Sight Machine just finished building a custom HA backend for o
Brendan MacDonell created FLINK-14109:
-
Summary: Improve javadocs and tests for high-availability backend
Key: FLINK-14109
URL: https://issues.apache.org/jira/browse/FLINK-14109
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-14107:
-
Summary: Kinesis consumer record emitter deadlock under event time
alignment (was: Kinesis cons
[
https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931775#comment-16931775
]
Jeffrey Martin commented on FLINK-14076:
Confirmed: the issue is that FlinkKafka
flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous
queue selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9702#issuecomment-532344762
## CI report:
* b5d14cefce1ec689f991fcc0e02bb229195f4418 : SUCCESS
[Build](http
flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous
queue selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9702#issuecomment-532344762
## CI report:
* b5d14cefce1ec689f991fcc0e02bb229195f4418 : PENDING
[Build](http
1 - 100 of 345 matches
Mail list logo
