[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.5.5 > Cleanup kafka example jar filters > - > >

[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: 1.5.5 > Re-scaling job sporadically fails with KeeperException >

[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: 1.5.5 > RotateLogFile may not work well when sed version is below 4.2 >

[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: 1.5.5 > Kafka consumer's commitedOffsets gauge metric is prematurely set >

[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.5.5 > Run MetricQueryService in separate thread pool >

[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.5.5 > Verify functionality of RollingSinkSecuredITCase >

[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: 1.5.5 > ContinuousFileMonitoringFunction wrongly ignores files with exact same >

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

[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: 1.5.5 > RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due

[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.5.5 > Confusing log during TaskManager registration >

[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: 1.5.5 > YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on

[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.5.5 > HA end-to-end/Jepsen tests for standby Dispatchers >

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

[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.5.5 > YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability >

[jira] [Updated] (FLINK-8724) Add BroadcastState examples with predetermined state transitions for the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-8724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8724: - Fix Version/s: 1.5.5 > Add BroadcastState examples with predetermined state transitions for the

[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.5.5 > BucketingSinkTest.testNonRollingAvroKeyValueWithCompressionWriter

[jira] [Updated] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9630: - Fix Version/s: 1.5.5 > Kafka09PartitionDiscoverer cause connection leak on >

[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: 1.5.5 > Improve error messages when receiving unexpected messages. >

[jira] [Updated] (FLINK-10075) HTTP connections to a secured REST endpoint flood the log

[ https://issues.apache.org/jira/browse/FLINK-10075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10075: -- Fix Version/s: 1.5.5 > HTTP connections to a secured REST endpoint flood the log >

[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.5.5 > IO worker threads BLOCKED on SSL Session Cache while CMS full gc >

[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.5.5 > Handle oversized response messages in AkkaRpcActor >

[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: 1.5.5 > Test instability >

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

[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.5.5 > Make buffer count per InputGate always #channels*buffersPerChannel + >

[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.5.5 > NoResourceAvailableException with FLIP-6 >

[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.5.5 > ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on

[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: 1.5.5 > SQL Client fails if same file is used as default and env configuration >

[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.5.5 > Cancel flink job occurs java.net.ConnectException >

[jira] [Updated] (FLINK-8722) Refactor BroadcastState examples.

[ https://issues.apache.org/jira/browse/FLINK-8722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8722: - Fix Version/s: 1.5.5 > Refactor BroadcastState examples. > - > >

[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.5.5 > Run MetricQueryService with lower priority >

[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.5.5 > ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis >

[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: 1.5.5 > Rowtime materialization causes "mismatched type" AssertionError >

[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.5.5 > test instability in JobClientActorRecoveryITCase#testJobClientRecovery >

[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.5.5 > Reduce heartbeat timeout for E2E tests >

[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: 1.5.5 > Provide separate thread-pool for REST endpoint >

[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.5.5 > Unstable test ConnectionUtilsTest > - > >

[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: 1.5.5 > Mini Cluster Shutdown with HA unstable, causing test failures >

[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: 1.5.5 > Support Hadoop-free variant of Flink on Mesos >

[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: 1.5.5 > ProcessFailureCancelingITCase.testCancelingOnProcessFailure failing on

[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: 1.5.5 > Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module >

[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.5.5 > HA Failover broken due to JobGraphs not being removed from Zookeeper

[jira] [Updated] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

[ https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9869: - Fix Version/s: 1.5.5 > Send PartitionInfo in batch to Improve perfornance >

[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.5.5 > Potential buffer leak in PartitionRequestClientHandler during job

[jira] [Updated] (FLINK-9719) Mesos should use hostname as default jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-9719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9719: - Fix Version/s: 1.5.5 > Mesos should use hostname as default jobmanager.rpc.address >

[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.5.5 > Reduce performance/stability impact of latency metrics >

[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: (was: 1.5.4) 1.5.5 > Wrong / missing exception when

[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.5.4) 1.5.5 > Configure Metaspace size by

[GitHub] fhueske commented on a change in pull request #6622: [FLINK-10222] [table] Table scalar function expression parses error when function name equals the exists keyword suffix

fhueske commented on a change in pull request #6622: [FLINK-10222] [table] Table scalar function expression parses error when function name equals the exists keyword suffix URL: https://github.com/apache/flink/pull/6622#discussion_r217892719 ## File path:

[jira] [Commented] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616459#comment-16616459 ] ASF GitHub Bot commented on FLINK-10222: fhueske commented on a change in pull request #6622:

[jira] [Assigned] (FLINK-10350) Add assignTimestampsAndWatermarks in KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-10350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao reassigned FLINK-10350: -- Assignee: Jiayi Liao > Add assignTimestampsAndWatermarks in KeyedStream >

[jira] [Created] (FLINK-10350) Add assignTimestampsAndWatermarks in KeyedStream

Jiayi Liao created FLINK-10350: -- Summary: Add assignTimestampsAndWatermarks in KeyedStream Key: FLINK-10350 URL: https://issues.apache.org/jira/browse/FLINK-10350 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616355#comment-16616355 ] ASF GitHub Bot commented on FLINK-10050: kl0u commented on a change in pull request #6646:

[GitHub] kl0u commented on a change in pull request #6646: [FLINK-10050] Support allowedLateness in CoGroupedStreams

kl0u commented on a change in pull request #6646: [FLINK-10050] Support allowedLateness in CoGroupedStreams URL: https://github.com/apache/flink/pull/6646#discussion_r217887352 ## File path:

[jira] [Commented] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

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

[jira] [Updated] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

[ https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10135: --- Labels: pull-request-available (was: ) > The JobManager doesn't report the cluster-level

[GitHub] yanghua opened a new pull request #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics

yanghua opened a new pull request #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics URL: https://github.com/apache/flink/pull/6702 ## What is the purpose of the change *This pull request fixed job manager does not report the cluster-level metrics*

[jira] [Commented] (FLINK-9990) Add regexp_extract supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616262#comment-16616262 ] ASF GitHub Bot commented on FLINK-9990: --- yanghua commented on issue #6448: [FLINK-9990] [table] Add

[GitHub] yanghua commented on issue #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL

yanghua commented on issue #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6448#issuecomment-421553068 @xccui I have rebased this PR, can you take a look? Thanks.

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616225#comment-16616225 ] ASF GitHub Bot commented on FLINK-10050: EugeneYushin commented on a change in pull request

[GitHub] EugeneYushin commented on a change in pull request #6646: [FLINK-10050] Support allowedLateness in CoGroupedStreams

EugeneYushin commented on a change in pull request #6646: [FLINK-10050] Support allowedLateness in CoGroupedStreams URL: https://github.com/apache/flink/pull/6646#discussion_r217879647 ## File path:

[jira] [Commented] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616222#comment-16616222 ] ASF GitHub Bot commented on FLINK-1: Clark closed pull request #6463:

[GitHub] Clarkkkkk closed pull request #6463: [FLINK-10000][streaming]Fix the example of CoGroupedStreams

Clark closed pull request #6463: [FLINK-1][streaming]Fix the example of CoGroupedStreams URL: https://github.com/apache/flink/pull/6463 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

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616215#comment-16616215 ] ASF GitHub Bot commented on FLINK-10340: yanghua commented on issue #6700: [FLINK-10340][table]

[GitHub] yanghua commented on issue #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

yanghua commented on issue #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#issuecomment-421539082 @xccui When you have time, can you take a look at this PR? thanks.

[jira] [Commented] (FLINK-10319) Too many requestPartitionState would crash JM

[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616210#comment-16616210 ] ASF GitHub Bot commented on FLINK-10319: TisonKun edited a comment on issue #6680: [FLINK-10319]

[GitHub] TisonKun edited a comment on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM

TisonKun edited a comment on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM URL: https://github.com/apache/flink/pull/6680#issuecomment-421222747 cc @tillrohrmann @GJL This is an

[jira] [Resolved] (FLINK-9991) Add regexp_replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-9991. Resolution: Implemented Implemented in 1.7.0: f03d15a08ad5df44a4bb742d3edfdce211bf9e48 > Add

[jira] [Commented] (FLINK-10349) Unify stopActor utils

[ https://issues.apache.org/jira/browse/FLINK-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615806#comment-16615806 ] ASF GitHub Bot commented on FLINK-10349: TisonKun commented on issue #6701: [FLINK-10349] Unify

[GitHub] TisonKun commented on issue #6701: [FLINK-10349] Unify stopActor utils

TisonKun commented on issue #6701: [FLINK-10349] Unify stopActor utils URL: https://github.com/apache/flink/pull/6701#issuecomment-421538114 In fact, this PR touches many legacy code which are considered removed in the near future. Hope we the community achieve it as expected.

[jira] [Updated] (FLINK-9991) Add regexp_replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9991: --- Fix Version/s: 1.7.0 > Add regexp_replace supported in TableAPI and SQL >

[jira] [Commented] (FLINK-9991) Add regexp_replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615635#comment-16615635 ] ASF GitHub Bot commented on FLINK-9991: --- asfgit closed pull request #6450: [FLINK-9991] [table] Add

[GitHub] asfgit closed pull request #6450: [FLINK-9991] [table] Add regexp_replace supported in TableAPI and SQL

asfgit closed pull request #6450: [FLINK-9991] [table] Add regexp_replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6450 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

[jira] [Commented] (FLINK-10349) Unify stopActor utils

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

[jira] [Updated] (FLINK-10349) Unify stopActor utils

[ https://issues.apache.org/jira/browse/FLINK-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10349: --- Labels: pull-request-available (was: ) > Unify stopActor utils > - > >

[GitHub] TisonKun opened a new pull request #6701: [FLINK-10349] Unify stopActor utils

TisonKun opened a new pull request #6701: [FLINK-10349] Unify stopActor utils URL: https://github.com/apache/flink/pull/6701 ## Brief change log As discuss at #6678 , we can unify `stopActor` utils. The `MesosResourceManager#stopActor` remains since it customizes the stop logic.

[jira] [Updated] (FLINK-10349) Unify stopActor utils

[ https://issues.apache.org/jira/browse/FLINK-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10349: Summary: Unify stopActor utils (was: Unify stopActor* utils) > Unify stopActor utils > - > >

[jira] [Created] (FLINK-10349) Unify stopActor* utils

陈梓立 created FLINK-10349: --- Summary: Unify stopActor* utils Key: FLINK-10349 URL: https://issues.apache.org/jira/browse/FLINK-10349 Project: Flink Issue Type: Improvement Components: Core

[jira] [Commented] (FLINK-10215) Add configuration of java option for historyserver

[ https://issues.apache.org/jira/browse/FLINK-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615621#comment-16615621 ] ASF GitHub Bot commented on FLINK-10215: liuxianjiao commented on a change in pull request

[GitHub] liuxianjiao commented on a change in pull request #6612: [FLINK-10215]Add configuration of java option for historyserver

liuxianjiao commented on a change in pull request #6612: [FLINK-10215]Add configuration of java option for historyserver URL: https://github.com/apache/flink/pull/6612#discussion_r217877944 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java

<    1   2   3