[jira] [Updated] (FLINK-8096) Fix time material issue when write to TableSink

2017-11-20 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8096: Priority: Blocker (was: Major) > Fix time material issue when write to TableSink >

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259041#comment-16259041 ] ASF GitHub Bot commented on FLINK-7416: --- Github user uce commented on a diff in the pull request:

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-11-20 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r151946320 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,364 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

2017-11-20 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259045#comment-16259045 ] Stefan Richter commented on FLINK-8098: --- >From a first glance, this does not look like a Flink

[jira] [Comment Edited] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

2017-11-20 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259045#comment-16259045 ] Stefan Richter edited comment on FLINK-8098 at 11/20/17 10:05 AM: -- >From

[GitHub] flink pull request #4883: [FLINK-4809] Operators should tolerate checkpoint ...

2017-11-20 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4883#discussion_r151948416 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -150,6 +150,9 @@ /** This flag defines if we use

[jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259046#comment-16259046 ] ASF GitHub Bot commented on FLINK-4809: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-11-20 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r151932203 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,364 @@ +/* + *

[GitHub] flink issue #5031: [FLINK-8099] Reduce default restart delay to 1 second

2017-11-20 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5031 @tillrohrmann I turned the option into a `ConfigOption`, it's still in `ConfigConstants`, though, but in the long-term the restart strategy options should probably all be migrated to `ConfigOption`

[GitHub] flink issue #4951: [FLINK-7989][yarn] do not deploy the dist.jar file twice

2017-11-20 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4951 #4939 has been merged now - I rebased this PR now so we can go ahead ---

[jira] [Commented] (FLINK-7989) flink-dist jar is deployed twice onto YARN

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259014#comment-16259014 ] ASF GitHub Bot commented on FLINK-7989: --- Github user NicoK commented on the issue:

[jira] [Created] (FLINK-8106) Optimize the timer logic in AbstractKeyedCEPPatternOperator

2017-11-20 Thread Dian Fu (JIRA)
Dian Fu created FLINK-8106: -- Summary: Optimize the timer logic in AbstractKeyedCEPPatternOperator Key: FLINK-8106 URL: https://issues.apache.org/jira/browse/FLINK-8106 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8106) Optimize the timer logic in AbstractKeyedCEPPatternOperator

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258936#comment-16258936 ] ASF GitHub Bot commented on FLINK-8106: --- GitHub user dianfu opened a pull request:

[GitHub] flink pull request #5036: [FLINK-8106] [cep] Optimize the timer logic in Abs...

2017-11-20 Thread dianfu
GitHub user dianfu opened a pull request: https://github.com/apache/flink/pull/5036 [FLINK-8106] [cep] Optimize the timer logic in AbstractKeyedCEPPatternOperator ## What is the purpose of the change *This pull request optimize the performance of

[jira] [Updated] (FLINK-8107) UNNEST causes cyclic type checking exception

2017-11-20 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8107: Affects Version/s: 1.4.0 > UNNEST causes cyclic type checking exception >

[jira] [Commented] (FLINK-8099) Reduce default restart delay to 1 second

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258983#comment-16258983 ] ASF GitHub Bot commented on FLINK-8099: --- Github user aljoscha commented on the issue:

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-11-20 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r151935549 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,364 @@ +/* + *

[jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259021#comment-16259021 ] ASF GitHub Bot commented on FLINK-4809: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4883: [FLINK-4809] Operators should tolerate checkpoint ...

2017-11-20 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4883#discussion_r151940619 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -1041,27 +1065,27 @@ public void

[GitHub] flink issue #5025: [FLINK-8096] [table] Fix time material issue when write t...

2017-11-20 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5025 Thanks for the PR @dianfu. It should be part of the next release. I will merge this. ---

[jira] [Commented] (FLINK-8096) Fix time material issue when write to TableSink

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259030#comment-16259030 ] ASF GitHub Bot commented on FLINK-8096: --- Github user twalthr commented on the issue:

[jira] [Updated] (FLINK-8106) Optimize the timer logic in AbstractKeyedCEPPatternOperator

2017-11-20 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-8106: --- Description: Currently the logic of {{AbstractKeyedCEPPatternOperator}} is as follows when event time

[jira] [Updated] (FLINK-8106) Optimize the timer logic in AbstractKeyedCEPPatternOperator

2017-11-20 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-8106: --- Description: Currently the logic of {{AbstractKeyedCEPPatternOperator}} is as follows when event time

[jira] [Updated] (FLINK-8106) Optimize the timer logic in AbstractKeyedCEPPatternOperator

2017-11-20 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-8106: --- Description: Currently the logic of {{AbstractKeyedCEPPatternOperator}} is as follows when event time

[jira] [Closed] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4228. --- > YARN artifact upload does not work with S3AFileSystem >

[jira] [Updated] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4228: Fix Version/s: (was: 1.5.0) > YARN artifact upload does not work with S3AFileSystem >

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258965#comment-16258965 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff in the pull

[jira] [Created] (FLINK-8107) UNNEST causes cyclic type checking exception

2017-11-20 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8107: --- Summary: UNNEST causes cyclic type checking exception Key: FLINK-8107 URL: https://issues.apache.org/jira/browse/FLINK-8107 Project: Flink Issue Type: Bug

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-11-20 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r151931122 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -322,22 +322,25 @@ private void

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258969#comment-16258969 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258992#comment-16258992 ] ASF GitHub Bot commented on FLINK-7416: --- Github user zhijiangW commented on a diff in the pull

[jira] [Commented] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259003#comment-16259003 ] ASF GitHub Bot commented on FLINK-8086: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5030: [FLINK-8086][kafka] Ignore ProducerFencedException

2017-11-20 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5030#discussion_r151938425 --- Diff: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java --- @@ -720,11

[GitHub] flink pull request #5030: [FLINK-8086][kafka] Ignore ProducerFencedException

2017-11-20 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5030#discussion_r151940978 --- Diff: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java --- @@ -720,11

[jira] [Commented] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259023#comment-16259023 ] ASF GitHub Bot commented on FLINK-8086: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-8095) Introduce ProjectSetOpTransposeRule to Flink

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259126#comment-16259126 ] ASF GitHub Bot commented on FLINK-8095: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5026: [FLINK-8095][TableAPI & SQL] Introduce ProjectSetOpTransp...

2017-11-20 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5026 Thank you @Xpray. Merging... ---

[jira] [Created] (FLINK-8108) Wrong args bound check in PythonPlanBinder

2017-11-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8108: --- Summary: Wrong args bound check in PythonPlanBinder Key: FLINK-8108 URL: https://issues.apache.org/jira/browse/FLINK-8108 Project: Flink Issue Type:

[jira] [Created] (FLINK-8109) PythonPlanBinder should check for script existence

2017-11-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8109: --- Summary: PythonPlanBinder should check for script existence Key: FLINK-8109 URL: https://issues.apache.org/jira/browse/FLINK-8109 Project: Flink Issue

[GitHub] flink pull request #5026: [FLINK-8095][TableAPI & SQL] Introduce ProjectSetO...

2017-11-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5026 ---

[jira] [Commented] (FLINK-8095) Introduce ProjectSetOpTransposeRule to Flink

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259145#comment-16259145 ] ASF GitHub Bot commented on FLINK-8095: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259380#comment-16259380 ] Chesnay Schepler commented on FLINK-7702: - Technically this does no longer affect 1.4; the

[GitHub] flink pull request #5038: [FLINK-7880][FLINK-7975][FLINK-7974][QS] QS test i...

2017-11-20 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/5038 ---

[jira] [Created] (FLINK-8116) Stale comments referring to Checkpointed interface

2017-11-20 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-8116: -- Summary: Stale comments referring to Checkpointed interface Key: FLINK-8116 URL: https://issues.apache.org/jira/browse/FLINK-8116 Project: Flink Issue Type: Bug

[GitHub] flink pull request #5039: [hotfix][docs] Fix some typos in the documentation...

2017-11-20 Thread ggevay
GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/5039 [hotfix][docs] Fix some typos in the documentation. Just some trivial typo fixes in the documentation. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Updated] (FLINK-7702) Javadocs are not being built

2017-11-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-7702: --- Fix Version/s: (was: 1.4.0) 1.5.0 > Javadocs are not being built >

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259437#comment-16259437 ] ASF GitHub Bot commented on FLINK-7977: --- Github user zentol commented on the issue:

[jira] [Created] (FLINK-8117) Eliminate modulo operation from RoundRobinChannelSelector and RebalancePartitioner

2017-11-20 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-8117: -- Summary: Eliminate modulo operation from RoundRobinChannelSelector and RebalancePartitioner Key: FLINK-8117 URL: https://issues.apache.org/jira/browse/FLINK-8117

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259549#comment-16259549 ] ASF GitHub Bot commented on FLINK-7977: --- Github user bowenli86 commented on the issue:

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259550#comment-16259550 ] ASF GitHub Bot commented on FLINK-7977: --- Github user bowenli86 closed the pull request at:

[GitHub] flink issue #4945: [FLINK-7977][build] bump version of compatibility check f...

2017-11-20 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4945 Sounds good. Thanks, @zentol ! ---

[GitHub] flink pull request #4945: [FLINK-7977][build] bump version of compatibility ...

2017-11-20 Thread bowenli86
Github user bowenli86 closed the pull request at: https://github.com/apache/flink/pull/4945 ---

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259388#comment-16259388 ] Chesnay Schepler commented on FLINK-7702: - The javadocs are apparently published under the wrong

[jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259424#comment-16259424 ] ASF GitHub Bot commented on FLINK-7880: --- Github user kl0u closed the pull request at:

[jira] [Closed] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7977. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: ddbc0150d97d5d26de6f9ab9d64d9fb4495c80aa

[GitHub] flink issue #4945: [FLINK-7977][build] bump version of compatibility check f...

2017-11-20 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4945 @bowenli86 I've merged the PR to 1.4, could you close the PR? Note that i have filed FLINK-8082 to bump the api check on master once 1.4 is released. ---

[GitHub] flink pull request #5040: [FLINK-8104][Table API] fixing ROW type value cons...

2017-11-20 Thread walterddr
GitHub user walterddr opened a pull request: https://github.com/apache/flink/pull/5040 [FLINK-8104][Table API] fixing ROW type value constructor for SQL API. ## What is the purpose of the change Supports creation of a ROW based on fields or literals. such as:

[jira] [Commented] (FLINK-8104) Fix Row value constructor

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259929#comment-16259929 ] ASF GitHub Bot commented on FLINK-8104: --- GitHub user walterddr opened a pull request:

[jira] [Commented] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

2017-11-20 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259659#comment-16259659 ] Shashank Agarwal commented on FLINK-8098: - Actually, we are not running any script on that

[jira] [Updated] (FLINK-5711) Deserialization schema that gives has full kafka log information

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5711: Fix Version/s: (was: 1.2.2) > Deserialization schema that gives has full kafka log

[jira] [Updated] (FLINK-6909) Flink should support Lombok POJO

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6909: Fix Version/s: (was: 1.2.1) > Flink should support Lombok POJO >

[jira] [Closed] (FLINK-7592) How to close the output log like "Connected to JobManager at Actor" and "Job execution switched to status RUNNING."?

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7592. --- Resolution: Invalid Fix Version/s: (was: 1.3.2) You can disable the printing of

[jira] [Updated] (FLINK-3549) Make streaming examples more streaming

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3549: Fix Version/s: (was: 1.0.1) > Make streaming examples more streaming >

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16260220#comment-16260220 ] ASF GitHub Bot commented on FLINK-7416: --- Github user zhijiangW commented on a diff in the pull

[jira] [Commented] (FLINK-7627) SingleElementIterable should implement with Serializable

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16260180#comment-16260180 ] ASF GitHub Bot commented on FLINK-7627: --- Github user wuchong commented on the issue:

[GitHub] flink issue #4674: [FLINK-7627] [table] SingleElementIterable should impleme...

2017-11-20 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4674 I'm +1 with the first option, i.e. declare the element field as `transient`. You are right, the `SingleElementIterable` is not necessary to be serialized. ---

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16260186#comment-16260186 ] ASF GitHub Bot commented on FLINK-6505: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4798: [FLINK-6505] Proactively cleanup local FS for RocksDBKeye...

2017-11-20 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4798 @StefanRRichter @aljoscha is it still possible to get this into 1.4? ---

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-11-20 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r152172765 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,364 @@ +/* + *

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-11-20 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r152193809 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java --- @@ -145,6 +145,10 @@ public Buffer

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16260360#comment-16260360 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on the issue:

[GitHub] flink issue #4559: [FLINK-7468][network] Implement sender backlog logic for ...

2017-11-20 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4559 @pnowojski , I have fixed all the comments. The failed test I checked seems no related with my updates. ---

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16260358#comment-16260358 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on a diff in the pull

[jira] [Commented] (FLINK-7954) sideoutput in async function

2017-11-20 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16260265#comment-16260265 ] Chen Qin commented on FLINK-7954: - [~phoenixjiangnan] Thanks for quick response. I think we can always

[jira] [Updated] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3931: Fix Version/s: (was: 1.2.0) > Implement Transport Encryption (SSL/TLS) >

[jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259172#comment-16259172 ] ASF GitHub Bot commented on FLINK-4809: --- Github user StefanRRichter commented on the issue:

[jira] [Closed] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8086. --- Fixed on master in d57ebd063bad571d0ea276da5beee18aeb568b50 Fixed on release-1.4 in

[jira] [Updated] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8086: Affects Version/s: (was: 1.5.0) > FlinkKafkaProducer011 can permanently fail in

[jira] [Created] (FLINK-8111) Add fasterxml relocation to flink-dist

2017-11-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8111: --- Summary: Add fasterxml relocation to flink-dist Key: FLINK-8111 URL: https://issues.apache.org/jira/browse/FLINK-8111 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7841) Add docs for Flink's S3 support

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259215#comment-16259215 ] ASF GitHub Bot commented on FLINK-7841: --- Github user NicoK commented on the issue:

[jira] [Updated] (FLINK-8112) Bump flink-shaded shade plugin version to 3.0.0

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8112: Fix Version/s: (was: 1.5.0) > Bump flink-shaded shade plugin version to 3.0.0 >

[jira] [Updated] (FLINK-8111) Add fasterxml relocation to flink-dist

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8111: Description: I propose to add a com.fasterxml.jackson relocation to flink-dist to relocate

[jira] [Updated] (FLINK-8112) Bump flink-shaded shade plugin version to 3.0.0

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8112: Affects Version/s: (was: 1.4.0) > Bump flink-shaded shade plugin version to 3.0.0 >

[jira] [Closed] (FLINK-8112) Bump flink-shaded shade plugin version to 3.0.0

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8112. --- Resolution: Fixed 2b69aa648a7d5c689c1e3c2709d7e55cb765b0a2 > Bump flink-shaded shade plugin

[jira] [Commented] (FLINK-8099) Reduce default restart delay to 1 second

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259220#comment-16259220 ] ASF GitHub Bot commented on FLINK-8099: --- Github user aljoscha closed the pull request at:

[GitHub] flink pull request #5031: [FLINK-8099] Reduce default restart delay to 1 sec...

2017-11-20 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/5031 ---

[GitHub] flink issue #5037: [FLINK-8110][dist] Relocate jackson services in flink-dis...

2017-11-20 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5037 We'll have a first indication whether this works properly in ~10 minutes: https://travis-ci.org/zentol/flink/builds/304724493 ---

[jira] [Commented] (FLINK-8110) fasterxml jackson services are not relocated

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259244#comment-16259244 ] ASF GitHub Bot commented on FLINK-8110: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5037: [FLINK-8110][dist] Relocate jackson services in fl...

2017-11-20 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5037 [FLINK-8110][dist] Relocate jackson services in flink-dist ## What is the purpose of the change This PR introduces a com.fasterxml.jackson relocation to flink-dist in order to relocate the

[GitHub] flink issue #4883: [FLINK-4809] Operators should tolerate checkpoint failure...

2017-11-20 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4883 @aljoscha Thanks for the review, I addressed your points. Will merge this. ---

[jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259177#comment-16259177 ] ASF GitHub Bot commented on FLINK-4809: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4883: [FLINK-4809] Operators should tolerate checkpoint ...

2017-11-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4883 ---

[jira] [Commented] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259179#comment-16259179 ] ASF GitHub Bot commented on FLINK-8086: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5030: [FLINK-8086][kafka] Ignore ProducerFencedException

2017-11-20 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5030#discussion_r151976605 --- Diff: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java --- @@ -720,11

[GitHub] flink issue #5030: [FLINK-8086][kafka] Ignore ProducerFencedException

2017-11-20 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/5030 Thanks :) ---

[jira] [Created] (FLINK-8112) Bump shade plugin version to 3.0.0

2017-11-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8112: --- Summary: Bump shade plugin version to 3.0.0 Key: FLINK-8112 URL: https://issues.apache.org/jira/browse/FLINK-8112 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-8095) Introduce ProjectSetOpTransposeRule to Flink

2017-11-20 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8095. - Resolution: Fixed Fix Version/s: 1.5.0 1.4.0 Fixed in 1.5:

[jira] [Updated] (FLINK-8112) Bump flink-shaded shade plugin version to 3.0.0

2017-11-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8112: Summary: Bump flink-shaded shade plugin version to 3.0.0 (was: Bump shade plugin version

[jira] [Commented] (FLINK-8099) Reduce default restart delay to 1 second

2017-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259221#comment-16259221 ] ASF GitHub Bot commented on FLINK-8099: --- Github user aljoscha commented on the issue:

[jira] [Closed] (FLINK-8099) Reduce default restart delay to 1 second

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8099. --- Resolution: Fixed Changed on release-1.4 in d0ea9d95109a7e8ca7eb81d42f72c7f132192321 Changed

  1   2   >