[jira] [Created] (FLINK-10685) Support history server on YARN

2018-10-25 Thread vinoyang (JIRA)
vinoyang created FLINK-10685: Summary: Support history server on YARN Key: FLINK-10685 URL: https://issues.apache.org/jira/browse/FLINK-10685 Project: Flink Issue Type: Improvement Comp

[jira] [Updated] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

2018-10-25 Thread Paul Lin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-10680: - Labels: pull-request-available (was: ) > Unable to set negative offsets for TumblingEventTimeWindow > -

[jira] [Created] (FLINK-10684) Improve the CSV reading process

2018-10-25 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10684: --- Summary: Improve the CSV reading process Key: FLINK-10684 URL: https://issues.apache.org/jira/browse/FLINK-10684 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10683) Error while executing BLOB connection. java.io.IOException: Unknown operation

2018-10-25 Thread Yee (JIRA)
Yee created FLINK-10683: --- Summary: Error while executing BLOB connection. java.io.IOException: Unknown operation Key: FLINK-10683 URL: https://issues.apache.org/jira/browse/FLINK-10683 Project: Flink

[jira] [Commented] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

2018-10-25 Thread Paul Lin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664559#comment-16664559 ] Paul Lin commented on FLINK-10680: -- [~hequn8128] Thanks for the pointer. I looked into

[jira] [Commented] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

2018-10-25 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664527#comment-16664527 ] Hequn Cheng commented on FLINK-10680: - [~Paul Lin] Hi, thanks for your contribution.

[jira] [Commented] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

2018-10-25 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664519#comment-16664519 ] vinoyang commented on FLINK-10680: -- [~Paul Lin] OK, I can help review it when I have ti

[jira] [Assigned] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

2018-10-25 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10680: Assignee: (was: vinoyang) > Unable to set negative offsets for TumblingEventTimeWindow >

[jira] [Commented] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

2018-10-25 Thread Paul Lin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664508#comment-16664508 ] Paul Lin commented on FLINK-10680: -- Hi [~yanghua], I've created a PR for this, would yo

[GitHub] link3280 opened a new pull request #6932: [Flink-10680][streaming] Fix IllegalArgumentException caused by negative offset in TumblingWindows

2018-10-25 Thread GitBox
link3280 opened a new pull request #6932: [Flink-10680][streaming] Fix IllegalArgumentException caused by negative offset in TumblingWindows URL: https://github.com/apache/flink/pull/6932 ## What is the purpose of the change By design, the offset could be either positive or negative

[jira] [Assigned] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

2018-10-25 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10680: Assignee: vinoyang > Unable to set negative offsets for TumblingEventTimeWindow > ---

[jira] [Issue Comment Deleted] (FLINK-10276) Job Manager and Task Manager Metrics Reporter Ports Configuration

