[GitHub] flink pull request #4952: [FLINK-7992][docs] extend the PR template asking f...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4952#discussion_r149067102 --- Diff: .github/PULL_REQUEST_TEMPLATE.md --- @@ -63,9 +63,9 @@ This change added tests and can be verified as follows: - The serializers: (yes /

[jira] [Commented] (FLINK-7992) extend PR template with S3 question

[ https://issues.apache.org/jira/browse/FLINK-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240217#comment-16240217 ] ASF GitHub Bot commented on FLINK-7992: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-7992) extend PR template with S3 question

[ https://issues.apache.org/jira/browse/FLINK-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240194#comment-16240194 ] ASF GitHub Bot commented on FLINK-7992: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4952: [FLINK-7992][docs] extend the PR template asking f...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4952 ---

[jira] [Closed] (FLINK-7992) extend PR template with S3 question

[ https://issues.apache.org/jira/browse/FLINK-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7992. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 423b969604a94128007654a7edeb947ac9b646a8 >

[jira] [Created] (FLINK-7995) Created curator/zk module in flink-shaded

Chesnay Schepler created FLINK-7995: --- Summary: Created curator/zk module in flink-shaded Key: FLINK-7995 URL: https://issues.apache.org/jira/browse/FLINK-7995 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-7994) Remove direct curator dependency from flink-mesos

[ https://issues.apache.org/jira/browse/FLINK-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240186#comment-16240186 ] ASF GitHub Bot commented on FLINK-7994: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4954: [FLINK-7994][mesos] Remove effectively unused cura...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4954 [FLINK-7994][mesos] Remove effectively unused curator dependency ## What is the purpose of the change This PR removes the effectively unused flink-shaded-curator dependency from flink-mesos.

[GitHub] flink pull request #4953: [FLINK-7993][kafka] Sync curator shading patterns

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4953 [FLINK-7993][kafka] Sync curator shading patterns ## What is the purpose of the change This PR syncs the curator shading patterns in flink-runtime and flink-connector-kafka-0.8. Fur

[jira] [Commented] (FLINK-7993) Kafka 08 curator shading pattern out-of-sync

[ https://issues.apache.org/jira/browse/FLINK-7993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240180#comment-16240180 ] ASF GitHub Bot commented on FLINK-7993: --- GitHub user zentol opened a pull request:

[jira] [Created] (FLINK-7994) Remove direct curator dependency from flink-mesos

Chesnay Schepler created FLINK-7994: --- Summary: Remove direct curator dependency from flink-mesos Key: FLINK-7994 URL: https://issues.apache.org/jira/browse/FLINK-7994 Project: Flink Issue T

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240176#comment-16240176 ] ASF GitHub Bot commented on FLINK-7652: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new RES...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4734 Maybe you could rebase your work on top of https://github.com/tillrohrmann/flink/tree/FLINK-7870. That's the branch where I stacked multiple of the pending handler PRs and which I will merge sho

[jira] [Created] (FLINK-7993) Kafka 08 curator shading pattern out-of-sync

Chesnay Schepler created FLINK-7993: --- Summary: Kafka 08 curator shading pattern out-of-sync Key: FLINK-7993 URL: https://issues.apache.org/jira/browse/FLINK-7993 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240172#comment-16240172 ] ASF GitHub Bot commented on FLINK-7652: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4734#discussion_r149057297 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobStatusesWithIdsOverview.java --- @@ -0,0 +1,235 @@ +/* +

[jira] [Commented] (FLINK-7990) Strange behavior when configuring Logback for logging

[ https://issues.apache.org/jira/browse/FLINK-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240166#comment-16240166 ] Teena K commented on FLINK-7990: Flink 1.3.2 version shows this behavior > Strange behavi

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

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240153#comment-16240153 ] Stefan Richter edited comment on FLINK-7880 at 11/6/17 11:20 AM: ---

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240154#comment-16240154 ] ASF GitHub Bot commented on FLINK-7652: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new RES...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4734 Thanks a lot @tzulitai. Will take another look at it and merge it if I have no other comments. ---

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

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240153#comment-16240153 ] Stefan Richter commented on FLINK-7880: --- Yes, but the test seems to expect that wait

[jira] [Commented] (FLINK-6407) Upgrade AVRO dependency version to 1.8.x

[ https://issues.apache.org/jira/browse/FLINK-6407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240152#comment-16240152 ] Aljoscha Krettek commented on FLINK-6407: - [~StephanEwen] discovered that Avro 1.8

[jira] [Commented] (FLINK-7992) extend PR template with S3 question

[ https://issues.apache.org/jira/browse/FLINK-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240149#comment-16240149 ] ASF GitHub Bot commented on FLINK-7992: --- Github user zentol commented on the issue:

[GitHub] flink issue #4952: [FLINK-7992][docs] extend the PR template asking for any ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4952 +1 ---

[jira] [Commented] (FLINK-7992) extend PR template with S3 question

[ https://issues.apache.org/jira/browse/FLINK-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240147#comment-16240147 ] ASF GitHub Bot commented on FLINK-7992: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #4952: [FLINK-7992][docs] extend the PR template asking f...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4952 [FLINK-7992][docs] extend the PR template asking for any S3 relation ## What is the purpose of the change This adds a question to the PR template whether a PR is S3-related because this needs

[jira] [Created] (FLINK-7992) extend PR template with S3 question

Nico Kruber created FLINK-7992: -- Summary: extend PR template with S3 question Key: FLINK-7992 URL: https://issues.apache.org/jira/browse/FLINK-7992 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7419) Shade jackson dependency in flink-avro

[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240142#comment-16240142 ] ASF GitHub Bot commented on FLINK-7419: --- Github user zentol commented on the issue:

[GitHub] flink issue #4524: [FLINK-7419] Shade jackson dependency in flink-avro

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4524 @zjureel The PR has been merged, could you close the PR? ---

[jira] [Assigned] (FLINK-7978) Kafka011 exactly-once Producer sporadically fails to commit under high parallelism

[ https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-7978: - Assignee: Piotr Nowojski > Kafka011 exactly-once Producer sporadically fails to commit un

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

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4951 [FLINK-7989][yarn] do not deploy the dist.jar file twice ## What is the purpose of the change We always add the dist.jar ourselves, but it could also be inside a shipped folder such as the "l

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

[ https://issues.apache.org/jira/browse/FLINK-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240098#comment-16240098 ] ASF GitHub Bot commented on FLINK-7989: --- GitHub user NicoK opened a pull request:

[jira] [Created] (FLINK-7991) Cleanup kafka example jar filters

Chesnay Schepler created FLINK-7991: --- Summary: Cleanup kafka example jar filters Key: FLINK-7991 URL: https://issues.apache.org/jira/browse/FLINK-7991 Project: Flink Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/FLINK-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7989: --- Description: We always add the {{flink-dist*.jar}} ourselves, but it could also be inside a shipped fo

[GitHub] flink issue #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new RES...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4734 @tillrohrmann the PR is now rebased. Previous comments have also been addressed. ---

[jira] [Created] (FLINK-7990) Strange behavior when configuring Logback for logging

Fabian Hueske created FLINK-7990: Summary: Strange behavior when configuring Logback for logging Key: FLINK-7990 URL: https://issues.apache.org/jira/browse/FLINK-7990 Project: Flink Issue Typ

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240110#comment-16240110 ] ASF GitHub Bot commented on FLINK-7652: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-7986) Introduce FilterSetOpTransposeRule to Flink

[ https://issues.apache.org/jira/browse/FLINK-7986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240113#comment-16240113 ] Fabian Hueske commented on FLINK-7986: -- Yes, this rule makes a lot of sense. > Intro

[jira] [Closed] (FLINK-7966) Create flink-connector-kafka-1.0 submodule

[ https://issues.apache.org/jira/browse/FLINK-7966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7966. --- Resolution: Duplicate > Create flink-connector-kafka-1.0 submodule > -

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

[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240066#comment-16240066 ] Aljoscha Krettek commented on FLINK-7977: - Actually, the API should stay stable fo

[jira] [Commented] (FLINK-7987) Use RexBuilder when converting Expression to RexNode

[ https://issues.apache.org/jira/browse/FLINK-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240064#comment-16240064 ] Fabian Hueske commented on FLINK-7987: -- Would we lose validation when there is no sch

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240061#comment-16240061 ] ASF GitHub Bot commented on FLINK-6094: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4471: [FLINK-6094] [table] Implement stream-stream proctime non...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4471 Thanks for the update @hequn8128! I'll be quite busy with testing and bug fixing for the upcoming 1.4 release in the next 2-3 weeks. I'll make another pass on this PR once the 1.4 work becomes l

[jira] [Updated] (FLINK-7266) Don't attempt to delete parent directory on S3

[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7266: Fix Version/s: (was: 1.4.0) > Don't attempt to delete parent directory on S3 > -

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5763: Fix Version/s: (was: 1.4.0) 1.5.0 > Make savepoints self-contained an

[jira] [Updated] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks

[ https://issues.apache.org/jira/browse/FLINK-5820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5820: Fix Version/s: (was: 1.4.0) 1.5.0 > Extend State Backend Abstraction

[jira] [Updated] (FLINK-7266) Don't attempt to delete parent directory on S3

[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7266: Fix Version/s: 1.5.0 > Don't attempt to delete parent directory on S3 >

[jira] [Updated] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5823: Fix Version/s: (was: 1.4.0) 1.5.0 > Store Checkpoint Root Metadata in

[GitHub] flink pull request #4950: [hotfix][s3] fix HadoopS3FileSystemITCase leaving ...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4950 [hotfix][s3] fix HadoopS3FileSystemITCase leaving test directories behind in S3 ## What is the purpose of the change This PR fixes `HadoopS3FileSystemITCase` leaving a test directory behind

[jira] [Updated] (FLINK-7978) Kafka011 exactly-once Producer sporadically fails to commit under high parallelism

[ https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7978: Affects Version/s: (was: 1.4.0) 1.5.0 > Kafka011 exactly-once Pro

[jira] [Updated] (FLINK-7978) Kafka011 exactly-once Producer sporadically fails to commit under high parallelism

[ https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7978: Affects Version/s: (was: 1.5.0) 1.4.0 > Kafka011 exactly-once Pro

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

Nico Kruber created FLINK-7989: -- Summary: flink-dist jar is deployed twice onto YARN Key: FLINK-7989 URL: https://issues.apache.org/jira/browse/FLINK-7989 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7988) HadoopS3FileSystemITCase leaves test directories behind in S3

Nico Kruber created FLINK-7988: -- Summary: HadoopS3FileSystemITCase leaves test directories behind in S3 Key: FLINK-7988 URL: https://issues.apache.org/jira/browse/FLINK-7988 Project: Flink Issu

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

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240024#comment-16240024 ] Till Rohrmann commented on FLINK-7880: -- The {{CancellationSuccess}} message is sent a

<    1   2   3