[GitHub] zentol commented on issue #7106: [hotfix] [docs] fix error about per-job YARN cluster

zentol commented on issue #7106: [hotfix] [docs] fix error about per-job YARN cluster URL: https://github.com/apache/flink/pull/7106#issuecomment-439800604 @tillrohrmann Is this a bug, or part of this whole "job-cluster is actually a session-cluster" deal? --

[GitHub] zentol closed pull request #7137: [hotfix] Fix typo in FlinkKafkaConsumerBase.

zentol closed pull request #7137: [hotfix] Fix typo in FlinkKafkaConsumerBase. URL: https://github.com/apache/flink/pull/7137 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pu

[jira] [Closed] (FLINK-10916) Include duplicated user-specified uid into error message

[ https://issues.apache.org/jira/browse/FLINK-10916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10916. Resolution: Fixed Fix Version/s: 1.7.0 1.6.3 1

[jira] [Created] (FLINK-10923) Make SlotPool Status Machine-Readable

Konstantin Knauf created FLINK-10923: Summary: Make SlotPool Status Machine-Readable Key: FLINK-10923 URL: https://issues.apache.org/jira/browse/FLINK-10923 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691345#comment-16691345 ] Chesnay Schepler commented on FLINK-9925: - Another instance on release-1.7@ef683c

[jira] [Commented] (FLINK-10916) Include duplicated user-specified uid into error message

[ https://issues.apache.org/jira/browse/FLINK-10916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691341#comment-16691341 ] ASF GitHub Bot commented on FLINK-10916: zentol closed pull request #7133: [FLIN

[GitHub] zentol closed pull request #7133: [FLINK-10916] [DataStream API] Include duplicated user-specified uid into error message

zentol closed pull request #7133: [FLINK-10916] [DataStream API] Include duplicated user-specified uid into error message URL: https://github.com/apache/flink/pull/7133 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[GitHub] link3280 opened a new pull request #7137: [hotfix] Fix typo in FlinkKafkaConsumerBase.

link3280 opened a new pull request #7137: [hotfix] Fix typo in FlinkKafkaConsumerBase. URL: https://github.com/apache/flink/pull/7137 This PR fixes a typo in FlinkKafkaConsumerBase.java. This is an automated message from the

[jira] [Commented] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691305#comment-16691305 ] ASF GitHub Bot commented on FLINK-10791: yanghua commented on issue #7038: [FLIN

[GitHub] yanghua commented on issue #7038: [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector

yanghua commented on issue #7038: [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector URL: https://github.com/apache/flink/pull/7038#issuecomment-439790249 @tillrohrmann I agree with your opinion. I have created a new issue (FLINK-10922) to rework specific modules (0.10, 0.11 a

[jira] [Created] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module

vinoyang created FLINK-10922: Summary: Refactor the placement of the Flink Kafka connector end to end test module Key: FLINK-10922 URL: https://issues.apache.org/jira/browse/FLINK-10922 Project: Flink

[jira] [Commented] (FLINK-10904) Expose Classloader before Pipeline execution

[ https://issues.apache.org/jira/browse/FLINK-10904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691287#comment-16691287 ] Luka Jurukovski commented on FLINK-10904: - Had to go through some old messages t

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691264#comment-16691264 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal closed pull request #7134:

[GitHub] imamitsehgal closed pull request #7134: FLINK-10918 fix for checkpoint dir creation error on window.

imamitsehgal closed pull request #7134: FLINK-10918 fix for checkpoint dir creation error on window. URL: https://github.com/apache/flink/pull/7134 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance:

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691243#comment-16691243 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal commented on issue #7134:

[GitHub] imamitsehgal commented on issue #7134: FLINK-10918 fix for checkpoint dir creation error on window.

imamitsehgal commented on issue #7134: FLINK-10918 fix for checkpoint dir creation error on window. URL: https://github.com/apache/flink/pull/7134#issuecomment-439767469 Why are builds failing while the change is not at all related?

[GitHub] ambition119 commented on issue #7120: fix up RowSerializer.copy occur ClassCastException

ambition119 commented on issue #7120: fix up RowSerializer.copy occur ClassCastException URL: https://github.com/apache/flink/pull/7120#issuecomment-439759507 > Please open a JIRA before opening a PR, and include a description as to when this issue can occur. Additionally we require a test

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691205#comment-16691205 ] ASF GitHub Bot commented on FLINK-9555: --- sunjincheng121 commented on a change in pu

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691206#comment-16691206 ] ASF GitHub Bot commented on FLINK-9555: --- sunjincheng121 commented on a change in pu

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691207#comment-16691207 ] ASF GitHub Bot commented on FLINK-9555: --- sunjincheng121 commented on a change in pu

[GitHub] sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r234481358 ## File path: flink-dist/pom.xml ## @@ -319,7 +319,6 @@ under the License.

[GitHub] sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r234478740 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@ -

[GitHub] sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r234478589 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@ -

[jira] [Updated] (FLINK-10299) RowSerializer.copy data value cast exception and use checkpoint function Lead to Could not restart this job

[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10299: - Attachment: image-2018-11-19-10-40-14-577.png > RowSerializer.copy data value cast exception and use che

[jira] [Commented] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

[ https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691161#comment-16691161 ] sunjincheng commented on FLINK-10875: - Thanks for the feedback [~fhueske] ！ It is a

[jira] [Created] (FLINK-10921) Prioritize shard consumers in Kinesis Consumer by event time

Thomas Weise created FLINK-10921: Summary: Prioritize shard consumers in Kinesis Consumer by event time Key: FLINK-10921 URL: https://issues.apache.org/jira/browse/FLINK-10921 Project: Flink

[jira] [Commented] (FLINK-10920) Remove Kafka examples from binary distribution

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

[jira] [Updated] (FLINK-10920) Remove Kafka examples from binary distribution

[ https://issues.apache.org/jira/browse/FLINK-10920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10920: --- Labels: pull-request-available (was: ) > Remove Kafka examples from binary distribution > -

[GitHub] tillrohrmann opened a new pull request #7136: [BP-1.7][FLINK-10920] Remove Kafka examples from flink-dist

tillrohrmann opened a new pull request #7136: [BP-1.7][FLINK-10920] Remove Kafka examples from flink-dist URL: https://github.com/apache/flink/pull/7136 Backport of #7135 to `release-1.7`. This is an automated message from th

[GitHub] tillrohrmann opened a new pull request #7135: [FLINK-10920] Remove Kafka examples from flink-dist

tillrohrmann opened a new pull request #7135: [FLINK-10920] Remove Kafka examples from flink-dist URL: https://github.com/apache/flink/pull/7135 ## What is the purpose of the change In order to decrease the size of Flink's binary distribution, this commit removes the Kafka exampl

[jira] [Created] (FLINK-10920) Remove Kafka examples from binary distribution

Till Rohrmann created FLINK-10920: - Summary: Remove Kafka examples from binary distribution Key: FLINK-10920 URL: https://issues.apache.org/jira/browse/FLINK-10920 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-10920) Remove Kafka examples from binary distribution

[ https://issues.apache.org/jira/browse/FLINK-10920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10920: - Assignee: Till Rohrmann > Remove Kafka examples from binary distribution >

[jira] [Created] (FLINK-10919) Flink binary distribution too large

Till Rohrmann created FLINK-10919: - Summary: Flink binary distribution too large Key: FLINK-10919 URL: https://issues.apache.org/jira/browse/FLINK-10919 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-10845) Support DISTINCT aggregates for batch

[ https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690918#comment-16690918 ] ASF GitHub Bot commented on FLINK-10845: hequn8128 commented on issue #7079: [FL

[GitHub] hequn8128 commented on issue #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

hequn8128 commented on issue #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#issuecomment-439697499 @xueyumusic thanks for the update. Looks good from my side. --

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690910#comment-16690910 ] Dawid Wysakowicz commented on FLINK-6756: - Hi [~dangdangdang] thanks for your int

[jira] [Closed] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10625. Resolution: Fixed Fix Version/s: (was: 1.8.0) 1.7.0 Fixed vi

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690908#comment-16690908 ] ASF GitHub Bot commented on FLINK-10625: dawidwys closed pull request #7070: [FL

[GitHub] dawidwys closed pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

dawidwys closed pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is

[jira] [Updated] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10918: --- Labels: pull-request-available (was: ) > incremental Keyed state with RocksDB throws cannot

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

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

[GitHub] imamitsehgal opened a new pull request #7134: FLINK-10918 fix for checkpoint dir creation error on window.

imamitsehgal opened a new pull request #7134: FLINK-10918 fix for checkpoint dir creation error on window. URL: https://github.com/apache/flink/pull/7134 FLINK-10918 [flink-state-backaends] fix for checkpoint dir creation error on window. 1 of the 4 failing test on windows are now passing

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690899#comment-16690899 ] Amit commented on FLINK-10918: -- Attaching a patch file. [^0001-FLINK-10918-Fix-for-checkpo

[jira] [Updated] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit updated FLINK-10918: - Attachment: 0001-FLINK-10918-Fix-for-checkpoint-creation-on-windows-1.patch > incremental Keyed state with Rocks

[jira] [Updated] (FLINK-9720) Introduce ResourceTag class for tag support in scheduling

[ https://issues.apache.org/jira/browse/FLINK-9720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9720: - Fix Version/s: (was: 1.7.0) 1.8.0 > Introduce ResourceTag class for tag su

[jira] [Updated] (FLINK-10503) Periodically check for new resources

[ https://issues.apache.org/jira/browse/FLINK-10503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10503: -- Fix Version/s: (was: 1.7.0) > Periodically check for new resources > -

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

[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8418: - Fix Version/s: 1.8.0 > Kafka08ITCase.testStartFromLatestOffsets() times out on Travis > -

[jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10435: -- Fix Version/s: 1.7.1 > Client sporadically hangs after Ctrl + C >

[jira] [Updated] (FLINK-10347) Kafka09SecuredRunITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10347: -- Fix Version/s: 1.8.0 > Kafka09SecuredRunITCase failed on Travis >

[jira] [Updated] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10842: -- Fix Version/s: 1.8.0 > Waiting loops are broken in e2e/common.sh > ---

[jira] [Updated] (FLINK-10252) Handle oversized metric messges

[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10252: -- Fix Version/s: 1.7.1 > Handle oversized metric messges > --- > >

[jira] [Updated] (FLINK-9812) SpanningRecordSerializationTest fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9812: - Fix Version/s: (was: 1.7.0) > SpanningRecordSerializationTest fails on travis > -

[jira] [Updated] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic)

[ https://issues.apache.org/jira/browse/FLINK-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9002: - Fix Version/s: (was: 1.7.0) > Add operators with input type that goes through Avro serializat

[jira] [Updated] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

[ https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7829: - Fix Version/s: 1.8.0 > Remove (or at least deprecate) DataStream.writeToFile/Csv > --

[jira] [Updated] (FLINK-10504) Decide actual parallelism based on available resources

[ https://issues.apache.org/jira/browse/FLINK-10504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10504: -- Fix Version/s: (was: 1.7.0) > Decide actual parallelism based on available resources > ---

[jira] [Updated] (FLINK-9054) IllegalStateException: Buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9054: - Fix Version/s: (was: 1.7.0) > IllegalStateException: Buffer pool is destroyed > -

[jira] [Updated] (FLINK-10610) Port slot sharing cases to new codebase

[ https://issues.apache.org/jira/browse/FLINK-10610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10610: -- Fix Version/s: (was: 1.7.0) > Port slot sharing cases to new codebase > --

[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 ] Till Rohrmann updated FLINK-9798: - Fix Version/s: (was: 1.7.0) > Drop canEqual() from TypeInformation, TypeSerializer, etc. > --

[jira] [Updated] (FLINK-10500) Let ExecutionGraphDriver react to fail signal

[ https://issues.apache.org/jira/browse/FLINK-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10500: -- Fix Version/s: (was: 1.7.0) > Let ExecutionGraphDriver react to fail signal >

[jira] [Updated] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6763: - Fix Version/s: (was: 1.7.0) > Inefficient PojoSerializerConfigSnapshot serialization format >

[jira] [Updated] (FLINK-9957) Rescale job with respect to available slots

[ https://issues.apache.org/jira/browse/FLINK-9957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9957: - Fix Version/s: (was: 1.7.0) > Rescale job with respect to available slots > -

[jira] [Updated] (FLINK-10346) MemoryStateBackend does not clean up checkpoint directory

[ https://issues.apache.org/jira/browse/FLINK-10346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10346: -- Fix Version/s: (was: 1.7.0) > MemoryStateBackend does not clean up checkpoint directory >

[jira] [Updated] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10842: -- Fix Version/s: (was: 1.7.0) > Waiting loops are broken in e2e/common.sh >

[jira] [Updated] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9193: - Fix Version/s: 1.8.0 > Deprecate non-well-defined output methods on DataStream >

[jira] [Updated] (FLINK-9205) Delete non-well-defined SinkFunctions

[ https://issues.apache.org/jira/browse/FLINK-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9205: - Fix Version/s: (was: 1.7.0) > Delete non-well-defined SinkFunctions > ---

[jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect

[ https://issues.apache.org/jira/browse/FLINK-9469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9469: - Fix Version/s: 1.7.1 > Add tests that cover PatternStream#flatSelect > --

[jira] [Updated] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable

[ https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8799: - Fix Version/s: (was: 1.7.0) > Make AbstractYarnClusterDescriptor immutable >

[jira] [Updated] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10481: -- Fix Version/s: (was: 1.7.0) > Wordcount end-to-end test in docker env unstable > -

[jira] [Updated] (FLINK-9980) wiki-edits quickstart docs aren't clear enough

[ https://issues.apache.org/jira/browse/FLINK-9980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9980: - Fix Version/s: (was: 1.7.0) > wiki-edits quickstart docs aren't clear enough > --

[jira] [Updated] (FLINK-10381) concurrent submit job get ProgramAbortException

[ https://issues.apache.org/jira/browse/FLINK-10381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10381: -- Fix Version/s: (was: 1.7.0) > concurrent submit job get ProgramAbortException > --

[jira] [Updated] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8997: - Fix Version/s: (was: 1.7.0) > Add sliding window aggregation to the job > ---

[jira] [Updated] (FLINK-10428) AbstractServerBase should bind to any address per default

[ https://issues.apache.org/jira/browse/FLINK-10428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10428: -- Fix Version/s: (was: 1.7.0) > AbstractServerBase should bind to any address per default >

[jira] [Updated] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10721: -- Fix Version/s: (was: 1.7.0) > kafkaFetcher runFetchLoop throw exception will cause follow-

[jira] [Updated] (FLINK-10344) Rethink SubmittedJobGraphListener

[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10344: -- Fix Version/s: (was: 1.7.0) > Rethink SubmittedJobGraphListener >

[jira] [Updated] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time

[ https://issues.apache.org/jira/browse/FLINK-10756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10756: -- Fix Version/s: (was: 1.7.0) > TaskManagerProcessFailureBatchRecoveryITCase did not finish

[jira] [Updated] (FLINK-10252) Handle oversized metric messges

[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10252: -- Fix Version/s: (was: 1.7.0) > Handle oversized metric messges > --

[jira] [Updated] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1

[ https://issues.apache.org/jira/browse/FLINK-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9142: - Fix Version/s: (was: 1.7.0) > Lower the minimum number of buffers for incoming channels to 1

[jira] [Updated] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.

[ https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10819: -- Fix Version/s: (was: 1.7.0) > The instability problem of CI, > JobManagerHAProcessFailure

[jira] [Updated] (FLINK-10522) Check if RecoverableWriter supportsResume and act accordingly.

[ https://issues.apache.org/jira/browse/FLINK-10522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10522: -- Fix Version/s: (was: 1.7.0) > Check if RecoverableWriter supportsResume and act accordingl

[jira] [Updated] (FLINK-10694) ZooKeeperHaServices Cleanup

[ https://issues.apache.org/jira/browse/FLINK-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10694: -- Fix Version/s: (was: 1.7.0) > ZooKeeperHaServices Cleanup > --- >

[jira] [Updated] (FLINK-9055) WebUI shows job as Running although not enough resources are available

[ https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9055: - Fix Version/s: (was: 1.7.0) > WebUI shows job as Running although not enough resources are av

[jira] [Updated] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

[ https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5125: - Fix Version/s: (was: 1.7.0) > ContinuousFileProcessingCheckpointITCase is Flaky > ---

[jira] [Updated] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10712: -- Fix Version/s: (was: 1.7.0) > RestartPipelinedRegionStrategy does not restore state >

[jira] [Updated] (FLINK-10507) Set target parallelism to maximum when using the standalone job cluster mode

[ https://issues.apache.org/jira/browse/FLINK-10507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10507: -- Fix Version/s: (was: 1.7.0) > Set target parallelism to maximum when using the standalone

[jira] [Updated] (FLINK-10335) Create common ZooKeeperStateStore based on ZooKeeperStateHandleStore and RetrievableStateStorageHelper

[ https://issues.apache.org/jira/browse/FLINK-10335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10335: -- Fix Version/s: (was: 1.7.0) > Create common ZooKeeperStateStore based on ZooKeeperStateHan

[jira] [Updated] (FLINK-10510) Bump asm version to 6

[ https://issues.apache.org/jira/browse/FLINK-10510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10510: -- Fix Version/s: (was: 1.7.0) > Bump asm version to 6 > - > >

[jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9646: - Fix Version/s: (was: 1.7.0) > ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart

[jira] [Updated] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job

[ https://issues.apache.org/jira/browse/FLINK-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9207: - Fix Version/s: (was: 1.7.0) > Client returns SUCCESS(0) return code for canceled job > --

[jira] [Updated] (FLINK-10505) Treat fail signal as scheduling event

[ https://issues.apache.org/jira/browse/FLINK-10505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10505: -- Fix Version/s: (was: 1.7.0) > Treat fail signal as scheduling event >

[jira] [Updated] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10625: -- Fix Version/s: (was: 1.7.0) > Add MATCH_RECOGNIZE documentation >

[jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8899: - Fix Version/s: (was: 1.7.0) > Submitting YARN job with FLIP-6 may lead to > ApplicationAttem

[jira] [Updated] (FLINK-10751) Checkpoints should be retained when job reaches suspended state

[ https://issues.apache.org/jira/browse/FLINK-10751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10751: -- Fix Version/s: (was: 1.7.0) > Checkpoints should be retained when job reaches suspended st

[jira] [Updated] (FLINK-10140) Log files are not available via web UI in containerized environment

[ https://issues.apache.org/jira/browse/FLINK-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10140: -- Fix Version/s: (was: 1.7.0) > Log files are not available via web UI in containerized envi

[jira] [Updated] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10333: -- Fix Version/s: (was: 1.7.0) > Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWork

[jira] [Updated] (FLINK-6437) Move history server configuration to a separate file

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6437: - Fix Version/s: (was: 1.7.0) > Move history server configuration to a separate file >

[jira] [Updated] (FLINK-7981) Bump commons-lang3 version to 3.6

[ https://issues.apache.org/jira/browse/FLINK-7981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7981: - Fix Version/s: (was: 1.7.0) > Bump commons-lang3 version to 3.6 > ---

[jira] [Updated] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10583: -- Fix Version/s: (was: 1.7.0) > Add support for state retention to the Processing Time versi

[jira] [Updated] (FLINK-9462) Disentangle flink-json and flink-table

[ https://issues.apache.org/jira/browse/FLINK-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9462: - Fix Version/s: (was: 1.7.0) > Disentangle flink-json and flink-table > --

[jira] [Updated] (FLINK-10304) Remove deprecated AbstractYarnClusterDescriptor field

[ https://issues.apache.org/jira/browse/FLINK-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10304: -- Fix Version/s: (was: 1.7.0) > Remove deprecated AbstractYarnClusterDescriptor field >

[jira] [Updated] (FLINK-10665) Port YARNSessionFIFOITCase#testJavaAPI to new codebase

[ https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10665: -- Fix Version/s: (was: 1.7.0) > Port YARNSessionFIFOITCase#testJavaAPI to new codebase > ---

  1   2   3   4   5   >