[jira] [Resolved] (FLINK-8572) Flink1.4 version of the document on the left menu click can not jump, the left drop-down menu can not be pulled

2018-02-06 Thread PengYang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PengYang resolved FLINK-8572. - Resolution: Fixed Release Note: I have found the problem is due to our company made some of

[jira] [Updated] (FLINK-8572) Flink1.4 version of the document on the left menu click can not jump, the left drop-down menu can not be pulled

2018-02-06 Thread PengYang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PengYang updated FLINK-8572: Description: [https://ci.apache.org/projects/flink/flink-docs-release-1.4/#collapse-116] Flink1.4 version

[jira] [Updated] (FLINK-8572) Flink1.4 version of the document on the left menu click can not jump, the left drop-down menu can not be pulled

2018-02-06 Thread PengYang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PengYang updated FLINK-8572: Summary: Flink1.4 version of the document on the left menu click can not jump, the left drop-down menu can

[jira] [Commented] (FLINK-8572) Flink1.4版本的document 左边的菜单点击无法跳转,左边的下拉菜单都无法下拉

2018-02-06 Thread PengYang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355094#comment-16355094 ] PengYang commented on FLINK-8572: - Thanks. I have found the problem is due to our company made some of

[jira] [Created] (FLINK-8573) Print JobID for failed jobs

2018-02-06 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8573: --- Summary: Print JobID for failed jobs Key: FLINK-8573 URL: https://issues.apache.org/jira/browse/FLINK-8573 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-8567) Maven-shade-plugin can't relocate Scala classes.

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8567. --- Resolution: Not A Problem > Maven-shade-plugin can't relocate Scala classes. >

[jira] [Reopened] (FLINK-8567) Maven-shade-plugin can't relocate Scala classes.

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8567: - > Maven-shade-plugin can't relocate Scala classes. >

[jira] [Updated] (FLINK-8567) Maven-shade-plugin can't relocate Scala classes.

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8567: Fix Version/s: (was: 2.0.0) > Maven-shade-plugin can't relocate Scala classes. >

[jira] [Commented] (FLINK-8572) Flink1.4版本的document 左边的菜单点击无法跳转,左边的下拉菜单都无法下拉

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355086#comment-16355086 ] Chesnay Schepler commented on FLINK-8572: - [~mingleizhang] Could you translate the issue for us

[jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355075#comment-16355075 ] ASF GitHub Bot commented on FLINK-8516: --- Github user tweise commented on the issue:

[GitHub] flink issue #5393: [FLINK-8516] Allow for custom hash function for shard to ...

2018-02-06 Thread tweise
Github user tweise commented on the issue: https://github.com/apache/flink/pull/5393 @tzulitai Assignment and restore are orthogonal; this PR doesn't change restore. I therefore don't see the need to add another migration test for it. There is also no change to how the index is

[jira] [Commented] (FLINK-8572) Flink1.4版本的document 左边的菜单点击无法跳转,左边的下拉菜单都无法下拉

2018-02-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355036#comment-16355036 ] mingleizhang commented on FLINK-8572: - [~LaiAng] You can try another browser to see whether it works.

[jira] [Commented] (FLINK-8572) Flink1.4版本的document 左边的菜单点击无法跳转,左边的下拉菜单都无法下拉

2018-02-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355032#comment-16355032 ] mingleizhang commented on FLINK-8572: - Hi, [~LaiAng] Change the subject to English. And what you

[jira] [Created] (FLINK-8572) Flink1.4版本的document 左边的菜单点击无法跳转,左边的下拉菜单都无法下拉

2018-02-06 Thread PengYang (JIRA)
PengYang created FLINK-8572: --- Summary: Flink1.4版本的document 左边的菜单点击无法跳转,左边的下拉菜单都无法下拉 Key: FLINK-8572 URL: https://issues.apache.org/jira/browse/FLINK-8572 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354988#comment-16354988 ] ASF GitHub Bot commented on FLINK-8516: --- Github user tweise commented on a diff in the pull request:

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

2018-02-06 Thread tweise
Github user tweise commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r166523133 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java --- @@ -0,0

[jira] [Closed] (FLINK-8567) Maven-shade-plugin can't relocate Scala classes.

2018-02-06 Thread John Fang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang closed FLINK-8567. Resolution: Fixed > Maven-shade-plugin can't relocate Scala classes. >

[jira] [Commented] (FLINK-8567) Maven-shade-plugin can't relocate Scala classes.

2018-02-06 Thread John Fang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354883#comment-16354883 ] John Fang commented on FLINK-8567: -- [~Zentol] Thank you. I have made a mistake.  > Maven-shade-plugin

[jira] [Commented] (FLINK-8553) switch flink-metrics-datadog to async mode

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354788#comment-16354788 ] ASF GitHub Bot commented on FLINK-8553: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #5418: [FLINK-8553] switch flink-metrics-datadog to async...

2018-02-06 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5418 [FLINK-8553] switch flink-metrics-datadog to async mode ## What is the purpose of the change Currently DatadogHttpClient in flink-metrics-datadog send http request synchronously. It

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-02-06 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354623#comment-16354623 ] Shuyi Chen commented on FLINK-8562: --- Hi, [~tzulitai], could you please help take a look at this? Thanks

[jira] [Closed] (FLINK-8559) Exceptions in RocksDBIncrementalSnapshotOperation#takeSnapshot cause job to get stuck

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8559. --- Resolution: Fixed master: dbb81acb5a1d0f2a9521c6eef7eeb2436bb8004d > Exceptions in

[jira] [Closed] (FLINK-8550) Iterate over entryset instead of keys

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8550. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[jira] [Closed] (FLINK-7803) Update savepoint Documentation

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7803. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[jira] [Updated] (FLINK-7803) Update savepoint Documentation

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7803: Affects Version/s: 1.5.0 1.4.0 > Update savepoint Documentation >

[jira] [Updated] (FLINK-7608) LatencyGauge change to histogram metric

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7608: Issue Type: Improvement (was: Bug) > LatencyGauge change to histogram metric >

[jira] [Closed] (FLINK-7608) LatencyGauge change to histogram metric

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7608. --- Resolution: Fixed master: e40cb34868e2c6ff7548653e1e5e2dfbe7d47967 > LatencyGauge change to

[jira] [Closed] (FLINK-8565) CheckpointOptionsTest unstable

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8565. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[jira] [Updated] (FLINK-7803) Update savepoint Documentation

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7803: Component/s: State Backends, Checkpointing > Update savepoint Documentation >

[jira] [Updated] (FLINK-7803) Update savepoint Documentation

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7803: Issue Type: Improvement (was: Bug) > Update savepoint Documentation >

[GitHub] flink pull request #5404: [FLINK-8550][table] Iterate over entryset instead ...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5404 ---

[GitHub] flink pull request #5417: [FLINK-8565][tests] Ensure locationBytes.length > ...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5417 ---

[jira] [Commented] (FLINK-8559) Exceptions in RocksDBIncrementalSnapshotOperation#takeSnapshot cause job to get stuck

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354552#comment-16354552 ] ASF GitHub Bot commented on FLINK-8559: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8550) Iterate over entryset instead of keys

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354551#comment-16354551 ] ASF GitHub Bot commented on FLINK-8550: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5407: [hotfix][build] Fix duplicate maven enforce plugin...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5407 ---

[jira] [Commented] (FLINK-8565) CheckpointOptionsTest unstable

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354554#comment-16354554 ] ASF GitHub Bot commented on FLINK-8565: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5161: [FLINK-7608][metric] Refactor latency statistics m...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5161 ---

[GitHub] flink pull request #5406: [hotfix] Fix typos in comments.

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5406 ---

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354553#comment-16354553 ] ASF GitHub Bot commented on FLINK-7608: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5408: [hotfix][docs] Fix typos in windows document

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5408 ---

[GitHub] flink pull request #5412: [FLINK-8559][RocksDB] Release resources if snapsho...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5412 ---

[jira] [Commented] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354391#comment-16354391 ] Tzu-Li (Gordon) Tai commented on FLINK-8275: Merged. 1.5 - 

[jira] [Resolved] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8275. Resolution: Fixed > Flink YARN deployment with Kerberos enabled not working >

[jira] [Commented] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354388#comment-16354388 ] Tzu-Li (Gordon) Tai commented on FLINK-8421: Merged. 1.5 - 

[jira] [Closed] (FLINK-8472) Extend migration tests for Flink 1.4

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8472. -- > Extend migration tests for Flink 1.4 > > >

[jira] [Closed] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8421. -- Resolution: Fixed > HeapInternalTimerService should reconfigure compatible key /

[jira] [Commented] (FLINK-8472) Extend migration tests for Flink 1.4

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354386#comment-16354386 ] Tzu-Li (Gordon) Tai commented on FLINK-8472: Merged. 1.5 - 

[jira] [Resolved] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8484. Resolution: Fixed > Kinesis consumer re-reads closed shards on job restart >

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354385#comment-16354385 ] Tzu-Li (Gordon) Tai commented on FLINK-8484: Merged. 1.5 - 

[jira] [Resolved] (FLINK-8472) Extend migration tests for Flink 1.4

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8472. Resolution: Fixed > Extend migration tests for Flink 1.4 >

[jira] [Commented] (FLINK-8022) Kafka at-least-once tests fail occasionally

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354380#comment-16354380 ] Tzu-Li (Gordon) Tai commented on FLINK-8022: Tests disabled. 1.5 - 

[jira] [Resolved] (FLINK-8022) Kafka at-least-once tests fail occasionally

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8022. Resolution: Resolved > Kafka at-least-once tests fail occasionally >

[jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354377#comment-16354377 ] Tzu-Li (Gordon) Tai commented on FLINK-8419: Merged. 1.5 - 

[jira] [Closed] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8419. -- Resolution: Fixed > Kafka consumer's offset metrics are not registered for dynamically

[jira] [Closed] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8409. -- Resolution: Fixed > Race condition in KafkaConsumerThread leads to potential NPE >

[jira] [Commented] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354373#comment-16354373 ] Tzu-Li (Gordon) Tai commented on FLINK-8409: Merged. 1.4 - 

[jira] [Comment Edited] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354373#comment-16354373 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8409 at 2/6/18 7:07 PM:

[jira] [Closed] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8398. -- Resolution: Fixed > Stabilize flaky KinesisDataFetcherTests >

[jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354371#comment-16354371 ] Tzu-Li (Gordon) Tai commented on FLINK-6004: Merged. 1.5 - 

[jira] [Updated] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6004: --- Fix Version/s: 1.5.0 > Allow FlinkKinesisConsumer to skip corrupted messages >

[jira] [Closed] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6004. -- Resolution: Fixed > Allow FlinkKinesisConsumer to skip corrupted messages >

[jira] [Commented] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests

2018-02-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354370#comment-16354370 ] Tzu-Li (Gordon) Tai commented on FLINK-8398: Merged. 1.4 - 

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354360#comment-16354360 ] ASF GitHub Bot commented on FLINK-8484: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354362#comment-16354362 ] ASF GitHub Bot commented on FLINK-8275: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354363#comment-16354363 ] ASF GitHub Bot commented on FLINK-8421: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354355#comment-16354355 ] ASF GitHub Bot commented on FLINK-8398: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8472) Extend migration tests for Flink 1.4

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354361#comment-16354361 ] ASF GitHub Bot commented on FLINK-8472: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8022) Kafka at-least-once tests fail occasionally

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354359#comment-16354359 ] ASF GitHub Bot commented on FLINK-8022: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354358#comment-16354358 ] ASF GitHub Bot commented on FLINK-8419: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354356#comment-16354356 ] ASF GitHub Bot commented on FLINK-8409: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354357#comment-16354357 ] ASF GitHub Bot commented on FLINK-6004: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5364: [FLINK-8472] [test] Extend all migration tests for...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5364 ---

[GitHub] flink pull request #5362: [FLINK-8421] [DataStream] Make timer serializers r...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5362 ---

[GitHub] flink pull request #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kin...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5337 ---

[GitHub] flink pull request #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer ...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5269 ---

[GitHub] flink pull request #5335: (master) [FLINK-8419] [kafka] Register metrics for...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5335 ---

[GitHub] flink pull request #5380: [hotfix][connectors] Fix log format strings

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5380 ---

[GitHub] flink pull request #5172: [FLINK-8275] [Security] fix keytab local path in Y...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5172 ---

[GitHub] flink pull request #5316: [FLINK-8022][kafka-tests] Disable at-least-once te...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5316 ---

[GitHub] flink pull request #5268: [FLINK-8398] [kinesis, tests] Harden KinesisDataFe...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5268 ---

[GitHub] flink pull request #5329: [FLINK-8409] [kafka] Fix potential NPE in KafkaCon...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5329 ---

[jira] [Updated] (FLINK-8570) Provide a hook in Flink KafkaConsumer(source function) implementation to override assignment of kafka partitions to individual task nodes

2018-02-06 Thread Nagarjun Guraja (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nagarjun Guraja updated FLINK-8570: --- Description: This hook can be leveraged in coassigning and managing the association between

[jira] [Created] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-06 Thread Nagarjun Guraja (JIRA)
Nagarjun Guraja created FLINK-8571: -- Summary: Provide an enhanced KeyedStream implementation to use ForwardPartitioner Key: FLINK-8571 URL: https://issues.apache.org/jira/browse/FLINK-8571 Project:

[jira] [Created] (FLINK-8570) Provide a hook in Flink KafkaConsumer(source function) implementation to override assignment of kafka partitions to individual task nodes

2018-02-06 Thread Nagarjun Guraja (JIRA)
Nagarjun Guraja created FLINK-8570: -- Summary: Provide a hook in Flink KafkaConsumer(source function) implementation to override assignment of kafka partitions to individual task nodes Key: FLINK-8570 URL:

[jira] [Created] (FLINK-8569) Provide a hook to override the default KeyGroupRangeAssignment

2018-02-06 Thread Nagarjun Guraja (JIRA)
Nagarjun Guraja created FLINK-8569: -- Summary: Provide a hook to override the default KeyGroupRangeAssignment Key: FLINK-8569 URL: https://issues.apache.org/jira/browse/FLINK-8569 Project: Flink

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

2018-02-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354203#comment-16354203 ] ASF GitHub Bot commented on FLINK-8101: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ (Transp...

2018-02-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5374 @cjolif sorry, I didn't have the chance, yet. But I agree that we should try getting this in for 1.5 (I saw your reply on the 1.5 release discussion thread in the mailing lists). I'll try

[jira] [Comment Edited] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354179#comment-16354179 ] Aljoscha Krettek edited comment on FLINK-7756 at 2/6/18 5:25 PM: - You can

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2018-02-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354183#comment-16354183 ] Aljoscha Krettek commented on FLINK-6321: - You can use {{1.5-SNAPSHOT}} as the version and add our

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354179#comment-16354179 ] Aljoscha Krettek commented on FLINK-7756: - You can use {{1.5-SNAPSHOT}} as the version and add our

[jira] [Closed] (FLINK-8568) flink table's guava classes can't beed relocated by maven-shed-plugin.

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8568. --- Resolution: Duplicate > flink table's guava classes can't beed relocated by

[jira] [Updated] (FLINK-8568) flink table's guava classes can't beed relocated by maven-shed-plugin.

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8568: Affects Version/s: (was: 2.0.0) > flink table's guava classes can't beed relocated by

[jira] [Commented] (FLINK-8567) Maven-shade-plugin can't relocate Scala classes.

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354159#comment-16354159 ] Chesnay Schepler commented on FLINK-8567: - Please see the instructions at

[jira] [Updated] (FLINK-8567) Maven-shade-plugin can't relocate Scala classes.

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8567: Affects Version/s: (was: 2.0.0) > Maven-shade-plugin can't relocate Scala classes. >

[jira] [Updated] (FLINK-8568) flink table's guava classes can't beed relocated by maven-shed-plugin.

2018-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8568: Fix Version/s: (was: 2.0.0) > flink table's guava classes can't beed relocated by

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2018-02-06 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354152#comment-16354152 ] Shashank Agarwal commented on FLINK-6321: - Sure I’ll check with 1.5 snapshot, only thing is during

[jira] [Closed] (FLINK-8501) Use single BlobCacheService per TaskExecutor

2018-02-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8501. Resolution: Fixed Fixed via 22bf3861c95ed93b2eb5f8d0661d282ef6cdbbc8 > Use single BlobCacheService

[jira] [Closed] (FLINK-8503) Port TaskManagerLogHandler to new REST endpoint

2018-02-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8503. Resolution: Fixed Fixed via 5f573804f0f486db7cc594ae678adff5ae7f217c > Port TaskManagerLogHandler

[jira] [Closed] (FLINK-8502) Remove LibraryCacheManager from JobMaster

2018-02-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8502. Resolution: Fixed Fixed via 2af2b7347c7036bae4b1fb5f37782eccc6749911 > Remove LibraryCacheManager

[jira] [Resolved] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

2018-02-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7856. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via 

  1   2   3   >