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

2018-11-09 Thread xueyu (JIRA)
[ 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] [Assigned] (FLINK-10845) Support DISTINCT aggregates for batch

2018-11-09 Thread xueyu (JIRA)
[ 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

2018-11-09 Thread Hequn Cheng (JIRA)
[ 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] [Updated] (FLINK-10838) Rewrite Kafka tests that fail Kafka brokers

2018-11-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10838: --- Priority: Critical (was: Major) Fix Version/s: 1.8.0 > Rewrite Kafka tests that

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

2018-11-09 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-10838: -- Summary: Rewrite Kafka tests that fail Kafka brokers Key: FLINK-10838 URL: https://issues.apache.org/jira/browse/FLINK-10838 Project: Flink Issue Type:

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

2018-11-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10838: --- Description: Currently we have many tests that in order to test for example

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

2018-11-09 Thread GitBox
pnowojski 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_r232207974 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681290#comment-16681290 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on a change in pull request #6927:

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

2018-11-09 Thread GitBox
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_r232224203 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml ##

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681106#comment-16681106 ] ASF GitHub Bot commented on FLINK-10820: Clark commented on issue #7051:

[jira] [Updated] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic?

2018-11-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10837: --- Component/s: Kafka Connector > Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681228#comment-16681228 ] ASF GitHub Bot commented on FLINK-10624: pnowojski commented on a change in pull request #6927:

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

2018-11-09 Thread GitBox
pnowojski 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_r232207878 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681227#comment-16681227 ] ASF GitHub Bot commented on FLINK-10624: pnowojski commented on a change in pull request #6927:

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681275#comment-16681275 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on a change in pull request #6927:

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

2018-11-09 Thread GitBox
yanghua 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_r232219046 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml ##

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

2018-11-09 Thread GitBox
yanghua 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_r232220070 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml ##

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

2018-11-09 Thread GitBox
ambition119 edited 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] [Comment Edited] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

2018-11-09 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681198#comment-16681198 ] zhijiang edited comment on FLINK-10662 at 11/9/18 10:07 AM: [~pnowojski], I

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

2018-11-09 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681198#comment-16681198 ] zhijiang edited comment on FLINK-10662 at 11/9/18 10:08 AM: [~pnowojski], I

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681238#comment-16681238 ] ASF GitHub Bot commented on FLINK-10674: ambition119 commented on issue #7067: [FLINK-10674]

[jira] [Commented] (FLINK-10834) TableAPI flatten() calculated value error

2018-11-09 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681236#comment-16681236 ] sunjincheng commented on FLINK-10834: - Hi,[~fhueske], Thanks for your comments! I think the 

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

2018-11-09 Thread GitBox
ambition119 commented 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 new pull request, is a new feature. Use statement : ```sql SELECT

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10674: --- Labels: pull-request-available (was: ) > DistinctAccumulator.remove lead to NPE >

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

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

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

2018-11-09 Thread GitBox
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_r232213530 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml ##

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681288#comment-16681288 ] ASF GitHub Bot commented on FLINK-10674: ambition119 edited a comment on issue #7067:

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

2018-11-09 Thread GitBox
yanghua 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_r232221415 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml ##

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

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

[jira] [Commented] (FLINK-10834) TableAPI flatten() calculated value error

2018-11-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681180#comment-16681180 ] Fabian Hueske commented on FLINK-10834: --- Do you know what the SQL standard defines for

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

2018-11-09 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681198#comment-16681198 ] zhijiang commented on FLINK-10662: -- [~pnowojski], I am currently working on this. If we change to

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

2018-11-09 Thread GitBox
ambition119 edited 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 new pull request, is a new feature. Use statement : ```sql

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681242#comment-16681242 ] ASF GitHub Bot commented on FLINK-10674: ambition119 edited a comment on issue #7067:

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681282#comment-16681282 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on a change in pull request #6927:

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ 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]

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

2018-11-09 Thread sunjincheng (JIRA)
[ 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] [Updated] (FLINK-10764) Add S3 entropy injection end-to-end/IT test

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ 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 >

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-11-09 Thread GitBox
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-10835) Remove duplicated Round-robin ChannelSelector implementation in RecordWriterTest

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ 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

2018-11-09 Thread GitBox
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-10674) DistinctAccumulator.remove lead to NPE

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ 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

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ 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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ 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:

[GitHub] yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges

2018-11-09 Thread GitBox
yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#issuecomment-437288416 @zentol Can you give a final check about this PR? thanks. This is an

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681070#comment-16681070 ] ASF GitHub Bot commented on FLINK-10252: yanghua commented on issue #6850: [FLINK-10252] Handle

[jira] [Closed] (FLINK-10733) Misleading clean_log_files() in common.sh

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

[jira] [Updated] (FLINK-10778) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10778: Fix Version/s: 1.8.0 > Update TypeSerializerSnapshotMigrationTestBase and