2018-10-25 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stavros Kontopoulos updated FLINK-10276: Comment: was deleted (was: This might be a problem on K8s too, which does not cove

[jira] [Commented] (FLINK-10276) Job Manager and Task Manager Metrics Reporter Ports Configuration

2018-10-25 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664420#comment-16664420 ] Stavros Kontopoulos commented on FLINK-10276: - This might be a problem on K8

[jira] [Comment Edited] (FLINK-10276) Job Manager and Task Manager Metrics Reporter Ports Configuration

2018-10-25 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664420#comment-16664420 ] Stavros Kontopoulos edited comment on FLINK-10276 at 10/25/18 11:28 PM: --

[jira] [Created] (FLINK-10682) EOFException occurs during deserialization of Avro class

2018-10-25 Thread Ben La Monica (JIRA)
Ben La Monica created FLINK-10682: - Summary: EOFException occurs during deserialization of Avro class Key: FLINK-10682 URL: https://issues.apache.org/jira/browse/FLINK-10682 Project: Flink Is

[jira] [Commented] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

2018-10-25 Thread Devin Thomson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664305#comment-16664305 ] Devin Thomson commented on FLINK-4582: -- [~yxu-lyft] [~tzulitai] Hey guys! Devin fro

[jira] [Comment Edited] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

2018-10-25 Thread Devin Thomson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664305#comment-16664305 ] Devin Thomson edited comment on FLINK-4582 at 10/25/18 9:23 PM: ---

[jira] [Updated] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6444: -- Labels: pull-request-available (was: ) > Add a check that '@VisibleForTesting' methods are onl

[jira] [Commented] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664278#comment-16664278 ] ASF GitHub Bot commented on FLINK-6444: --- zentol closed pull request #4705: [FLINK-6

[GitHub] zentol closed pull request #4705: [FLINK-6444] [build] Add a check that '@VisibleForTesting' methods ar…

2018-10-25 Thread GitBox
zentol closed pull request #4705: [FLINK-6444] [build] Add a check that '@VisibleForTesting' methods ar… URL: https://github.com/apache/flink/pull/4705 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenanc

[jira] [Updated] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6857: -- Labels: pull-request-available (was: ) > Add global default Kryo serializer configuration to S

[jira] [Commented] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664270#comment-16664270 ] ASF GitHub Bot commented on FLINK-6857: --- zentol closed pull request #4166: [FLINK-6

[GitHub] zentol closed pull request #4166: [FLINK-6857] [types] Add global default Kryo serializer configuration…

2018-10-25 Thread GitBox
zentol closed pull request #4166: [FLINK-6857] [types] Add global default Kryo serializer configuration… URL: https://github.com/apache/flink/pull/4166 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenanc

[jira] [Commented] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA library installed

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664189#comment-16664189 ] ASF GitHub Bot commented on FLINK-10681: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #6928: [FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library

2018-10-25 Thread GitBox
zentol commented on a change in pull request #6928: [FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library URL: https://github.com/apache/flink/pull/6928#discussion_r228302547 ## File path: flink-connectors/flink-connector-elasticsearch6/pom.xml ## @@ -278,

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664026#comment-16664026 ] ASF GitHub Bot commented on FLINK-9808: --- tzulitai removed a comment on issue #6931:

[GitHub] tzulitai removed a comment on issue #6931: [FLINK-9808] [state-backends] Migrate state when necessary in state backends

2018-10-25 Thread GitBox
tzulitai removed a comment on issue #6931: [FLINK-9808] [state-backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6931#issuecomment-433123169 cc @StefanRRichter & @kl0u This PR subsumes #6875. Stefan, I've also addressed your latest com

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663989#comment-16663989 ] ASF GitHub Bot commented on FLINK-9808: --- tzulitai closed pull request #6875: [FLINK

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663988#comment-16663988 ] ASF GitHub Bot commented on FLINK-9808: --- tzulitai commented on issue #6875: [FLINK-

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663986#comment-16663986 ] ASF GitHub Bot commented on FLINK-9808: --- tzulitai commented on issue #6931: [FLINK-

[GitHub] tzulitai closed pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

2018-10-25 Thread GitBox
tzulitai closed pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of p

[GitHub] tzulitai commented on issue #6931: [FLINK-9808] [state-backends] Migrate state when necessary in state backends

2018-10-25 Thread GitBox
tzulitai commented on issue #6931: [FLINK-9808] [state-backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6931#issuecomment-433123169 cc @StefanRRichter & @kl0u This PR subsumes #6875. Stefan, I've also addressed your latest comments in

[GitHub] tzulitai commented on issue #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

2018-10-25 Thread GitBox
tzulitai commented on issue #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#issuecomment-433123440 This PR is now subsumed by #6931. All comments have been addressed in the new PR. ---

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663983#comment-16663983 ] ASF GitHub Bot commented on FLINK-9808: --- tzulitai opened a new pull request #6931:

[GitHub] tzulitai opened a new pull request #6931: [FLINK-9808] [state-backends] Migrate state when necessary

2018-10-25 Thread GitBox
tzulitai opened a new pull request #6931: [FLINK-9808] [state-backends] Migrate state when necessary URL: https://github.com/apache/flink/pull/6931 ## What is the purpose of the change This PR is based on #6930. Only the last commit is relevant. This PR adds the procedure of m

[GitHub] tzulitai opened a new pull request #6930: [FLINK-10679] Remove deprecated CompatibilityResult and related classes from framework code

2018-10-25 Thread GitBox
tzulitai opened a new pull request #6930: [FLINK-10679] Remove deprecated CompatibilityResult and related classes from framework code URL: https://github.com/apache/flink/pull/6930 ## What is the purpose of the change The main purpose of this PR is the following: 1) The now de

[jira] [Updated] (FLINK-10679) Let TypeSerializerSchemaCompatibility.resolveSchemaCompatibility() be the entry point for compatibility checks in framework code

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10679: --- Labels: pull-request-available (was: ) > Let TypeSerializerSchemaCompatibility.resolveSchem

[jira] [Commented] (FLINK-10679) Let TypeSerializerSchemaCompatibility.resolveSchemaCompatibility() be the entry point for compatibility checks in framework code

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663977#comment-16663977 ] ASF GitHub Bot commented on FLINK-10679: tzulitai opened a new pull request #693

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663950#comment-16663950 ] ASF GitHub Bot commented on FLINK-10599: yanghua commented on issue #6889: [FLIN

[GitHub] yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#issuecomment-433110004 @pnowojski updated. This is an automate

[GitHub] tillrohrmann opened a new pull request #6929: [BP-1.6][FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library

2018-10-25 Thread GitBox
tillrohrmann opened a new pull request #6929: [BP-1.6][FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library URL: https://github.com/apache/flink/pull/6929 Backport of #6928 to `release-1.6`. This is an automa

[jira] [Commented] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA library installed

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663933#comment-16663933 ] ASF GitHub Bot commented on FLINK-10681: tillrohrmann opened a new pull request

[jira] [Updated] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA library installed

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10681: --- Labels: pull-request-available (was: ) > elasticsearch6.ElasticsearchSinkITCase fails if wr

[GitHub] tillrohrmann opened a new pull request #6928: [FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library

2018-10-25 Thread GitBox
tillrohrmann opened a new pull request #6928: [FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library URL: https://github.com/apache/flink/pull/6928 ## What is the purpose of the change Set the system property jna.nosys=true to avoid ElasticsearchSinkITCase test failu

[jira] [Updated] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA library installed

2018-10-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10681: -- Fix Version/s: (was: 1.6.2) 1.6.3 > elasticsearch6.ElasticsearchSinkITC

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663928#comment-16663928 ] ASF GitHub Bot commented on FLINK-10357: azagrebin commented on a change in pull

[jira] [Updated] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA library installed

2018-10-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10681: -- Summary: elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA library installed (was: el

[GitHub] azagrebin commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-25 Thread GitBox
azagrebin commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r228228728 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663923#comment-16663923 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on a change in pull reque

[GitHub] GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-25 Thread GitBox
GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r228226695 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @@ -45,

[jira] [Updated] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA librar installed

2018-10-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10681: -- Summary: elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA librar installed (was: ela

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663919#comment-16663919 ] ASF GitHub Bot commented on FLINK-10357: GJL commented on a change in pull reque

[jira] [Created] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA installed

2018-10-25 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10681: - Summary: elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA installed Key: FLINK-10681 URL: https://issues.apache.org/jira/browse/FLINK-10681 Project: Flink

[GitHub] GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-25 Thread GitBox
GJL commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r228225734 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @@ -45,

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663914#comment-16663914 ] ASF GitHub Bot commented on FLINK-10599: pnowojski commented on a change in pull

[GitHub] pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r228218658 ## File path: docs/dev/connectors/kafka.md ## @@ -108,15 +108,15 @

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663907#comment-16663907 ] ASF GitHub Bot commented on FLINK-10357: azagrebin commented on a change in pull

[jira] [Commented] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663908#comment-16663908 ] ASF GitHub Bot commented on FLINK-10357: azagrebin commented on a change in pull

[GitHub] azagrebin commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-25 Thread GitBox
azagrebin commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r228220548 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @

[GitHub] azagrebin commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

2018-10-25 Thread GitBox
azagrebin commented on a change in pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6907#discussion_r228218936 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh ## @

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663900#comment-16663900 ] ASF GitHub Bot commented on FLINK-10599: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663896#comment-16663896 ] ASF GitHub Bot commented on FLINK-10599: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663899#comment-16663899 ] ASF GitHub Bot commented on FLINK-10599: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663901#comment-16663901 ] ASF GitHub Bot commented on FLINK-10599: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663897#comment-16663897 ] ASF GitHub Bot commented on FLINK-10599: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663898#comment-16663898 ] ASF GitHub Bot commented on FLINK-10599: pnowojski commented on a change in pull

[GitHub] pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r228219659 ## File path: docs/dev/connectors/kafka.md ## @@ -650,13 +650,13 @

[GitHub] pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r228218658 ## File path: docs/dev/connectors/kafka.md ## @@ -108,15 +108,15 @

[GitHub] pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r228217863 ## File path: docs/dev/connectors/kafka.md ## @@ -85,7 +85,7 @@ Fo

[GitHub] pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r228219170 ## File path: docs/dev/connectors/kafka.md ## @@ -134,7 +134,7 @@

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663891#comment-16663891 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread GitBox
yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#discussion_r228220202 ## File path: flink-end-to-end-tests/test-scripts/test-data/modern-kafka-common.sh #

[GitHub] pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r228219298 ## File path: docs/dev/connectors/kafka.md ## @@ -524,7 +524,7 @@

[GitHub] pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
pnowojski commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r228219609 ## File path: docs/dev/connectors/kafka.md ## @@ -650,13 +650,13 @

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663894#comment-16663894 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread GitBox
yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#discussion_r228219980 ## File path: flink-end-to-end-tests/test-scripts/test-data/modern-kafka-common.sh #

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663889#comment-16663889 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread GitBox
yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#discussion_r228219566 ## File path: flink-end-to-end-tests/test-scripts/test-data/modern-kafka-common.sh #

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663881#comment-16663881 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread GitBox
yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#discussion_r228217901 ## File path: flink-end-to-end-tests/test-scripts/test-data/modern-kafka-common.sh #

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663868#comment-16663868 ] ASF GitHub Bot commented on FLINK-10599: yanghua commented on issue #6889: [FLIN

[jira] [Commented] (FLINK-10096) Metrics report incorrect subtask ids

2018-10-25 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663869#comment-16663869 ] Piotr Nowojski commented on FLINK-10096: Maybe in that case renaming the ticket

[GitHub] yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector

2018-10-25 Thread GitBox
yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#issuecomment-433089952 @pnowojski thanks for your suggestion, updated.

[jira] [Commented] (FLINK-10666) Port YarnClusterDescriptorTest to new codebase

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663821#comment-16663821 ] ASF GitHub Bot commented on FLINK-10666: TisonKun edited a comment on issue #691

[jira] [Commented] (FLINK-10666) Port YarnClusterDescriptorTest to new codebase

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663820#comment-16663820 ] ASF GitHub Bot commented on FLINK-10666: TisonKun commented on issue #6919: [FLI

[GitHub] TisonKun commented on issue #6919: [FLINK-10666] [tests] Port YarnClusterDescriptorTest to new codebase

2018-10-25 Thread GitBox
TisonKun commented on issue #6919: [FLINK-10666] [tests] Port YarnClusterDescriptorTest to new codebase URL: https://github.com/apache/flink/pull/6919#issuecomment-433075429 cc @StefanRRichter @tillrohrmann I think this pull request is quite trivial since it just replaces `LegacyYar

[GitHub] TisonKun edited a comment on issue #6919: [FLINK-10666] [tests] Port YarnClusterDescriptorTest to new codebase

2018-10-25 Thread GitBox
TisonKun edited a comment on issue #6919: [FLINK-10666] [tests] Port YarnClusterDescriptorTest to new codebase URL: https://github.com/apache/flink/pull/6919#issuecomment-433075429 cc @StefanRRichter @tillrohrmann @GJL I think this pull request is quite trivial since it just replace

[GitHub] TisonKun commented on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c…

2018-10-25 Thread GitBox
TisonKun commented on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c… URL: https://github.com/apache/flink/pull/6917#issuecomment-433074450 @zentol I fix the checkstyle issue. Can you review this? -

[jira] [Commented] (FLINK-10665) Port YARNSessionFIFOITCase#testJavaAPI to new codebase

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663816#comment-16663816 ] ASF GitHub Bot commented on FLINK-10665: TisonKun commented on issue #6917: [FLI

[jira] [Commented] (FLINK-10096) Metrics report incorrect subtask ids

2018-10-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663806#comment-16663806 ] Chesnay Schepler commented on FLINK-10096: -- I did not close it due to being low

[jira] [Commented] (FLINK-10668) Streaming File Sink E2E test fails because not all legitimate exceptions are excluded

2018-10-25 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663794#comment-16663794 ] Hequn Cheng commented on FLINK-10668: - [~gjy] Hi, thanks for the information about h

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663757#comment-16663757 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663756#comment-16663756 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663758#comment-16663758 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663760#comment-16663760 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663754#comment-16663754 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663759#comment-16663759 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663752#comment-16663752 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663755#comment-16663755 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663753#comment-16663753 ] ASF GitHub Bot commented on FLINK-10600: pnowojski commented on a change in pull

  1   2   3   >