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

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

[jira] [Commented] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709774#comment-16709774 ] ASF GitHub Bot commented on FLINK-10784: yanghua commented on issue #7230: [FLINK-10784] Update

[jira] [Created] (FLINK-11076) Processing for Avro generated classes is very slow

2018-12-05 Thread JIRA
Maciej Bryński created FLINK-11076: -- Summary: Processing for Avro generated classes is very slow Key: FLINK-11076 URL: https://issues.apache.org/jira/browse/FLINK-11076 Project: Flink Issue

[jira] [Commented] (FLINK-11062) web ui log error

2018-12-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709745#comment-16709745 ] Chesnay Schepler commented on FLINK-11062: -- Please check the server logs for any errors. > web

[GitHub] dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

2018-12-05 Thread GitBox
dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238972922 ## File path:

[GitHub] xueyumusic commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

2018-12-05 Thread GitBox
xueyumusic commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#discussion_r238973205 ## File path:

[jira] [Commented] (FLINK-11073) Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709761#comment-16709761 ] ASF GitHub Bot commented on FLINK-11073: tzulitai opened a new pull request #7239: [FLINK-11073]

[jira] [Commented] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709762#comment-16709762 ] ASF GitHub Bot commented on FLINK-10784: yanghua commented on issue #7230: [FLINK-10784] Update

[jira] [Updated] (FLINK-11073) Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11073: --- Labels: pull-request-available (was: ) > Make serializers immutable / provide option >

[jira] [Closed] (FLINK-10347) Kafka09SecuredRunITCase failed on Travis

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10347. - Resolution: Cannot Reproduce Reopen if it should reoccur. > Kafka09SecuredRunITCase failed on

[jira] [Updated] (FLINK-11075) Remove redundant code path in CompatibilityUtil

