[
https://issues.apache.org/jira/browse/FLINK-14951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991708#comment-16991708
]
Andrey Zagrebin commented on FLINK-14951:
-
True we could firstly set
[
https://issues.apache.org/jira/browse/FLINK-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15161:
---
Labels: pull-request-available (was: )
> Introduce TypeTransformation interface and basic
wuchong opened a new pull request #10500: [FLINK-15161][table-common] Introduce
TypeTransformation interface and basic transformations
URL: https://github.com/apache/flink/pull/10500
## What is the purpose of the change
Introduce `TypeTransformation` interface to
[
https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-15139:
---
Summary: misc end to end test failed cause loss jars in converting to
jobgraph (was: misc end to
[
https://issues.apache.org/jira/browse/FLINK-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991707#comment-16991707
]
Aljoscha Krettek commented on FLINK-14834:
--
This issue can be clossed when FLINK-15013 is
[
https://issues.apache.org/jira/browse/FLINK-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-14834:
Assignee: (was: Aljoscha Krettek)
> Kerberized YARN on Docker test fails on
[
https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-15139:
---
Component/s: (was: Tests)
Table SQL / Client
> misc end to end test failed on
flinkbot edited a comment on issue #10499: [FLINK-14170] [flink-hadoop-fs]
Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder
URL: https://github.com/apache/flink/pull/10499#issuecomment-563281882
## CI report:
* dbeb4cd748d6e81404fccddc95ab87517a9c7b85 Travis:
flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add
documentation for memory control of RocksDB state backend
URL: https://github.com/apache/flink/pull/10498#issuecomment-563242008
## CI report:
* dd347fe423313a8bb7c975e3f04ba626fe5dd1b2 Travis:
[
https://issues.apache.org/jira/browse/FLINK-15129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991705#comment-16991705
]
Aljoscha Krettek commented on FLINK-15129:
--
This raises the interesting point, that it is a bit
flinkbot edited a comment on issue #10497: [FLINK-14992][client] Add job
listener to execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563230075
## CI report:
* c2bbd3752050a609680b68f2bf4f92457ba360b1 UNKNOWN
*
azagrebin commented on a change in pull request #10348: [FLINK-14951][tests]
Harden the thread safety of State TTL backend tests
URL: https://github.com/apache/flink/pull/10348#discussion_r355516266
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991704#comment-16991704
]
Piotr Nowojski commented on FLINK-15103:
[~xintongsong] [~azagrebin], [~sewen] was explaining to
Timo Walther created FLINK-15162:
Summary: Merge Java and Scala ClosureCleaner
Key: FLINK-15162
URL: https://issues.apache.org/jira/browse/FLINK-15162
Project: Flink
Issue Type: Improvement
flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs
to contain jobmanager component label
URL: https://github.com/apache/flink/pull/10496#issuecomment-563198013
## CI report:
* 793df2e323b4f84433f99f21515b30a21524658c Travis:
Jark Wu created FLINK-15161:
---
Summary: Introduce TypeTransformation interface and basic
transformations
Key: FLINK-15161
URL: https://issues.apache.org/jira/browse/FLINK-15161
Project: Flink
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java]
StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959
## CI report:
* 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:
flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass
configuration to the underlying ExecutionEnvironment from TableEnvironment
URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619
## CI report:
* e0b1afaebe5bd4fc07e61785a38ef82f55e16f69
[
https://issues.apache.org/jira/browse/FLINK-15067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-15067.
Resolution: Fixed
Implemented in bb6fd8281654be2a4e03a04c09e755525ec058ca
> Pass
dawidwys merged pull request #10431: [FLINK-15067][table] Pass configuration
to the underlying ExecutionEnvironment from TableEnvironment
URL: https://github.com/apache/flink/pull/10431
This is an automated message from
flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs
to contain jobmanager component label
URL: https://github.com/apache/flink/pull/10496#issuecomment-563198013
## CI report:
* 793df2e323b4f84433f99f21515b30a21524658c Travis:
flinkbot commented on issue #10499: [FLINK-14170] [flink-hadoop-fs] Support
hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder
URL: https://github.com/apache/flink/pull/10499#issuecomment-563281882
## CI report:
* dbeb4cd748d6e81404fccddc95ab87517a9c7b85 UNKNOWN
flinkbot edited a comment on issue #10497: [FLINK-14992][client] Add job
listener to execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563230075
## CI report:
* c2bbd3752050a609680b68f2bf4f92457ba360b1 UNKNOWN
*
azagrebin commented on issue #10387: [FLINK-14949] [Runtime/Task] Task
cancellation can be stuck against out-of-thread error
URL: https://github.com/apache/flink/pull/10387#issuecomment-563279007
Thanks for working on this @pnowojski and @hwanju !
No big concerns from my side.
I
[
https://issues.apache.org/jira/browse/FLINK-14376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-14376.
--
Fix Version/s: 1.10.0
Resolution: Fixed
> Introduce the Executor abstraction (FLIP-73)
[
https://issues.apache.org/jira/browse/FLINK-14916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reopened FLINK-14916:
> Asynchronously deploy cluster in AbstractJobClusterExecutor#execute
>
[
https://issues.apache.org/jira/browse/FLINK-14916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-14916.
--
Resolution: Won't Fix
> Asynchronously deploy cluster in AbstractJobClusterExecutor#execute
>
[
https://issues.apache.org/jira/browse/FLINK-14916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-14916.
--
Resolution: Fixed
For a clean Jira I will close this until the discussion in
flinkbot edited a comment on issue #10495: [FLINK-15151][table-planner-blink]
Use new type system in TableSource…
URL: https://github.com/apache/flink/pull/10495#issuecomment-563194106
## CI report:
* fbbc9e5281372342a8fe58bc7640b94af947c824 Travis:
[
https://issues.apache.org/jira/browse/FLINK-15144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-15144.
--
Resolution: Duplicate
Yes, I opened it in the same time (+/- 5minute) and forgot to close
flinkbot edited a comment on issue #10446: [FLINK-15076][task] Fix
SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#issuecomment-562210711
## CI report:
* b23a4477442b92ceda70901ab0a3736eefb4b224 Travis:
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355490815
##
File path:
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355479323
##
File path:
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355482653
##
File path:
flinkbot commented on issue #10499: [FLINK-14170] [flink-hadoop-fs] Support
hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder
URL: https://github.com/apache/flink/pull/10499#issuecomment-563270698
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
dasbh opened a new pull request #10499: [FLINK-14170] [flink-hadoop-fs] Support
hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder
URL: https://github.com/apache/flink/pull/10499
## What is the purpose of the change
* Pull request implements changes discussed in
[
https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14170:
---
Labels: pull-request-available (was: )
> Support hadoop < 2.7 with
[
https://issues.apache.org/jira/browse/FLINK-14951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991629#comment-16991629
]
Yangze Guo edited comment on FLINK-14951 at 12/9/19 2:30 PM:
-
Actually, I
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java]
StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959
## CI report:
* 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:
flinkbot edited a comment on issue #10482: WIP [Flink-11956] Unshade s3
filesystems
URL: https://github.com/apache/flink/pull/10482#issuecomment-562885821
## CI report:
* 3ad923385d40723d4ff6aba32cde9fb31d124c1f Travis:
flinkbot edited a comment on issue #10446: [FLINK-15076][task] Fix
SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#issuecomment-562210711
## CI report:
* b23a4477442b92ceda70901ab0a3736eefb4b224 Travis:
flinkbot edited a comment on issue #8649: [FLINK-12770] [elasticsearch] Make
number of bulk concurrentRequests configurable
URL: https://github.com/apache/flink/pull/8649#issuecomment-563247514
## CI report:
* dfeebf6c4160f17143ecc67e21322b6ed00bf438 Travis:
[
https://issues.apache.org/jira/browse/FLINK-14951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991629#comment-16991629
]
Yangze Guo commented on FLINK-14951:
Actually, I execute it by run_singe_test.sh. Many tests will
[
https://issues.apache.org/jira/browse/FLINK-13980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin reopened FLINK-13980:
-
We should update the release notes before closing
> FLIP-49 Unified Memory Configuration
[
https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991625#comment-16991625
]
Jeff Zhang edited comment on FLINK-15157 at 12/9/19 2:18 PM:
-
[~aljoscha]
[
https://issues.apache.org/jira/browse/FLINK-15144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991626#comment-16991626
]
Andrey Zagrebin commented on FLINK-15144:
-
is it not what
[
https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991625#comment-16991625
]
Jeff Zhang commented on FLINK-15157:
[~aljoscha] [~kkl0u] This is how I use it in Zeppelin
kl0u commented on issue #10491: [FLINK-15093][streaming-java]
StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#issuecomment-563255892
> > Now I noticed that you added a second execution of the same
`statement2`. In this case, it would make sense to
flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add
documentation for memory control of RocksDB state backend
URL: https://github.com/apache/flink/pull/10498#issuecomment-563242008
## CI report:
* dd347fe423313a8bb7c975e3f04ba626fe5dd1b2 Travis:
flinkbot edited a comment on issue #10497: [FLINK-14992][client] Add job
listener to execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563230075
## CI report:
* c2bbd3752050a609680b68f2bf4f92457ba360b1 UNKNOWN
*
pnowojski edited a comment on issue #10446: [FLINK-15076][task] Fix
SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#issuecomment-563250152
@rkhachatryan because of the failing travis test (some
`InterruptedException` was wrapped multiple times, first into the
[
https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991607#comment-16991607
]
Kostas Kloudas commented on FLINK-15157:
[~zjffdu] I understand the reason. If we expose them we
zjffdu commented on issue #10497: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563250659
@aljoscha This PR works with Zeppelin pretty, thanks for that. +1 from me
[
https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991609#comment-16991609
]
Aljoscha Krettek commented on FLINK-15157:
--
I'm in favour of enabling use cases even if it
pnowojski commented on issue #10446: [FLINK-15076][task] Fix SourceStreamTask
cancellation
URL: https://github.com/apache/flink/pull/10446#issuecomment-563250152
@rkhachatryan because of the failing travis test, I had to add quite a lot
of code to this PR. Could you take a look again?
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java]
StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959
## CI report:
* 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:
flinkbot edited a comment on issue #10482: WIP [Flink-11956] Unshade s3
filesystems
URL: https://github.com/apache/flink/pull/10482#issuecomment-562885821
## CI report:
* 3ad923385d40723d4ff6aba32cde9fb31d124c1f Travis:
[
https://issues.apache.org/jira/browse/FLINK-15129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991601#comment-16991601
]
Aljoscha Krettek commented on FLINK-15129:
--
I noticed one problem, if we return a Future and
flinkbot commented on issue #8649: [FLINK-12770] [elasticsearch] Make number of
bulk concurrentRequests configurable
URL: https://github.com/apache/flink/pull/8649#issuecomment-563247514
## CI report:
* dfeebf6c4160f17143ecc67e21322b6ed00bf438 UNKNOWN
Bot commands
[
https://issues.apache.org/jira/browse/FLINK-15134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-15134.
--
Resolution: Fixed
Merged on master with 4ee54776de65049fd4d782b3ca25b9d92feee677
> Delete
kl0u merged pull request #10489: [FLINK-15134][client] Delete temporary files
created in YarnClusterDescriptor
URL: https://github.com/apache/flink/pull/10489
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991594#comment-16991594
]
Jeff Zhang commented on FLINK-15157:
[~kkl0u] I talked about concept of general FlinkClient which
[
https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-14193:
Fix Version/s: 1.11.0
> Update RestAPI / Web UI
> ---
>
>
flinkbot commented on issue #10498: [FLINK-14495][docs] Add documentation for
memory control of RocksDB state backend
URL: https://github.com/apache/flink/pull/10498#issuecomment-563242008
## CI report:
* dd347fe423313a8bb7c975e3f04ba626fe5dd1b2 UNKNOWN
Bot commands
[
https://issues.apache.org/jira/browse/FLINK-14194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-14194:
Fix Version/s: 1.11.0
> Clean-up of legacy mode.
>
>
>
aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563242195
Yes, too many PRs, but I think this should cover all the use cases,
especially I added tests that verify that we call
[
https://issues.apache.org/jira/browse/FLINK-14191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-14191:
Fix Version/s: 1.11.0
> Extend SlotManager to support dynamic slot allocation on pending
flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs
to contain jobmanager component label
URL: https://github.com/apache/flink/pull/10496#issuecomment-563198013
## CI report:
* 793df2e323b4f84433f99f21515b30a21524658c Travis:
flinkbot edited a comment on issue #10497: [FLINK-14992][client] Add job
listener to execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563230075
## CI report:
* c2bbd3752050a609680b68f2bf4f92457ba360b1 UNKNOWN
*
TisonKun closed pull request #10408: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10408
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-14190:
Fix Version/s: 1.11.0
> Extend SlotManager to support dynamic slot allocation on
wsry commented on a change in pull request #10492: [FLINK-15140][runtime] Fix
shuffle data compression doesn't work with BroadcastRecordWriter.
URL: https://github.com/apache/flink/pull/10492#discussion_r355452265
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-14192:
Fix Version/s: 1.11.0
> Enable the dynamic slot allocation feature.
>
wsry commented on a change in pull request #10492: [FLINK-15140][runtime] Fix
shuffle data compression doesn't work with BroadcastRecordWriter.
URL: https://github.com/apache/flink/pull/10492#discussion_r355451663
##
File path:
wsry commented on a change in pull request #10492: [FLINK-15140][runtime] Fix
shuffle data compression doesn't work with BroadcastRecordWriter.
URL: https://github.com/apache/flink/pull/10492#discussion_r355451131
##
File path:
wsry commented on a change in pull request #10492: [FLINK-15140][runtime] Fix
shuffle data compression doesn't work with BroadcastRecordWriter.
URL: https://github.com/apache/flink/pull/10492#discussion_r355450458
##
File path:
zjffdu commented on issue #10497: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563240155
haha，didn't realize this is another new PR. Will try it with Zeppelin soon
[
https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991588#comment-16991588
]
Andrey Zagrebin commented on FLINK-15146:
-
[~hehuiyuan]
I think you are right, although
[
https://issues.apache.org/jira/browse/FLINK-9469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-9469:
---
Assignee: (was: Dawid Wysakowicz)
> Add tests that cover
[
https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991579#comment-16991579
]
Leonard Xu commented on FLINK-15139:
[~jark] thanks，I'll work for this.
> misc end to end test
flinkbot commented on issue #10498: [FLINK-14495][docs] Add documentation for
memory control of RocksDB state backend
URL: https://github.com/apache/flink/pull/10498#issuecomment-563237595
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
[
https://issues.apache.org/jira/browse/FLINK-12770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991585#comment-16991585
]
tankilo commented on FLINK-12770:
-
Will there be any new progress?
> Make number of bulk
[
https://issues.apache.org/jira/browse/FLINK-14495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14495:
---
Labels: pull-request-available (was: )
> Add documentation for memory control of RocksDB
danny0405 edited a comment on issue #10491: [FLINK-15093][streaming-java]
StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#issuecomment-563234831
> Now I noticed that you added a second execution of the same `statement2`.
In this case, it would make
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java]
StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959
## CI report:
* 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:
[
https://issues.apache.org/jira/browse/FLINK-15122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991584#comment-16991584
]
Piotr Nowojski edited comment on FLINK-15122 at 12/9/19 1:23 PM:
-
Can
Myasuka opened a new pull request #10498: [FLINK-14495][docs] Add documentation
for memory control of RocksDB state backend
URL: https://github.com/apache/flink/pull/10498
## What is the purpose of the change
Add user documentation of how to bound total memory for RocksDB
flinkbot edited a comment on issue #10482: WIP [Flink-11956] Unshade s3
filesystems
URL: https://github.com/apache/flink/pull/10482#issuecomment-562885821
## CI report:
* 3ad923385d40723d4ff6aba32cde9fb31d124c1f Travis:
aljoscha commented on issue #10497: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563236208
Yes, that's what I'm proposing, you can actually see it in the code of this
PR. When `executeAsync()` is called we
hehuiyuan created FLINK-15159:
-
Summary: the string of json is mapped to VARCHAR or STRING?
Key: FLINK-15159
URL: https://issues.apache.org/jira/browse/FLINK-15159
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991576#comment-16991576
]
Kostas Kloudas commented on FLINK-15157:
This means that we expose the {{ClusterClient}} and the
Dawid Wysakowicz created FLINK-15160:
Summary: Clean up is not applied if there are no incoming events
for a key.
Key: FLINK-15160
URL: https://issues.apache.org/jira/browse/FLINK-15160
Project:
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network
metric in IOMetricsInfo
URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569
## CI report:
* 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:
[
https://issues.apache.org/jira/browse/FLINK-15122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991584#comment-16991584
]
Piotr Nowojski commented on FLINK-15122:
Can you provide a benchmark
[
https://issues.apache.org/jira/browse/FLINK-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991576#comment-16991576
]
Kostas Kloudas edited comment on FLINK-15157 at 12/9/19 1:16 PM:
-
This
danny0405 commented on issue #10491: [FLINK-15093][streaming-java]
StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#issuecomment-563234831
> Now I noticed that you added a second execution of the same `statement2`.
In this case, it would make sense
flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass
configuration to the underlying ExecutionEnvironment from TableEnvironment
URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619
## CI report:
* e0b1afaebe5bd4fc07e61785a38ef82f55e16f69
zjffdu commented on issue #10497: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10497#issuecomment-563233520
@aljoscha Do you mean to change the JobListener as following:
```
interface JobListener{
void
danny0405 commented on a change in pull request #10491:
[FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#discussion_r355441192
##
File path:
hehuiyuan created FLINK-15158:
-
Summary: Why convert integer to bigdecimal for formart-json when
kafka is used
Key: FLINK-15158
URL: https://issues.apache.org/jira/browse/FLINK-15158
Project: Flink
301 - 400 of 793 matches
Mail list logo
