[jira] [Assigned] (FLINK-10845) Support DISTINCT aggregates for batch

[ https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10845: - Assignee: xueyu > Support DISTINCT aggregates for batch > - > >

[jira] [Assigned] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10847: --- Assignee: Hequn Cheng > Add support for IS NOT DISTINCT FROM in code generator >

[jira] [Assigned] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10846: - Assignee: xueyu > Add support for IS DISTINCT FROM in code generator >

[jira] [Comment Edited] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

[ https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681734#comment-16681734 ] Stefan Richter edited comment on FLINK-10844 at 11/9/18 5:28 PM: - I

[jira] [Commented] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

[ https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681734#comment-16681734 ] Stefan Richter commented on FLINK-10844: I don't think that it is an issue with the code. What

[jira] [Commented] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681680#comment-16681680 ] Andrey Zagrebin commented on FLINK-10482: - [~JBiason] do you still have the full log? can you

[jira] [Updated] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10847: - Issue Type: Sub-task (was: New Feature) Parent: FLINK-6810 > Add support for IS NOT

[jira] [Created] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator

Timo Walther created FLINK-10847: Summary: Add support for IS NOT DISTINCT FROM in code generator Key: FLINK-10847 URL: https://issues.apache.org/jira/browse/FLINK-10847 Project: Flink Issue

[jira] [Updated] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10846: - Issue Type: Sub-task (was: New Feature) Parent: FLINK-6810 > Add support for IS

[jira] [Created] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

Timo Walther created FLINK-10846: Summary: Add support for IS DISTINCT FROM in code generator Key: FLINK-10846 URL: https://issues.apache.org/jira/browse/FLINK-10846 Project: Flink Issue

[jira] [Created] (FLINK-10845) Support DISTINCT aggregates for batch

Timo Walther created FLINK-10845: Summary: Support DISTINCT aggregates for batch Key: FLINK-10845 URL: https://issues.apache.org/jira/browse/FLINK-10845 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681562#comment-16681562 ] ASF GitHub Bot commented on FLINK-10736: azagrebin opened a new pull request #7077:

[jira] [Updated] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10736: --- Labels: pull-request-available test-stability (was: test-stability) > Shaded Hadoop S3A

[GitHub] azagrebin opened a new pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests

azagrebin opened a new pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests URL: https://github.com/apache/flink/pull/7077 ## What is the purpose of the change Remove s3 put/delete from s3 shaded e2e tests and use already uploaded,

[jira] [Commented] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

[ https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681533#comment-16681533 ] Daniel Harper commented on FLINK-10844: --- Note I can see this code was changed for versions >=

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681556#comment-16681556 ] ASF GitHub Bot commented on FLINK-7155: --- zentol commented on a change in pull request #6976:

[GitHub] zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r232280371 ## File path:

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681550#comment-16681550 ] ASF GitHub Bot commented on FLINK-7155: --- zentol commented on a change in pull request #6976:

[GitHub] zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r232279530 ## File path:

[jira] [Created] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

Daniel Harper created FLINK-10844: - Summary: ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2) Key: FLINK-10844 URL: https://issues.apache.org/jira/browse/FLINK-10844 Project: Flink

[jira] [Commented] (FLINK-10626) Add documentation for event-time temporal table joins

[ https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681513#comment-16681513 ] ASF GitHub Bot commented on FLINK-10626: pnowojski commented on a change in pull request #7065:

[jira] [Commented] (FLINK-10626) Add documentation for event-time temporal table joins

[ https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681512#comment-16681512 ] ASF GitHub Bot commented on FLINK-10626: pnowojski commented on a change in pull request #7065:

[jira] [Commented] (FLINK-10626) Add documentation for event-time temporal table joins

[ https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681514#comment-16681514 ] ASF GitHub Bot commented on FLINK-10626: pnowojski commented on a change in pull request #7065:

[GitHub] pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins

pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins URL: https://github.com/apache/flink/pull/7065#discussion_r232268635 ## File path: docs/dev/table/streaming/joins.md ## @@ -189,14

[GitHub] pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins

pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins URL: https://github.com/apache/flink/pull/7065#discussion_r232267090 ## File path: docs/dev/table/streaming/joins.md ## @@ -189,14

[GitHub] pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins

pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins URL: https://github.com/apache/flink/pull/7065#discussion_r232268772 ## File path: docs/dev/table/streaming/joins.md ## @@ -189,14

[jira] [Commented] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681505#comment-16681505 ] Till Rohrmann commented on FLINK-10828: --- I was referring to

[jira] [Commented] (FLINK-10674) DistinctAccumulator.remove lead to NPE

[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681497#comment-16681497 ] ASF GitHub Bot commented on FLINK-10674: wenhuitang opened a new pull request #7076: [Patch]:Fix

[GitHub] wenhuitang opened a new pull request #7076: [Patch]:Fix [FLINK-10674]DistinctAccumulator.remove lead to NPE.

wenhuitang opened a new pull request #7076: [Patch]:Fix [FLINK-10674]DistinctAccumulator.remove lead to NPE. URL: https://github.com/apache/flink/pull/7076 ## What is the purpose of the change This pull request fixes the problem reported by FLINK-10674 DistinctAccumulator.remove

[jira] [Closed] (FLINK-10835) Remove duplicated Round-robin ChannelSelector implementation in RecordWriterTest

[ https://issues.apache.org/jira/browse/FLINK-10835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10835. -- Resolution: Fixed Fix Version/s: 1.8.0 merged commit 091cff3 into apache:master >

[jira] [Commented] (FLINK-10835) Remove duplicated Round-robin ChannelSelector implementation in RecordWriterTest

[ https://issues.apache.org/jira/browse/FLINK-10835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681490#comment-16681490 ] ASF GitHub Bot commented on FLINK-10835: pnowojski closed pull request #7069:

[GitHub] pnowojski closed pull request #7069: [FLINK-10835][network] Remove duplicated round-robin ChannelSelector implementation

pnowojski closed pull request #7069: [FLINK-10835][network] Remove duplicated round-robin ChannelSelector implementation URL: https://github.com/apache/flink/pull/7069 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[jira] [Commented] (FLINK-10764) Add S3 entropy injection end-to-end/IT test

[ https://issues.apache.org/jira/browse/FLINK-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681488#comment-16681488 ] ASF GitHub Bot commented on FLINK-10764: GJL opened a new pull request #7075:

[jira] [Updated] (FLINK-10764) Add S3 entropy injection end-to-end/IT test

[ https://issues.apache.org/jira/browse/FLINK-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10764: --- Labels: pull-request-available (was: ) > Add S3 entropy injection end-to-end/IT test >

[GitHub] GJL opened a new pull request #7075: [FLINK-10764][tests] Add ITCase for checkpoint path entropy injection.

GJL opened a new pull request #7075: [FLINK-10764][tests] Add ITCase for checkpoint path entropy injection. URL: https://github.com/apache/flink/pull/7075 Add a test that verifies that checkpoint data on the file system has additional entropy added to its path. Remove code

[jira] [Commented] (FLINK-10628) Add end-to-end test for REST communication encryption

[ https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681477#comment-16681477 ] ASF GitHub Bot commented on FLINK-10628: azagrebin commented on issue #6967:

[jira] [Assigned] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10481: Assignee: Dawid Wysakowicz > Wordcount end-to-end test in docker env unstable >

[jira] [Updated] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10842: --- Labels: pull-request-available (was: ) > Waiting loops are broken in e2e/common.sh >

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681483#comment-16681483 ] ASF GitHub Bot commented on FLINK-7155: --- 1u0 commented on a change in pull request #6976:

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681482#comment-16681482 ] ASF GitHub Bot commented on FLINK-10820: pnowojski commented on a change in pull request #7051:

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681480#comment-16681480 ] ASF GitHub Bot commented on FLINK-10827: zentol commented on a change in pull request #7061:

[GitHub] 1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r232263625 ## File path:

[jira] [Commented] (FLINK-10628) Add end-to-end test for REST communication encryption

[ https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681479#comment-16681479 ] ASF GitHub Bot commented on FLINK-10628: azagrebin edited a comment on issue #6967:

[GitHub] azagrebin edited a comment on issue #6967: [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests

azagrebin edited a comment on issue #6967: [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests URL: https://github.com/apache/flink/pull/6967#issuecomment-437369228 I reverted the loop changes and factored out them into another PR #7073 for new issue

[GitHub] dawidwys opened a new pull request #7074: [FLINK-10481][e2e] Added retry logic for building docker image

dawidwys opened a new pull request #7074: [FLINK-10481][e2e] Added retry logic for building docker image URL: https://github.com/apache/flink/pull/7074 Added retry logic around building docker job image. This is an automated

[GitHub] zentol commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

zentol commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232263454 ## File path:

[GitHub] pnowojski commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

pnowojski commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#discussion_r232263469 ## File path:

[jira] [Commented] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681478#comment-16681478 ] ASF GitHub Bot commented on FLINK-10481: dawidwys opened a new pull request #7074:

[GitHub] azagrebin commented on issue #6967: [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests

azagrebin commented on issue #6967: [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests URL: https://github.com/apache/flink/pull/6967#issuecomment-437369228 I reverted the loop changes and factored out them into another PR #7073 for new issue FLINK-10842.

[jira] [Updated] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10481: --- Labels: pull-request-available test-stability (was: test-stability) > Wordcount end-to-end

[jira] [Commented] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.

[ https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681469#comment-16681469 ] sunjincheng commented on FLINK-10819: - Thanks [~till.rohrmann]， I am sorry that I did not keep the

[jira] [Commented] (FLINK-10674) DistinctAccumulator.remove lead to NPE

[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681456#comment-16681456 ] ASF GitHub Bot commented on FLINK-10674: ambition119 commented on issue #7067: [FLINK-10674]

[GitHub] azagrebin commented on issue #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh

azagrebin commented on issue #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh URL: https://github.com/apache/flink/pull/7073#issuecomment-437367164 cc @zentol This is an automated message from the

[jira] [Commented] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681462#comment-16681462 ] ASF GitHub Bot commented on FLINK-10842: azagrebin opened a new pull request #7073:

[jira] [Updated] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10842: Affects Version/s: 1.7.0 > Waiting loops are broken in e2e/common.sh >

[jira] [Created] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

Timo Walther created FLINK-10843: Summary: Make Kafka version definition more flexible for new Kafka table factory Key: FLINK-10843 URL: https://issues.apache.org/jira/browse/FLINK-10843 Project:

[jira] [Commented] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681463#comment-16681463 ] ASF GitHub Bot commented on FLINK-10842: azagrebin commented on issue #7073: [FLINK-10842][E2E

[jira] [Resolved] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10771. --- Resolution: Fixed Fix Version/s: 1.7.0 Fixed via

[GitHub] azagrebin opened a new pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh

azagrebin opened a new pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh URL: https://github.com/apache/flink/pull/7073 ## What is the purpose of the change There are 3 loops in flink-end-to-end-tests/test-scripts/common.sh where the script waits

[GitHub] ambition119 commented on issue #7067: [FLINK-10674] [table] DistinctAccumulator.remove occur NPE

ambition119 commented on issue #7067: [FLINK-10674] [table] DistinctAccumulator.remove occur NPE URL: https://github.com/apache/flink/pull/7067#issuecomment-437366592 sorry, Complex Event Processing (CEP) SQL Realization this commit I can't remove

[jira] [Commented] (FLINK-6046) Add support for oversized messages during deployment

[ https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681453#comment-16681453 ] ASF GitHub Bot commented on FLINK-6046: --- TisonKun commented on issue #7050: [hotfix] Follow up

[jira] [Commented] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681454#comment-16681454 ] Piotr Nowojski commented on FLINK-10662: Yes, back in the past I was also thinking about this

[GitHub] TisonKun commented on issue #7050: [hotfix] Follow up FLINK-6046 to clean unused variable

TisonKun commented on issue #7050: [hotfix] Follow up FLINK-6046 to clean unused variable URL: https://github.com/apache/flink/pull/7050#issuecomment-437366246 Thank @zhijiangW and @tillrohrmann for reviews! To @zhijiangW sorry for response too late to catch the discussion. I copy

[jira] [Updated] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10843: - Affects Version/s: 1.7.0 > Make Kafka version definition more flexible for new Kafka table

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681448#comment-16681448 ] ASF GitHub Bot commented on FLINK-10771: asfgit closed pull request #7054: [FLINK-10771] Replace

[GitHub] asfgit closed pull request #7054: [FLINK-10771] Replace hard code of job graph file path with config option for FileJobGraphRetriever

asfgit closed pull request #7054: [FLINK-10771] Replace hard code of job graph file path with config option for FileJobGraphRetriever URL: https://github.com/apache/flink/pull/7054 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed

[jira] [Updated] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10842: Fix Version/s: 1.7.0 > Waiting loops are broken in e2e/common.sh >

[jira] [Updated] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10842: Component/s: E2E Tests > Waiting loops are broken in e2e/common.sh >

[jira] [Created] (FLINK-10842) Waiting loops are broken in e2e/common.sh

Andrey Zagrebin created FLINK-10842: --- Summary: Waiting loops are broken in e2e/common.sh Key: FLINK-10842 URL: https://issues.apache.org/jira/browse/FLINK-10842 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681446#comment-16681446 ] ASF GitHub Bot commented on FLINK-10624: twalthr commented on a change in pull request #6927:

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681445#comment-16681445 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on a change in pull request

[GitHub] twalthr commented on a change in pull request #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

twalthr commented on a change in pull request #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#discussion_r232257714 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml ##

[GitHub] StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232249327 ## File path:

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681441#comment-16681441 ] ASF GitHub Bot commented on FLINK-7155: --- 1u0 commented on a change in pull request #6976:

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681439#comment-16681439 ] ASF GitHub Bot commented on FLINK-7155: --- 1u0 commented on a change in pull request #6976:

[GitHub] 1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r232255912 ## File path:

[GitHub] 1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r232256095 ## File path:

[jira] [Created] (FLINK-10841) Reduce the number of ListObjects calls when checkpointing to S3

Pawel Bartoszek created FLINK-10841: --- Summary: Reduce the number of ListObjects calls when checkpointing to S3 Key: FLINK-10841 URL: https://issues.apache.org/jira/browse/FLINK-10841 Project: Flink

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681433#comment-16681433 ] ASF GitHub Bot commented on FLINK-7155: --- 1u0 commented on a change in pull request #6976:

[GitHub] tillrohrmann closed pull request #7050: [hotfix] Follow up FLINK-6046 to clean unused variable

tillrohrmann closed pull request #7050: [hotfix] Follow up FLINK-6046 to clean unused variable URL: https://github.com/apache/flink/pull/7050 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 provenance: As

[GitHub] 1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r232254767 ## File path:

[jira] [Commented] (FLINK-6046) Add support for oversized messages during deployment

[ https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681430#comment-16681430 ] ASF GitHub Bot commented on FLINK-6046: --- tillrohrmann closed pull request #7050: [hotfix] Follow up

[jira] [Updated] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10828: -- Fix Version/s: 1.8.0 > Enforce that all TypeSerializers are tested through SerializerTestBase

[jira] [Commented] (FLINK-10840) BucketingSink incorrectly clears the pendingFiles List

[ https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681421#comment-16681421 ] Till Rohrmann commented on FLINK-10840: --- You pass in the {{Collection}} stored in

[jira] [Commented] (FLINK-10674) DistinctAccumulator.remove lead to NPE

[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681419#comment-16681419 ] ASF GitHub Bot commented on FLINK-10674: ambition119 removed a comment on issue #7067:

[GitHub] ambition119 removed a comment on issue #7067: [FLINK-10674] [table] DistinctAccumulator.remove occur NPE

ambition119 removed a comment on issue #7067: [FLINK-10674] [table] DistinctAccumulator.remove occur NPE URL: https://github.com/apache/flink/pull/7067#issuecomment-437321281 Complex Event Processing (CEP) SQL Realization is a new feature. Use statement : ```sql SELECT [ ALL |

[jira] [Updated] (FLINK-10838) Rewrite Kafka tests that fail Kafka brokers

[ https://issues.apache.org/jira/browse/FLINK-10838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10838: - Description: Currently we have many tests that in order to test for example

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681417#comment-16681417 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on a change in pull request

[GitHub] StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232249327 ## File path:

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681415#comment-16681415 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on a change in pull request

[GitHub] StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232249327 ## File path:

[jira] [Commented] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not resume from Externalized Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681409#comment-16681409 ] ASF GitHub Bot commented on FLINK-10821: igalshilman opened a new pull request #7072:

[jira] [Updated] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not resume from Externalized Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10821: --- Labels: pull-request-available (was: ) > Resuming Externalized Checkpoint E2E test does

[GitHub] igalshilman opened a new pull request #7072: [FLINK-10821] E2E now uses externalized checkpoint

igalshilman opened a new pull request #7072: [FLINK-10821] E2E now uses externalized checkpoint URL: https://github.com/apache/flink/pull/7072 ## What is the purpose of the change This PR fixes the `test_resume_externalized_checkpoints.sh` script, by providing the path to the

[jira] [Commented] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681407#comment-16681407 ] ASF GitHub Bot commented on FLINK-10251: tillrohrmann commented on issue #6876: [FLINK-10251]

[GitHub] tillrohrmann commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor

tillrohrmann commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor URL: https://github.com/apache/flink/pull/6876#issuecomment-437353852 Thanks for the reminder @yanghua. I'm still busy with the 1.7 release. Once it is out, I'll take a look at this PR.

[jira] [Commented] (FLINK-10840) BucketingSink incorrectly clears the pendingFiles List

[ https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681398#comment-16681398 ] vinoyang commented on FLINK-10840: -- yes.Isn't it? > BucketingSink incorrectly clears the pendingFiles

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681397#comment-16681397 ] ASF GitHub Bot commented on FLINK-10827: zentol commented on a change in pull request #7061:

[GitHub] zentol commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

zentol commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232240467 ## File path:

[jira] [Commented] (FLINK-10840) BucketingSink incorrectly clears the pendingFiles List

[ https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681395#comment-16681395 ] Chesnay Schepler commented on FLINK-10840: -- [~yanghua] are you asking whether

  1   2   3   >