[jira] [Commented] (FLINK-8787) Deploying FLIP-6 YARN session with HA fails

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16378174#comment-16378174 ] ASF GitHub Bot commented on FLINK-8787: --- Github user GJL commented on the issue:

[GitHub] flink issue #5584: [FLINK-8787][flip6] WIP Deploying FLIP-6 YARN session wit...

2018-02-26 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5584 test failures due to ``` // logback + log4j, with/out krb5, different JVM opts // IMPORTANT: Be aware that we are using side effects here to modify the created YarnClusterDescriptor, //

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16378162#comment-16378162 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5282: [FLINK-6352] [kafka] Timestamp-based offset configuration...

2018-02-26 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5282 @aljoscha sorry about the leftover merge markers, I've fixed them now. ---

[jira] [Updated] (FLINK-6997) SavepointITCase fails in master branch sometimes

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6997: Priority: Blocker (was: Critical) > SavepointITCase fails in master branch sometimes >

[jira] [Updated] (FLINK-6645) JobMasterTest failed on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6645: Fix Version/s: 1.5.0 > JobMasterTest failed on Travis > -- > >

[jira] [Updated] (FLINK-6645) JobMasterTest failed on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6645: Priority: Blocker (was: Major) > JobMasterTest failed on Travis >

[jira] [Updated] (FLINK-7064) test instability in WordCountMapreduceITCase

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7064: Fix Version/s: 1.5.0 > test instability in WordCountMapreduceITCase >

[jira] [Updated] (FLINK-7064) test instability in WordCountMapreduceITCase

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7064: Priority: Blocker (was: Critical) > test instability in WordCountMapreduceITCase >

[jira] [Updated] (FLINK-8034) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failing on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8034: Priority: Blocker (was: Critical) >

[jira] [Updated] (FLINK-7733) test instability in Kafka end-to-end test (RetriableCommitFailedException)

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7733: Priority: Blocker (was: Critical) > test instability in Kafka end-to-end test

[jira] [Updated] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8163: Priority: Blocker (was: Critical) > NonHAQueryableStateFsBackendITCase test getting stuck

[jira] [Updated] (FLINK-8034) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failing on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8034: Fix Version/s: 1.5.0 > ProcessFailureCancelingITCase.testCancelingOnProcessFailure failing

[jira] [Updated] (FLINK-7733) test instability in Kafka end-to-end test (RetriableCommitFailedException)

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7733: Fix Version/s: 1.5.0 > test instability in Kafka end-to-end test

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

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8336: Priority: Blocker (was: Critical) > YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3

[jira] [Updated] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8073: Fix Version/s: 1.5.0 > Test instability >

[jira] [Updated] (FLINK-8337) GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled instable

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8337: Priority: Blocker (was: Critical) >

[jira] [Updated] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8073: Priority: Blocker (was: Critical) > Test instability >

[jira] [Updated] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8163: Fix Version/s: 1.5.0 > NonHAQueryableStateFsBackendITCase test getting stuck on Travis >

[jira] [Updated] (FLINK-8460) UtilsTest.testYarnFlinkResourceManagerJobManagerLostLeadership instable on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8460: Fix Version/s: 1.5.0 > UtilsTest.testYarnFlinkResourceManagerJobManagerLostLeadership

[jira] [Updated] (FLINK-8460) UtilsTest.testYarnFlinkResourceManagerJobManagerLostLeadership instable on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8460: Priority: Blocker (was: Critical) >

[jira] [Updated] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8402: Priority: Blocker (was: Critical) > HadoopS3FileSystemITCase.testDirectoryListing fails on

[jira] [Updated] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8408: Priority: Blocker (was: Critical) >

[jira] [Updated] (FLINK-8452) BucketingSinkTest.testNonRollingAvroKeyValueWithCompressionWriter instable on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8452: Priority: Blocker (was: Critical) >

[jira] [Updated] (FLINK-8452) BucketingSinkTest.testNonRollingAvroKeyValueWithCompressionWriter instable on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8452: Fix Version/s: 1.5.0 > BucketingSinkTest.testNonRollingAvroKeyValueWithCompressionWriter

[jira] [Updated] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8418: Priority: Blocker (was: Critical) > Kafka08ITCase.testStartFromLatestOffsets() times out

[jira] [Updated] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8521: Priority: Blocker (was: Critical) >

[jira] [Updated] (FLINK-8512) HAQueryableStateFsBackendITCase unstable on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8512: Priority: Blocker (was: Critical) > HAQueryableStateFsBackendITCase unstable on Travis >

[jira] [Updated] (FLINK-8517) StaticlyNestedIterationsITCase.testJobWithoutObjectReuse unstable on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8517: Priority: Blocker (was: Critical) >

[jira] [Updated] (FLINK-8731) TwoInputStreamTaskTest flaky on travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8731: Issue Type: Bug (was: Improvement) > TwoInputStreamTaskTest flaky on travis >

[jira] [Commented] (FLINK-8792) bad semantic of method name MessageQueryParameter.convertStringToValue

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16378136#comment-16378136 ] ASF GitHub Bot commented on FLINK-8792: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5587: [FLINK-8792][REST] bad semantic of method name Mes...

2018-02-26 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5587 [FLINK-8792][REST] bad semantic of method name MessageQueryParameter.convertStringToValue ## What is the purpose of the change *This pull request changed a method name to let it has a good

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16378122#comment-16378122 ] ASF GitHub Bot commented on FLINK-8689: --- Github user hequn8128 commented on a diff in the pull

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16378121#comment-16378121 ] ASF GitHub Bot commented on FLINK-8689: --- Github user hequn8128 commented on a diff in the pull

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-02-26 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r170828036 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1393,6 +1393,21 @@ object

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

2018-02-26 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r170828027 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/DistinctAggDelegateFunction.scala --- @@ -0,0 +1,122

[jira] [Updated] (FLINK-8792) bad semantic of method name MessageQueryParameter.convertStringToValue

2018-02-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-8792: Description: the method name {code:java} MessageQueryParameter.convertStringToValue {code} should be 

[jira] [Updated] (FLINK-8792) bad semantic of method name MessageQueryParameter.convertStringToValue

2018-02-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-8792: Description: the method name  (was: the ) > bad semantic of method name

[jira] [Updated] (FLINK-8792) bad semantic of method MessageQueryParameter.convertStringToValue

2018-02-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-8792: Description: the  > bad semantic of method MessageQueryParameter.convertStringToValue >

[jira] [Updated] (FLINK-8792) bad semantic of method name MessageQueryParameter.convertStringToValue

2018-02-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-8792: Summary: bad semantic of method name MessageQueryParameter.convertStringToValue (was: bad semantic of

[jira] [Closed] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8543. --- Resolution: Fixed Fix Version/s: 1.4.3 Fixed on release-1.4 in

[jira] [Created] (FLINK-8792) bad semantic of method MessageQueryParameter.convertStringToValue

2018-02-26 Thread vinoyang (JIRA)
vinoyang created FLINK-8792: --- Summary: bad semantic of method MessageQueryParameter.convertStringToValue Key: FLINK-8792 URL: https://issues.apache.org/jira/browse/FLINK-8792 Project: Flink

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16378093#comment-16378093 ] ASF GitHub Bot commented on FLINK-8756: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5573: [FLINK-8756][Client] Support ClusterClient.getAccumulator...

2018-02-26 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5573 @GJL I have refactored the code and test case, could you please review the new commit? Thanks. ---

[jira] [Closed] (FLINK-8044) Introduce scheduling mechanism to satisfy both state locality and input

2018-02-26 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou closed FLINK-8044. - Resolution: Duplicate Release Note: Already fixed by Stefan Richter. > Introduce scheduling

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377993#comment-16377993 ] ASF GitHub Bot commented on FLINK-8620: --- Github user ifndef-SleePy commented on a diff in the pull

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-02-26 Thread ifndef-SleePy
Github user ifndef-SleePy commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r170804963 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java --- @@ -314,6 +315,9 @@ public static TaskExecutor

[jira] [Commented] (FLINK-8245) Add some interval between logs when requested resources are not available

2018-02-26 Thread Wind (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377964#comment-16377964 ] Wind commented on FLINK-8245: - Anyone can assign it to me if possible ? > Add some interval between logs when

[jira] [Updated] (FLINK-8245) Add some interval between logs when requested resources are not available

2018-02-26 Thread Wind (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wind updated FLINK-8245: Labels: starter (was: ) > Add some interval between logs when requested resources are not available >

[jira] [Updated] (FLINK-8753) Introduce savepoint that go though the incremental checkpoint path

2018-02-26 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-8753: -- Summary: Introduce savepoint that go though the incremental checkpoint path (was: Introduce

[jira] [Comment Edited] (FLINK-8753) Introduce Incremental savepoint

2018-02-26 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377908#comment-16377908 ] Sihua Zhou edited comment on FLINK-8753 at 2/27/18 2:26 AM: [~StephanEwen]

[jira] [Commented] (FLINK-8753) Introduce Incremental savepoint

2018-02-26 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377908#comment-16377908 ] Sihua Zhou commented on FLINK-8753: --- [~StephanEwen] Thanks for your reply. Indeed, what I am trying to

[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2018-02-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 2/27/18 2:08 AM: error-prone has JDK 8

[jira] [Updated] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

2018-02-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7897: -- Description: nio.Files#delete() provides better clue as to why the deletion may fail:

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377898#comment-16377898 ] ASF GitHub Bot commented on FLINK-8335: --- Github user tedyu commented on the issue:

[GitHub] flink issue #5488: [FLINK-8335] [hbase] Upgrade hbase connector dependency t...

2018-02-26 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/5488 Should be good after 1.4.1 is filled in ---

[jira] [Updated] (FLINK-8554) Upgrade AWS SDK

2018-02-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8554: -- Description: AWS SDK 1.11.271 fixes a lot of bugs. One of which would exhibit the following: {code} Caused by:

[jira] [Commented] (FLINK-8720) Logging exception with S3 connector and BucketingSink

2018-02-26 Thread dejan miljkovic (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377835#comment-16377835 ] dejan miljkovic commented on FLINK-8720: Thanks for the suggestions. Removing Hadoop dependencies

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

2018-02-26 Thread Ken Krugler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377679#comment-16377679 ] Ken Krugler commented on FLINK-7477: The odd stuff (some of which might be bogus)... # I had to

[jira] [Commented] (FLINK-8791) Fix documentation on how to link dependencies

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377662#comment-16377662 ] ASF GitHub Bot commented on FLINK-8791: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink pull request #5586: [FLINK-8791] [docs] Fix documentation about config...

2018-02-26 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/5586 [FLINK-8791] [docs] Fix documentation about configuring dependencies This fixes the incorrect docs currently under [Linking with

[jira] [Created] (FLINK-8791) Fix documentation on how to link dependencies

2018-02-26 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8791: --- Summary: Fix documentation on how to link dependencies Key: FLINK-8791 URL: https://issues.apache.org/jira/browse/FLINK-8791 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8753) Introduce Incremental savepoint

2018-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377654#comment-16377654 ] Stephan Ewen commented on FLINK-8753: - It sounds like what you are trying to achieve is closer to a

[jira] [Commented] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

2018-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377623#comment-16377623 ] Stephan Ewen commented on FLINK-8770: - Thank you for reporting this. [~till.rohrmann] - do you have

[jira] [Commented] (FLINK-8784) Share network buffer pool among different partition operators

2018-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377622#comment-16377622 ] Stephan Ewen commented on FLINK-8784: - The choice to not share the network buffer pool, but partition

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377510#comment-16377510 ] ASF GitHub Bot commented on FLINK-8543: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

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

[GitHub] flink issue #5563: [FLINK-8543] Don't call super.close() in AvroKeyValueSink...

2018-02-26 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5563 merged ---

[GitHub] flink pull request #5563: [FLINK-8543] Don't call super.close() in AvroKeyVa...

2018-02-26 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/5563 ---

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-02-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377472#comment-16377472 ] Chesnay Schepler commented on FLINK-8703: - second batch merged to master in

[jira] [Commented] (FLINK-8645) Support convenient extension of parent-first ClassLoader patterns

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

[jira] [Commented] (FLINK-8593) Latency metric docs are outdated

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

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Commented] (FLINK-8596) Custom command line code does not correctly catch errors

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

[GitHub] flink pull request #5543: [FLINK-8596][CLI] Also catch NoClassDefFoundErrors

2018-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5543 ---

[GitHub] flink pull request #5484: [FLINK-8593][metrics] Update latency metric docs

2018-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5484 ---

[GitHub] flink pull request #5544: [FLINK-8645][configuration] Split classloader.pare...

2018-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5544 ---

[GitHub] flink pull request #5542: [FLINK-8703][tests] Migrate tests from LocalFlinkM...

2018-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5542 ---

[jira] [Closed] (FLINK-8645) Support convenient extension of parent-first ClassLoader patterns

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

[jira] [Closed] (FLINK-8596) Custom command line code does not correctly catch errors

2018-02-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8596. --- Resolution: Fixed master: f3bfd22b41acd4c16f71d6d69f7983abc63a1e71 > Custom command line

[jira] [Closed] (FLINK-8593) Latency metric docs are outdated

2018-02-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8593. --- Resolution: Fixed master: a2d1d084b90f0f47b91aa372525f01a382c892e7 > Latency metric docs are

[GitHub] flink pull request #5585: Release 1.4

2018-02-26 Thread ArtHustonHitachi
Github user ArtHustonHitachi closed the pull request at: https://github.com/apache/flink/pull/5585 ---

[GitHub] flink pull request #5585: Release 1.4

2018-02-26 Thread ArtHustonHitachi
GitHub user ArtHustonHitachi opened a pull request: https://github.com/apache/flink/pull/5585 Release 1.4 *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review your contribution in the best

[jira] [Commented] (FLINK-8787) Deploying FLIP-6 YARN session with HA fails

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377273#comment-16377273 ] ASF GitHub Bot commented on FLINK-8787: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5584: [FLINK-8787][flip6] WIP

2018-02-26 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5584#discussion_r170679952 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -186,7 +187,7 @@ public YarnClient getYarnClient() {

[jira] [Commented] (FLINK-8787) Deploying FLIP-6 YARN session with HA fails

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377267#comment-16377267 ] ASF GitHub Bot commented on FLINK-8787: --- GitHub user GJL opened a pull request:

[GitHub] flink pull request #5584: [FLINK-8787][flip6] WIP

2018-02-26 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5584 [FLINK-8787][flip6] WIP WIP ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way

[jira] [Updated] (FLINK-8787) Deploying FLIP-6 YARN session with HA fails

2018-02-26 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8787: Description: Starting a YARN session with HA in FLIP-6 mode fails with an exception. Commit:

[jira] [Updated] (FLINK-8787) Deploying FLIP-6 YARN session with HA fails

2018-02-26 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8787: Summary: Deploying FLIP-6 YARN session with HA fails (was: Deploying FLIP-6 YARN session fails) >

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

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

[jira] [Commented] (FLINK-8737) Creating a union of UnionGate instances will fail with UnsupportedOperationException when retrieving buffers

2018-02-26 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377176#comment-16377176 ] Nico Kruber commented on FLINK-8737: We ([~uce] and me) could not think of any way a user can create a

[jira] [Assigned] (FLINK-8737) Creating a union of UnionGate instances will fail with UnsupportedOperationException when retrieving buffers

2018-02-26 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-8737: -- Assignee: Nico Kruber > Creating a union of UnionGate instances will fail with >

[GitHub] flink pull request #5282: [FLINK-6352] [kafka] Timestamp-based offset config...

2018-02-26 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5282#discussion_r170663674 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010FetcherTest.java --- @@

[jira] [Commented] (FLINK-8737) Creating a union of UnionGate instances will fail with UnsupportedOperationException when retrieving buffers

2018-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377172#comment-16377172 ] ASF GitHub Bot commented on FLINK-8737: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #5583: [FLINK-8737][network] disallow creating a union of...

2018-02-26 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5583 [FLINK-8737][network] disallow creating a union of UnionGate instances ## What is the purpose of the change Recently, the `InputGate#pollNextBufferOrEvent()` was added but not implemented in

[jira] [Updated] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8770: Fix Version/s: 1.5.0 > CompletedCheckPoints stored on ZooKeeper is not up-to-date, when

[jira] [Updated] (FLINK-8779) ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8779: Priority: Blocker (was: Critical) > ClassLoaderITCase.testKMeansJobWithCustomClassLoader

[jira] [Updated] (FLINK-8783) Test instability SlotPoolRpcTest.testExtraSlotsAreKept

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8783: Priority: Blocker (was: Critical) > Test instability SlotPoolRpcTest.testExtraSlotsAreKept

[jira] [Updated] (FLINK-8783) Test instability SlotPoolRpcTest.testExtraSlotsAreKept

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8783: Fix Version/s: 1.5.0 > Test instability SlotPoolRpcTest.testExtraSlotsAreKept >

[jira] [Updated] (FLINK-8789) StoppableFunctions sometimes not detected

2018-02-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8789: Fix Version/s: 1.5.0 > StoppableFunctions sometimes not detected >

  1   2   3   4   >