[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555251#comment-16555251
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555242#comment-16555242
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555246#comment-16555246
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555252#comment-16555252
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555243#comment-16555243
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555244#comment-16555244
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555248#comment-16555248
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555253#comment-16555253
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555240#comment-16555240
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555250#comment-16555250
]
ASF GitHub Bot commented on FLINK-9885:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204756208
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555238#comment-16555238
]
ASF GitHub Bot commented on FLINK-9897:
---
Github user tzulitai commented on a diff i
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204999073
--- Diff: flink-end-to-end-tests/run-nightly-tests.sh ---
@@ -96,6 +96,7 @@ run_test "Local recovery and sticky scheduling end-to-end
test" "$END_TO_END_DIR
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204991878
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/EmbeddedElasticsearchNodeEnvironmentI
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204758828
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204758434
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204993234
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204994308
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/test/resources/log4j-test.properties
---
@@ -0,0 +1,27 @@
+##
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204990734
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java
---
@@ -
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204775927
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java
---
@@ -
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204992515
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204991006
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java
---
@@ -
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204993809
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/examples/ElasticsearchSinkExample.ja
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204991076
--- Diff:
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java
---
@@ -
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204757871
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204750192
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -138,6 +143,31 @@ input.addSink(new ElasticsearchSink<>(config,
transportAddresses, new Elasticsea
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204752713
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -190,9 +220,30 @@ input.addSink(new ElasticsearchSink(config,
transportAddresses, new Elasticsearc
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555234#comment-16555234
]
ASF GitHub Bot commented on FLINK-9694:
---
Github user yanghua closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555233#comment-16555233
]
ASF GitHub Bot commented on FLINK-9694:
---
Github user yanghua commented on the issue
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6408#discussion_r204999405
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -233,26
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555230#comment-16555230
]
ASF GitHub Bot commented on FLINK-9694:
---
Github user yanghua commented on the issue
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6408#discussion_r204996330
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -233,26
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6231
PR #6392 fixed this issue.
---
Github user yanghua closed the pull request at:
https://github.com/apache/flink/pull/6231
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6408#discussion_r204998677
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -233,26
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6392
+1, I will close my PR #6231 about this issue
---
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555222#comment-16555222
]
Timo Walther commented on FLINK-6935:
-
Thanks for renewing the discussion. Sorry, tha
[
https://issues.apache.org/jira/browse/FLINK-9942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555214#comment-16555214
]
Chesnay Schepler commented on FLINK-9942:
-
[~GJL] What was the reasoning behind t
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6392
LGTM, +1
---
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555209#comment-16555209
]
ASF GitHub Bot commented on FLINK-9694:
---
Github user tzulitai commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555201#comment-16555201
]
Dian Fu commented on FLINK-6935:
The community is focusing on modules such as runtime, ta
Chesnay Schepler created FLINK-9942:
---
Summary: Guard handlers against null fields in requests
Key: FLINK-9942
URL: https://issues.apache.org/jira/browse/FLINK-9942
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555190#comment-16555190
]
aitozi commented on FLINK-9938:
---
Can it be done by checking periodic ? so that the clean up
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555185#comment-16555185
]
ASF GitHub Bot commented on FLINK-9941:
---
Github user buptljy commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555186#comment-16555186
]
ASF GitHub Bot commented on FLINK-9941:
---
Github user buptljy closed the pull reques
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/6412
Duplicate. Close.
---
Github user buptljy closed the pull request at:
https://github.com/apache/flink/pull/6412
---
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555183#comment-16555183
]
ASF GitHub Bot commented on FLINK-9941:
---
GitHub user buptljy opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9934.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in 1.7.0: 378cbb7c2e580ba73f215234e7dff542c3e
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/6412
[FLINK-9941] Flush in ScalaCsvOutputFormat before close
## What is the purpose of the change
- Flush in ScalaCsvOutputFormat before close.We've already finished it in
org.apache.flink.api.java.i
[
https://issues.apache.org/jira/browse/FLINK-9934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555181#comment-16555181
]
ASF GitHub Bot commented on FLINK-9934:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555180#comment-16555180
]
ASF GitHub Bot commented on FLINK-5281:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6403
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3124
---
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555179#comment-16555179
]
ASF GitHub Bot commented on FLINK-9941:
---
GitHub user Lemonjing opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9941:
--
Labels: pull-request-available (was: )
> Flush in ScalaCsvOutputFormat before close method
> -
GitHub user Lemonjing opened a pull request:
https://github.com/apache/flink/pull/6411
[FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before closing, to
ensure CI stability
## What is the purpose of the change
This pull request update scala api `ScalaCsvOutputFormat` to in
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555175#comment-16555175
]
buptljy commented on FLINK-9941:
[~lemonjing] You're right. I'll fix it.
> Flush in Scal
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-9941:
--
Assignee: buptljy
> Flush in ScalaCsvOutputFormat before close method
> --
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rannn Tao updated FLINK-9941:
-
Description:
Because not every stream's close method will flush, in order to ensure the
stability of con
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rannn Tao updated FLINK-9941:
-
Description:
Because not every stream's close method will flush, in order to ensure the
stability of con
Rannn Tao created FLINK-9941:
Summary: Flush in ScalaCsvOutputFormat before close method
Key: FLINK-9941
URL: https://issues.apache.org/jira/browse/FLINK-9941
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555165#comment-16555165
]
buptljy commented on FLINK-6935:
I am very interested in the CEP part. And my team is exp
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-6938:
--
Assignee: Jark Wu (was: buptljy)
> IterativeCondition should support RichFunction interface
> ---
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-6938:
--
Assignee: buptljy (was: Jark Wu)
> IterativeCondition should support RichFunction interface
> ---
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555162#comment-16555162
]
Timo Walther commented on FLINK-5315:
-
Thanks for working on this [~walterddr]. {{t.s
[
https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy closed FLINK-9834.
--
Resolution: Won't Do
> Unable to support scala BasicArrayTypeInfo
> --
[
https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555157#comment-16555157
]
buptljy commented on FLINK-9834:
It seems that we can use _*implicitly[TypeInformation[Ar
[
https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huyen Levan updated FLINK-9940:
---
Priority: Blocker (was: Major)
> File source continuous monitoring mode: S3 files sometimes missed
>
Huyen Levan created FLINK-9940:
--
Summary: File source continuous monitoring mode: S3 files
sometimes missed
Key: FLINK-9940
URL: https://issues.apache.org/jira/browse/FLINK-9940
Project: Flink
Github user uang520 closed the pull request at:
https://github.com/apache/flink/pull/6410
---
GitHub user uang520 opened a pull request:
https://github.com/apache/flink/pull/6410
Release 1.6
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution in the best possible way, ple
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555003#comment-16555003
]
ASF GitHub Bot commented on FLINK-5860:
---
Github user maheshsenni commented on the i
Github user maheshsenni commented on the issue:
https://github.com/apache/flink/pull/6399
@zentol I have addressed your comments in a new commit. Can you look into
it please?
---
Github user rileyli closed the pull request at:
https://github.com/apache/flink/pull/6401
---
[
https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554917#comment-16554917
]
Lakshmi Rao commented on FLINK-9899:
Thanks [~yanghua] !
> Add more metrics to the
[
https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9899:
---
Assignee: Lakshmi Rao (was: vinoyang)
> Add more metrics to the Kinesis source connector
>
[
https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554915#comment-16554915
]
vinoyang commented on FLINK-9899:
-
hi [~glaksh100] I have not started this issue yet. I h
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554901#comment-16554901
]
ASF GitHub Bot commented on FLINK-9897:
---
Github user glaksh100 commented on a diff
Github user glaksh100 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6408#discussion_r204942574
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -233,26
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554866#comment-16554866
]
Rong Rong commented on FLINK-9294:
--
Had an initial diff for discussion on what needs to
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554837#comment-16554837
]
ASF GitHub Bot commented on FLINK-9897:
---
Github user tweise commented on a diff in
Github user tweise commented on a diff in the pull request:
https://github.com/apache/flink/pull/6408#discussion_r204922265
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -233,26 +2
[
https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554822#comment-16554822
]
Lakshmi Rao edited comment on FLINK-9899 at 7/24/18 9:35 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554822#comment-16554822
]
Lakshmi Rao commented on FLINK-9899:
[~yanghua] I created a PR with my changes - Let
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554820#comment-16554820
]
ASF GitHub Bot commented on FLINK-9897:
---
GitHub user glaksh100 opened a pull reques
GitHub user glaksh100 opened a pull request:
https://github.com/apache/flink/pull/6409
Flink 9899.kinesis connector metrics
## What is the purpose of the change
The purpose of this change is to add metrics to the `ShardConsumer` to get
more observability into the performanc
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao updated FLINK-9897:
---
Summary: Further enhance adaptive reads in Kinesis Connector to read more
records in the case of long
[
https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao updated FLINK-9899:
---
Affects Version/s: 1.4.2
1.5.1
> Add more metrics to the Kinesis source connec
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao updated FLINK-9897:
---
Summary: Further enhance adaptive reads in Kinesis Connector to depend on
run loop time (was: Furthe
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao updated FLINK-9897:
---
Affects Version/s: 1.4.2
1.5.1
> Further enhance adaptiveReads in Kinesis Conn
[
https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554732#comment-16554732
]
Lakshmi Rao commented on FLINK-9899:
[~yanghua] Are you planning on working on this?
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao reassigned FLINK-9897:
--
Assignee: Lakshmi Rao
> Further enhance adaptiveReads in Kinesis Connector to read more record
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9897:
--
Labels: pull-request-available (was: )
> Further enhance adaptiveReads in Kinesis Connector to
[
https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554727#comment-16554727
]
ASF GitHub Bot commented on FLINK-9897:
---
GitHub user glaksh100 opened a pull reques
GitHub user glaksh100 opened a pull request:
https://github.com/apache/flink/pull/6408
[FLINK-9897] Make adaptive reads depend on run loop time instead of
fetchintervalmillis
## What is the purpose of the change
[FLINK-9692](https://github.com/apache/flink/pull/6300) introduced
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554689#comment-16554689
]
Juan Miguel Cejuela commented on FLINK-7811:
Moved to 1.7.0? So unfortunate :
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6401
Thanks for your contribution @rileyli. Even though this change seems rather
trivial I would like to discourage these kind of contributions. The problem is
that it does not add much additional va
[
https://issues.apache.org/jira/browse/FLINK-9939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-9939:
Fix Version/s: 1.5.2
> Mesos: Not setting TMP dirs causes NPE
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-9939:
Affects Version/s: 1.5.2
> Mesos: Not setting TMP dirs causes NPE
> --
1 - 100 of 290 matches
Mail list logo
