[jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

[ https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491491#comment-16491491 ] Ted Yu commented on FLINK-9185: --- Can someone assign this to Stephen ? Thanks > Potential n

[jira] [Commented] (FLINK-8430) Implement stream-stream non-window full outer join

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

[GitHub] flink pull request #6079: [FLINK-8430] [table] Implement stream-stream non-w...

GitHub user hequn8128 opened a pull request: https://github.com/apache/flink/pull/6079 [FLINK-8430] [table] Implement stream-stream non-window full outer join ## What is the purpose of the change Support stream-stream non-window full outer join. ## Brief c

[jira] [Assigned] (FLINK-5505) Harmonize ZooKeeper configuration parameters

[ https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-5505: --- Assignee: vinoyang > Harmonize ZooKeeper configuration parameters > -

[GitHub] flink issue #5992: [FLINK-8944] [Kinesis Connector] Use listShards instead o...

Github user kailashhd commented on the issue: https://github.com/apache/flink/pull/5992 Please note I rebased my changes to the master as I was having some failures when building just the flink-connector-kinesis maven project. I hope this will not cause problems with reviewing the cod

[jira] [Commented] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector

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

[jira] [Commented] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491432#comment-16491432 ] ASF GitHub Bot commented on FLINK-8944: --- Github user kailashhd commented on a diff i

[jira] [Commented] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491433#comment-16491433 ] ASF GitHub Bot commented on FLINK-8944: --- Github user kailashhd commented on a diff i

[GitHub] flink pull request #5992: [FLINK-8944] [Kinesis Connector] Use listShards in...

Github user kailashhd commented on a diff in the pull request: https://github.com/apache/flink/pull/5992#discussion_r191033585 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java --- @@ -26,20 +

[GitHub] flink pull request #5992: [FLINK-8944] [Kinesis Connector] Use listShards in...

Github user kailashhd commented on a diff in the pull request: https://github.com/apache/flink/pull/5992#discussion_r191033584 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java --- @@ -26,20 +

[jira] [Created] (FLINK-9440) Allow cancelation and reset of timers

Elias Levy created FLINK-9440: - Summary: Allow cancelation and reset of timers Key: FLINK-9440 URL: https://issues.apache.org/jira/browse/FLINK-9440 Project: Flink Issue Type: Bug Compo

[jira] [Updated] (FLINK-9344) Support INTERSECT and INTERSECT ALL for streaming

[ https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-9344: -- Description: support non-window intersect and non-window intersect all for both SQL and TableAPI (was:

[jira] [Commented] (FLINK-9344) Support INTERSECT and INTERSECT ALL for streaming

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

[GitHub] flink issue #5998: [FLINK-9344] [TableAPI & SQL] Support INTERSECT and INTER...

Github user Xpray commented on the issue: https://github.com/apache/flink/pull/5998 Thanks for the review @walterddr @fhueske , I've updated the PR. ---

[jira] [Updated] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos

[ https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8247: - Fix Version/s: (was: 1.5.0) 1.5.1 > Support Hadoop-free variant of Flink on

[jira] [Updated] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

[ https://issues.apache.org/jira/browse/FLINK-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8770: - Fix Version/s: (was: 1.5.0) 1.5.1 > CompletedCheckPoints stored on ZooKeepe

[jira] [Updated] (FLINK-9301) NotSoMiniClusterIterations job fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9301: - Fix Version/s: (was: 1.5.0) 1.5.1 > NotSoMiniClusterIterations job fails on

[jira] [Updated] (FLINK-8744) Add annotations for documentation common/advanced options

[ https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8744: - Fix Version/s: (was: 1.5.0) 1.5.1 > Add annotations for documentation commo

[jira] [Updated] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7697: - Fix Version/s: (was: 1.5.0) 1.5.1 > Add metrics for Elasticsearch Sink > --

[jira] [Updated] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException

[ https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9215: - Fix Version/s: (was: 1.5.0) 1.5.1 > TaskManager Releasing - org.apache.fli

[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.5.0) 1.5.1 > Test instability > FlinkKafkaProducer0

[jira] [Updated] (FLINK-9004) Cluster test: Run general purpose job with failures with Yarn session

[ https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9004: - Fix Version/s: (was: 1.5.0) 1.5.1 > Cluster test: Run general purpose job w

[jira] [Updated] (FLINK-6369) Better support for overlay networks

[ https://issues.apache.org/jira/browse/FLINK-6369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6369: - Fix Version/s: (was: 1.5.0) 1.5.1 > Better support for overlay networks > -

[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: (was: 1.5.0) 1.5.1 > YarnFileStageTestS3ITCase.testRecursive

[jira] [Updated] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9013: - Fix Version/s: (was: 1.5.0) 1.5.1 > Document yarn.containers.vcores only be

[jira] [Updated] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8046: - Fix Version/s: (was: 1.5.0) 1.5.1 > ContinuousFileMonitoringFunction wrongl

[jira] [Updated] (FLINK-8343) Add support for job cluster deployment

[ https://issues.apache.org/jira/browse/FLINK-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8343: - Fix Version/s: (was: 1.5.0) 1.5.1 > Add support for job cluster deployment

[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.5.0) 1.5.1 > Verify functionality of RollingSinkSecu

[jira] [Updated] (FLINK-7550) Give names to REST client/server for clearer logging.

[ https://issues.apache.org/jira/browse/FLINK-7550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7550: - Fix Version/s: (was: 1.5.0) 1.5.1 > Give names to REST client/server for cl

[jira] [Updated] (FLINK-9109) Add flink modify command to documentation

[ https://issues.apache.org/jira/browse/FLINK-9109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9109: - Fix Version/s: (was: 1.5.0) 1.5.1 > Add flink modify command to documentati

[jira] [Updated] (FLINK-8302) Support shift_left and shift_right in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8302: - Fix Version/s: (was: 1.5.0) 1.5.1 > Support shift_left and shift_right in T

[jira] [Updated] (FLINK-9046) Improve error messages when receiving unexpected messages.

[ https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9046: - Fix Version/s: (was: 1.5.0) 1.5.1 > Improve error messages when receiving u

[jira] [Updated] (FLINK-8731) TwoInputStreamTaskTest flaky on travis

[ https://issues.apache.org/jira/browse/FLINK-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8731: - Fix Version/s: (was: 1.5.0) 1.5.1 > TwoInputStreamTaskTest flaky on travis

[jira] [Updated] (FLINK-8971) Create general purpose testing job

[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8971: - Fix Version/s: (was: 1.5.0) 1.5.1 > Create general purpose testing job > --

[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 ] Till Rohrmann updated FLINK-6022: - Fix Version/s: (was: 1.5.0) 1.5.1 > Don't serialise Schema when serialising

[jira] [Updated] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9328: - Fix Version/s: (was: 1.5.0) 1.5.1 > RocksDBStateBackend might use Placehold

[jira] [Updated] (FLINK-5018) Make source idle timeout user configurable

[ https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5018: - Fix Version/s: (was: 1.5.0) 1.5.1 > Make source idle timeout user configura

[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.5.0) 1.5.1 > ClassLoaderITCase.testKMeansJobWithCust

[jira] [Updated] (FLINK-6997) SavepointITCase fails in master branch sometimes

[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6997: - Fix Version/s: (was: 1.5.0) 1.5.1 > SavepointITCase fails in master branch

[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.5.0) 1.5.1 > ContinuousFileProcessingCheckpointITCas

[jira] [Updated] (FLINK-7009) dogstatsd mode in statsd reporter

[ https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7009: - Fix Version/s: (was: 1.5.0) 1.5.1 > dogstatsd mode in statsd reporter > ---

[jira] [Updated] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE

[ https://issues.apache.org/jira/browse/FLINK-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9032: - Fix Version/s: (was: 1.5.0) 1.5.1 > Deprecate ConfigConstants#YARN_CONTAINE

[jira] [Updated] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback

[ https://issues.apache.org/jira/browse/FLINK-8067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8067: - Fix Version/s: (was: 1.5.0) 1.5.1 > User code ClassLoader not set before ca

[jira] [Updated] (FLINK-7727) Extend logging in file server handlers

[ https://issues.apache.org/jira/browse/FLINK-7727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7727: - Fix Version/s: (was: 1.5.0) 1.5.1 > Extend logging in file server handlers

[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.5.0) 1.5.1 > Bump commons-lang3 version to 3.6 > ---

[jira] [Updated] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8417: - Fix Version/s: (was: 1.5.0) 1.5.1 > Support STSAssumeRoleSessionCredentials

[jira] [Updated] (FLINK-8707) Excessive amount of files opened by flink task manager

[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8707: - Fix Version/s: (was: 1.5.0) 1.5.1 > Excessive amount of files opened by fli

[jira] [Updated] (FLINK-7816) Support Scala 2.12 closures and Java 8 lambdas in ClosureCleaner

[ https://issues.apache.org/jira/browse/FLINK-7816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7816: - Fix Version/s: (was: 1.5.0) 1.5.1 > Support Scala 2.12 closures and Java 8

[jira] [Updated] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8946: - Fix Version/s: (was: 1.5.0) 1.5.1 > TaskManager stop sending metrics after

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6856: - Fix Version/s: (was: 1.5.0) 1.5.1 > Eagerly check if serializer config snap

[jira] [Updated] (FLINK-7982) Bump commons-configuration to 2.2

[ https://issues.apache.org/jira/browse/FLINK-7982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7982: - Fix Version/s: (was: 1.5.0) 1.5.1 > Bump commons-configuration to 2.2 > ---

[jira] [Updated] (FLINK-5505) Harmonize ZooKeeper configuration parameters

[ https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5505: - Fix Version/s: (was: 1.5.0) 1.5.1 > Harmonize ZooKeeper configuration param

[jira] [Updated] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod

[ https://issues.apache.org/jira/browse/FLINK-7582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7582: - Fix Version/s: (was: 1.5.0) 1.5.1 > Rest client may buffer responses indefi

[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.5.0) 1.5.1 > Move history server configuration to a

[jira] [Updated] (FLINK-7881) flink can't deployed on yarn with ha

[ https://issues.apache.org/jira/browse/FLINK-7881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7881: - Fix Version/s: (was: 1.5.0) 1.5.1 > flink can't deployed on yarn with ha >

[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.5.0) 1.5.1 > Unstable test ConnectionUtilsTest > ---

[jira] [Updated] (FLINK-7551) Add VERSION to the REST urls.

[ https://issues.apache.org/jira/browse/FLINK-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7551: - Fix Version/s: (was: 1.5.0) 1.5.1 > Add VERSION to the REST urls. > --

[jira] [Updated] (FLINK-8718) Non-parallel DataStreamSource does not set max parallelism

[ https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8718: - Fix Version/s: (was: 1.5.0) 1.5.1 > Non-parallel DataStreamSource does not

[jira] [Updated] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures

[ https://issues.apache.org/jira/browse/FLINK-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8803: - Fix Version/s: (was: 1.5.0) 1.5.1 > Mini Cluster Shutdown with HA unstable,

[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.5.0) 1.5.1 > Lower the minimum number of buffers for

[jira] [Updated] (FLINK-8101) Elasticsearch 6.x support

[ https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8101: - Fix Version/s: (was: 1.5.0) 1.5.1 > Elasticsearch 6.x support > ---

[jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider

[ https://issues.apache.org/jira/browse/FLINK-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8416: - Fix Version/s: (was: 1.5.0) 1.5.1 > Kinesis consumer doc examples should de

[jira] [Updated] (FLINK-8357) enable rolling in default log settings

[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8357: - Fix Version/s: (was: 1.5.0) 1.5.1 > enable rolling in default log settings

[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: (was: 1.5.0) 1.5.1 > NoResourceAvailableException with FLIP-

[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: (was: 1.5.0) 1.5.1 > test instability in JobClientActorRecov

[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.5.0) 1.5.1 > Make buffer count per InputGate always

[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.5.0) 1.5.1 > YarnFileStageTestS3ITCase.testRecursive

[jira] [Updated] (FLINK-7964) Add Apache Kafka 1.0 connector

[ https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7964: - Fix Version/s: (was: 1.5.0) 1.5.1 > Add Apache Kafka 1.0 connector > --

[jira] [Updated] (FLINK-8135) Add description to MessageParameter

[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8135: - Fix Version/s: (was: 1.5.0) 1.5.1 > Add description to MessageParameter > -

[jira] [Updated] (FLINK-8410) Kafka consumer's commitedOffsets gauge metric is prematurely set

[ https://issues.apache.org/jira/browse/FLINK-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8410: - Fix Version/s: (was: 1.5.0) 1.5.1 > Kafka consumer's commitedOffsets gauge

[jira] [Updated] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

[ https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9257: - Fix Version/s: (was: 1.5.0) 1.5.1 > End-to-end tests prints "All tests PASS

[jira] [Updated] (FLINK-9098) ClassLoaderITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9098: - Fix Version/s: (was: 1.5.0) 1.5.1 > ClassLoaderITCase unstable > --

[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.5.0) 1.5.1 > FlinkKafkaConsumer010 reads too many by

[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.5.0) 1.5.1 > Kafka08ITCase.testStartFromLatestOffset

[jira] [Updated] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5789: - Fix Version/s: (was: 1.5.0) 1.5.1 > Make Bucketing Sink independent of Hado

[jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6571: - Fix Version/s: (was: 1.5.0) 1.5.1 > InfiniteSource in SourceStreamOperatorT

[jira] [Updated] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8521: - Fix Version/s: (was: 1.5.0) 1.5.1 > FlinkKafkaProducer011ITCase.testRunOutO

[jira] [Updated] (FLINK-8161) Flakey YARNSessionCapacitySchedulerITCase on Travis

[ https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8161: - Fix Version/s: (was: 1.5.0) 1.5.1 > Flakey YARNSessionCapacitySchedulerITCa

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

[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9187: - Fix Version/s: (was: 1.5.0) 1.5.1 > add prometheus pushgateway reporter > -

[jira] [Updated] (FLINK-8907) Unable to start the process by start-cluster.sh

[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8907: - Fix Version/s: (was: 1.5.0) 1.5.1 > Unable to start the process by start-cl

[jira] [Updated] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7386: - Fix Version/s: (was: 1.5.0) 1.5.1 > Flink Elasticsearch 5 connector is not

[jira] [Updated] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

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

[jira] [Updated] (FLINK-8768) Change NettyMessageDecoder to inherit from LengthFieldBasedFrameDecoder

[ https://issues.apache.org/jira/browse/FLINK-8768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8768: - Fix Version/s: (was: 1.5.0) 1.5.1 > Change NettyMessageDecoder to inherit f

[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: (was: 1.5.0) 1.5.1 > Deprecate non-well-defined output metho

[jira] [Updated] (FLINK-9355) Simplify configuration of local recovery to a simple on/off

[ https://issues.apache.org/jira/browse/FLINK-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9355: - Fix Version/s: (was: 1.5.0) 1.5.1 > Simplify configuration of local recover

[jira] [Updated] (FLINK-8825) Disallow new String() without charset in checkstyle

[ https://issues.apache.org/jira/browse/FLINK-8825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8825: - Fix Version/s: (was: 1.5.0) 1.5.1 > Disallow new String() without charset i

[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: (was: 1.5.0) 1.5.1 > BucketingSinkTest.testNonRollingAvroKey

[jira] [Updated] (FLINK-7916) Remove NetworkStackThroughputITCase

[ https://issues.apache.org/jira/browse/FLINK-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7916: - Fix Version/s: (was: 1.5.0) 1.5.1 > Remove NetworkStackThroughputITCase > -

[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.5.0) 1.5.1 > ConnectionUtilsTest.testReturnLocalHost

[jira] [Updated] (FLINK-9360) HA end-to-end nightly test takes more than 15 min in Travis CI

[ https://issues.apache.org/jira/browse/FLINK-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9360: - Fix Version/s: (was: 1.5.0) 1.5.1 > HA end-to-end nightly test takes more t

[jira] [Updated] (FLINK-8192) Properly annotate APIs of all Flink connectors with @Public / @PublicEvolving / @Internal

[ https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8192: - Fix Version/s: (was: 1.5.0) 1.5.1 > Properly annotate APIs of all Flink con

[jira] [Updated] (FLINK-8160) Extend OperatorHarness to expose metrics

[ https://issues.apache.org/jira/browse/FLINK-8160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8160: - Fix Version/s: (was: 1.5.0) 1.5.1 > Extend OperatorHarness to expose metric

[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: (was: 1.5.0) 1.5.1 > Remove (or at least deprecate) DataStre

[jira] [Updated] (FLINK-8822) RotateLogFile may not work well when sed version is below 4.2

[ https://issues.apache.org/jira/browse/FLINK-8822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8822: - Fix Version/s: (was: 1.5.0) 1.5.1 > RotateLogFile may not work well when se

[jira] [Updated] (FLINK-8672) Support continuous processing in CSV table source

[ https://issues.apache.org/jira/browse/FLINK-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8672: - Fix Version/s: (was: 1.5.0) 1.5.1 > Support continuous processing in CSV ta

[jira] [Updated] (FLINK-7565) Add support for HTTP 1.1 (Chunked transfer encoding) to Flink web UI

[ https://issues.apache.org/jira/browse/FLINK-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7565: - Fix Version/s: (was: 1.5.0) 1.5.1 > Add support for HTTP 1.1 (Chunked trans

[jira] [Updated] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables

[ https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9258: - Fix Version/s: (was: 1.5.0) 1.5.1 > ConcurrentModificationException in Comp

[jira] [Updated] (FLINK-8897) Rowtime materialization causes "mismatched type" AssertionError

[ https://issues.apache.org/jira/browse/FLINK-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8897: - Fix Version/s: (was: 1.5.0) 1.5.1 > Rowtime materialization causes "mismatc

[jira] [Updated] (FLINK-8034) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failing on Travis

[ https://issues.apache.org/jira/browse/FLINK-8034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8034: - Fix Version/s: (was: 1.5.0) 1.5.1 > ProcessFailureCancelingITCase.testCance

[jira] [Updated] (FLINK-8851) SQL Client fails if same file is used as default and env configuration

[ https://issues.apache.org/jira/browse/FLINK-8851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8851: - Fix Version/s: (was: 1.5.0) 1.5.1 > SQL Client fails if same file is used a

  1   2   3   >