[jira] [Commented] (FLINK-10325) [State TTL] Refactor TtlListState to use only loops, no java stream API for performance

[ https://issues.apache.org/jira/browse/FLINK-10325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616593#comment-16616593 ] ASF GitHub Bot commented on FLINK-10325: Clark commented on issue #6683: [FLINK-10325]

[GitHub] Clarkkkkk commented on issue #6683: [FLINK-10325] [State TTL] Refactor TtlListState to use only loops, no java stream API for performance

Clark commented on issue #6683: [FLINK-10325] [State TTL] Refactor TtlListState to use only loops, no java stream API for performance URL: https://github.com/apache/flink/pull/6683#issuecomment-421695107 @tillrohrmann Thanks for your reply. Sounds reasonable.

[jira] [Commented] (FLINK-9697) Provide connector for Kafka 2.0.0

[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616592#comment-16616592 ] ASF GitHub Bot commented on FLINK-9697: --- yanghua commented on issue #6703: [FLINK-9697] Provide

[GitHub] yanghua commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0

yanghua commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#issuecomment-421693803 Currently this PR is not ready to be reviewed, it still needs some refactoring.

[jira] [Updated] (FLINK-9697) Provide connector for Kafka 2.0.0

[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9697: -- Labels: pull-request-available (was: ) > Provide connector for Kafka 2.0.0 >

[jira] [Commented] (FLINK-9697) Provide connector for Kafka 2.0.0

[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616588#comment-16616588 ] ASF GitHub Bot commented on FLINK-9697: --- yanghua opened a new pull request #6703: [FLINK-9697]

[GitHub] yanghua opened a new pull request #6703: [FLINK-9697] Provide connector for Kafka 2.0.0

yanghua opened a new pull request #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703 ## What is the purpose of the change *This pull request provides connector for Kafka 2.0.0* ## Brief change log - *Provide connector

[jira] [Assigned] (FLINK-7360) Support Scala map type in Table API

[ https://issues.apache.org/jira/browse/FLINK-7360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-7360: Assignee: xueyu > Support Scala map type in Table API > --- > >

[jira] [Assigned] (FLINK-10253) Run MetricQueryService with lower priority

[ https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10253: Assignee: vinoyang > Run MetricQueryService with lower priority >

[jira] [Updated] (FLINK-9824) Support IPv6 literal

[ https://issues.apache.org/jira/browse/FLINK-9824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9824: -- Description: Currently we use colon as separator when parsing host and port. We should support the usage of

[GitHub] fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause

fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause URL: https://github.com/apache/flink/pull/6508#discussion_r217895759 ## File path:

[GitHub] fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause

fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause URL: https://github.com/apache/flink/pull/6508#discussion_r217895771 ## File path:

[GitHub] fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause

fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause URL: https://github.com/apache/flink/pull/6508#discussion_r217896170 ## File path:

[GitHub] fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause

fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause URL: https://github.com/apache/flink/pull/6508#discussion_r217895776 ## File path:

[GitHub] fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause

fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause URL: https://github.com/apache/flink/pull/6508#discussion_r217896469 ## File path:

[GitHub] fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause

fhueske commented on a change in pull request #6508: [Flink-10079] [table] Support external sink table in the INSERT INTO clause URL: https://github.com/apache/flink/pull/6508#discussion_r217897374 ## File path:

[jira] [Closed] (FLINK-8855) SQL client result serving gets stuck in result-mode=table

[ https://issues.apache.org/jira/browse/FLINK-8855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8855. Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.5) 1.7.0

[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.6.2 > Kafka08ITCase.testStartFromLatestOffsets() times out on Travis >

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10309: -- Fix Version/s: (was: 1.6.1) > Cancel flink job occurs java.net.ConnectException >

[jira] [Updated] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9749: - Fix Version/s: (was: 1.6.1) > Rework Bucketing Sink > - > >

[jira] [Updated] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10291: -- Fix Version/s: (was: 1.6.1) > Generate JobGraph with fixed/configurable JobID in >

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

[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7991: - Fix Version/s: 1.6.2 > Cleanup kafka example jar filters > - > >

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

[ https://issues.apache.org/jira/browse/FLINK-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8452: - Fix Version/s: 1.6.2 > BucketingSinkTest.testNonRollingAvroKeyValueWithCompressionWriter

[jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException

[ https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8902: - Fix Version/s: (was: 1.6.1) > Re-scaling job sporadically fails with KeeperException >

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9525: - Fix Version/s: (was: 1.6.1) > Missing META-INF/services/*FileSystemFactory in

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9010: - Fix Version/s: 1.6.2 > NoResourceAvailableException with FLIP-6 >

[jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests

[ https://issues.apache.org/jira/browse/FLINK-9680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9680: - Fix Version/s: 1.6.2 > Reduce heartbeat timeout for E2E tests >

[jira] [Updated] (FLINK-7915) Verify functionality of RollingSinkSecuredITCase

[ https://issues.apache.org/jira/browse/FLINK-7915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7915: - Fix Version/s: (was: 1.6.1) > Verify functionality of RollingSinkSecuredITCase >

[jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations

[ https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9457: - Fix Version/s: (was: 1.6.1) > Cancel container requests when cancelling pending slot

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

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

[jira] [Updated] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes

[ https://issues.apache.org/jira/browse/FLINK-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8820: - Fix Version/s: 1.6.2 > FlinkKafkaConsumer010 reads too many bytes >

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10241: -- Fix Version/s: (was: 1.6.1) > Reduce performance/stability impact of latency metrics >

[jira] [Updated] (FLINK-4052) Unstable test ConnectionUtilsTest

[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4052: - Fix Version/s: 1.6.2 > Unstable test ConnectionUtilsTest > - > >

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

[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8336: - Fix Version/s: 1.6.2 > YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability >

[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: 1.6.2 > ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on

[jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState

[ https://issues.apache.org/jira/browse/FLINK-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9481: - Fix Version/s: 1.6.2 > FlinkKafkaProducer011ITCase deadlock in initializeState >

[jira] [Updated] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

[ https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9253: - Fix Version/s: (was: 1.6.1) > Make buffer count per InputGate always

[jira] [Updated] (FLINK-10312) Wrong / missing exception when submitting job

[ https://issues.apache.org/jira/browse/FLINK-10312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10312: -- Fix Version/s: 1.6.2 > Wrong / missing exception when submitting job >

[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.6.1) > SpanningRecordSerializationTest fails on travis >

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10241: -- Fix Version/s: 1.6.2 > Reduce performance/stability impact of latency metrics >

[jira] [Updated] (FLINK-10260) Confusing log during TaskManager registration

[ https://issues.apache.org/jira/browse/FLINK-10260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10260: -- Fix Version/s: (was: 1.6.1) > Confusing log during TaskManager registration >

[jira] [Updated] (FLINK-4052) Unstable test ConnectionUtilsTest

[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4052: - Fix Version/s: (was: 1.6.1) > Unstable test ConnectionUtilsTest >

[jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations

[ https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9457: - Fix Version/s: 1.6.2 > Cancel container requests when cancelling pending slot allocations >

[jira] [Updated] (FLINK-9582) dist assemblies access jars outside of flink-dist

[ https://issues.apache.org/jira/browse/FLINK-9582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9582: - Fix Version/s: 1.6.2 > dist assemblies access jars outside of flink-dist >

[jira] [Updated] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10251: -- Fix Version/s: 1.6.2 > Handle oversized response messages in AkkaRpcActor >

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

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

[jira] [Updated] (FLINK-10247) Run MetricQueryService in separate thread pool

[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10247: -- Fix Version/s: (was: 1.6.1) > Run MetricQueryService in separate thread pool >

[jira] [Updated] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

[ https://issues.apache.org/jira/browse/FLINK-9788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9788: - Fix Version/s: 1.6.2 > ExecutionGraph Inconsistency prevents Job from recovering >

[jira] [Updated] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10251: -- Fix Version/s: (was: 1.6.1) > Handle oversized response messages in AkkaRpcActor >

[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: 1.6.2 > Submitting YARN job with FLIP-6 may lead to >

[jira] [Updated] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

[ https://issues.apache.org/jira/browse/FLINK-9788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9788: - Fix Version/s: (was: 1.6.1) > ExecutionGraph Inconsistency prevents Job from recovering >

[jira] [Updated] (FLINK-9485) Improving Flink’s timer management for large state

[ https://issues.apache.org/jira/browse/FLINK-9485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9485: - Fix Version/s: (was: 1.6.1) > Improving Flink’s timer management for large state >

[jira] [Updated] (FLINK-7351) test instability in JobClientActorRecoveryITCase#testJobClientRecovery

[ https://issues.apache.org/jira/browse/FLINK-7351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7351: - Fix Version/s: 1.6.2 > test instability in JobClientActorRecoveryITCase#testJobClientRecovery >

[jira] [Updated] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis

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

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

[ https://issues.apache.org/jira/browse/FLINK-8779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8779: - Fix Version/s: 1.6.2 > ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis >

[jira] [Updated] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis

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

[jira] [Updated] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8623: - Fix Version/s: 1.6.2 > ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on

[jira] [Updated] (FLINK-7915) Verify functionality of RollingSinkSecuredITCase

[ https://issues.apache.org/jira/browse/FLINK-7915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7915: - Fix Version/s: 1.6.2 > Verify functionality of RollingSinkSecuredITCase >

[jira] [Updated] (FLINK-10260) Confusing log during TaskManager registration

[ https://issues.apache.org/jira/browse/FLINK-10260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10260: -- Fix Version/s: 1.6.2 > Confusing log during TaskManager registration >

[jira] [Updated] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

[ https://issues.apache.org/jira/browse/FLINK-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9764: - Fix Version/s: (was: 1.6.1) > Failure in LocalRecoveryRocksDBFullITCase >

[jira] [Updated] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes

[ https://issues.apache.org/jira/browse/FLINK-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8820: - Fix Version/s: (was: 1.6.1) > FlinkKafkaConsumer010 reads too many bytes >

[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10292: -- Fix Version/s: 1.6.2 > Generate JobGraph in StandaloneJobClusterEntrypoint only once >

[jira] [Updated] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9878: - Fix Version/s: (was: 1.6.1) > IO worker threads BLOCKED on SSL Session Cache while CMS full

[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10292: -- Fix Version/s: (was: 1.6.1) > Generate JobGraph in StandaloneJobClusterEntrypoint only

[jira] [Updated] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files

[ https://issues.apache.org/jira/browse/FLINK-9587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9587: - Fix Version/s: (was: 1.6.1) > ContinuousFileMonitoringFunction crashes on short living files

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10309: -- Fix Version/s: 1.6.2 > Cancel flink job occurs java.net.ConnectException >

[jira] [Updated] (FLINK-10317) Configure Metaspace size by default

[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10317: -- Fix Version/s: (was: 1.6.1) > Configure Metaspace size by default >

[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.6.2 > Add tests that cover PatternStream#flatSelect >

[jira] [Updated] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

[ https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9253: - Fix Version/s: 1.6.2 > Make buffer count per InputGate always #channels*buffersPerChannel + >

[jira] [Updated] (FLINK-10311) HA end-to-end/Jepsen tests for standby Dispatchers

[ https://issues.apache.org/jira/browse/FLINK-10311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10311: -- Fix Version/s: 1.6.2 > HA end-to-end/Jepsen tests for standby Dispatchers >

[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: 1.6.2 > Lower the minimum number of buffers for incoming channels to 1 >

[jira] [Updated] (FLINK-10259) Key validation for GroupWindowAggregate is broken

[ https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10259: -- Fix Version/s: (was: 1.6.1) > Key validation for GroupWindowAggregate is broken >

[jira] [Updated] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10291: -- Fix Version/s: 1.6.2 > Generate JobGraph with fixed/configurable JobID in >

[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: 1.6.2 > ContinuousFileProcessingCheckpointITCase is Flaky >

[jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4387: - Fix Version/s: 1.6.2 > Instability in KvStateClientTest.testClientServerIntegration() >

[jira] [Updated] (FLINK-10246) Harden and separate MetricQueryService

[ https://issues.apache.org/jira/browse/FLINK-10246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10246: -- Fix Version/s: (was: 1.6.1) > Harden and separate MetricQueryService >

[jira] [Updated] (FLINK-9485) Improving Flink’s timer management for large state

[ https://issues.apache.org/jira/browse/FLINK-9485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9485: - Fix Version/s: 1.6.2 > Improving Flink’s timer management for large state >

[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down

[ https://issues.apache.org/jira/browse/FLINK-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9228: - Fix Version/s: 1.6.2 > log details about task fail/task manager is shutting down >

[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.6.1) > Submitting YARN job with FLIP-6 may lead to >

[jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState

[ https://issues.apache.org/jira/browse/FLINK-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9481: - Fix Version/s: (was: 1.6.1) > FlinkKafkaProducer011ITCase deadlock in initializeState >

[jira] [Updated] (FLINK-10253) Run MetricQueryService with lower priority

[ https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10253: -- Fix Version/s: (was: 1.6.1) > Run MetricQueryService with lower priority >

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

[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7991: - Fix Version/s: (was: 1.6.1) > Cleanup kafka example jar filters >

[jira] [Updated] (FLINK-9776) Interrupt TaskThread only while in User/Operator code

[ https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9776: - Fix Version/s: (was: 1.6.1) > Interrupt TaskThread only while in User/Operator code >

[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: (was: 1.6.1) > Add tests that cover PatternStream#flatSelect >

[jira] [Updated] (FLINK-10282) Provide separate thread-pool for REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-10282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10282: -- Fix Version/s: (was: 1.6.1) > Provide separate thread-pool for REST endpoint >

[jira] [Updated] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10184: -- Fix Version/s: 1.6.2 > HA Failover broken due to JobGraphs not being removed from Zookeeper

[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.6.1) > Handle oversized metric messges >

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

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

[jira] [Updated] (FLINK-10253) Run MetricQueryService with lower priority

[ https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10253: -- Fix Version/s: 1.6.2 > Run MetricQueryService with lower priority >

[jira] [Updated] (FLINK-9752) Add an S3 RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9752: - Fix Version/s: 1.6.2 > Add an S3 RecoverableWriter > --- > >

[jira] [Updated] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9878: - Fix Version/s: 1.6.2 > IO worker threads BLOCKED on SSL Session Cache while CMS full gc >

[jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

[ https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9761: - Fix Version/s: 1.6.2 > Potential buffer leak in PartitionRequestClientHandler during job

[jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

[ https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9761: - Fix Version/s: (was: 1.6.1) > Potential buffer leak in PartitionRequestClientHandler during

[jira] [Updated] (FLINK-10311) HA end-to-end/Jepsen tests for standby Dispatchers

[ https://issues.apache.org/jira/browse/FLINK-10311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10311: -- Fix Version/s: (was: 1.6.1) > HA end-to-end/Jepsen tests for standby Dispatchers >

[jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters

[ https://issues.apache.org/jira/browse/FLINK-9879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9879: - Fix Version/s: 1.6.2 > Find sane defaults for (advanced) SSL session parameters >

[jira] [Updated] (FLINK-10247) Run MetricQueryService in separate thread pool

[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10247: -- Fix Version/s: 1.6.2 > Run MetricQueryService in separate thread pool >

[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: (was: 1.6.1) > Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

[jira] [Updated] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

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

[jira] [Updated] (FLINK-10097) More tests to increase StreamingFileSink test coverage

[ https://issues.apache.org/jira/browse/FLINK-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10097: -- Fix Version/s: (was: 1.6.1) > More tests to increase StreamingFileSink test coverage >

[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.6.1) >

  1   2   3   >