2018-12-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11075: Description: In {{CompatibilityUtil#resolveCompatibilityResult}}: {code}

[jira] [Created] (FLINK-11075) Remove redundant code path in CompatibilityUtil

2018-12-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11075: --- Summary: Remove redundant code path in CompatibilityUtil Key: FLINK-11075 URL: https://issues.apache.org/jira/browse/FLINK-11075 Project: Flink

[jira] [Commented] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709781#comment-16709781 ] ASF GitHub Bot commented on FLINK-10784: zentol commented on issue #7230: [FLINK-10784] Update

[GitHub] zentol commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread GitBox
zentol commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7 URL: https://github.com/apache/flink/pull/7230#issuecomment-11861 correct  This is an automated message from the Apache

[jira] [Updated] (FLINK-11075) Remove redundant code path in CompatibilityUtil

2018-12-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11075: Description: In {{CompatibilityUtil#resolveCompatibilityResult}}: {code:java}

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

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

[jira] [Comment Edited] (FLINK-11076) Processing for Avro generated classes is very slow

2018-12-05 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-11076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709850#comment-16709850 ] Maciej Bryński edited comment on FLINK-11076 at 12/5/18 10:03 AM: -- In

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709923#comment-16709923 ] ASF GitHub Bot commented on FLINK-9740: --- XuQianJin-Stars closed pull request #7228:

[GitHub] XuQianJin-Stars commented on issue #7228: [FLINK-9740][Table API ] Support group windows over intervals of months

2018-12-05 Thread GitBox
XuQianJin-Stars commented on issue #7228: [FLINK-9740][Table API ] Support group windows over intervals of months URL: https://github.com/apache/flink/pull/7228#issuecomment-46404 @twalthr I will close this pr and redesign it.

[jira] [Created] (FLINK-11074) Improve the harness test to make it possible test with state backend

2018-12-05 Thread Dian Fu (JIRA)
Dian Fu created FLINK-11074: --- Summary: Improve the harness test to make it possible test with state backend Key: FLINK-11074 URL: https://issues.apache.org/jira/browse/FLINK-11074 Project: Flink

[jira] [Commented] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709754#comment-16709754 ] ASF GitHub Bot commented on FLINK-10784: zentol commented on issue #7230: [FLINK-10784] Update

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10781: --- Labels: pull-request-available (was: ) > Update BucketingSinkMigrationTest for Flink 1.7 >

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

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

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

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

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709825#comment-16709825 ] ASF GitHub Bot commented on FLINK-10781: hequn8128 opened a new pull request #7242:

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

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10560. - Resolution: Not A Problem > JVM_ARGS doesn't work in jobmanager and taskmangers' JVM on yarn >

[jira] [Closed] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11045. --- Resolution: Fixed Fixed in master: 3eac4193b31dd4b9bcf0bd09e2adc02bda4a2873 Fixed in release-1.7:

[GitHub] hzyuemeng1 opened a new pull request #7244: [FLINK-6065][es-connector] Make TransportClient for ES5 pluggable

2018-12-05 Thread GitBox
hzyuemeng1 opened a new pull request #7244: [FLINK-6065][es-connector] Make TransportClient for ES5 pluggable URL: https://github.com/apache/flink/pull/7244 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob

[jira] [Commented] (FLINK-6065) Make TransportClient for ES5 pluggable

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709844#comment-16709844 ] ASF GitHub Bot commented on FLINK-6065: --- hzyuemeng1 opened a new pull request #7244:

[jira] [Closed] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8336. Resolution: Cannot Reproduce Reopen if it should reoccur. >

[GitHub] yanghua commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread GitBox
yanghua commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7 URL: https://github.com/apache/flink/pull/7230#issuecomment-10085 Yes, it seems that this is wrong, I think I should do these things on the release-1.7.0 branch.

[jira] [Commented] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709784#comment-16709784 ] ASF GitHub Bot commented on FLINK-10784: yanghua commented on issue #7230: [FLINK-10784] Update

[GitHub] zhijiangW commented on a change in pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

2018-12-05 Thread GitBox
zhijiangW commented on a change in pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#discussion_r238983295 ## File path:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709817#comment-16709817 ] ASF GitHub Bot commented on FLINK-10780: hequn8128 opened a new pull request #7241:

[GitHub] yanghua commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-12-05 Thread GitBox
yanghua commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r238988939 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQueryService.java

[GitHub] kl0u commented on issue #7232: [hotfix][docs] Fix StreamingFileSink examples

2018-12-05 Thread GitBox
kl0u commented on issue #7232: [hotfix][docs] Fix StreamingFileSink examples URL: https://github.com/apache/flink/pull/7232#issuecomment-19690 I am merging! This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11045: Fix Version/s: 1.7.1 1.8.0 1.6.3 > UserCodeClassLoader has

[jira] [Closed] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11045. --- Resolution: Fixed > UserCodeClassLoader has not been set correctly for RuntimeUDFContext in >

[jira] [Reopened] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reopened FLINK-11045: - set fix version > UserCodeClassLoader has not been set correctly for RuntimeUDFContext in >

[jira] [Updated] (FLINK-10895) TypeSerializerSnapshotMigrationITCase.testSavepoint test failed on travis

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10895: -- Priority: Critical (was: Major) > TypeSerializerSnapshotMigrationITCase.testSavepoint test

[jira] [Updated] (FLINK-10881) SavepointITCase deadlocks on travis

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10881: -- Labels: test-stability (was: ) > SavepointITCase deadlocks on travis >

[jira] [Closed] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9646. Resolution: Cannot Reproduce Reopen if it should reoccur. >

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

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

[GitHub] zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-12-05 Thread GitBox
zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r238982072 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQueryService.java

[GitHub] hequn8128 opened a new pull request #7242: [FLINK-10781][fs] Update BucketingSinkMigrationTest for Flink 1.7

2018-12-05 Thread GitBox
hequn8128 opened a new pull request #7242: [FLINK-10781][fs] Update BucketingSinkMigrationTest for Flink 1.7 URL: https://github.com/apache/flink/pull/7242 ## What is the purpose of the change Update BucketingSinkMigrationTest for Flink 1.7 ## Brief change log -

[GitHub] zhijiangW commented on a change in pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

2018-12-05 Thread GitBox
zhijiangW commented on a change in pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#discussion_r238986485 ## File path:

[jira] [Commented] (FLINK-11075) Remove redundant code path in CompatibilityUtil

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709839#comment-16709839 ] ASF GitHub Bot commented on FLINK-11075: tzulitai opened a new pull request #7243: [FLINK-11075]

[jira] [Commented] (FLINK-11076) Processing for Avro generated classes is very slow

2018-12-05 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-11076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709850#comment-16709850 ] Maciej Bryński commented on FLINK-11076: In my workload removing "extends

[jira] [Updated] (FLINK-10885) Avro Confluent Schema Registry E2E test failed on Travis

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10885: -- Labels: test-stability (was: ) > Avro Confluent Schema Registry E2E test failed on Travis >

[GitHub] yanghua commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread GitBox
yanghua commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7 URL: https://github.com/apache/flink/pull/7230#issuecomment-07845 Hi @zentol I followed this `TODO` message : ``` /** * TODO change this to the corresponding savepoint

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709748#comment-16709748 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on a change in pull request #7201:

[GitHub] tzulitai opened a new pull request #7239: [FLINK-11073] [core] Allow immutable serializers

2018-12-05 Thread GitBox
tzulitai opened a new pull request #7239: [FLINK-11073] [core] Allow immutable serializers URL: https://github.com/apache/flink/pull/7239 ## What is the purpose of the change See JIRA [FLINK-11073](https://issues.apache.org/jira/browse/FLINK-11073) for a detailed description of the

[jira] [Commented] (FLINK-10586) Running RestServerEndpointITCase may cause Kernel Panic

2018-12-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709770#comment-16709770 ] Aljoscha Krettek commented on FLINK-10586: -- [~gjy] Can you check whether FLINK-10690 fixes this

[GitHub] zentol commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread GitBox
zentol commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7 URL: https://github.com/apache/flink/pull/7230#issuecomment-08984 with the current master? This is an automated message

[jira] [Commented] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709771#comment-16709771 ] ASF GitHub Bot commented on FLINK-10784: zentol commented on issue #7230: [FLINK-10784] Update

[GitHub] yanghua commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread GitBox
yanghua commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7 URL: https://github.com/apache/flink/pull/7230#issuecomment-12301 @zentol Thank you for your guidance, I will update the snapshot file.

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10780: --- Labels: pull-request-available (was: ) > Update Java / Scala

[GitHub] hequn8128 opened a new pull request #7241: [FLINK-10780][tests] Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7

2018-12-05 Thread GitBox
hequn8128 opened a new pull request #7241: [FLINK-10780][tests] Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7 URL: https://github.com/apache/flink/pull/7241 ## What is the purpose of the change Update Java / Scala StatefulJobWBroadcastStateMigrationITCase

[jira] [Commented] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709816#comment-16709816 ] ASF GitHub Bot commented on FLINK-11045: asfgit closed pull request #7213: [FLINK-11045][table]

[GitHub] asfgit closed pull request #7213: [FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread GitBox
asfgit closed pull request #7213: [FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor URL: https://github.com/apache/flink/pull/7213 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed

[jira] [Commented] (FLINK-11065) Migrate flink-table runtime classes

2018-12-05 Thread xueyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709815#comment-16709815 ] xueyu commented on FLINK-11065: --- hi, [~twalthr], how about create one sub-issue which ports

[jira] [Updated] (FLINK-11077) Make subtask aware of the timeout of checkpoint and abort the current ongoing asynccheckpoint

2018-12-05 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi updated FLINK-11077: --- Description: Now checkpoint coordinator will cancel the checkpoint when checkpoint timeout. But the subtask

[GitHub] XuQianJin-Stars closed pull request #7228: [FLINK-9740][Table API ] Support group windows over intervals of months

2018-12-05 Thread GitBox
XuQianJin-Stars closed pull request #7228: [FLINK-9740][Table API ] Support group windows over intervals of months URL: https://github.com/apache/flink/pull/7228 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[jira] [Updated] (FLINK-10885) Avro Confluent Schema Registry E2E test failed on Travis

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10885: -- Priority: Critical (was: Major) > Avro Confluent Schema Registry E2E test failed on Travis >

[GitHub] zentol commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-12-05 Thread GitBox
zentol commented on issue #7230: [FLINK-10784] Update FlinkKafkaConsumerBaseMigrationTest for 1.7 URL: https://github.com/apache/flink/pull/7230#issuecomment-06142 @yanghua Can you explain how you generated the snapshots? (step-by-step)

[jira] [Closed] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8820. Resolution: Cannot Reproduce Fix Version/s: (was: 1.7.1) (was:

[GitHub] hequn8128 opened a new pull request #7240: [FLINK-10779][tests] Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7

2018-12-05 Thread GitBox
hequn8128 opened a new pull request #7240: [FLINK-10779][tests] Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7 URL: https://github.com/apache/flink/pull/7240 ## What is the purpose of the change Update Java / Scala StatefulJobSavepointMigrationITCase so that it

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709814#comment-16709814 ] ASF GitHub Bot commented on FLINK-10779: hequn8128 opened a new pull request #7240:

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

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10779: --- Labels: pull-request-available (was: ) > Update Java / Scala

[jira] [Updated] (FLINK-11075) Remove redundant code path in CompatibilityUtil

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11075: --- Labels: pull-request-available (was: ) > Remove redundant code path in CompatibilityUtil >

[GitHub] tzulitai opened a new pull request #7243: [FLINK-11075] [core] Remove irrelevant code in CompatibilityUtil#resolveCompatibilityResult

2018-12-05 Thread GitBox
tzulitai opened a new pull request #7243: [FLINK-11075] [core] Remove irrelevant code in CompatibilityUtil#resolveCompatibilityResult URL: https://github.com/apache/flink/pull/7243 ## What is the purpose of the change This PR removes irrelevant code in

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

2018-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709837#comment-16709837 ] Till Rohrmann commented on FLINK-10560: --- Hi [~wind_ljy], I think the problem is that we don't use

[jira] [Created] (FLINK-11077) Make subtask aware of the timeout of checkpoint and abort the current ongoing asynccheckpoint

2018-12-05 Thread aitozi (JIRA)
aitozi created FLINK-11077: -- Summary: Make subtask aware of the timeout of checkpoint and abort the current ongoing asynccheckpoint Key: FLINK-11077 URL: https://issues.apache.org/jira/browse/FLINK-11077

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709922#comment-16709922 ] ASF GitHub Bot commented on FLINK-9740: --- XuQianJin-Stars commented on issue #7228:

[jira] [Comment Edited] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

2018-12-05 Thread Miguel E. Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710007#comment-16710007 ] Miguel E. Coimbra edited comment on FLINK-10867 at 12/5/18 12:29 PM: -

[jira] [Commented] (FLINK-11078) Capability to define the numerical range for running TaskExecutors

2018-12-05 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710061#comment-16710061 ] Jeff Zhang commented on FLINK-11078: [~Tison] Do you mean dynamic allocation via specifying the

[jira] [Comment Edited] (FLINK-10640) Enable Slot Resource Profile for Resource Management

2018-12-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710041#comment-16710041 ] TisonKun edited comment on FLINK-10640 at 12/5/18 1:36 PM: --- @[~wuzang] After 

[jira] [Commented] (FLINK-10640) Enable Slot Resource Profile for Resource Management

2018-12-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710041#comment-16710041 ] TisonKun commented on FLINK-10640: -- @[~wuzang] After an offline discuss with [~till.rohrmann], for

[jira] [Created] (FLINK-11078) Capability to define the numerical range for running TaskExecutors

2018-12-05 Thread TisonKun (JIRA)
TisonKun created FLINK-11078: Summary: Capability to define the numerical range for running TaskExecutors Key: FLINK-11078 URL: https://issues.apache.org/jira/browse/FLINK-11078 Project: Flink

[jira] [Commented] (FLINK-11078) Capability to define the numerical range for running TaskExecutors

2018-12-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710072#comment-16710072 ] TisonKun commented on FLINK-11078: -- Yes. I've updated the description. > Capability to define the

[jira] [Updated] (FLINK-11078) Capability to define the numerical range for running TaskExecutors

2018-12-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11078: - Description: In pre-FLIP-6 context, we start a yarn session with fixed number of running

[jira] [Updated] (FLINK-11078) Capability to define the numerical range for running TaskExecutors

2018-12-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11078: - Description: In pre-FLIP-6 context, we start a yarn session with fixed number of running

[jira] [Updated] (FLINK-11069) Remove FutureUtil

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11069: --- Labels: pull-request-available (was: ) > Remove FutureUtil > - > >

[GitHub] TisonKun opened a new pull request #7245: [FLINK-11069] [utils] Remove FutureUtil

2018-12-05 Thread GitBox
TisonKun opened a new pull request #7245: [FLINK-11069] [utils] Remove FutureUtil URL: https://github.com/apache/flink/pull/7245 ## What is the purpose of the change The utility class `FutureUtil` contains duplicate methods and method which are not implemented optimally. I suggest

[jira] [Commented] (FLINK-11069) Remove FutureUtil

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709978#comment-16709978 ] ASF GitHub Bot commented on FLINK-11069: TisonKun opened a new pull request #7245: [FLINK-11069]

[jira] [Commented] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

2018-12-05 Thread Miguel E. Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710007#comment-16710007 ] Miguel E. Coimbra commented on FLINK-10867: --- [~StephanEwen], I've been thinking how to go

[jira] [Updated] (FLINK-11078) Capability to define the numerical range for running TaskExecutors

2018-12-05 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11078: - Description: In pre-FLIP-6 context, we start a yarn session with fixed number of running

[jira] [Created] (FLINK-11079) Update LICENSE and NOTICE files for flnk-storm-examples

2018-12-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11079: Summary: Update LICENSE and NOTICE files for flnk-storm-examples Key: FLINK-11079 URL: https://issues.apache.org/jira/browse/FLINK-11079 Project: Flink

[GitHub] zentol opened a new pull request #7246: 11023 batch1

2018-12-05 Thread GitBox
zentol opened a new pull request #7246: 11023 batch1 URL: https://github.com/apache/flink/pull/7246 ## What is the purpose of the change This PR is the first batch of licensing updates for our connectors. It adds NOTICE an licenses to the cassandra, ES1, ES2, ES5 and kinesis

[GitHub] zentol commented on issue #7246: [FLINK-11023] Add LICENSE & NOTICE files for connectors (batch #1)

2018-12-05 Thread GitBox
zentol commented on issue #7246: [FLINK-11023] Add LICENSE & NOTICE files for connectors (batch #1) URL: https://github.com/apache/flink/pull/7246#issuecomment-94614 . This is an automated message from the Apache Git

[jira] [Updated] (FLINK-10509) Drop flink-storm

2018-12-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10509: - Fix Version/s: (was: 1.8.0) 1.9.0 > Drop flink-storm >

[jira] [Updated] (FLINK-11080) Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11080: --- Labels: pull-request-available (was: ) > Define flink-connector-elasticsearch6 uber-jar

[jira] [Created] (FLINK-11081) Support binding port range for REST server

2018-12-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11081: - Summary: Support binding port range for REST server Key: FLINK-11081 URL: https://issues.apache.org/jira/browse/FLINK-11081 Project: Flink Issue Type:

[GitHub] maqingxiang commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel

2018-12-05 Thread GitBox
maqingxiang commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7197#issuecomment-444504701 @zentol Please help review it, thanks.

[jira] [Commented] (FLINK-11079) Update LICENSE and NOTICE files for flnk-storm-examples

2018-12-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710132#comment-16710132 ] Chesnay Schepler commented on FLINK-11079: -- flink-storm will only be fully removed in 1.9 (the

[jira] [Commented] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710096#comment-16710096 ] ASF GitHub Bot commented on FLINK-11023: zentol commented on issue #7246: [FLINK-11023] Add

[jira] [Closed] (FLINK-10522) Check if RecoverableWriter supportsResume and act accordingly.

2018-12-05 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10522. -- Resolution: Fixed Merged on master with 600bd9cdbb42b709cfa6fa313648fcea317ad781 and on

[GitHub] zentol opened a new pull request #7247: [FLINK-11080][ES] Rework shade-plugin filters

2018-12-05 Thread GitBox
zentol opened a new pull request #7247: [FLINK-11080][ES] Rework shade-plugin filters URL: https://github.com/apache/flink/pull/7247 ## What is the purpose of the change This PR reworks the shade-plugin filtering for the elasticsearch6 connector. The existing approach was rather

[jira] [Commented] (FLINK-11080) Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet

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

[jira] [Updated] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

2018-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11023: --- Labels: pull-request-available (was: ) > Update LICENSE and NOTICE files for

  1   2   3   >