[jira] [Updated] (FLINK-10780) Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10780: Fix Version/s: 1.8.0 > Update Java / Scala

[jira] [Commented] (FLINK-10630) Update migration tests for Flink 1.7

2018-11-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681074#comment-16681074 ] Stefan Richter commented on FLINK-10630: There is no work for 1.8 from my side, because this was

[jira] [Updated] (FLINK-10779) Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10779: Affects Version/s: 1.8.0 > Update Java / Scala

[jira] [Updated] (FLINK-10781) Update BucketingSinkMigrationTest for Flink 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10781: Fix Version/s: 1.8.0 > Update BucketingSinkMigrationTest for Flink 1.7 >

[jira] [Updated] (FLINK-10780) Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10780: Affects Version/s: 1.8.0 > Update Java / Scala

[jira] [Closed] (FLINK-10648) Update ContinuousFileProcessingMigrationTest for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10648. --- Resolution: Duplicate > Update ContinuousFileProcessingMigrationTest for 1.7 >

[jira] [Commented] (FLINK-10801) Fix sql client integrate elasticsearch connector test failure

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681084#comment-16681084 ] ASF GitHub Bot commented on FLINK-10801: pnowojski closed pull request #7060: [FLINK-10801][e2e]

[GitHub] pnowojski closed pull request #7060: [FLINK-10801][e2e] Retry verify_result_hash in elastichsearch-common

2018-11-09 Thread GitBox
pnowojski closed pull request #7060: [FLINK-10801][e2e] Retry verify_result_hash in elastichsearch-common URL: https://github.com/apache/flink/pull/7060 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

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681090#comment-16681090 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on issue #7061:

[GitHub] yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-09 Thread GitBox
yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-437294266 @pnowojski Currently Travis is passed, I see that you have merged the fix for elasticsearch, I will merge your fix

[GitHub] Clarkkkkk commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

2018-11-09 Thread GitBox
Clark commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#issuecomment-437295933 Codes LGTM. Since RebalancePartitioner and RoundRobinPartitioner are duplicate right now, I would vote for

[jira] [Closed] (FLINK-10823) Missing scala suffixes

2018-11-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10823. Resolution: Fixed master: * 146467fe789ab17180392f0400a0024f1cf9bafd (jdbc) *

[jira] [Commented] (FLINK-10733) Misleading clean_log_files() in common.sh

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681064#comment-16681064 ] ASF GitHub Bot commented on FLINK-10733: zentol closed pull request #7030: [FLINK-10733]

[GitHub] zentol closed pull request #7030: [FLINK-10733] Misleading clean_log_files() in common.sh

2018-11-09 Thread GitBox
zentol closed pull request #7030: [FLINK-10733] Misleading clean_log_files() in common.sh URL: https://github.com/apache/flink/pull/7030 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 this is

[GitHub] zentol commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs

2018-11-09 Thread GitBox
zentol commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045#discussion_r231874926 ## File path: nightly.sh ## @@ -43,7 +43,7 @@ mkdir -p $ARTIFACTS_DIR || { echo "FAILURE: cannot create log

[GitHub] yanghua edited a comment on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-09 Thread GitBox
yanghua edited a comment on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-437294266 @pnowojski Currently Travis is passed, I see that you have merged the fix for elasticsearch, I will merge

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681100#comment-16681100 ] ASF GitHub Bot commented on FLINK-10624: yanghua edited a comment on issue #6927: [FLINK-10624]

[GitHub] zentol closed pull request #7055: [FLINK-10823] Add missing scala suffixes

2018-11-09 Thread GitBox
zentol closed pull request #7055: [FLINK-10823] Add missing scala suffixes URL: https://github.com/apache/flink/pull/7055 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 this is a foreign pull

[jira] [Closed] (FLINK-10646) Update AbstractOperatorRestoreTestBase for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10646. --- Resolution: Duplicate > Update AbstractOperatorRestoreTestBase for 1.7 >

[jira] [Closed] (FLINK-10813) Automatically seach for missing scala suffixes

2018-11-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10813. Resolution: Fixed Fix Version/s: (was: 1.8.0) 1.7.0 master:

[jira] [Closed] (FLINK-10645) Update StatefulJobSavepointMigrationITCase for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10645. --- Resolution: Duplicate > Update StatefulJobSavepointMigrationITCase for 1.7 >

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

2018-11-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681072#comment-16681072 ] Stefan Richter commented on FLINK-10828: When I was talking to [~trohrm...@apache.org], he said

[jira] [Closed] (FLINK-10650) Update BucketingSinkMigrationTest for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10650. --- Resolution: Duplicate > Update BucketingSinkMigrationTest for 1.7 >

[jira] [Closed] (FLINK-10647) Update WindowOperatorMigrationTest for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10647. --- Resolution: Duplicate > Update WindowOperatorMigrationTest for 1.7 >

