[GitHub] flink pull request #6296: When submitting a flink job with yarn-cluster, fli...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6296#discussion_r201586679 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -1189,9 +1189,9 @@ private static Path

[GitHub] flink pull request #6296: When submitting a flink job with yarn-cluster, fli...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6296#discussion_r201586773 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -1227,7 +1227,6 @@ public FileVisitResult

[GitHub] flink pull request #6296: When submitting a flink job with yarn-cluster, fli...

Github user linjun007 commented on a diff in the pull request: https://github.com/apache/flink/pull/6296#discussion_r201588919 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -1227,7 +1227,6 @@ public FileVisitResult

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539646#comment-16539646 ] Chesnay Schepler commented on FLINK-8985: - Let's not over-complicate this thing from the get-go.

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

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

[jira] [Commented] (FLINK-9687) Delay the state fetch only when the triggerResult is fire

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

[GitHub] flink issue #6224: [FLINK-9687]Delay the state fetch only when the triggerRe...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/6224 @Aitozi Is it ok for you that I merge it but rename to FLINK-5363 and write in the commit message that it also resolves FLINK-9687? I also assigned you to both of these issues. ---

[jira] [Commented] (FLINK-9791) Outdated savepoint compatibility table

[ https://issues.apache.org/jira/browse/FLINK-9791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539730#comment-16539730 ] David Anderson commented on FLINK-9791: --- A table that has to be updated with each release is

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

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

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

[ https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539792#comment-16539792 ] ASF GitHub Bot commented on FLINK-8558: --- Github user twalthr closed the pull request at:

[GitHub] flink pull request #6264: [FLINK-8558] [table] Add unified format interfaces...

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

[GitHub] flink issue #5381: [FLINK-8523][network] Stop assigning floating buffers for...

Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/5381 Yes, I think it can make better use of floating buffers. As last confirmation with Piotr, this PR will not be merged into release-1.5, because there were still some issues not confirmed

[GitHub] flink issue #6264: [FLINK-8558] [table] Add unified format interfaces and se...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6264 Thanks for the in-depth review @pnowojski. I hope I could address most of your comments. Since this PR heavily overlaps with #6201 and that PR needs a review and some additional work as well. I will

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/6103 okey... I encounter issue when submit jobs, stack as below, looks the same with this one. Is this a regression, or are we thinking the fix will break existing code?

[jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

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

[jira] [Updated] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

[ https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9413: -- Labels: pull-request-available (was: ) > Tasks can fail with PartitionNotFoundException if

[GitHub] flink issue #5381: [FLINK-8523][network] Stop assigning floating buffers for...

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5381 @zhijiangW is this PR still useful? if so, was there any progress? ---

[jira] [Assigned] (FLINK-5363) Fire timers when window state is currently empty

[ https://issues.apache.org/jira/browse/FLINK-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5363: --- Assignee: aitozi > Fire timers when window state is currently empty >

[jira] [Commented] (FLINK-9789) Watermark metrics for an operator shadow each other

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

[GitHub] flink issue #6292: [FLINK-9789][metrics] Ensure uniqueness of watermark metr...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/6292 +1 to merge this now but I think in the long run we should make the metrics system not rely on metrics objects being unique (or them correctly implementing `hashCode()`/`equals()`). ---

[jira] [Created] (FLINK-9799) Generalize/unify state meta info

Stefan Richter created FLINK-9799: - Summary: Generalize/unify state meta info Key: FLINK-9799 URL: https://issues.apache.org/jira/browse/FLINK-9799 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-9791) Outdated savepoint compatibility table

[ https://issues.apache.org/jira/browse/FLINK-9791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-9791: Description: Savepoint compatibility table is outdated, does not cover 1.4.x nor 1.5.x. We

[jira] [Created] (FLINK-9802) Harden End-to-end tests against download failures

Chesnay Schepler created FLINK-9802: --- Summary: Harden End-to-end tests against download failures Key: FLINK-9802 URL: https://issues.apache.org/jira/browse/FLINK-9802 Project: Flink Issue

[jira] [Closed] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9743. --- Resolution: Fixed master: 2fbe562d4db93ecef8b5cf4a3f477148d43208f6 1.5:

[jira] [Commented] (FLINK-9801) flink-dist is missing dependency on flink-examples

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

[jira] [Reopened] (FLINK-9768) Only build flink-dist for binary releases

[ https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9768: - > Only build flink-dist for binary releases > - > >

[jira] [Closed] (FLINK-9768) Only build flink-dist for binary releases

[ https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9768. --- Resolution: Fixed > Only build flink-dist for binary releases >

[jira] [Updated] (FLINK-9754) Release scripts refers to non-existing profile

[ https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9754: Fix Version/s: (was: 1.5.1) 1.5.2 > Release scripts refers to

[jira] [Updated] (FLINK-9768) Only build flink-dist for binary releases

[ https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9768: Fix Version/s: (was: 1.5.1) 1.5.2 > Only build flink-dist for

[jira] [Reopened] (FLINK-9754) Release scripts refers to non-existing profile

[ https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9754: - > Release scripts refers to non-existing profile >

[jira] [Closed] (FLINK-9754) Release scripts refers to non-existing profile

[ https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9754. --- Resolution: Fixed > Release scripts refers to non-existing profile >

[jira] [Updated] (FLINK-9801) flink-dist is missing dependency on flink-examples

[ https://issues.apache.org/jira/browse/FLINK-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9801: Fix Version/s: (was: 1.5.1) 1.5.2 > flink-dist is missing

[jira] [Commented] (FLINK-9703) Mesos does not expose TM Prometheus port

[ https://issues.apache.org/jira/browse/FLINK-9703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539889#comment-16539889 ] ASF GitHub Bot commented on FLINK-9703: --- Github user rsltrifork commented on a diff in the pull

[GitHub] flink pull request #6288: [FLINK-9703] [flink-mesos] Expose Prometheus port ...

Github user rsltrifork commented on a diff in the pull request: https://github.com/apache/flink/pull/6288#discussion_r201645393 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java --- @@ -332,6 +334,22 @@ public String

[GitHub] flink issue #6303: [hotfix][JobManageOptions]modify annotation of EXECUTION_...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6303 If you modify the description of config options you have to regenerate the documentation. See the test error message for instructions. ---

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

[ https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539673#comment-16539673 ] ASF GitHub Bot commented on FLINK-8558: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6264: [FLINK-8558] [table] Add unified format interfaces...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6264#discussion_r201592609 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/formats/TableFormatFactory.scala --- @@ -0,0 +1,85 @@ +/* + *

[GitHub] flink pull request #6264: [FLINK-8558] [table] Add unified format interfaces...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6264#discussion_r201593060 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/formats/TableFormatFactoryService.scala --- @@ -0,0 +1,245 @@ +/* + *

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

[ https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539672#comment-16539672 ] ASF GitHub Bot commented on FLINK-8558: --- Github user pnowojski commented on a diff in the pull

[jira] [Updated] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8523: -- Labels: pull-request-available (was: ) > Stop assigning floating buffers for blocked input

[jira] [Created] (FLINK-9797) Separate state serializers from network serializers

Nico Kruber created FLINK-9797: -- Summary: Separate state serializers from network serializers Key: FLINK-9797 URL: https://issues.apache.org/jira/browse/FLINK-9797 Project: Flink Issue Type:

[GitHub] flink pull request #6303: [hotfix][JobManageOptions]modify annotation of EXE...

GitHub user maqingxiang opened a pull request: https://github.com/apache/flink/pull/6303 [hotfix][JobManageOptions]modify annotation of EXECUTION_FAILOVER_STRATEGY in JobManageOptions You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.

Aljoscha Krettek created FLINK-9798: --- Summary: Drop canEqual() from TypeInformation, TypeSerializer, etc. Key: FLINK-9798 URL: https://issues.apache.org/jira/browse/FLINK-9798 Project: Flink

[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.

[ https://issues.apache.org/jira/browse/FLINK-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9798: Issue Type: Sub-task (was: Improvement) Parent: FLINK-3957 > Drop canEqual() from

[GitHub] flink pull request #6304: [FLINK-9801][build] Add missing example dependenci...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6304 [FLINK-9801][build] Add missing example dependencies to flink-dist ## What is the purpose of the change With this PR `flink-dist` explicitly depends on `flink-examples-batch` and

[jira] [Updated] (FLINK-9801) flink-dist is missing dependency on flink-examples

[ https://issues.apache.org/jira/browse/FLINK-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9801: -- Labels: pull-request-available (was: ) > flink-dist is missing dependency on flink-examples >

[jira] [Updated] (FLINK-9803) Drop canEqual() from TypeInformation, TypeSerializer, etc.

[ https://issues.apache.org/jira/browse/FLINK-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9803: Description: See discussion from

[jira] [Updated] (FLINK-9803) Drop canEqual() from TypeSerializer

[ https://issues.apache.org/jira/browse/FLINK-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9803: Summary: Drop canEqual() from TypeSerializer (was: Drop canEqual() from TypeInformation,

[GitHub] flink issue #6304: [FLINK-9801][build] Add missing example dependencies to f...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/6304 LGTM ---

[GitHub] flink issue #6304: [FLINK-9801][build] Add missing example dependencies to f...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6304 merging. ---

[jira] [Commented] (FLINK-9801) flink-dist is missing dependency on flink-examples

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

[jira] [Closed] (FLINK-9470) Allow querying the key in KeyedProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-9470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9470. --- Resolution: Fixed Implemented in cde504eb401441e589b3f295e40db37a005ee6d9 > Allow querying

[jira] [Commented] (FLINK-9470) Allow querying the key in KeyedProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-9470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539687#comment-16539687 ] ASF GitHub Bot commented on FLINK-9470: --- Github user aljoscha closed the pull request at:

[jira] [Updated] (FLINK-9470) Allow querying the key in KeyedProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-9470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9470: -- Labels: pull-request-available (was: ) > Allow querying the key in KeyedProcessFunction >

[jira] [Closed] (FLINK-9668) In some case Trigger.onProcessingTime don't exectue

[ https://issues.apache.org/jira/browse/FLINK-9668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9668. --- Resolution: Duplicate > In some case Trigger.onProcessingTime don't exectue >

[GitHub] flink issue #6224: [FLINK-9687]Delay the state fetch only when the triggerRe...

Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/6224 OK 👌 ---

[jira] [Commented] (FLINK-9687) Delay the state fetch only when the triggerResult is fire

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

[jira] [Created] (FLINK-9800) Return the relation between a running job and the original jar in REST API

Lasse Nedergaard created FLINK-9800: Summary: Return the relation between a running job and the original jar in REST API Key: FLINK-9800 URL: https://issues.apache.org/jira/browse/FLINK-9800

[jira] [Commented] (FLINK-9789) Watermark metrics for an operator shadow each other

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

[GitHub] flink issue #6292: [FLINK-9789][metrics] Ensure uniqueness of watermark metr...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6292 Relying on hashCode/equals implementations would mean we could no longer use lambdas/method references for gauges which imo isn't a viable option. ---

[jira] [Closed] (FLINK-9789) Watermark metrics for an operator shadow each other

[ https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9789. --- master: 60df251ad34ac033ed6c4423a69765739cb04199 1.5: a0a810720d251fb9ab6a4cf9d995828d99a3f2c8

[jira] [Closed] (FLINK-9187) add prometheus pushgateway reporter

[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9187. --- Resolution: Fixed master: 5ee5dbf3dd9e5240ed13c8c3eaff6cca158010b3 > add prometheus

[jira] [Closed] (FLINK-9730) avoid access static via class reference

[ https://issues.apache.org/jira/browse/FLINK-9730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9730. --- Resolution: Fixed master: 5ee5dbf3dd9e5240ed13c8c3eaff6cca158010b3 > avoid access static

[jira] [Commented] (FLINK-9563) Migrate integration tests for CEP

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

[GitHub] flink issue #6170: [FLINK-9563]: Using a custom sink function for tests in C...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6170 alrighty, looks good to me, merging. ---

[jira] [Commented] (FLINK-9801) flink-dist is missing dependency on flink-examples

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

[GitHub] flink pull request #6097: [FLINK-9470] Allow querying the key in KeyedProces...

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

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

[ https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539744#comment-16539744 ] ASF GitHub Bot commented on FLINK-8558: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6264: [FLINK-8558] [table] Add unified format interfaces...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6264#discussion_r201611503 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/formats/TableFormatFactory.scala --- @@ -0,0 +1,85 @@ +/* + * Licensed

[jira] [Created] (FLINK-9801) flink-dist is missing dependency on flink-examples

Chesnay Schepler created FLINK-9801: --- Summary: flink-dist is missing dependency on flink-examples Key: FLINK-9801 URL: https://issues.apache.org/jira/browse/FLINK-9801 Project: Flink Issue

[jira] [Commented] (FLINK-9801) flink-dist is missing dependency on flink-examples

[ https://issues.apache.org/jira/browse/FLINK-9801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539798#comment-16539798 ] Chesnay Schepler commented on FLINK-9801: - Note that this exact problem occurred in RC3 for

[GitHub] flink pull request #6075: [FLINK-9407] [hdfs connector] Support orc rolling ...

Github user yuruiz commented on a diff in the pull request: https://github.com/apache/flink/pull/6075#discussion_r201630927 --- Diff: flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java --- @@ -0,0 +1,269 @@ +/** + * Licensed to the Apache

[jira] [Commented] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539813#comment-16539813 ] ASF GitHub Bot commented on FLINK-9407: --- Github user yuruiz commented on a diff in the pull

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

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

[jira] [Commented] (FLINK-9666) short-circuit logic should be used in boolean contexts

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

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

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

[jira] [Commented] (FLINK-9730) avoid access static via class reference

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

[jira] [Closed] (FLINK-9768) Only build flink-dist for binary releases

[ https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9768. --- Resolution: Fixed Fix Version/s: (was: 1.5.2) 1.5.1 master:

[jira] [Closed] (FLINK-9754) Release scripts refers to non-existing profile

[ https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9754. --- Resolution: Fixed Fix Version/s: 1.6.0 1.5.1 master:

[jira] [Commented] (FLINK-9789) Watermark metrics for an operator shadow each other

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

[jira] [Commented] (FLINK-9754) Release scripts refers to non-existing profile

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

[jira] [Commented] (FLINK-9768) Only build flink-dist for binary releases

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

[jira] [Closed] (FLINK-9584) Unclosed streams in Bucketing-/RollingSink

[ https://issues.apache.org/jira/browse/FLINK-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9584. --- Resolution: Fixed master: 04a7cd4d9232e757560e156a684e224d54b71176 1.5:

[jira] [Commented] (FLINK-9584) Unclosed streams in Bucketing-/RollingSink

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

[GitHub] flink pull request #6285: [FLINK-9768][release] Speed up binary release

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

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

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

[GitHub] flink pull request #6295: Add *.snapshot binary files to RAT exclusion list

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

[GitHub] flink pull request #6292: [FLINK-9789][metrics] Ensure uniqueness of waterma...

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

[GitHub] flink pull request #6247: [FLINK-9730] [code refactor] fix access static via...

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

[GitHub] flink pull request #6164: [FLINK-9584][connector] Properly close the output ...

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

[GitHub] flink pull request #6286: [FLINK-9754][release] Remove references to scala p...

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

[GitHub] flink pull request #6230: [FLINK-9666] short-circuit logic should be used in...

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

[GitHub] flink pull request #6184: [FLINK-9187][METRICS] add prometheus pushgateway r...

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

[jira] [Updated] (FLINK-9803) Drop canEqual() from TypeInformation, TypeSerializer, etc.

[ https://issues.apache.org/jira/browse/FLINK-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9803: Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-3957) > Drop

[jira] [Created] (FLINK-9803) Drop canEqual() from TypeInformation, TypeSerializer, etc.

Aljoscha Krettek created FLINK-9803: --- Summary: Drop canEqual() from TypeInformation, TypeSerializer, etc. Key: FLINK-9803 URL: https://issues.apache.org/jira/browse/FLINK-9803 Project: Flink

[jira] [Commented] (FLINK-9799) Generalize/unify state meta info

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

[jira] [Updated] (FLINK-9799) Generalize/unify state meta info

[ https://issues.apache.org/jira/browse/FLINK-9799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9799: -- Labels: pull-request-available (was: ) > Generalize/unify state meta info >

[jira] [Commented] (FLINK-9799) Generalize/unify state meta info

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

[jira] [Commented] (FLINK-9794) JDBCOutputFormat does not consider idle connection and multithreads synchronization

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

  1   2   3   4   >