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

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

[GitHub] yanghua commented on issue #7030: [FLINK-10733] Misleading clean_log_files() in common.sh

2018-11-08 Thread GitBox
yanghua commented on issue #7030: [FLINK-10733] Misleading clean_log_files() in common.sh URL: https://github.com/apache/flink/pull/7030#issuecomment-437278322 @zentol updated This is an automated message from the Apache Git

[jira] [Assigned] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-10721: Assignee: Chesnay Schepler > kafkaFetcher runFetchLoop throw exception will

[jira] [Commented] (FLINK-10560) JVM_ARGS doesn't work in jobmanager and taskmangers' JVM on yarn

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680978#comment-16680978 ] Chesnay Schepler commented on FLINK-10560: -- How did yo attempt to set the jvm args? Have you

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

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680975#comment-16680975 ] ASF GitHub Bot commented on FLINK-10835: zhijiangW commented on issue #7069:

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

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

[GitHub] zentol commented on issue #7030: [FLINK-10733] Misleading clean_log_files() in common.sh

2018-11-08 Thread GitBox
zentol commented on issue #7030: [FLINK-10733] Misleading clean_log_files() in common.sh URL: https://github.com/apache/flink/pull/7030#issuecomment-437271182 As of right now no test is calling this method, I'd rather just inline this method into `test-runner-common.sh` so it's no longer

[GitHub] zhijiangW commented on issue #7069: [FLINK-10835][network] Remove duplicated round-robin ChannelSelector implementation

2018-11-08 Thread GitBox
zhijiangW commented on issue #7069: [FLINK-10835][network] Remove duplicated round-robin ChannelSelector implementation URL: https://github.com/apache/flink/pull/7069#issuecomment-437271247 cc @pnowojski This is an

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

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680973#comment-16680973 ] ASF GitHub Bot commented on FLINK-10835: zhijiangW opened a new pull request #7069:

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

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10835: --- Labels: pull-request-available (was: ) > Remove duplicated Round-robin ChannelSelector

[GitHub] zhijiangW opened a new pull request #7069: [FLINK-10835][network] Remove duplicated round-robin ChannelSelector implementation

2018-11-08 Thread GitBox
zhijiangW opened a new pull request #7069: [FLINK-10835][network] Remove duplicated round-robin ChannelSelector implementation URL: https://github.com/apache/flink/pull/7069 ## What is the purpose of the change *`RoundRobinChannelSelector` exists for default selector in RecordWriter

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

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680972#comment-16680972 ] Chesnay Schepler commented on FLINK-10733: -- As of right now no test is calling this method, I'd

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

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680972#comment-16680972 ] Chesnay Schepler edited comment on FLINK-10733 at 11/9/18 7:11 AM: --- As

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

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680967#comment-16680967 ] Chesnay Schepler commented on FLINK-10828: -- Do you have a suggestion on how to implement this?

[jira] [Commented] (FLINK-10836) Add repositories and pluginRepositories in root pom.xml

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680951#comment-16680951 ] Chesnay Schepler commented on FLINK-10836: -- If you're having trouble accessing default

[jira] [Closed] (FLINK-10691) StreamSQL E2E test relies on hadoop

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

[jira] [Commented] (FLINK-10691) StreamSQL E2E test relies on hadoop

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

[GitHub] zentol closed pull request #6988: [FLINK-10691][e2e] Remove dependency on hadoop for StreamSQL E2E test

2018-11-08 Thread GitBox
zentol closed pull request #6988: [FLINK-10691][e2e] Remove dependency on hadoop for StreamSQL E2E test URL: https://github.com/apache/flink/pull/6988 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] [Comment Edited] (FLINK-10836) Add repositories and pluginRepositories in root pom.xml

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680951#comment-16680951 ] Chesnay Schepler edited comment on FLINK-10836 at 11/9/18 6:51 AM: --- If

[jira] [Commented] (FLINK-10836) Add repositories and pluginRepositories in root pom.xml

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680948#comment-16680948 ] ASF GitHub Bot commented on FLINK-10836: bjkonglu closed pull request #7068: [FLINK-10836] Add

[GitHub] bjkonglu closed pull request #7068: [FLINK-10836] Add repositories and pluginRepositories in root pom.xml

