[jira] [Updated] (FLINK-8020) Deadlock found in Flink Streaming job

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Jiang updated FLINK-8020: Description: Our streaming job run into trouble in these days after a long time smooth running.

[jira] [Created] (FLINK-8020) Deadlock found in Flink Streaming job

Weihua Jiang created FLINK-8020: --- Summary: Deadlock found in Flink Streaming job Key: FLINK-8020 URL: https://issues.apache.org/jira/browse/FLINK-8020 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8020) Deadlock found in Flink Streaming job

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Jiang updated FLINK-8020: Attachment: jstack67976-2.log > Deadlock found in Flink Streaming job >

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

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

[jira] [Commented] (FLINK-5176) Properly wait for component shutdown in Runner components

[ https://issues.apache.org/jira/browse/FLINK-5176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243534#comment-16243534 ] Shuyi Chen commented on FLINK-5176: --- [~till.rohrmann] is this still an issue? > Properly wait for

[jira] [Commented] (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:comment-tabpanel=16243540#comment-16243540 ] Aljoscha Krettek commented on FLINK-7978: - I forgot to commit on master so the commits that are

[jira] [Comment Edited] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243362#comment-16243362 ] Muhammad Imran Tariq edited comment on FLINK-8008 at 11/8/17 4:40 AM: --

[jira] [Commented] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243362#comment-16243362 ] Muhammad Imran Tariq commented on FLINK-8008: - I am calling _public PojoTypeInfo(Class

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

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

[GitHub] flink issue #4969: (release-1.3) [FLINK-8001] [kafka] Mark subtask as IDLE i...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4969 Rerunning Travis and then merging this :) Thanks for the review! ---

[GitHub] flink pull request #4967: [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmit...

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

[jira] [Comment Edited] (FLINK-5176) Properly wait for component shutdown in Runner components

[ https://issues.apache.org/jira/browse/FLINK-5176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243534#comment-16243534 ] Shuyi Chen edited comment on FLINK-5176 at 11/8/17 8:41 AM: Hi

[jira] [Commented] (FLINK-8020) Deadlock found in Flink Streaming job

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243538#comment-16243538 ] Weihua Jiang commented on FLINK-8020: - Sorry, after further analyzing, it seems the deadlock is caused

[GitHub] flink issue #4972: [FLINK-8009][build][runtime] Remove transitive dependency...

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

[jira] [Closed] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8001. -- Resolution: Fixed > Mark Kafka Consumer as idle if it doesn't have partitions >

[jira] [Updated] (FLINK-8011) Set dist flink-python dependency to provided

[ https://issues.apache.org/jira/browse/FLINK-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8011: Priority: Trivial (was: Major) > Set dist flink-python dependency to provided >

[jira] [Commented] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243845#comment-16243845 ] Chesnay Schepler commented on FLINK-8009: - We have separate branches, with different commits, so

[jira] [Reopened] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7810: - Reopen to fix release note. > Switch from custom Flakka to Akka 2.4.x >

[jira] [Closed] (FLINK-7838) Kafka011ProducerExactlyOnceITCase do not finish

[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7838. --- Resolution: Fixed Release Note: (was: Resolved issues on our side. There is still

[jira] [Reopened] (FLINK-7838) Kafka011ProducerExactlyOnceITCase do not finish

[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7838: - Reopen to fix release note. > Kafka011ProducerExactlyOnceITCase do not finish >

[jira] [Closed] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7810. --- Resolution: Fixed Release Note: (was: Fixed via

[jira] [Reopened] (FLINK-7473) Possible Leak in GlobalWindows

[ https://issues.apache.org/jira/browse/FLINK-7473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7473: - Reopen to fix release note. > Possible Leak in GlobalWindows >

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

[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7419. --- Resolution: Fixed Release Note: (was: Fixed via

[jira] [Reopened] (FLINK-7233) TaskManagerHeapSizeCalculationJavaBashTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7233: - Reopen to fix release note. > TaskManagerHeapSizeCalculationJavaBashTest failed on Travis >

[jira] [Commented] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

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

[jira] [Closed] (FLINK-7150) Code improvements to the ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-7150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7150. --- Resolution: Fixed Release Note: (was: Fixed via

[GitHub] flink issue #4929: [FLINK-7922][Table API]make FlinkTypeFactory override lea...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4929 Thanks for the PR @walterddr. I'll add the test for the Streaming API and merge it. Thanks, Fabian ---

[jira] [Created] (FLINK-8024) Let ClusterOverviewHandler directly extend from AbstractRestHandler

Till Rohrmann created FLINK-8024: Summary: Let ClusterOverviewHandler directly extend from AbstractRestHandler Key: FLINK-8024 URL: https://issues.apache.org/jira/browse/FLINK-8024 Project: Flink

[GitHub] flink pull request #4984: [FLINK-8026] Let ClusterConfigHandler directly ext...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4984 [FLINK-8026] Let ClusterConfigHandler directly extend AbstractRestHandler ## What is the purpose of the change Let ClusterConfigHandler directly extend AbstractRestHandler. ##

[jira] [Created] (FLINK-8026) Let ClusterConfigHandler extend from AbstractRestHandler

Till Rohrmann created FLINK-8026: Summary: Let ClusterConfigHandler extend from AbstractRestHandler Key: FLINK-8026 URL: https://issues.apache.org/jira/browse/FLINK-8026 Project: Flink Issue

[GitHub] flink pull request #4955: [FLINK-7978][kafka] Ensure that transactional ids ...

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

[jira] [Commented] (FLINK-8005) Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues

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

[jira] [Updated] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8009: Affects Version/s: (was: 1.5.0) > flink-dist pulls in flink-runtime's transitive

[jira] [Closed] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8009. --- Resolution: Fixed Closed again with only 1.4.0 as fixVersion. We don't have to fix it for

[jira] [Reopened] (FLINK-7768) Load File Systems via Java Service abstraction

[ https://issues.apache.org/jira/browse/FLINK-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7768: - Reopen to fix release note. > Load File Systems via Java Service abstraction >

[jira] [Closed] (FLINK-7768) Load File Systems via Java Service abstraction

[ https://issues.apache.org/jira/browse/FLINK-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7768. --- Resolution: Fixed Release Note: (was: Implemented in

[jira] [Closed] (FLINK-7772) Test instability in BlobCacheDeleteTest

[ https://issues.apache.org/jira/browse/FLINK-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7772. --- Resolution: Fixed Release Note: (was: Fixed via

[jira] [Closed] (FLINK-7766) Remove obsolete reflection for hflush on HDFS

[ https://issues.apache.org/jira/browse/FLINK-7766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7766. --- Resolution: Fixed Release Note: (was: Fixed via

[jira] [Closed] (FLINK-7767) Avoid loading Hadoop conf dynamically at runtime

[ https://issues.apache.org/jira/browse/FLINK-7767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7767. --- Resolution: Fixed Release Note: (was: Fixed via

[jira] [Reopened] (FLINK-7766) Remove obsolete reflection for hflush on HDFS

[ https://issues.apache.org/jira/browse/FLINK-7766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7766: - Reopen to fix release note. > Remove obsolete reflection for hflush on HDFS >

[jira] [Reopened] (FLINK-7767) Avoid loading Hadoop conf dynamically at runtime

[ https://issues.apache.org/jira/browse/FLINK-7767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7767: - Reopen to fix release note. > Avoid loading Hadoop conf dynamically at runtime >

[jira] [Reopened] (FLINK-7158) Wrong test jar dependency in flink-clients

[ https://issues.apache.org/jira/browse/FLINK-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7158: - Reopen to fix release note. > Wrong test jar dependency in flink-clients >

[jira] [Closed] (FLINK-7158) Wrong test jar dependency in flink-clients

[ https://issues.apache.org/jira/browse/FLINK-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7158. --- Resolution: Fixed Release Note: (was: Fixed in 1.3.2 via

[jira] [Closed] (FLINK-7149) Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink

[ https://issues.apache.org/jira/browse/FLINK-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7149. --- Resolution: Fixed Release Note: (was: Fixed in - 1.4.0 via

[jira] [Reopened] (FLINK-7150) Code improvements to the ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-7150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7150: - Reopen to fix release note. > Code improvements to the ElasticSearch connector >

[jira] [Reopened] (FLINK-7149) Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink

[ https://issues.apache.org/jira/browse/FLINK-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7149: - Reopen to fix release note. > Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink >

[jira] [Commented] (FLINK-8024) Let ClusterOverviewHandler directly extend from AbstractRestHandler

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

[jira] [Updated] (FLINK-8022) Kafka at-least-once tests fail occasionally

[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8022: --- Labels: test-stability (was: ) > Kafka at-least-once tests fail occasionally >

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

[GitHub] flink pull request #4961: [FLINK-7973] fix shading and relocating Hadoop for...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4961#discussion_r149635850 --- Diff: flink-filesystems/flink-s3-fs-hadoop/README.md --- @@ -0,0 +1,27 @@ +This project is a wrapper around Hadoop's s3a file system. By pulling a

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243741#comment-16243741 ] Robert Metzger commented on FLINK-6022: --- I agree. When I opened the issue, we were sending the avro

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r149636445 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -227,14 +242,27 @@ public void startNewWorker(ResourceProfile

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

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

[jira] [Commented] (FLINK-7765) Enable dependency convergence

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

[jira] [Closed] (FLINK-7476) Try to recover from failure in TwoPhaseCommitSinkFunction.beginTransaction

[ https://issues.apache.org/jira/browse/FLINK-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7476. --- Resolution: Won't Fix Release Note: (was: Currently there is no way in Flink for

[jira] [Reopened] (FLINK-7476) Try to recover from failure in TwoPhaseCommitSinkFunction.beginTransaction

[ https://issues.apache.org/jira/browse/FLINK-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7476: - Reopen to fix release note. > Try to recover from failure in

[jira] [Closed] (FLINK-7473) Possible Leak in GlobalWindows

[ https://issues.apache.org/jira/browse/FLINK-7473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7473. --- Resolution: Not A Problem Release Note: (was: user error.) > Possible Leak in

[jira] [Reopened] (FLINK-7558) Improve SQL ValidationException message.

[ https://issues.apache.org/jira/browse/FLINK-7558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7558: - Reopen to fix release note. > Improve SQL ValidationException message. >

[GitHub] flink pull request #4983: [FLINK-8025] Let DashboardConfigHandler directly e...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4983 [FLINK-8025] Let DashboardConfigHandler directly extend AbstractRestHandler ## What is the purpose of the change Let DashboardConfigHandler directly extend AbstractRestHandler.

[GitHub] flink pull request #4972: [FLINK-8009][build][runtime] Remove transitive dep...

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

[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=16243688#comment-16243688 ] Chesnay Schepler commented on FLINK-7419: - At the very least this wouldn't fail categorically.

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243699#comment-16243699 ] Tzu-Li (Gordon) Tai commented on FLINK-8001: master: 6bce2b83382640dd926c9a7860f5c10c1336450e

[GitHub] flink pull request #4777: [FLINK-7765] Enable dependency convergence

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4777#discussion_r149654340 --- Diff: pom.xml --- @@ -289,6 +289,48 @@ under the License. 1.8.2 +

[jira] [Commented] (FLINK-7765) Enable dependency convergence

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

[jira] [Updated] (FLINK-6022) Don't serialise Schema when serialising Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6022: Priority: Major (was: Blocker) > Don't serialise Schema when serialising Avro

[jira] [Updated] (FLINK-6022) Don't serialise Schema when serialising Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6022: Fix Version/s: (was: 1.4.0) 1.5.0 > Don't serialise Schema when

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

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

[GitHub] flink issue #4911: [FLINK-7878] [api] make resource type extendible in Resou...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4911 I think what you are referring to is the current trunk branch of Hadoop where they introduce `ResourceInformation`. Currently, the set of supported resources is `"memory-mb", "vcores",

[jira] [Reopened] (FLINK-7310) always use HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7310: - Reopen to fix release note. > always use HybridMemorySegment >

[jira] [Closed] (FLINK-7310) always use HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7310. --- Resolution: Fixed Release Note: (was: Implemented in

[jira] [Reopened] (FLINK-7365) excessive warning logs of attempt to override final parameter: fs.s3.buffer.dir

[ https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7365: - Reopen to fix release note. > excessive warning logs of attempt to override final parameter:

[jira] [Closed] (FLINK-7365) excessive warning logs of attempt to override final parameter: fs.s3.buffer.dir

[ https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7365. --- Resolution: Duplicate Release Note: (was: Duplicate of FLINK-7643) > excessive

[jira] [Closed] (FLINK-7312) activate checkstyle for flink/core/memory/*

[ https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7312. --- Resolution: Fixed Release Note: (was: Fixed in

[jira] [Commented] (FLINK-8025) Let DashboardConfigHandler extend from AbstractRestHandler

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

[jira] [Created] (FLINK-8028) Let JobMaster impelment RestfulGateway

Till Rohrmann created FLINK-8028: Summary: Let JobMaster impelment RestfulGateway Key: FLINK-8028 URL: https://issues.apache.org/jira/browse/FLINK-8028 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243626#comment-16243626 ] Aljoscha Krettek commented on FLINK-8008: - I believe you can use this constructor instead: {code}

[jira] [Commented] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

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

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243726#comment-16243726 ] Aljoscha Krettek commented on FLINK-6022: - [~rmetzger] opened this but the issue description has

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

[GitHub] flink issue #4980: [FLINK-8005] [runtime] Set user code class loader before ...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4980 These changes look good! 👍 I'll wait for travis and then merge. ---

[GitHub] flink pull request #4980: [FLINK-8005] [runtime] Set user code class loader ...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4980#discussion_r149637566 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java --- @@ -58,99 +58,119 @@ import org.junit.Before;

[jira] [Commented] (FLINK-7971) Fix potential NPE with inconsistent state

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

[GitHub] flink pull request #4981: 7419

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4981 7419 ## What is the purpose of the change This PR relocates avros jackson dependency in flink-dist. ## Brief change log * remove ineffective jackson shading configuration

[jira] [Closed] (FLINK-8023) User proper AvroSerializer for Avro types

[ https://issues.apache.org/jira/browse/FLINK-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8023. --- Resolution: Implemented Implemented in this PR:

[jira] [Reopened] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8009: - > flink-dist pulls in flink-runtime's transitive avro/jackson dependency >

[jira] [Updated] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8009: Fix Version/s: (was: 1.5.0) > flink-dist pulls in flink-runtime's transitive

[jira] [Reopened] (FLINK-7809) Drop support for Scala 2.10

[ https://issues.apache.org/jira/browse/FLINK-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7809: - Reopen to fix release note. > Drop support for Scala 2.10 > --- > >

[jira] [Reopened] (FLINK-7794) Link Broken in -- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html

[ https://issues.apache.org/jira/browse/FLINK-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7794: - Reopen to fix release note. > Link Broken in -- >

[jira] [Closed] (FLINK-7809) Drop support for Scala 2.10

[ https://issues.apache.org/jira/browse/FLINK-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7809. --- Resolution: Fixed Release Note: (was: Done in

[jira] [Reopened] (FLINK-7772) Test instability in BlobCacheDeleteTest

[ https://issues.apache.org/jira/browse/FLINK-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7772: - Reopen to fix release note. > Test instability in BlobCacheDeleteTest >

[jira] [Closed] (FLINK-7794) Link Broken in -- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html

[ https://issues.apache.org/jira/browse/FLINK-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7794. --- Resolution: Fixed Release Note: (was: Someone fixed the issue.) Someone fixed the

[jira] [Closed] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8008. --- Resolution: Not A Problem Closing because this is working as intended. Please open again if

[GitHub] flink issue #4961: [FLINK-7973] fix shading and relocating Hadoop for the S3...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4961 I think this looks good now that the comments are addressed. @zentol what do you think? ---

[jira] [Commented] (FLINK-8005) Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues

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

[GitHub] flink pull request #4980: [FLINK-8005] [runtime] Set user code class loader ...

GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/4980 [FLINK-8005] [runtime] Set user code class loader before snapshot ## What is the purpose of the change *During checkpointing, user code may dynamically load classes from the user code jar.

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

[GitHub] flink issue #4961: [FLINK-7973] fix shading and relocating Hadoop for the S3...

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4961 looks like I created a new word: `fute` ;) - fixed the typos both of you found ---

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

  1   2   3   4   >