[
https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403241#comment-16403241
]
ASF GitHub Bot commented on FLINK-8915:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5703
cc @GJL : thanks for your suggestion, please review.
---
[
https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403233#comment-16403233
]
ASF GitHub Bot commented on FLINK-9011:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5712
Hi @GJL please look at this, if you have time, thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403232#comment-16403232
]
ASF GitHub Bot commented on FLINK-9011:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5712
[FLINK-9011] YarnResourceManager spamming log file at INFO level
## What is the purpose of the change
*This pull request changed some log's level*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403210#comment-16403210
]
mingleizhang commented on FLINK-8970:
-
Very nice to me.
> Add more automated end-to-e
[
https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9011:
---
Assignee: vinoyang
> YarnResourceManager spamming log file at INFO level
> --
[
https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16307281#comment-16307281
]
Ted Yu edited comment on FLINK-6105 at 3/17/18 1:54 AM:
In
flink-
[
https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403198#comment-16403198
]
ASF GitHub Bot commented on FLINK-8843:
---
Github user yanghua closed the pull request
Github user yanghua closed the pull request at:
https://github.com/apache/flink/pull/5632
---
[
https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7917:
--
Description:
Currently in ExecutionJobVertex#getTaskInformationOrBlobKey:
{code}
}
return taskInformati
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5700
Since we are not shading anything we could also use the Maven JAR plugin:
```
org.apache.maven.plugins
maven-jar-plugin
3.0.2
[
https://issues.apache.org/jira/browse/FLINK-8833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403171#comment-16403171
]
ASF GitHub Bot commented on FLINK-8833:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403168#comment-16403168
]
ASF GitHub Bot commented on FLINK-8852:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5704
Since we are not shading anything we could also use the Maven JAR plugin:
```
org.apache.maven.plugins
maven-jar-plugin
3.0.2
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16403095#comment-16403095
]
ASF GitHub Bot commented on FLINK-8903:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5706
updated PR
---
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402691#comment-16402691
]
ASF GitHub Bot commented on FLINK-8903:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5706#discussion_r175230116
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala
---
@@ -103,6 +106,19 @@ cl
Shuyi Chen created FLINK-9015:
-
Summary: Upgrade Calcite dependency to 1.17
Key: FLINK-9015
URL: https://issues.apache.org/jira/browse/FLINK-9015
Project: Flink
Issue Type: Task
Repor
[
https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-8981:
-
Assignee: Shuyi Chen
> End-to-end test: Kerberos security
> --
>
[
https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402515#comment-16402515
]
Shuyi Chen commented on FLINK-8988:
---
[~till.rohrmann], wondering if the current Cassandr
[
https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402515#comment-16402515
]
Shuyi Chen edited comment on FLINK-8988 at 3/16/18 8:50 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402416#comment-16402416
]
ASF GitHub Bot commented on FLINK-8894:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5711
[FLINK-8894][REST] CurrentJobIdsHandler fails to serialize response
## What is the purpose of the change
*This fixes a serialization error in `CurrentJobIdsHandler`.*
cc: @tillrohrmann
[
https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8894:
---
Assignee: Gary Yao
> CurrentJobIdsHandler fails to serialize response
> -
[
https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402379#comment-16402379
]
ASF GitHub Bot commented on FLINK-8843:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5632#discussion_r175192336
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/RestOptions.java ---
@@ -33,7 +33,7 @@
*/
public static final ConfigOption RES
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8946:
Fix Version/s: 1.5.0
> TaskManager stop sending metrics after JobManager failover
>
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8946:
Priority: Blocker (was: Major)
> TaskManager stop sending metrics after JobManager failover
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402345#comment-16402345
]
ASF GitHub Bot commented on FLINK-8903:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5706#discussion_r175183811
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala
---
@@ -103,6 +106,19 @@ c
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402335#comment-16402335
]
ASF GitHub Bot commented on FLINK-8903:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5706#discussion_r175181100
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala
---
@@ -103,6 +106,19 @@ cl
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402332#comment-16402332
]
ASF GitHub Bot commented on FLINK-8903:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5706
Updated the PR with the Calcite issue.
---
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402328#comment-16402328
]
Stephan Ewen commented on FLINK-8922:
-
[~sihuazhou]'s findings could be the right fix.
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402323#comment-16402323
]
Pankaj edited comment on FLINK-9009 at 3/16/18 6:35 PM:
No, Is not
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402323#comment-16402323
]
Pankaj edited comment on FLINK-9009 at 3/16/18 6:34 PM:
No, Is not
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402323#comment-16402323
]
Pankaj commented on FLINK-9009:
---
No, Is not related with Kafka. I have already tried and che
[
https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8364.
---
Resolution: Invalid
Fix Version/s: (was: 1.5.0)
> Add iterator() to ListState which
[
https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-8364:
-
reopen to change fixVersion
> Add iterator() to ListState which returns empty iterator when i
[
https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402299#comment-16402299
]
Ted Yu commented on FLINK-7488:
---
{code}
compareNetworkBufShellScriptWithJava(org.apache.flin
Nico Kruber created FLINK-9014:
--
Summary: Adapt BackPressureStatsTracker to work with credit-based
flow control
Key: FLINK-9014
URL: https://issues.apache.org/jira/browse/FLINK-9014
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402251#comment-16402251
]
Aljoscha Krettek commented on FLINK-8922:
-
[~sihuazhou] Unfortunately, I don't kno
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402247#comment-16402247
]
ASF GitHub Bot commented on FLINK-8402:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5624
Unfortunately, this is not entirely under our control, since we rely on the
underlying `FileSystem` implementation. I can probably reduce some parts of the
tests that may lead to eventual consistent op
[
https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402229#comment-16402229
]
ASF GitHub Bot commented on FLINK-8948:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5710
it may be better to make `BufferBuilder#finish()` idempotent
---
[
https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402218#comment-16402218
]
ASF GitHub Bot commented on FLINK-8945:
---
Github user tweise commented on the issue:
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5698
@StephanEwen thanks for unblocking our work!
---
[
https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402053#comment-16402053
]
ASF GitHub Bot commented on FLINK-8915:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402055#comment-16402055
]
ASF GitHub Bot commented on FLINK-8915:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402054#comment-16402054
]
ASF GitHub Bot commented on FLINK-8915:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5703#discussion_r175125460
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
---
@@ -438,4 +453,58 @@ public int hashCode(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5703#discussion_r175126334
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
---
@@ -438,4 +453,58 @@ public int hashCode(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5703#discussion_r175126066
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
---
@@ -273,7 +274,21 @@ public static Checkp
Nico Kruber created FLINK-9013:
--
Summary: Document yarn.containers.vcores only being effective when
adapting YARN config
Key: FLINK-9013
URL: https://issues.apache.org/jira/browse/FLINK-9013
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402031#comment-16402031
]
ASF GitHub Bot commented on FLINK-8968:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5705
@StefanRRichter I have updated the code, could you please have a look...
---
[
https://issues.apache.org/jira/browse/FLINK-8976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402023#comment-16402023
]
Sihua Zhou commented on FLINK-8976:
---
Hi [~till.rohrmann] could I ask why this issue won'
[
https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-9010:
--
Assignee: Nico Kruber
> NoResourceAvailableException with FLIP-6
> ---
[
https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402014#comment-16402014
]
ASF GitHub Bot commented on FLINK-8948:
---
GitHub user pnowojski opened a pull request
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5710
[FLINK-8948][runtime] Fix IllegalStateException when closing StreamTask
All methods in
org.apache.flink.streaming.runtime.tasks.OperatorChain#releaseOutputs shouldn't
throw any exceptions and
Nico Kruber created FLINK-9012:
--
Summary: Shaded Hadoop S3A end-to-end test failing with S3 bucket
in Ireland
Key: FLINK-9012
URL: https://issues.apache.org/jira/browse/FLINK-9012
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9010:
---
Issue Type: Bug (was: Improvement)
> NoResourceAvailableException with FLIP-6
>
Nico Kruber created FLINK-9011:
--
Summary: YarnResourceManager spamming log file at INFO level
Key: FLINK-9011
URL: https://issues.apache.org/jira/browse/FLINK-9011
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9011:
---
Labels: flip-6 (was: )
> YarnResourceManager spamming log file at INFO level
> --
Nico Kruber created FLINK-9010:
--
Summary: NoResourceAvailableException with FLIP-6
Key: FLINK-9010
URL: https://issues.apache.org/jira/browse/FLINK-9010
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9010:
---
Labels: flip-6 (was: )
> NoResourceAvailableException with FLIP-6
>
[
https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401994#comment-16401994
]
ASF GitHub Bot commented on FLINK-8968:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5705
You can cover it here and I will review it again ð
---
[
https://issues.apache.org/jira/browse/FLINK-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401983#comment-16401983
]
ASF GitHub Bot commented on FLINK-8872:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5672
thanks for the review, I also did not like the side-effect approach and
after thinking a bit about your first message, I independently came up with the
same thing as you proposed in the second one :p
[
https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401958#comment-16401958
]
Gary Yao commented on FLINK-8073:
-
Another instance: https://travis-ci.org/apache/flink/jo
[
https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401952#comment-16401952
]
ASF GitHub Bot commented on FLINK-8968:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5705
@StefanRRichter Sorry for pinging you again in this PR, but I found there
maybe be another issue for `full checkpoint`. It's about the
`kvStateInformation`, we should create a deep copy of `kvState
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401945#comment-16401945
]
Sihua Zhou commented on FLINK-8922:
---
[~srichter] Yes, the downside is obvious and I also
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-8941:
---
Component/s: Network
> SpanningRecordSerializationTest fails on Travis
> -
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-8941:
---
Affects Version/s: 1.6.0
1.5.0
> SpanningRecordSerializationTest fails on Travi
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-8941:
---
Fix Version/s: 1.6.0
> SpanningRecordSerializationTest fails on Travis
> -
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5709
[FLINK-8941][network][serializer] improve SpanningRecordSerializationTest
and ensure unique spilling files
## What is the purpose of the change
This PR contains two commits trying to tackle F
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401936#comment-16401936
]
ASF GitHub Bot commented on FLINK-8941:
---
GitHub user NicoK opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401933#comment-16401933
]
Stefan Richter commented on FLINK-8922:
---
Hmm, I wonder why that should be a fix? Doe
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401925#comment-16401925
]
Sihua Zhou commented on FLINK-8922:
---
Ah, happy to tell you guys that finally I find the
[
https://issues.apache.org/jira/browse/FLINK-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7851.
Resolution: Won't Fix
Reverted via
1.6.0: 91d346e9e7611be530509154cc7034cbde22653d
1.5.0: c74f80869f
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401917#comment-16401917
]
Stephan Ewen commented on FLINK-8922:
-
[~srichter] and me had a discussion about this
[
https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401912#comment-16401912
]
ASF GitHub Bot commented on FLINK-8984:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/5708
Thanks piotr, I agree with it.
---
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401901#comment-16401901
]
Stephan Ewen commented on FLINK-9009:
-
I assume that error is reported by Kafka?
Can y
[
https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8945.
-
Resolution: Fixed
Assignee: Kailash Hassan Dayanand
Fix Version/s: 1.5.0
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8945.
---
> Allow customization of the KinesisProxy
> ---
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-:
---
Assignee: Kailash Hassan Dayanand
> Upgrade AWS SDK in flink-connector-kinesis
>
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-.
---
> Upgrade AWS SDK in flink-connector-kinesis
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in
- 1.5.0 via 5896840b17d6b39345c836ad2bba0
Pankaj created FLINK-9009:
-
Summary: Error| You are creating too many HashedWheelTimer
instances. HashedWheelTimer is a shared resource that must be reused across
the application, so that only a few instances are created.
Key: FLINK-900
Till Rohrmann created FLINK-9008:
Summary: End-to-end test: Quickstarts
Key: FLINK-9008
URL: https://issues.apache.org/jira/browse/FLINK-9008
Project: Flink
Issue Type: Sub-task
Com
Till Rohrmann created FLINK-9007:
Summary: Cluster test: Kinesis connector
Key: FLINK-9007
URL: https://issues.apache.org/jira/browse/FLINK-9007
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-9006:
Summary: Cluster test: Run general purpose job with failures with
Yarn and per-job mode
Key: FLINK-9006
URL: https://issues.apache.org/jira/browse/FLINK-9006
Project:
1 - 100 of 196 matches
Mail list logo