2018-11-08 Thread GitBox
bjkonglu closed pull request #7068: [FLINK-10836] Add repositories and pluginRepositories in root pom.xml URL: https://github.com/apache/flink/pull/7068 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-10836) Add repositories and pluginRepositories in root pom.xml

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680945#comment-16680945 ] ASF GitHub Bot commented on FLINK-10836: bjkonglu opened a new pull request #7068: [FLINK-10836]

[GitHub] bjkonglu opened a new pull request #7068: [FLINK-10836] Add repositories and pluginRepositories in root pom.xml

2018-11-08 Thread GitBox
bjkonglu opened a new pull request #7068: [FLINK-10836] Add repositories and pluginRepositories in root pom.xml URL: https://github.com/apache/flink/pull/7068 ## Background When developer want to build flink project use maven, they may encounter dependency problem which maven can't

[jira] [Updated] (FLINK-10836) Add repositories and pluginRepositories in root pom.xml

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10836: --- Labels: pull-request-available (was: ) > Add repositories and pluginRepositories in root

[jira] [Created] (FLINK-10836) Add repositories and pluginRepositories in root pom.xml

2018-11-08 Thread bjkonglu (JIRA)
bjkonglu created FLINK-10836: Summary: Add repositories and pluginRepositories in root pom.xml Key: FLINK-10836 URL: https://issues.apache.org/jira/browse/FLINK-10836 Project: Flink Issue Type:

[jira] [Closed] (FLINK-10814) Kafka examples modules need scala suffix

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10814. Resolution: Fixed master: 2c929d6c697bd82dedd829a018ff933be582ef31 1.7:

[jira] [Commented] (FLINK-10814) Kafka examples modules need scala suffix

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

[GitHub] zentol closed pull request #7052: [FLINK-10814][examples] Add scala suffix for Kafka example module

2018-11-08 Thread GitBox
zentol closed pull request #7052: [FLINK-10814][examples] Add scala suffix for Kafka example module URL: https://github.com/apache/flink/pull/7052 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:

[jira] [Closed] (FLINK-10825) ConnectedComponents test instable on Travis

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10825. Resolution: Fixed master: ecd4567bcf5403f26c46d212d6e1698b3eeadbfb 1.7:

[jira] [Commented] (FLINK-10825) ConnectedComponents test instable on Travis

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

[GitHub] zentol closed pull request #7062: [FLINK-10825][tests] Increase request-backoff for high-parallelism e2e test

2018-11-08 Thread GitBox
zentol closed pull request #7062: [FLINK-10825][tests] Increase request-backoff for high-parallelism e2e test URL: https://github.com/apache/flink/pull/7062 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

[GitHub] xueyumusic commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common

2018-11-08 Thread GitBox
xueyumusic commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7059#discussion_r232149628 ## File path:

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

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

[jira] [Updated] (FLINK-10776) Update migration tests for Flink 1.7

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

[jira] [Updated] (FLINK-10776) Update migration tests for Flink 1.7

2018-11-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10776: Priority: Blocker (was: Major) > Update migration tests for Flink 1.7 >

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

2018-11-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680909#comment-16680909 ] Tzu-Li (Gordon) Tai commented on FLINK-10630: - This and FLINK-10776 are duplicates. I will

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

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

[jira] [Updated] (FLINK-10776) Update migration tests for Flink 1.7

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

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

2018-11-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680905#comment-16680905 ] Tzu-Li (Gordon) Tai commented on FLINK-10776: - Sorry about the confusion, I should have

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