[GitHub] zentol commented on issue #7066: [FLINK-10826][test] Decrease deployment size of heavy deplyment e2e t…

2018-11-09 Thread GitBox
zentol commented on issue #7066: [FLINK-10826][test] Decrease deployment size of heavy deplyment e2e t… URL: https://github.com/apache/flink/pull/7066#issuecomment-437290799 You may want to increase the network timeout like we did for the high-parallelism iterations test.

[jira] [Commented] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681080#comment-16681080 ] ASF GitHub Bot commented on FLINK-10826: zentol commented on issue #7066: [FLINK-10826][test]

[jira] [Commented] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state

2018-11-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681078#comment-16681078 ] Stefan Richter commented on FLINK-9702: --- I think it still makes sense, please consider the link in

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

2018-11-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10674: - Component/s: (was: flink-contrib) Table API & SQL >

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681085#comment-16681085 ] ASF GitHub Bot commented on FLINK-10827: zentol commented on issue #7061: [FLINK-10827][tests]

[GitHub] zentol commented on issue #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

2018-11-09 Thread GitBox
zentol commented on issue #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#issuecomment-437292479 Related test-failure: ``` testDuplicate(org.apache.flink.api.java.typeutils.runtime.PojoSubclassSerializerTest)

[GitHub] StefanRRichter commented on issue #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

2018-11-09 Thread GitBox
StefanRRichter commented on issue #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#issuecomment-437293862 Thanks, the failure is great because we probably caught another offender.

[jira] [Created] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic?

2018-11-09 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-10837: -- Summary: Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic? Key: FLINK-10837 URL: https://issues.apache.org/jira/browse/FLINK-10837

[jira] [Commented] (FLINK-10823) Missing scala suffixes

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681059#comment-16681059 ] ASF GitHub Bot commented on FLINK-10823: zentol closed pull request #7055: [FLINK-10823] Add

[jira] [Closed] (FLINK-10652) Update StatefulJobWBroadcastStateMigrationITCase for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10652. --- Resolution: Duplicate > Update StatefulJobWBroadcastStateMigrationITCase for 1.7 >

[jira] [Updated] (FLINK-10777) Update TypeSerializerSnapshotMigrationITCase for Flink 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10777: Affects Version/s: 1.8.0 > Update TypeSerializerSnapshotMigrationITCase for Flink

[jira] [Updated] (FLINK-10778) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10778: Affects Version/s: 1.8.0 > Update TypeSerializerSnapshotMigrationTestBase and

[jira] [Updated] (FLINK-10777) Update TypeSerializerSnapshotMigrationITCase for Flink 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10777: Fix Version/s: 1.8.0 > Update TypeSerializerSnapshotMigrationITCase for Flink 1.7

[jira] [Closed] (FLINK-10651) Update CEPMigrationTest for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10651. --- Resolution: Duplicate > Update CEPMigrationTest for 1.7 >

[jira] [Updated] (FLINK-10779) Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10779: Fix Version/s: 1.8.0 > Update Java / Scala StatefulJobSavepointMigrationITCase

[jira] [Closed] (FLINK-10649) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10649. --- Resolution: Duplicate > Update FlinkKafkaConsumerBaseMigrationTest for 1.7 >

[jira] [Updated] (FLINK-10781) Update BucketingSinkMigrationTest for Flink 1.7

2018-11-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10781: Affects Version/s: 1.8.0 > Update BucketingSinkMigrationTest for Flink 1.7 >

[jira] [Closed] (FLINK-10801) Fix sql client integrate elasticsearch connector test failure

2018-11-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10801. -- Resolution: Fixed Fix Version/s: 1.7.0 merged commit eaa2959 into apache:master merged

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681093#comment-16681093 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on issue #6927: [FLINK-10624] Extend

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

2018-11-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681322#comment-16681322 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on a change in pull request #6927:

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

2018-11-09 Thread GitBox
yanghua 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_r232227925 ## File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml ##

[jira] [Commented] (FLINK-10839) Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer

2018-11-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681347#comment-16681347 ] Stefan Richter commented on FLINK-10839: https://github.com/apache/flink/pull/7061 > Fix

[GitHub] ambition119 opened a new pull request #7071: Complex Event Processing (CEP) SQL Realization

2018-11-09 Thread GitBox
ambition119 opened a new pull request #7071: Complex Event Processing (CEP) SQL Realization URL: https://github.com/apache/flink/pull/7071 Complex Event Processing (CEP) SQL Realization is a new feature. Use statement : ```sql SELECT [ ALL | DISTINCT ] { * | projectItem [,

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

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

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

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

[jira] [Resolved] (FLINK-7062) Support the basic functionality of MATCH_RECOGNIZE

2018-11-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-7062. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.7.0:

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

2018-11-09 Thread GitBox
zentol 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-437339953 Update: The loop changes are causing some test failures. Please open a separate JIRA as this is probably a larger issue.

  1   2   3   >