[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

2018-11-14 Thread chunpinghe (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687577#comment-16687577 ] chunpinghe commented on FLINK-10884: what's your solution? yarn will check the phys

[jira] [Commented] (FLINK-10891) Upgrade Kafka client version to 2.0.1

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687555#comment-16687555 ] ASF GitHub Bot commented on FLINK-10891: yanghua commented on issue #7101: [FLIN

[GitHub] yanghua commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1

2018-11-14 Thread GitBox
yanghua commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1 URL: https://github.com/apache/flink/pull/7101#issuecomment-438935809 @twalthr This PR also blocked by FLINK-10624 which contains Kafka server version (2.0.0). ---

[jira] [Commented] (FLINK-10872) Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687554#comment-16687554 ] ASF GitHub Bot commented on FLINK-10872: yanghua commented on issue #7100: [FLIN

[jira] [Updated] (FLINK-10872) Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10872: --- Labels: pull-request-available (was: ) > Extend SQL client end-to-end to test KafkaTableSin

[GitHub] yanghua commented on issue #7100: [FLINK-10872] Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11

2018-11-14 Thread GitBox
yanghua commented on issue #7100: [FLINK-10872] Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11 URL: https://github.com/apache/flink/pull/7100#issuecomment-43893 @twalthr I cherry-picked your refactor about FLINK-10624 and squashed them so that I can proces

[jira] [Updated] (FLINK-10891) Upgrade Kafka client version to 2.0.1

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10891: --- Labels: pull-request-available (was: ) > Upgrade Kafka client version to 2.0.1 > --

[GitHub] yanghua opened a new pull request #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1

2018-11-14 Thread GitBox
yanghua opened a new pull request #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1 URL: https://github.com/apache/flink/pull/7101 ## What is the purpose of the change *This pull request upgrades Kafka client version to 2.0.1* ## Brief change log - *Upgra

[jira] [Commented] (FLINK-10891) Upgrade Kafka client version to 2.0.1

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687538#comment-16687538 ] ASF GitHub Bot commented on FLINK-10891: yanghua opened a new pull request #7101

[jira] [Created] (FLINK-10891) Upgrade Kafka client version to 2.0.1

2018-11-14 Thread vinoyang (JIRA)
vinoyang created FLINK-10891: Summary: Upgrade Kafka client version to 2.0.1 Key: FLINK-10891 URL: https://issues.apache.org/jira/browse/FLINK-10891 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-10890) CLONE - Add DataStream HBase Sink

2018-11-14 Thread jocean....@gamil.com (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jocean@gamil.com closed FLINK-10890. Resolution: Won't Do > CLONE - Add DataStream HBase Sink > ---

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

2018-11-14 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687524#comment-16687524 ] Dian Fu commented on FLINK-8159: Thanks a lot for the reply and advice. I will submit a P

[jira] [Created] (FLINK-10890) CLONE - Add DataStream HBase Sink

2018-11-14 Thread jocean....@gamil.com (JIRA)
jocean@gamil.com created FLINK-10890: Summary: CLONE - Add DataStream HBase Sink Key: FLINK-10890 URL: https://issues.apache.org/jira/browse/FLINK-10890 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9718) Add enviroment variable in start-scala-shell.sh & flink to enable remote debug

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687507#comment-16687507 ] ASF GitHub Bot commented on FLINK-9718: --- zjffdu commented on issue #6245: [FLINK-97

[GitHub] zjffdu commented on issue #6245: [FLINK-9718][scala-shell]. Add enviroment variable in start-scala-shell.sh and flink to enable remote debug

2018-11-14 Thread GitBox
zjffdu commented on issue #6245: [FLINK-9718][scala-shell]. Add enviroment variable in start-scala-shell.sh and flink to enable remote debug URL: https://github.com/apache/flink/pull/6245#issuecomment-438922942 ping @yanghua

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

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

[GitHub] tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

2018-11-14 Thread GitBox
tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#discussion_r233715375 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/watermark/SourceWater

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

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

[GitHub] tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

2018-11-14 Thread GitBox
tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#discussion_r233714795 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/watermark/SourceWater

[GitHub] tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

2018-11-14 Thread GitBox
tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#discussion_r233714283 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/watermark/SourceWater

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

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

[jira] [Commented] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687465#comment-16687465 ] ASF GitHub Bot commented on FLINK-10774: stevenzwu commented on issue #7020: [FL

[GitHub] stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

2018-11-14 Thread GitBox
stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#issuecomment-438914628 Got the evidence that it is thread safety problem ``` 2018-11-15 04:24:17,795 ERROR org.apache.

[jira] [Assigned] (FLINK-10889) Semantic inconsistency between DataSet#print and DataStream#print

2018-11-14 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10889: Assignee: vinoyang > Semantic inconsistency between DataSet#print and DataStream#print >

[jira] [Created] (FLINK-10889) Semantic inconsistency between DataSet#print and DataStream#print

2018-11-14 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-10889: -- Summary: Semantic inconsistency between DataSet#print and DataStream#print Key: FLINK-10889 URL: https://issues.apache.org/jira/browse/FLINK-10889 Project: Flink

[GitHub] yanghua opened a new pull request #7100: [Flink 10872] Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11

2018-11-14 Thread GitBox
yanghua opened a new pull request #7100: [Flink 10872] Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11 URL: https://github.com/apache/flink/pull/7100 ## What is the purpose of the change *This pull request extends SQL client end-to-end to test KafkaTableS

[jira] [Assigned] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

2018-11-14 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10873: --- Assignee: Hequn Cheng > Remove tableEnv in DataSetConversions#toTable and > DataStreamConv

[jira] [Commented] (FLINK-10886) Event time synchronization across sources

2018-11-14 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687333#comment-16687333 ] Jamie Grier commented on FLINK-10886: - ML discussion: [http://apache-flink-mailing-

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687311#comment-16687311 ] ASF GitHub Bot commented on FLINK-10887: jgrier opened a new pull request #7099:

[jira] [Updated] (FLINK-10887) Add source watermark tracking to the JobMaster

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10887: --- Labels: pull-request-available (was: ) > Add source watermark tracking to the JobMaster > -

[GitHub] jgrier opened a new pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

2018-11-14 Thread GitBox
jgrier opened a new pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099 ## What is the purpose of the change This commit adds a JobMaster RPC endpoint that is used to share information across sou

[jira] [Commented] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687278#comment-16687278 ] ASF GitHub Bot commented on FLINK-10774: stevenzwu edited a comment on issue #70

[GitHub] stevenzwu edited a comment on issue #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

2018-11-14 Thread GitBox
stevenzwu edited a comment on issue #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#issuecomment-438544127 we saw some exception regarding redundant calls to close method. will need to fix it. ``` 20

[jira] [Created] (FLINK-10888) Expose new global watermark RPC to sources

2018-11-14 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-10888: --- Summary: Expose new global watermark RPC to sources Key: FLINK-10888 URL: https://issues.apache.org/jira/browse/FLINK-10888 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-10887) Add source watermark tracking to the JobMaster

2018-11-14 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Grier updated FLINK-10887: Summary: Add source watermark tracking to the JobMaster (was: Add source watermarking tracking to

[jira] [Created] (FLINK-10887) Add source watermarking tracking to the JobMaster

2018-11-14 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-10887: --- Summary: Add source watermarking tracking to the JobMaster Key: FLINK-10887 URL: https://issues.apache.org/jira/browse/FLINK-10887 Project: Flink Issue Type: S

[jira] [Created] (FLINK-10886) Event time synchronization across sources

2018-11-14 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-10886: --- Summary: Event time synchronization across sources Key: FLINK-10886 URL: https://issues.apache.org/jira/browse/FLINK-10886 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-10869) Update S3 testing settings

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686940#comment-16686940 ] ASF GitHub Bot commented on FLINK-10869: StephanEwen commented on issue #7098: [

[GitHub] StephanEwen commented on issue #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

2018-11-14 Thread GitBox
StephanEwen commented on issue #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098#issuecomment-438763465 Thanks for the reviews. The migration of credentials is not yet complete. End-to-end te

[jira] [Commented] (FLINK-10869) Update S3 testing settings

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686891#comment-16686891 ] ASF GitHub Bot commented on FLINK-10869: zentol commented on issue #7098: [FLINK

[GitHub] zentol commented on issue #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

2018-11-14 Thread GitBox
zentol commented on issue #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098#issuecomment-438748425 btw, for verifying this change we can push it to a separate branch in the apache repo. --

[jira] [Commented] (FLINK-10869) Update S3 testing settings

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686887#comment-16686887 ] ASF GitHub Bot commented on FLINK-10869: zentol commented on issue #7098: [FLINK

[GitHub] zentol commented on issue #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

2018-11-14 Thread GitBox
zentol commented on issue #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098#issuecomment-438746732 @dawidwys * all S3 tests already check whether credentials are provided, and if not are skippe

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

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

[GitHub] kl0u commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test.

2018-11-14 Thread GitBox
kl0u commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test. URL: https://github.com/apache/flink/pull/7036#issuecomment-438735965 @azagrebin Please have another look and let me know what you think! Thi

[jira] [Commented] (FLINK-10851) sqlUpdate support complex insert grammar

2018-11-14 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686774#comment-16686774 ] Dawid Wysakowicz commented on FLINK-10851: -- [~frank wang] have you resolved you

[jira] [Commented] (FLINK-10869) Update S3 testing settings

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686764#comment-16686764 ] ASF GitHub Bot commented on FLINK-10869: dawidwys commented on issue #7098: [FLI

[GitHub] dawidwys commented on issue #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

2018-11-14 Thread GitBox
dawidwys commented on issue #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098#issuecomment-438713201 Does it mean that those tests will always fail on user's travis(unless they setup AWS credential

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

2018-11-14 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686705#comment-16686705 ] Dawid Wysakowicz commented on FLINK-8159: - Ad. 1 Agree with that approach with ad

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

2018-11-14 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686655#comment-16686655 ] Flavio Pompermaier commented on FLINK-10864: If you look at the JarListInfo,

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

2018-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10885: Summary: Avro Confluent Schema Registry E2E test failed on Travis Key: FLINK-10885 URL: https://issues.apache.org/jira/browse/FLINK-10885 Project: Flink

[jira] [Updated] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

2018-11-14 Thread wgcn (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-10884: - Labels: yarn (was: ) > Flink on yarn TM container will be killed by nodemanager because of the > exceeded p

[jira] [Created] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

2018-11-14 Thread wgcn (JIRA)
wgcn created FLINK-10884: Summary: Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory. Key: FLINK-10884 URL: https://issues.apache.org/jira/browse/FLINK-10884

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

2018-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686532#comment-16686532 ] Chesnay Schepler commented on FLINK-10864: -- Personally I'd throw that one out i

[jira] [Updated] (FLINK-10882) Misleading job/task state for scheduled jobs

2018-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10882: - Description: When submitting a job when not enough resources are available currently cua

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

2018-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686497#comment-16686497 ] Chesnay Schepler commented on FLINK-10864: -- When you suggest a separate _manife

[jira] [Commented] (FLINK-10880) Failover strategies should not be applied to Batch Execution

2018-11-14 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686519#comment-16686519 ] TisonKun commented on FLINK-10880: -- Hi [~StephanEwen], I'd like to meet the consensus o

[jira] [Assigned] (FLINK-10880) Failover strategies should not be applied to Batch Execution

2018-11-14 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-10880: Assignee: TisonKun > Failover strategies should not be applied to Batch Execution > -

[jira] [Updated] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout

2018-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10883: - Description: When submitting a job without enough slots being available the job will sta

[jira] [Updated] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout

2018-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10883: - Description: When submitting a job without enough slots being available the job will sta

[jira] [Created] (FLINK-10882) Misleading job/task state for scheduled jobs

2018-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10882: Summary: Misleading job/task state for scheduled jobs Key: FLINK-10882 URL: https://issues.apache.org/jira/browse/FLINK-10882 Project: Flink Issue Ty

[jira] [Created] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout

2018-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10883: Summary: Submitting a jobs without enough slots times out due to a unspecified timeout Key: FLINK-10883 URL: https://issues.apache.org/jira/browse/FLINK-10883

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

2018-11-14 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686505#comment-16686505 ] Flavio Pompermaier commented on FLINK-10864: No, I suggest to add an attribu

[jira] [Updated] (FLINK-10869) Update S3 testing settings

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10869: --- Labels: pull-request-available (was: ) > Update S3 testing settings > -

[GitHub] StephanEwen opened a new pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

2018-11-14 Thread GitBox
StephanEwen opened a new pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098 ## What is the purpose of the change This updates the S3 credentials used for Integration Tests that in

[jira] [Commented] (FLINK-10869) Update S3 testing settings

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

[jira] [Updated] (FLINK-10874) Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10874: --- Labels: pull-request-available (was: ) > Kafka 2.0 connector testMigrateFromAtLeastOnceToEx

[jira] [Commented] (FLINK-10874) Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686473#comment-16686473 ] ASF GitHub Bot commented on FLINK-10874: pnowojski opened a new pull request #70

[GitHub] pnowojski opened a new pull request #7097: [FLINK-10874][kafka-docs] Document likely cause of UnknownTopicOrPartitionException

2018-11-14 Thread GitBox
pnowojski opened a new pull request #7097: [FLINK-10874][kafka-docs] Document likely cause of UnknownTopicOrPartitionException URL: https://github.com/apache/flink/pull/7097 This is a change in documentation only. This is an

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

2018-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10881: Summary: SavepointITCase deadlocks on travis Key: FLINK-10881 URL: https://issues.apache.org/jira/browse/FLINK-10881 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

2018-11-14 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686459#comment-16686459 ] Flavio Pompermaier commented on FLINK-10864: What about program-class attrib

[GitHub] twalthr commented on issue #7045: [hotfix] Update nightly master cron jobs

2018-11-14 Thread GitBox
twalthr commented on issue #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045#issuecomment-438646738 The changes have been applied to `cron-master-e2e` and `cron-1.7-e2e`. This is an

[GitHub] twalthr closed pull request #7045: [hotfix] Update nightly master cron jobs

2018-11-14 Thread GitBox
twalthr closed pull request #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045 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] [Reopened] (FLINK-10856) Harden resume from externalized checkpoint E2E test

2018-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-10856: -- The latest fix introduced a new instability where we attempt to resume from an incomplete

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686446#comment-16686446 ] ASF GitHub Bot commented on FLINK-10419: dawidwys opened a new pull request #709

[GitHub] dawidwys opened a new pull request #7096: [FLINK-10419] Call JobMasterGateway through RpcCheckpointResponder in…

2018-11-14 Thread GitBox
dawidwys opened a new pull request #7096: [FLINK-10419] Call JobMasterGateway through RpcCheckpointResponder in… URL: https://github.com/apache/flink/pull/7096 Improved test to call `JobMasterGateway` through `RpcCheckpointResponder`. ---

[jira] [Closed] (FLINK-10852) Decremented number of unfinished producers below 0. This is most likely a bug in the execution state/intermediate result partition management

2018-11-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-10852. Resolution: Duplicate Fix Version/s: (was: 1.8.0) Not a bug in itself, rather a symptom

[jira] [Commented] (FLINK-10852) Decremented number of unfinished producers below 0. This is most likely a bug in the execution state/intermediate result partition management

2018-11-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686417#comment-16686417 ] Stephan Ewen commented on FLINK-10852: -- {{jobmanager.execution.failover-strategy}}

[jira] [Created] (FLINK-10880) Failover strategies should not be applied to Batch Execution

2018-11-14 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-10880: Summary: Failover strategies should not be applied to Batch Execution Key: FLINK-10880 URL: https://issues.apache.org/jira/browse/FLINK-10880 Project: Flink

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

2018-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686413#comment-16686413 ] Chesnay Schepler commented on FLINK-10864: -- I don't like the idea of introducin

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

2018-11-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686407#comment-16686407 ] Stephan Ewen commented on FLINK-10864: -- I am skeptical about that, to be honest. Th

[jira] [Created] (FLINK-10879) Align Flink clients on env.execute()

2018-11-14 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-10879: -- Summary: Align Flink clients on env.execute() Key: FLINK-10879 URL: https://issues.apache.org/jira/browse/FLINK-10879 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription

2018-11-14 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686391#comment-16686391 ] Flavio Pompermaier commented on FLINK-10862: What do you mean with "proper a

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

2018-11-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686380#comment-16686380 ] Stephan Ewen commented on FLINK-10867: -- [~mcoimbra] This is an interesting idea. A

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

2018-11-14 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686368#comment-16686368 ] Flavio Pompermaier commented on FLINK-10864: I don't suggest to scan the ent

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

2018-11-14 Thread Miguel E. Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel E. Coimbra updated FLINK-10867: -- Labels: (was: pull-request-available) > Add a DataSet-based CacheOperator to reuse r

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

2018-11-14 Thread Miguel E. Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel E. Coimbra updated FLINK-10867: -- Description: *Motivation.* There are job scenarios where Flink batch processing users

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

2018-11-14 Thread Miguel E. Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel E. Coimbra updated FLINK-10867: -- Description: *Motivation.* There are job scenarios where Flink batch processing users

[jira] [Commented] (FLINK-10874) Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure

2018-11-14 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686361#comment-16686361 ] Piotr Nowojski commented on FLINK-10874: Google search for this error suggests t

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

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

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

2018-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686346#comment-16686346 ] Chesnay Schepler commented on FLINK-10867: -- [~yanghua] Yes, thanks! It should p

[GitHub] twalthr commented on issue #7045: [hotfix] Update nightly master cron jobs

2018-11-14 Thread GitBox
twalthr commented on issue #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045#issuecomment-438621835 Thanks @zentol. I will remove the kubernetes test and merge this. Once Travis gives green light.

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686356#comment-16686356 ] ASF GitHub Bot commented on FLINK-10419: tillrohrmann commented on a change in p

[GitHub] tillrohrmann commented on a change in pull request #7093: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

2018-11-14 Thread GitBox
tillrohrmann commented on a change in pull request #7093: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7093#discussion_r233398912 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686347#comment-16686347 ] ASF GitHub Bot commented on FLINK-10419: dawidwys closed pull request #7093: [F

[GitHub] dawidwys closed pull request #7093: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

2018-11-14 Thread GitBox
dawidwys closed pull request #7093: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7093 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for t

[jira] [Created] (FLINK-10878) State evolution E2E test failed on travis

2018-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10878: Summary: State evolution E2E test failed on travis Key: FLINK-10878 URL: https://issues.apache.org/jira/browse/FLINK-10878 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription

2018-11-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686343#comment-16686343 ] Stephan Ewen commented on FLINK-10862: -- The ProgramDescription is a bit of an artif

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

2018-11-14 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686345#comment-16686345 ] vinoyang commented on FLINK-10867: -- [~Zentol] Maybe the PR you submitted should not bin

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

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686342#comment-16686342 ] ASF GitHub Bot commented on FLINK-10634: zentol commented on issue #7056: [FLINK

  1   2   >