2018-11-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10834: Description: We have a UDF as follows: {code:java} object FuncRow extends ScalarFunction { def

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

2018-11-08 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10834: --- Assignee: Hequn Cheng > TableAPI flatten() calculated value error >

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

2018-11-08 Thread zhijiang (JIRA)
zhijiang created FLINK-10835: Summary: Remove duplicated Round-robin ChannelSelector implementation in RecordWriterTest Key: FLINK-10835 URL: https://issues.apache.org/jira/browse/FLINK-10835 Project:

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

2018-11-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10834: Summary: TableAPI flatten() calculated value error (was: TableAPI flatten calculated value

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

2018-11-08 Thread ryantaocer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680808#comment-16680808 ] ryantaocer commented on FLINK-10644: An initial design doc:

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

2018-11-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10834: Description: We have a UDF as follows: {code:java} object FuncRow extends ScalarFunction {    

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

2018-11-08 Thread sunjincheng (JIRA)
sunjincheng created FLINK-10834: --- Summary: TableAPI flatten calculated value error Key: FLINK-10834 URL: https://issues.apache.org/jira/browse/FLINK-10834 Project: Flink Issue Type: Bug

[GitHub] ambition119 opened a new pull request #7067: DistinctAccumulator.remove occur NPE

2018-11-08 Thread GitBox
ambition119 opened a new pull request #7067: DistinctAccumulator.remove occur NPE URL: https://github.com/apache/flink/pull/7067 Submitted JIRA and modified code. JIRA links [https://issues.apache.org/jira/browse/FLINK-10674](url)

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

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

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

2018-11-08 Thread GitBox
zhijiangW commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#issuecomment-437232756 cc @pnowojski This is an automated message

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

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

[GitHub] zhijiangW commented on a change in pull request #7050: [hotfix] Follow up FLINK-6046 to clean unused variable

2018-11-08 Thread GitBox
zhijiangW commented on a change in pull request #7050: [hotfix] Follow up FLINK-6046 to clean unused variable URL: https://github.com/apache/flink/pull/7050#discussion_r232129216 ## File path:

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

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680733#comment-16680733 ] 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-08 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_r232123322 ## 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-08 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_r232122707 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client_common.sh ##

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

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

[jira] [Commented] (FLINK-10814) Kafka examples modules need scala suffix

2018-11-08 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680718#comment-16680718 ] vinoyang commented on FLINK-10814: -- [~hequn8128] It doesn't matter, I am glad to see that you have

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

2018-11-08 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680702#comment-16680702 ] vinoyang commented on FLINK-10776: -- [~till.rohrmann] and [~tzulitai]  I tend to close FLINK-10630. If

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

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

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

2018-11-08 Thread Arnaud Linz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Description: In 1.5.5, 1.6.1 and 1.6.2 (it works in 1.6.0 and 1.3.2),  This code never ends :   

[jira] [Commented] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679947#comment-16679947 ] ASF GitHub Bot commented on FLINK-10531: kl0u edited a comment on issue #7036:

[GitHub] bowenli86 commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common

2018-11-08 Thread GitBox
bowenli86 commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7059#discussion_r232002211 ## File path:

[jira] [Commented] (FLINK-10814) Kafka examples modules need scala suffix

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679935#comment-16679935 ] ASF GitHub Bot commented on FLINK-10814: hequn8128 commented on issue #7052:

[jira] [Created] (FLINK-10831) Consider making processing time monotonically increasing by default

2018-11-08 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10831: --- Summary: Consider making processing time monotonically increasing by default Key: FLINK-10831 URL: https://issues.apache.org/jira/browse/FLINK-10831 Project:

[jira] [Commented] (FLINK-10814) Kafka examples modules need scala suffix

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

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

2018-11-08 Thread Arnaud Linz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Description: In 1.5.5, 1.6.1 and 1.6.2 (it works in 1.6.0 and 1.3.2),  This code never ends :   

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

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

[jira] [Commented] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679925#comment-16679925 ] ASF GitHub Bot commented on FLINK-10531: kl0u commented on issue #7036: [FLINK-10531][e2e] Fix

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

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

[jira] [Updated] (FLINK-10829) Extend FlinkDistribution to support running jars

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10829: --- Labels: pull-request-available (was: ) > Extend FlinkDistribution to support running jars

[jira] [Closed] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

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

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

2018-11-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679724#comment-16679724 ] Till Rohrmann commented on FLINK-10682: --- Great to hear that this solved your problem [~mstar_benl]

[jira] [Commented] (FLINK-10814) Kafka examples modules need scala suffix

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679838#comment-16679838 ] ASF GitHub Bot commented on FLINK-10814: hequn8128 commented on issue #7052:

[jira] [Commented] (FLINK-10753) Propagate and log snapshotting exceptions

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679863#comment-16679863 ] ASF GitHub Bot commented on FLINK-10753: StefanRRichter opened a new pull request #7064:

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

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10801: --- Labels: pull-request-available (was: ) > Fix sql client integrate elasticsearch connector

[jira] [Closed] (FLINK-10811) Hcatalog modules needs scala suffix

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10811. Resolution: Fixed master: ad17588c167a89f0dcfdd49e681c08106e6fbd39 1.7:

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

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

[jira] [Updated] (FLINK-10825) ConnectedComponents test instable on Travis

2018-11-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10825: - Attachment: log.txt > ConnectedComponents test instable on Travis >

[jira] [Updated] (FLINK-10634) End-to-end test: Metrics accessible via REST API

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10634: --- Labels: pull-request-available (was: ) > End-to-end test: Metrics accessible via REST API

[jira] [Commented] (FLINK-10814) Kafka examples modules need scala suffix

2018-11-08 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679407#comment-16679407 ] Hequn Cheng commented on FLINK-10814: - [~yanghua] Oh, sorry that haven't seen your reply. I have

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

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10827: --- Labels: pull-request-available (was: ) > Add test for duplicate() to SerializerTestBase >

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

2018-11-08 Thread zhijiang (JIRA)
zhijiang created FLINK-10820: Summary: Simplify the RebalancePartitioner implementation Key: FLINK-10820 URL: https://issues.apache.org/jira/browse/FLINK-10820 Project: Flink Issue Type:

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

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

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

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

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

2018-11-08 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679868#comment-16679868 ] Hequn Cheng commented on FLINK-10826: - I think we can echo some messages in the script when the test

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

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

[jira] [Commented] (FLINK-10258) Allow streaming sources to be present for batch executions

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679963#comment-16679963 ] ASF GitHub Bot commented on FLINK-10258: twalthr commented on issue #6675: [FLINK-10258]

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

2018-11-08 Thread Igal Shilman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-10821: Assignee: Igal Shilman > Resuming Externalized Checkpoint E2E test does not resume from

[jira] [Commented] (FLINK-10803) Add documentation about S3 support by the StreamingFileSink

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

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

2018-11-08 Thread sunjincheng (JIRA)
sunjincheng created FLINK-10819: --- Summary: The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail. Key: FLINK-10819 URL:

[jira] [Closed] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

2018-11-08 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun closed FLINK-9869. --- Resolution: Won't Fix close for no longer interest > Send PartitionInfo in batch to Improve perfornance >

[jira] [Updated] (FLINK-10635) End-to-end test: Take & resume from savepoint when using per-job mode

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10635: --- Labels: pull-request-available (was: ) > End-to-end test: Take & resume from savepoint

[jira] [Commented] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679946#comment-16679946 ] ASF GitHub Bot commented on FLINK-10531: kl0u commented on issue #7036: [FLINK-10531][e2e] Fix

[jira] [Created] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

2018-11-08 Thread ambition (JIRA)
ambition created FLINK-10818: Summary: RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job. Key: FLINK-10818 URL:

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679811#comment-16679811 ] ASF GitHub Bot commented on FLINK-8997: --- dawidwys commented on issue #7039: [FLINK-8997] Added

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

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

[jira] [Commented] (FLINK-10775) Quarantined address [akka.tcp://flink@flink-jobmanager:6123] is still unreachable or has not been restarted. Keeping it quarantined.

2018-11-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679529#comment-16679529 ] Till Rohrmann commented on FLINK-10775: --- Have you tried using Flink's latest version {{1.5.5}} or

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679576#comment-16679576 ] ASF GitHub Bot commented on FLINK-10634: zentol opened a new pull request #7056:

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

2018-11-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679779#comment-16679779 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter opened a new pull request #7061:

[jira] [Updated] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time

2018-11-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10756: -- Labels: test-stability (was: ) > TaskManagerProcessFailureBatchRecoveryITCase did not finish

[jira] [Commented] (FLINK-10825) ConnectedComponents test instable on Travis

2018-11-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679680#comment-16679680 ] Chesnay Schepler commented on FLINK-10825: -- There's another exception in the logs: {code}

  1   2   3   4   >