yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-532995742
PTAL @kl0u
--
flinkbot commented on issue #9714: [FLINK-14123]Change
taskmanager.memory.fraction default value to 0.6
URL: https://github.com/apache/flink/pull/9714#issuecomment-532994026
## CI report:
* 9c2f79d83a667cefc8364c4244f183e3798d9602 : UNKNOWN
--
flinkbot edited a comment on issue #9713: [hotfix][API/DataStream] Add missing
assert for checkpoint lock checks
URL: https://github.com/apache/flink/pull/9713#issuecomment-532988933
## CI report:
* f0fb6004eb0d0cf294f530aa0348ce23c5e701d8 : PENDING
[Build](https://travis-ci.com
flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts
for yarn job cluster
URL: https://github.com/apache/flink/pull/9711#issuecomment-532971678
## CI report:
* 2011905b5abe4cb332a60bc3f70378c777482924 : FAILURE
[Build](https://travis-ci.com/flink-ci/flin
xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add
an implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#discussion_r326013357
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/BatchOpe
xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add
an implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#discussion_r326013260
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/BatchOpe
flinkbot commented on issue #9714: [FLINK-14123]Change
taskmanager.memory.fraction default value to 0.6
URL: https://github.com/apache/flink/pull/9714#issuecomment-532990781
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
liupc opened a new pull request #9714: [FLINK-14123]Change
taskmanager.memory.fraction default value to 0.6
URL: https://github.com/apache/flink/pull/9714
## What is the purpose of the change
The default JVM Option value `NewRatio` is 2, that means the old generation
ocuppies 2/
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14123:
---
Labels: pull-request-available (was: )
> Change taskmanager.memory.fraction default value t
flinkbot commented on issue #9713: [hotfix][API/DataStream] Add missing assert
for checkpoint lock checks
URL: https://github.com/apache/flink/pull/9713#issuecomment-532988933
## CI report:
* f0fb6004eb0d0cf294f530aa0348ce23c5e701d8 : UNKNOWN
flinkbot edited a comment on issue #9712: [FLINK-13656]
[sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to
1.21.0
URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287
## CI report:
* f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE
[B
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445
## CI report:
* dc9cdc1364b9050c3d2f3cba
liupengcheng created FLINK-14123:
Summary: Change taskmanager.memory.fraction default value to 0.6
Key: FLINK-14123
URL: https://issues.apache.org/jira/browse/FLINK-14123
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933091#comment-16933091
]
Jeff Yang edited comment on FLINK-13682 at 9/19/19 6:23 AM:
flinkbot commented on issue #9713: [hotfix][API/DataStream] Add missing assert
for checkpoint lock checks
URL: https://github.com/apache/flink/pull/9713#issuecomment-532985575
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revi
[
https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933091#comment-16933091
]
Jeff Yang commented on FLINK-13682:
---
Hi, [~jark] I am already done ,Please take a lo
link3280 opened a new pull request #9713: [hotfix][API/DataStream] Add missing
assert for checkpoint lock checks
URL: https://github.com/apache/flink/pull/9713
## What is the purpose of the change
The return value of `Thread.holdsLock(checkpointLock)` is unused, which are
supposed t
[
https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13682:
---
Labels: pull-request-available (was: )
> Translate "Code Style - Scala Guide" page into Chi
flinkbot commented on issue #9712: [FLINK-13656]
[sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to
1.21.0
URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287
## CI report:
* f2b7710f65f478342de389c8e099799287ddf3f9 : UNKNOWN
-
flinkbot edited a comment on issue #9683: [FLINK-14037]Use same
userCodeClassLoader as jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778
## CI report:
* ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS
[Build](https://
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445
## CI report:
* dc9cdc1364b9050c3d2f3cba
yxu-valleytider commented on a change in pull request #9581:
[FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to
allow for easier subclassing of StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#discussion_r326002753
##
File path:
flink-stre
yxu-valleytider commented on a change in pull request #9581:
[FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to
allow for easier subclassing of StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#discussion_r326000120
##
File path:
flink-stre
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933087#comment-16933087
]
liupengcheng commented on FLINK-14037:
--
[~zhuzh]
Yes, that's weird, Maybe I think
yxu-valleytider commented on a change in pull request #9581:
[FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to
allow for easier subclassing of StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#discussion_r325999744
##
File path:
flink-stre
yxu-valleytider commented on a change in pull request #9581:
[FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to
allow for easier subclassing of StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#discussion_r326002736
##
File path:
flink-stre
yxu-valleytider commented on a change in pull request #9581:
[FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to
allow for easier subclassing of StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#discussion_r326002700
##
File path:
flink-stre
flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts
for yarn job cluster
URL: https://github.com/apache/flink/pull/9711#issuecomment-532971678
## CI report:
* 2011905b5abe4cb332a60bc3f70378c777482924 : FAILURE
[Build](https://travis-ci.com/flink-ci/flin
flinkbot edited a comment on issue #9683: [FLINK-14037]Use same
userCodeClassLoader as jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778
## CI report:
* ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS
[Build](https://
flinkbot commented on issue #9712: [FLINK-13656]
[sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to
1.21.0
URL: https://github.com/apache/flink/pull/9712#issuecomment-532978281
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I he
[
https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13656:
---
Labels: pull-request-available (was: )
> Upgrade Calcite dependency to 1.21
> -
liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as
jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#issuecomment-532977900
@aljoscha @TisonKun I find it's hard to make the classloader outside the
packagedProgram, there are lots
danny0405 opened a new pull request #9712: [FLINK-13656]
[sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to
1.21.0
URL: https://github.com/apache/flink/pull/9712
### SQL Parser
Some refactoring in flink-sql-parser
### Flink Planner
- `org.apache.calcit
flinkbot edited a comment on issue #9710: [FLINK-11859][runtime]Improve
SpanningRecordSerializer performance by serializing record length to data
buffer directly.
URL: https://github.com/apache/flink/pull/9710#issuecomment-532961713
## CI report:
* 9df06c32a009c53dce3f13c7de1289
flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts
for yarn job cluster
URL: https://github.com/apache/flink/pull/9711#issuecomment-532971678
## CI report:
* 2011905b5abe4cb332a60bc3f70378c777482924 : PENDING
[Build](https://travis-ci.com/flink-ci/flin
flinkbot commented on issue #9711: [FLINK-14033] upload user artifacts for yarn
job cluster
URL: https://github.com/apache/flink/pull/9711#issuecomment-532971678
## CI report:
* 2011905b5abe4cb332a60bc3f70378c777482924 : UNKNOWN
--
[
https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933057#comment-16933057
]
Zhenqiu Huang commented on FLINK-14033:
---
[~trohrmann][~fly_in_gis]
Would you pleas
flinkbot commented on issue #9711: [FLINK-14033] upload user artifacts for yarn
job cluster
URL: https://github.com/apache/flink/pull/9711#issuecomment-532968944
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull r
[
https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14033:
---
Labels: pull-request-available (was: )
> Distributed caches are not registered in Yarn Per
HuangZhenQiu opened a new pull request #9711: [FLINK-14033] upload user
artifacts for yarn job cluster
URL: https://github.com/apache/flink/pull/9711
## What is the purpose of the change
Upload user artifacts that registered in distributed caches for yarn job
clusters. Currently, di
carp84 commented on a change in pull request #9501: [FLINK-12697] [State
Backends] Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#discussion_r325990356
##
File path:
flink-state-backends/flink-statebackend-heap-spillable/src
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445
## CI report:
* dc9cdc1364b9050c3d2f3cba
flinkbot edited a comment on issue #9710: [FLINK-11859][runtime]Improve
SpanningRecordSerializer performance by serializing record length to data
buffer directly.
URL: https://github.com/apache/flink/pull/9710#issuecomment-532961713
## CI report:
* 9df06c32a009c53dce3f13c7de1289
carp84 commented on a change in pull request #9501: [FLINK-12697] [State
Backends] Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#discussion_r325987134
##
File path:
flink-state-backends/flink-statebackend-heap-spillable/src
carp84 commented on a change in pull request #9501: [FLINK-12697] [State
Backends] Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#discussion_r325986596
##
File path:
flink-state-backends/flink-statebackend-heap-spillable/src
flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve
SpanningRecordSerializer performance by serializing record length to data
buffer directly.
URL: https://github.com/apache/flink/pull/9710#issuecomment-532961713
## CI report:
* 9df06c32a009c53dce3f13c7de12892eb8563
flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve
SpanningRecordSerializer performance by serializing record length to data
buffer directly.
URL: https://github.com/apache/flink/pull/9710#issuecomment-532959252
Thanks a lot for your contribution to the Apache Flink project.
[
https://issues.apache.org/jira/browse/FLINK-11859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-11859:
Fix Version/s: 1.10.0
> Improve SpanningRecordSerializer performance by serializing record length
[
https://issues.apache.org/jira/browse/FLINK-11859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11859:
---
Labels: pull-request-available (was: )
> Improve SpanningRecordSerializer performance by se
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445
## CI report:
* dc9cdc1364b9050c3d2f3cba
wsry opened a new pull request #9710: [FLINK-11859][runtime]Improve
SpanningRecordSerializer performance by serializing record length to data
buffer directly.
URL: https://github.com/apache/flink/pull/9710
## What is the purpose of the change
The purpose of this pr is to improve the
gaoyunhaii commented on a change in pull request #9679: [hotfix] Fix the
comments related to side output.
URL: https://github.com/apache/flink/pull/9679#discussion_r325982849
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.jav
AT-Fieldless opened a new pull request #9350: [FLINK-13485]
[chinese-translation] Translate "Table API Example Walkthrough" page into
Chinese
URL: https://github.com/apache/flink/pull/9350
## What is the purpose of the change
Translate "Table API Example Walkthrough" page in
KarmaGYZ commented on a change in pull request #9679: [hotfix] Fix the comments
related to side output.
URL: https://github.com/apache/flink/pull/9679#discussion_r325982247
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add
an implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#discussion_r325981768
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/source/T
carp84 commented on a change in pull request #9501: [FLINK-12697] [State
Backends] Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#discussion_r325980641
##
File path:
flink-state-backends/flink-statebackend-heap-spillable/src
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445
## CI report:
* dc9cdc1364b9050c3d2f3cba
liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as
jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#issuecomment-532955334
@TisonKun @aljoscha Thanks for reply, I will update as commented.
--
zzsmdfj commented on issue #9705: [hotfix][comment]remove useless comment
URL: https://github.com/apache/flink/pull/9705#issuecomment-532953571
> Thanks for the hotfix, but IMO removed comment is not useless.
> -1 for this pr.
that comment is just meaning for "session windows UTTes
KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix
FilterableTableSource does not change after applyPredicate
URL: https://github.com/apache/flink/pull/8468#issuecomment-532953494
Never mind, it's me didn't explain my thought clear enough.
---
KarmaGYZ commented on issue #9705: [hotfix][comment]remove useless comment
URL: https://github.com/apache/flink/pull/9705#issuecomment-532950384
Thanks for the hotfix, but IMO removed comment is not useless.
-1 for this pr.
[
https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933030#comment-16933030
]
TisonKun commented on FLINK-14010:
--
[~trohrmann] Technically I agree that it is a valid
[
https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933023#comment-16933023
]
Jark Wu commented on FLINK-14118:
-
Is it only affect to 1.9? Should we also fix this in
[
https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933022#comment-16933022
]
TisonKun commented on FLINK-14112:
--
I agree with [~trohrmann]'s comments.
Another ques
HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-532946316
@suez1224 @fhueske @danny0405 Would you please take a look the PR?
This is an a
AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation]
Translate "Table API Example Walkthrough" page into Chinese
URL: https://github.com/apache/flink/pull/9350#issuecomment-532942135
> Hi @AT-Fieldless , do you have time to update this PR?
Yes, I will create a n
AT-Fieldless closed pull request #9350: [FLINK-13485] [chinese-translation]
Translate "Table API Example Walkthrough" page into Chinese
URL: https://github.com/apache/flink/pull/9350
This is an automated message from the Apa
AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation]
Translate "Table API Example Walkthrough" page into Chinese
URL: https://github.com/apache/flink/pull/9350#issuecomment-532941960
> Hi @AT-Fieldless , do you have time to update this PR?
AT-Fieldless removed a comment on issue #9350: [FLINK-13485]
[chinese-translation] Translate "Table API Example Walkthrough" page into
Chinese
URL: https://github.com/apache/flink/pull/9350#issuecomment-532941960
> Hi @AT-Fieldless , do you have time to update this PR?
---
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933009#comment-16933009
]
Zijie Lu edited comment on FLINK-14099 at 9/19/19 2:44 AM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933009#comment-16933009
]
Zijie Lu commented on FLINK-14099:
--
I have tried what you mentioned, but it seems that
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445
## CI report:
* dc9cdc1364b9050c3d2f3cba
[
https://issues.apache.org/jira/browse/FLINK-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932996#comment-16932996
]
zzsmdfj commented on FLINK-14093:
-
[~Tison] yes, you are right. I will start a discussi
[
https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932995#comment-16932995
]
Yang Wang commented on FLINK-14033:
---
[~ZhenqiuHuang]
Yeah, even many users are using -
flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445
## CI report:
* dc9cdc1364b9050c3d2f3cba
[
https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-13993:
--
Remaining Estimate: 168h
Original Estimate: 168h
> Using FlinkUserCodeClassLoaders to load the us
docete commented on a change in pull request #8706: [FLINK-12814][sql-client]
Support a traditional and scrolling view of…
URL: https://github.com/apache/flink/pull/8706#discussion_r325963191
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gat
docete commented on a change in pull request #8706: [FLINK-12814][sql-client]
Support a traditional and scrolling view of…
URL: https://github.com/apache/flink/pull/8706#discussion_r325963126
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/con
[
https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14119:
Affects Version/s: 1.9.0
> Clean idle state for RetractableTopNFunction
>
[
https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932988#comment-16932988
]
Jark Wu commented on FLINK-14119:
-
Yes. We need to cleanup the idle state in {{onTimer()
[
https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-14119:
---
Assignee: ALEC CHEN
> Clean idle state for RetractableTopNFunction
> --
docete commented on a change in pull request #8706: [FLINK-12814][sql-client]
Support a traditional and scrolling view of…
URL: https://github.com/apache/flink/pull/8706#discussion_r325960076
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/con
[
https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932982#comment-16932982
]
liupengcheng commented on FLINK-14038:
--
[~zhuzh] [~trohrmann] This PR not only prov
docete commented on a change in pull request #8706: [FLINK-12814][sql-client]
Support a traditional and scrolling view of…
URL: https://github.com/apache/flink/pull/8706#discussion_r325958937
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli
docete commented on a change in pull request #8706: [FLINK-12814][sql-client]
Support a traditional and scrolling view of…
URL: https://github.com/apache/flink/pull/8706#discussion_r325959037
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli
docete commented on a change in pull request #8706: [FLINK-12814][sql-client]
Support a traditional and scrolling view of…
URL: https://github.com/apache/flink/pull/8706#discussion_r325958597
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli
Seth Wiesman created FLINK-14122:
Summary: Extend State Processor API to read ListCheckpointed
operator state
Key: FLINK-14122
URL: https://issues.apache.org/jira/browse/FLINK-14122
Project: Flink
TisonKun commented on issue #9684: [FLINK-13992][coordination] Refactor
Optional parameter in InputGateWithMetrics#updateMetrics
URL: https://github.com/apache/flink/pull/9684#issuecomment-532922137
ping @azagrebin as a reminder :-)
-
[
https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932959#comment-16932959
]
TisonKun commented on FLINK-14109:
--
[~bremac] aha, nice to hear :-)
> Improve javadocs
tweise merged pull request #9708: [FLINK-14107][kinesis] Erroneous queue
selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9708
This is an automated message from the Apache Git Servic
tweise commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue
selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9708#issuecomment-532910734
unrelated test failure
This is an
tweise merged pull request #9709: [FLINK-14107][kinesis] Erroneous queue
selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9709
This is an automated message from the Apache Git Servic
tweise commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue
selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9709#issuecomment-532910374
unrelated test failure
This is an
flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous
queue selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597
## CI report:
* adf5d969d37c127653d77821bfa5fe48cf212a6d : FAILURE
[Build](http
flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous
queue selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619
## CI report:
* 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : FAILURE
[Build](http
flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous
queue selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619
## CI report:
* 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : PENDING
[Build](http
flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous
queue selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597
## CI report:
* adf5d969d37c127653d77821bfa5fe48cf212a6d : PENDING
[Build](http
flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue
selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597
## CI report:
* adf5d969d37c127653d77821bfa5fe48cf212a6d : UNKNOWN
---
flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue
selection in record emitter may lead to deadlock
URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619
## CI report:
* 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : UNKNOWN
---
[
https://issues.apache.org/jira/browse/FLINK-14107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-14107.
--
Fix Version/s: 1.10.0
Resolution: Fixed
> Kinesis consumer record emitter deadlock unde
1 - 100 of 339 matches
Mail list logo
