[jira] [Updated] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14359: --- Labels: pull-request-available (was: ) > Create a module called flink-sql-connector-hbase

[jira] [Updated] (FLINK-14390) Add class for SqlOperators, and add sql operations to AlgoOperator, BatchOperator and StreamOperator.

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14390: --- Labels: pull-request-available (was: ) > Add class for SqlOperators, and add sql

[jira] [Updated] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4883: -- Labels: pull-request-available (was: ) > Prevent UDFs implementations through Scala singleton

[jira] [Updated] (FLINK-4705) Instrument FixedLengthRecordSorter

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4705: -- Labels: pull-request-available (was: ) > Instrument FixedLengthRecordSorter >

[jira] [Updated] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4615: -- Labels: pull-request-available (was: ) > Reusing the memory allocated for the drivers and

[jira] [Updated] (FLINK-4205) Implement stratified sampling for DataSet

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4205: -- Labels: pull-request-available (was: ) > Implement stratified sampling for DataSet >

[jira] [Updated] (FLINK-2055) Implement Streaming HBaseSink

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-2055: -- Labels: pull-request-available (was: ) > Implement Streaming HBaseSink >

[jira] [Updated] (FLINK-4521) Fix "Submit new Job" panel in development mode

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4521: -- Labels: pull-request-available (was: ) > Fix "Submit new Job" panel in development mode >

[jira] [Updated] (FLINK-3030) Enhance Dashboard to show Execution Attempts

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3030: -- Labels: pull-request-available (was: ) > Enhance Dashboard to show Execution Attempts >

[jira] [Updated] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3322: -- Labels: pull-request-available (was: ) > MemoryManager creates too much GC pressure with

[jira] [Updated] (FLINK-3783) Support weighted random sampling with reservoir

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3783: -- Labels: pull-request-available (was: ) > Support weighted random sampling with reservoir >

[jira] [Updated] (FLINK-3857) Add reconnect attempt to Elasticsearch host

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3857: -- Labels: pull-request-available (was: ) > Add reconnect attempt to Elasticsearch host >

[jira] [Updated] (FLINK-3996) Add addition, subtraction and multiply by scalar to DenseVector.scala and SparseVector.scala

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3996: -- Labels: pull-request-available (was: ) > Add addition, subtraction and multiply by scalar to

[jira] [Updated] (FLINK-4016) FoldApplyWindowFunction is not properly initialized

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4016: -- Labels: easyfix pull-request-available (was: easyfix) > FoldApplyWindowFunction is not

[jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-1725: -- Labels: LoadBalancing Partitioner pull-request-available (was: LoadBalancing Partitioner) >

[jira] [Updated] (FLINK-3109) Join two streams with two different buffer time

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3109: -- Labels: easyfix patch pull-request-available (was: easyfix patch) > Join two streams with two

[jira] [Updated] (FLINK-2030) Implement discrete and continuous histograms

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-2030: -- Labels: pull-request-available (was: ) > Implement discrete and continuous histograms >

[jira] [Updated] (FLINK-14045) Rewrite DefaultExecutionSlotAllocator to use SlotProviderStrategy

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14045: --- Labels: pull-request-available (was: ) > Rewrite DefaultExecutionSlotAllocator to use

[jira] [Updated] (FLINK-14342) Remove method FunctionDefinition#getLanguage

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14342: --- Labels: pull-request-available (was: ) > Remove method FunctionDefinition#getLanguage >

[jira] [Updated] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE

2019-10-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13999: --- Labels: pull-request-available (was: ) > Correct the documentation of MATCH_RECOGNIZE >

[jira] [Updated] (FLINK-14272) Support Blink planner for Python UDF

2019-10-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14272: --- Labels: pull-request-available (was: ) > Support Blink planner for Python UDF >

[jira] [Updated] (FLINK-14355) Example code in state processor API docs doesn't compile

2019-10-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14355: --- Labels: pull-request-available (was: ) > Example code in state processor API docs doesn't

[jira] [Updated] (FLINK-14227) Add Razorpay to Chinese Powered By page

2019-10-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14227: --- Labels: pull-request-available (was: ) > Add Razorpay to Chinese Powered By page >

[jira] [Updated] (FLINK-14215) Add Docs for TM and JM Environment Variable Setting

2019-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14215: --- Labels: pull-request-available (was: ) > Add Docs for TM and JM Environment Variable

[jira] [Updated] (FLINK-14208) Optimize Python UDFs with parameters of constant values

2019-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14208: --- Labels: pull-request-available (was: ) > Optimize Python UDFs with parameters of constant

[jira] [Updated] (FLINK-14027) Add documentation for Python user-defined functions

2019-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14027: --- Labels: pull-request-available (was: ) > Add documentation for Python user-defined

[jira] [Updated] (FLINK-14344) Snapshot master hook state asynchronously

2019-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14344: --- Labels: pull-request-available (was: ) > Snapshot master hook state asynchronously >

[jira] [Updated] (FLINK-14266) Introduce RowCsvInputFormat to new CSV module

2019-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14266: --- Labels: pull-request-available (was: ) > Introduce RowCsvInputFormat to new CSV module >

[jira] [Updated] (FLINK-13818) Check whether web submission are enabled

2019-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13818: --- Labels: pull-request-available (was: ) > Check whether web submission are enabled >

[jira] [Updated] (FLINK-1430) Add test for streaming scala api completeness

2019-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-1430: -- Labels: pull-request-available (was: ) > Add test for streaming scala api completeness >

[jira] [Updated] (FLINK-14377) Translate ProgramOptions relevant for job execution to ConfigOptions.

2019-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14377: --- Labels: pull-request-available (was: ) > Translate ProgramOptions relevant for job

[jira] [Updated] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

2019-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14347: --- Labels: pull-request-available (was: ) >

[jira] [Updated] (FLINK-14334) ElasticSearch docs refer to non-existent ExceptionUtils.containsThrowable

2019-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14334: --- Labels: pull-request-available (was: ) > ElasticSearch docs refer to non-existent

[jira] [Updated] (FLINK-14149) Introduce ZooKeeperLeaderElectionServiceNG

2019-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14149: --- Labels: pull-request-available (was: ) > Introduce ZooKeeperLeaderElectionServiceNG >

[jira] [Updated] (FLINK-14360) Flink on yarn should support obtain delegation tokens of multi hdfs namespaces

2019-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14360: --- Labels: pull-request-available (was: ) > Flink on yarn should support obtain delegation

[jira] [Updated] (FLINK-14134) Introduce LimitableTableSource to optimize limit

2019-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14134: --- Labels: pull-request-available (was: ) > Introduce LimitableTableSource to optimize limit

[jira] [Updated] (FLINK-14240) The configuration added via TableConfig#configuration should be added to GlobalJobParameters for the legacy planner

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14240: --- Labels: pull-request-available (was: ) > The configuration added via

[jira] [Updated] (FLINK-14336) Exceptions in AsyncCheckpointRunnable#run are never logged

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14336: --- Labels: pull-request-available (was: ) > Exceptions in AsyncCheckpointRunnable#run are

[jira] [Updated] (FLINK-14353) Enable fork-reuse for table-planner

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14353: --- Labels: pull-request-available (was: ) > Enable fork-reuse for table-planner >

[jira] [Updated] (FLINK-14291) Add unit tests for DefaultScheduler to test concurrent failover behavior

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14291: --- Labels: pull-request-available (was: ) > Add unit tests for DefaultScheduler to test

[jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14350: --- Labels: pull-request-available (was: ) > Introduce dedicated MetricScope >

[jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14351: --- Labels: pull-request-available (was: ) > Refactor MetricRegistry delimiter retrieval into

[jira] [Updated] (FLINK-14349) Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14349: --- Labels: pull-request-available (was: ) > Create a Connector Descriptor for HBase so that

[jira] [Updated] (FLINK-14212) Support Python UDFs without arguments

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14212: --- Labels: pull-request-available (was: ) > Support Python UDFs without arguments >

[jira] [Updated] (FLINK-14254) Introduce FileSystemOutputFormat for batch

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14254: --- Labels: pull-request-available (was: ) > Introduce FileSystemOutputFormat for batch >

[jira] [Updated] (FLINK-14008) Flink Scala 2.12 binary distribution contains incorrect NOTICE-binary file

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14008: --- Labels: pull-request-available (was: ) > Flink Scala 2.12 binary distribution contains

[jira] [Updated] (FLINK-14335) Java version of ExampleIntegrationTest in testing docs is incorrect

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14335: --- Labels: pull-request-available (was: ) > Java version of ExampleIntegrationTest in testing

[jira] [Updated] (FLINK-14237) No need to rename shipped Flink jar

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14237: --- Labels: pull-request-available (was: ) > No need to rename shipped Flink jar >

[jira] [Updated] (FLINK-14331) Reset vertices right after they transition to terminated states

2019-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14331: --- Labels: pull-request-available (was: ) > Reset vertices right after they transition to

[jira] [Updated] (FLINK-14300) StreamTask#invoke leaks threads if OperatorChain fails to be constructed

2019-10-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14300: --- Labels: pull-request-available (was: ) > StreamTask#invoke leaks threads if OperatorChain

[jira] [Updated] (FLINK-14337) HistoryServerTest.testHistoryServerIntegration failed on Travis

2019-10-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14337: --- Labels: pull-request-available test-stability (was: test-stability) >

[jira] [Updated] (FLINK-14306) flink-python build fails with No module named pkg_resources

2019-10-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14306: --- Labels: pull-request-available (was: ) > flink-python build fails with No module named

[jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes

2019-10-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14230: --- Labels: pull-request-available (was: ) > Change the endInput call of the downstream

[jira] [Updated] (FLINK-13904) Avoid competition between different rounds of checkpoint triggering

2019-10-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13904: --- Labels: pull-request-available (was: ) > Avoid competition between different rounds of

[jira] [Updated] (FLINK-14343) Remove uncompleted YARNHighAvailabilityService

2019-10-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14343: --- Labels: pull-request-available (was: ) > Remove uncompleted YARNHighAvailabilityService >

[jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

2019-10-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14341: --- Labels: pull-request-available (was: ) > Flink-python builds with failure: no such option:

[jira] [Updated] (FLINK-14332) add flink-metrics-signalfx to flink-metrics

2019-10-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14332: --- Labels: pull-request-available (was: ) > add flink-metrics-signalfx to flink-metrics >

[jira] [Updated] (FLINK-14310) Get ExecutionVertexID from ExecutionVertex rather than creating new instances

2019-10-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14310: --- Labels: pull-request-available (was: ) > Get ExecutionVertexID from ExecutionVertex rather

[jira] [Updated] (FLINK-14271) Remove legacy RestartPipelinedRegionStrategy

2019-10-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14271: --- Labels: pull-request-available (was: ) > Remove legacy RestartPipelinedRegionStrategy >

[jira] [Updated] (FLINK-14329) Simplify code with lambda expressions in flink-core module

2019-10-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14329: --- Labels: pull-request-available (was: ) > Simplify code with lambda expressions in

[jira] [Updated] (FLINK-14296) SqlNodes in the parser module should use an Optional for optional parameters

2019-10-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14296: --- Labels: pull-request-available (was: ) > SqlNodes in the parser module should use an

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

2019-10-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14319: --- Labels: pull-request-available (was: ) > Register user jar files in

[jira] [Updated] (FLINK-14315) NPE with JobMaster.disconnectTaskManager

2019-10-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14315: --- Labels: pull-request-available (was: ) > NPE with JobMaster.disconnectTaskManager >

[jira] [Updated] (FLINK-14317) make hadoop history server logs accessible through flink ui

2019-10-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14317: --- Labels: pull-request-available (was: ) > make hadoop history server logs accessible

[jira] [Updated] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

2019-10-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14309: --- Labels: pull-request-available test-stability (was: test-stability) >

[jira] [Updated] (FLINK-14247) Use NoResourceAvailableException to wrap TimeoutException on slot allocation (Scheduler NG)

2019-10-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14247: --- Labels: pull-request-available (was: ) > Use NoResourceAvailableException to wrap

[jira] [Updated] (FLINK-14276) Quickstarts Scala nightly end-to-end test fails on Travis

2019-10-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14276: --- Labels: pull-request-available test-stability (was: test-stability) > Quickstarts Scala

[jira] [Updated] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11843: --- Labels: pull-request-available (was: ) > Dispatcher fails to recover jobs if leader change

[jira] [Updated] (FLINK-14278) Pass in ioExecutor into AbstractDispatcherResourceManagerComponentFactory

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14278: --- Labels: pull-request-available (was: ) > Pass in ioExecutor into

[jira] [Updated] (FLINK-14307) Extract JobGraphWriter from JobGraphStore

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14307: --- Labels: pull-request-available (was: ) > Extract JobGraphWriter from JobGraphStore >

[jira] [Updated] (FLINK-14184) Provide a stage listener API to be invoked per task manager

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14184: --- Labels: pull-request-available (was: ) > Provide a stage listener API to be invoked per

[jira] [Updated] (FLINK-14252) Encapsulate Dispatcher services in DispatcherServices container

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14252: --- Labels: pull-request-available (was: ) > Encapsulate Dispatcher services in

[jira] [Updated] (FLINK-14305) Move ownership of JobManagerMetricGroup to Dispatcher

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14305: --- Labels: pull-request-available (was: ) > Move ownership of JobManagerMetricGroup to

[jira] [Updated] (FLINK-14303) Factor resource manager related metrics out of JobManagerMetricGroup

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14303: --- Labels: pull-request-available (was: ) > Factor resource manager related metrics out of

[jira] [Updated] (FLINK-14299) Factor status and system metrics out of JobManagerMetricGroup

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14299: --- Labels: pull-request-available (was: ) > Factor status and system metrics out of

[jira] [Updated] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14302: --- Labels: pull-request-available (was: ) > FlinkKafkaInternalProducer should not send

[jira] [Updated] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

2019-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14273: --- Labels: pull-request-available (was: ) > when User-Defined Aggregate Functions(UDAF)

[jira] [Updated] (FLINK-14216) introduce temp system functions to FunctionCatalog

2019-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14216: --- Labels: pull-request-available (was: ) > introduce temp system functions to

[jira] [Updated] (FLINK-14298) Change LeaderContender#getAddress into LeaderContender#getDescription

2019-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14298: --- Labels: pull-request-available (was: ) > Change LeaderContender#getAddress into

[jira] [Updated] (FLINK-14290) Decouple plan translation from job execution/ClusterClient

2019-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14290: --- Labels: pull-request-available (was: ) > Decouple plan translation from job

[jira] [Updated] (FLINK-14246) Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG

2019-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14246: --- Labels: pull-request-available (was: ) > Annotate all MiniCluster tests in flink-runtime

[jira] [Updated] (FLINK-14289) Remove Optional fields from RecordWriter relevant classes

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14289: --- Labels: pull-request-available (was: ) > Remove Optional fields from RecordWriter relevant

[jira] [Updated] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14178: --- Labels: pull-request-available (was: ) > maven-shade-plugin 3.2.1 doesn't work on ARM for

[jira] [Updated] (FLINK-14288) Add Py4j NOTICE for source release

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14288: --- Labels: pull-request-available (was: ) > Add Py4j NOTICE for source release >

[jira] [Updated] (FLINK-14117) Translate changes on documentation index page to Chinese

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14117: --- Labels: pull-request-available (was: ) > Translate changes on documentation index page to

[jira] [Updated] (FLINK-14283) Update Kinesis consumer documentation for watermarks and event time alignment

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14283: --- Labels: pull-request-available (was: ) > Update Kinesis consumer documentation for

[jira] [Updated] (FLINK-14287) Decouple leader address from LeaderContender

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14287: --- Labels: pull-request-available (was: ) > Decouple leader address from LeaderContender >

[jira] [Updated] (FLINK-14286) Remove Akka specific parsing logic from LeaderConnectionInfo

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14286: --- Labels: pull-request-available (was: ) > Remove Akka specific parsing logic from

[jira] [Updated] (FLINK-14285) Simplify Dispatcher factories by removing generics

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14285: --- Labels: pull-request-available (was: ) > Simplify Dispatcher factories by removing

[jira] [Updated] (FLINK-14284) Add shut down future to Dispatcher

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14284: --- Labels: pull-request-available (was: ) > Add shut down future to Dispatcher >

[jira] [Updated] (FLINK-14282) Simplify DispatcherResourceManagerComponent

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14282: --- Labels: pull-request-available (was: ) > Simplify DispatcherResourceManagerComponent >

[jira] [Updated] (FLINK-14281) Introduce DispatcherRunner#getShutDownFuture

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14281: --- Labels: pull-request-available (was: ) > Introduce DispatcherRunner#getShutDownFuture >

[jira] [Updated] (FLINK-14280) Introduce DispatcherRunner for better separation of concerns

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14280: --- Labels: pull-request-available (was: ) > Introduce DispatcherRunner for better separation

[jira] [Updated] (FLINK-14277) Replace InMemoryJobGraphStore with proper TestingJobGraphStore implementation

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14277: --- Labels: pull-request-available (was: ) > Replace InMemoryJobGraphStore with proper

[jira] [Updated] (FLINK-14227) Add Razorpay to Chinese Powered By page

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14227: --- Labels: pull-request-available (was: ) > Add Razorpay to Chinese Powered By page >

[jira] [Updated] (FLINK-14239) Emitting the max watermark in StreamSource#run may cause it to arrive the downstream early

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14239: --- Labels: pull-request-available (was: ) > Emitting the max watermark in StreamSource#run

[jira] [Updated] (FLINK-14265) Don't use ContinuousFileReaderOperator to support multiple paths

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14265: --- Labels: pull-request-available (was: ) > Don't use ContinuousFileReaderOperator to support

[jira] [Updated] (FLINK-13361) Add documentation for JDBC connector for Table API & SQL

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13361: --- Labels: pull-request-available (was: ) > Add documentation for JDBC connector for Table

[jira] [Updated] (FLINK-13983) Launch task executor with new memory calculation logics

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13983: --- Labels: pull-request-available (was: ) > Launch task executor with new memory calculation

[jira] [Updated] (FLINK-13827) shell variable should be escaped in start-scala-shell.sh

2019-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13827: --- Labels: pull-request-available (was: ) > shell variable should be escaped in

  1   2   3   4   5   6   7   8   9   10   >