[
https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254863#comment-16254863
]
Fabian Hueske commented on FLINK-7962:
--
Implemented for 1.5.0 with
[
https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6105:
--
Description:
When catching InterruptedException, we should throw InterruptedIOException
instead of
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16211139#comment-16211139
]
Ted Yu edited comment on FLINK-5486 at 11/16/17 3:49 AM:
-
The reason for
[
https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-7962.
Resolution: Fixed
> Add built-in support for min/max aggregation for Timestamp
>
[
https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254675#comment-16254675
]
ASF GitHub Bot commented on FLINK-7962:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4936
---
[
https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254591#comment-16254591
]
Bowen Li commented on FLINK-7954:
-
[~foxss] [~aljoscha] Hi guys, I think this feature is really useful and
[
https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7954:
Priority: Major (was: Minor)
> sideoutput in async function
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7642:
--
Description:
Surefire 2.19 release introduced more useful test filters which would let us
run a subset of the
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7897:
--
Description:
nio.Files#delete() provides better clue as to why the deletion may fail:
Joshua Griffith created FLINK-8091:
--
Summary: Support running historyserver in foreground
Key: FLINK-8091
URL: https://issues.apache.org/jira/browse/FLINK-8091
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253961#comment-16253961
]
ASF GitHub Bot commented on FLINK-8076:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5017
cc @tzulitai
---
[
https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253959#comment-16253959
]
ASF GitHub Bot commented on FLINK-7977:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4945
Sounds good. Thanks @zentol ! ð
---
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-8090:
-
Assignee: (was: Kostas Kloudas)
> Improve error message when registering different
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-8090:
-
Assignee: Kostas Kloudas
> Improve error message when registering different states under
[
https://issues.apache.org/jira/browse/FLINK-8060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-8060:
-
Assignee: Kostas Kloudas
> Operator can make states queryable under the same name
>
[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-7942.
-
Resolution: Fixed
Fix Version/s: 1.5.0
1.4.0
Fixed in 1.5:
[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253840#comment-16253840
]
ASF GitHub Bot commented on FLINK-7942:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5019
---
[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253814#comment-16253814
]
ASF GitHub Bot commented on FLINK-7942:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5019
Looks good. +1 to merge
---
[
https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-7490.
-
Resolution: Fixed
Fixed in 1.5: 59df4b75fa9c6754c89ea1922e05cfdb22e761da
Fixed in 1.4:
[
https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-7490:
Fix Version/s: 1.5.0
1.3.3
> UDF Agg throws Exception when flink-table is loaded
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151188168
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253794#comment-16253794
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253790#comment-16253790
]
ASF GitHub Bot commented on FLINK-7490:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253789#comment-16253789
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5018
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151187261
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
[
https://issues.apache.org/jira/browse/FLINK-8041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253784#comment-16253784
]
Greg Hogan commented on FLINK-8041:
---
Currently the vertex value can be any implementation of
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253781#comment-16253781
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151184658
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253782#comment-16253782
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151184079
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253772#comment-16253772
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151184645
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253770#comment-16253770
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151184384
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253768#comment-16253768
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253767#comment-16253767
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151183892
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253766#comment-16253766
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151183957
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253765#comment-16253765
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user kl0u commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151183730
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151183695
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-7678:
Fix Version/s: 1.5.0
1.4.0
> SQL UserDefineTableFunction does not take
[
https://issues.apache.org/jira/browse/FLINK-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-7678.
-
Resolution: Fixed
Fixed in 1.5: 54eeccfe18ace636b77ff0226ce1f91d35e4d49d
Fixed in 1.4:
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253757#comment-16253757
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151183131
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253756#comment-16253756
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151182879
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253755#comment-16253755
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151182277
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
[
https://issues.apache.org/jira/browse/FLINK-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253751#comment-16253751
]
ASF GitHub Bot commented on FLINK-7678:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4726
---
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-8090:
--
Summary: Improve error message when registering different states under the
same name. (was: An
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-8090:
--
Description:
Currently a {{ProcessFunction}} like this:
{code}
final
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-8090:
--
Description:
Currently a {{ProcessFunction}} like this is a valid job:
{code}
final
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253745#comment-16253745
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151179694
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253744#comment-16253744
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151179388
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-8090:
-
Assignee: (was: Kostas Kloudas)
> An operator should not be able to register two
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-8090:
-
Assignee: Kostas Kloudas
> An operator should not be able to register two states with
[
https://issues.apache.org/jira/browse/FLINK-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253719#comment-16253719
]
ASF GitHub Bot commented on FLINK-7678:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4726
Merging...
---
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-8090:
--
Description:
Currently a {{ProcessFunction}} like this is a valid job:
{code}
final
Kostas Kloudas created FLINK-8090:
-
Summary: An operator should not be able to register two states
with the same name.
Key: FLINK-8090
URL: https://issues.apache.org/jira/browse/FLINK-8090
Project:
[
https://issues.apache.org/jira/browse/FLINK-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-8048.
---
Resolution: Not A Problem
> RAT check complaint
> ---
>
> Key: FLINK-8048
>
[
https://issues.apache.org/jira/browse/FLINK-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253683#comment-16253683
]
Greg Hogan commented on FLINK-8048:
---
[~tedyu] {{mvn rat:check}} is from a different plugin and {{mvn
Till Rohrmann created FLINK-8089:
Summary: Fulfil slot requests with unused offered slots
Key: FLINK-8089
URL: https://issues.apache.org/jira/browse/FLINK-8089
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253657#comment-16253657
]
ASF GitHub Bot commented on FLINK-7490:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5018#discussion_r151163785
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetAggFunction.scala
---
@@ -46,7 +46,7 @@ class
[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253654#comment-16253654
]
ASF GitHub Bot commented on FLINK-7942:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5019
Thanks @fhueske. I simplified the changes a bit more. Now we use explicit
aliases only for windows and the alias operator.
---
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5021
Thanks for the review @aljoscha ! I will wait a bit for another travis run
and then merge.
---
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253652#comment-16253652
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253650#comment-16253650
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151162640
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253647#comment-16253647
]
Aljoscha Krettek commented on FLINK-8064:
-
We also thought about having those three modules but
[
https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253642#comment-16253642
]
ASF GitHub Bot commented on FLINK-8063:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5021#discussion_r151160873
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
---
@@
Till Rohrmann created FLINK-8088:
Summary: Bind logical slots to their request id instead of the
slot allocation id
Key: FLINK-8088
URL: https://issues.apache.org/jira/browse/FLINK-8088
Project:
[
https://issues.apache.org/jira/browse/FLINK-8079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253631#comment-16253631
]
Aljoscha Krettek commented on FLINK-8079:
-
Sounds good!
> Skip remaining E2E tests if one failed
[
https://issues.apache.org/jira/browse/FLINK-8083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253598#comment-16253598
]
Aljoscha Krettek commented on FLINK-8083:
-
So we probably have to add that method to satisfy our
[
https://issues.apache.org/jira/browse/FLINK-8013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8013.
-
Resolution: Fixed
Fix Version/s: 1.5.0
1.4.0
Fixed in 1.5:
[
https://issues.apache.org/jira/browse/FLINK-8013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253595#comment-16253595
]
ASF GitHub Bot commented on FLINK-8013:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5011
---
[
https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8022:
-
Affects Version/s: 1.5.0
> Kafka at-least-once tests fail occasionally
>
[
https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253587#comment-16253587
]
Till Rohrmann commented on FLINK-8022:
--
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253584#comment-16253584
]
ASF GitHub Bot commented on FLINK-7490:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5018#discussion_r151153655
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetAggFunction.scala
---
@@ -46,7 +46,7 @@ class
[
https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8086:
Fix Version/s: 1.4.0
> FlinkKafkaProducer011 can permanently fail in recovery through
>
[
https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253580#comment-16253580
]
ASF GitHub Bot commented on FLINK-7490:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5018#discussion_r151147760
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetAggFunction.scala
---
@@ -46,7 +46,7 @@ class
[
https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-8086:
-
Assignee: Piotr Nowojski
> FlinkKafkaProducer011 can permanently fail in recovery
[
https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-8086:
--
Description:
Chaos monkey test in a cluster environment can permanently bring down our
1 - 100 of 213 matches
Mail list logo
