[jira] [Commented] (FLINK-14175) Upgrade KPL version in flink-connector-kinesis to fix application OOM

2019-10-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951717#comment-16951717 ] Robert Metzger commented on FLINK-14175: I would target {{master}} for the upcoming 1.10 release

[jira] [Updated] (FLINK-13880) The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc

2019-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13880: --- Component/s: Runtime / Coordination > The behavior of

[jira] [Updated] (FLINK-14169) Cleanup expired jobs from history server

2019-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14169: --- Component/s: Runtime / Web Frontend > Cleanup expired jobs from history server >

[jira] [Updated] (FLINK-14198) Add type options to all flink python API doc

2019-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14198: --- Component/s: API / Python > Add type options to all flink python API doc >

[jira] [Updated] (FLINK-14166) Reuse cache from previous history server run

2019-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14166: --- Component/s: Runtime / Web Frontend > Reuse cache from previous history server run >

[jira] [Updated] (FLINK-13703) AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

2019-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13703: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > AvroTypeInfo requires

[jira] [Updated] (FLINK-13956) Add sequence file format with repeated sync blocks

2019-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13956: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Add sequence file format

[jira] [Updated] (FLINK-13710) JarListHandler always extract the jar package

2019-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13710: --- Component/s: Runtime / Web Frontend > JarListHandler always extract the jar package >

[jira] [Updated] (FLINK-14103) StreamTask refactoring: refine and improve exceptions passed to failExternally call

2019-10-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14103: --- Component/s: Runtime / Task > StreamTask refactoring: refine and improve exceptions passed

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

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14184: --- Component/s: Runtime / Coordination > Provide a stage listener API to be invoked per task

[jira] [Updated] (FLINK-14254) Introduce BatchFileSystemSink

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14254: --- Component/s: Table SQL / Planner > Introduce BatchFileSystemSink >

[jira] [Updated] (FLINK-13984) Separate on-heap and off-heap managed memory pools

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13984: --- Component/s: Runtime / Coordination > Separate on-heap and off-heap managed memory pools >

[jira] [Updated] (FLINK-13925) ClassLoader in BlobLibraryCacheManager is not using context class loader

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13925: --- Component/s: Runtime / Coordination > ClassLoader in BlobLibraryCacheManager is not using

[jira] [Updated] (FLINK-14060) Set slot sharing groups according to pipelined regions

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14060: --- Component/s: Runtime / Coordination > Set slot sharing groups according to pipelined

[jira] [Updated] (FLINK-14156) Execute/run processing timer triggers taking into account operator level mailbox loops

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14156: --- Component/s: Runtime / Task > Execute/run processing timer triggers taking into account

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

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14239: --- Component/s: API / DataStream > Emitting the max watermark in StreamSource#run may cause it

[jira] [Updated] (FLINK-13982) Implement memory calculation logics

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13982: --- Component/s: (was: Runtime / Task) Runtime / Coordination > Implement

[jira] [Updated] (FLINK-13982) Implement memory calculation logics

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13982: --- Component/s: Runtime / Task > Implement memory calculation logics >

[jira] [Updated] (FLINK-13803) Introduce SpillableHeapKeyedStateBackend and all necessities

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13803: --- Component/s: Runtime / State Backends > Introduce SpillableHeapKeyedStateBackend and all

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

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13983: --- Component/s: Runtime / Task > Launch task executor with new memory calculation logics >

[jira] [Updated] (FLINK-13813) metrics is different between overview ui and metric response

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13813: --- Component/s: Runtime / Web Frontend > metrics is different between overview ui and metric

[jira] [Updated] (FLINK-13846) Implement benchmark case on MapState#isEmpty

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13846: --- Component/s: Benchmarks > Implement benchmark case on MapState#isEmpty >

[jira] [Updated] (FLINK-13860) Flink Apache Kudu Connector

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13860: --- Component/s: Connectors / Common > Flink Apache Kudu Connector >

[jira] [Updated] (FLINK-14099) SQL supports timestamp in Long

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14099: --- Component/s: Table SQL / Planner > SQL supports timestamp in Long >

[jira] [Updated] (FLINK-14057) Add Remove Other Timers to TimerService

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14057: --- Component/s: API / DataStream > Add Remove Other Timers to TimerService >

[jira] [Updated] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14172: --- Component/s: Deployment / Kubernetes > Implement KubeClient with official Java client

[jira] [Updated] (FLINK-14063) Operators use fractions to decide how many managed memory to allocate

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14063: --- Component/s: Runtime / Task > Operators use fractions to decide how many managed memory to

[jira] [Updated] (FLINK-14191) Extend SlotManager to support dynamic slot allocation on pending task executors

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14191: --- Component/s: Runtime / Coordination > Extend SlotManager to support dynamic slot allocation

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

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14134: --- Component/s: Connectors / Hive > Introduce LimitableTableSource to optimize limit >

[jira] [Updated] (FLINK-14062) Set managed memory fractions according to slot sharing groups

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14062: --- Component/s: Runtime / Task > Set managed memory fractions according to slot sharing groups

[jira] [Updated] (FLINK-14192) Enable the dynamic slot allocation feature.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14192: --- Component/s: Runtime / Coordination > Enable the dynamic slot allocation feature. >

[jira] [Updated] (FLINK-14061) Introduce managed memory fractions to StreamConfig

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14061: --- Component/s: Runtime / Task > Introduce managed memory fractions to StreamConfig >

[jira] [Updated] (FLINK-14190) Extend SlotManager to support dynamic slot allocation on registered TaskExecutors.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14190: --- Component/s: Runtime / Coordination > Extend SlotManager to support dynamic slot allocation

[jira] [Updated] (FLINK-14194) Clean-up of legacy mode.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14194: --- Component/s: Runtime / Coordination > Clean-up of legacy mode. > >

[jira] [Updated] (FLINK-14199) Only use dedicated/named classes for mailbox letters.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14199: --- Component/s: Runtime / Task > Only use dedicated/named classes for mailbox letters. >

[jira] [Updated] (FLINK-14193) Update RestAPI / Web UI

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14193: --- Component/s: Runtime / Web Frontend Runtime / Coordination > Update

[jira] [Updated] (FLINK-14189) Extend TaskExecutor to support dynamic slot allocation

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14189: --- Component/s: Runtime / Coordination > Extend TaskExecutor to support dynamic slot

[jira] [Updated] (FLINK-14188) TaskExecutor derive and register with default slot resource profile

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14188: --- Component/s: Runtime / Coordination > TaskExecutor derive and register with default slot

[jira] [Updated] (FLINK-13854) Support Aggregating in Join and CoGroup

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13854: --- Component/s: API / DataStream > Support Aggregating in Join and CoGroup >

[jira] [Updated] (FLINK-13986) Clean-up of legacy mode

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13986: --- Component/s: Runtime / Task > Clean-up of legacy mode > --- > >

[jira] [Updated] (FLINK-14146) Introduce Pulsar connector

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14146: --- Component/s: Connectors / Common > Introduce Pulsar connector > --

[jira] [Updated] (FLINK-13985) Use unsafe memory for managed memory.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13985: --- Component/s: Runtime / Task > Use unsafe memory for managed memory. >

[jira] [Updated] (FLINK-14100) Introduce OracleDialect

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14100: --- Component/s: Connectors / JDBC > Introduce OracleDialect > --- > >

[jira] [Updated] (FLINK-14102) Introduce DB2Dialect

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14102: --- Component/s: (was: Table SQL / Planner) Connectors / JDBC > Introduce

[jira] [Updated] (FLINK-14101) Introduce SqlServerDialect

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14101: --- Component/s: Connectors / JDBC > Introduce SqlServerDialect > -- >

[jira] [Updated] (FLINK-14102) Introduce DB2Dialect

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14102: --- Component/s: Table SQL / Planner > Introduce DB2Dialect > > >

[jira] [Updated] (FLINK-13878) Flink CLI fails (TimeoutException) for unknown reason

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13878: --- Component/s: Command Line Client > Flink CLI fails (TimeoutException) for unknown reason >

[jira] [Updated] (FLINK-13878) Flink CLI fails (TimeoutException) for unknown reason

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13878: --- Component/s: Runtime / Coordination > Flink CLI fails (TimeoutException) for unknown reason

[jira] [Updated] (FLINK-13938) Use yarn public distributed cache to speed up containers launch

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13938: --- Component/s: Deployment / YARN > Use yarn public distributed cache to speed up containers

[jira] [Updated] (FLINK-13777) Introduce sql function wrappers and conversion to ExpressionConverter

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13777: --- Component/s: Table SQL / Planner > Introduce sql function wrappers and conversion to

[jira] [Updated] (FLINK-13788) Document state migration constraints on keys

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13788: --- Component/s: API / Type Serialization System > Document state migration constraints on keys

[jira] [Updated] (FLINK-13788) Document state migration constraints on keys

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13788: --- Component/s: Documentation > Document state migration constraints on keys >

[jira] [Commented] (FLINK-14175) Upgrade KPL version in flink-connector-kinesis to fix application OOM

2019-09-30 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940729#comment-16940729 ] Robert Metzger commented on FLINK-14175: [~phoenixjiangnan]: you have recently worked on Kinesis

[jira] [Commented] (FLINK-13821) Website must link to License etc

2019-09-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925166#comment-16925166 ] Robert Metzger commented on FLINK-13821: Very nice, thank you! > Website must link to License

[jira] [Resolved] (FLINK-13821) Website must link to License etc

2019-09-05 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-13821. Resolution: Fixed This has been resolved in 

[jira] [Created] (FLINK-13978) Evaluate Azure Pipelines as a CI tool for Flink

2019-09-05 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-13978: -- Summary: Evaluate Azure Pipelines as a CI tool for Flink Key: FLINK-13978 URL: https://issues.apache.org/jira/browse/FLINK-13978 Project: Flink Issue

[jira] [Assigned] (FLINK-13821) Website must link to License etc

2019-08-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13821: -- Assignee: Robert Metzger > Website must link to License etc >

[jira] [Commented] (FLINK-13821) Website must link to License etc

2019-08-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1691#comment-1691 ] Robert Metzger commented on FLINK-13821: Thanks for opening this ticket Sebb. I was wondering

[jira] [Updated] (FLINK-13821) Website must link to License etc

2019-08-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13821: --- Component/s: Project Website > Website must link to License etc >

[jira] [Commented] (FLINK-4463) FLIP-3: Restructure Documentation

2019-08-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909017#comment-16909017 ] Robert Metzger commented on FLINK-4463: --- I would propose to close all subtasks as Invalid with a

[jira] [Commented] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2019-08-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909006#comment-16909006 ] Robert Metzger commented on FLINK-9941: --- [~wind_ljy] why did you close the Jira ticket? > Flush in

[jira] [Updated] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

2019-08-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13739: --- Issue Type: Bug (was: Task) > BinaryRowTest.testWriteString() fails in some environments >

[jira] [Updated] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

2019-08-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13738: --- Issue Type: Bug (was: Task) > NegativeArraySizeException in LongHybridHashTable >

[jira] [Commented] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

2019-08-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908205#comment-16908205 ] Robert Metzger commented on FLINK-13739: Indeed, the machine is using {{US-ASCII}} as the

[jira] [Assigned] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

2019-08-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13739: -- Assignee: Jingsong Lee (was: Robert Metzger) > BinaryRowTest.testWriteString()

[jira] [Assigned] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

2019-08-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13739: -- Assignee: Robert Metzger > BinaryRowTest.testWriteString() fails in some

[jira] [Created] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

2019-08-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-13739: -- Summary: BinaryRowTest.testWriteString() fails in some environments Key: FLINK-13739 URL: https://issues.apache.org/jira/browse/FLINK-13739 Project: Flink

[jira] [Updated] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

2019-08-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13738: --- Description: Executing this (meaningless) query: {code:java} INSERT INTO sinkTable ( SELECT

[jira] [Created] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

2019-08-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-13738: -- Summary: NegativeArraySizeException in LongHybridHashTable Key: FLINK-13738 URL: https://issues.apache.org/jira/browse/FLINK-13738 Project: Flink Issue

[jira] [Commented] (FLINK-13700) PubSub connector example not included in flink-dist

2019-08-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907039#comment-16907039 ] Robert Metzger commented on FLINK-13700: [~Xeli] do you want to kick off a short discussion on

[jira] [Commented] (FLINK-13700) PubSub connector example not included in flink-dist

2019-08-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905948#comment-16905948 ] Robert Metzger commented on FLINK-13700: According to this discussion: 

[jira] [Commented] (FLINK-13306) flink-examples-streaming-gcp-pubsub is missing NOTICE

2019-08-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905947#comment-16905947 ] Robert Metzger commented on FLINK-13306: [~Zentol]: Why was this closed as invalid? There's now

[jira] [Assigned] (FLINK-13700) PubSub connector example not included in flink-dist

2019-08-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13700: -- Assignee: Richard Deurwaarder > PubSub connector example not included in flink-dist

[jira] [Closed] (FLINK-13701) KafkaTableSourceSink doesn't support topic pattern

2019-08-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-13701. -- Resolution: Duplicate This is a duplicate of FLINK-13340. Closing. > KafkaTableSourceSink

[jira] [Updated] (FLINK-13701) KafkaTableSourceSink doesn't support topic pattern

2019-08-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13701: --- Component/s: (was: Connectors / Hadoop Compatibility) Table SQL / API

[jira] [Updated] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

2019-08-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13588: --- Component/s: Runtime / Task > StreamTask.handleAsyncException throws away the exception

[jira] [Assigned] (FLINK-13646) Add ARM CI job definition scripts

2019-08-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13646: -- Assignee: wangxiyuan > Add ARM CI job definition scripts >

[jira] [Commented] (FLINK-13450) Adjust tests to tolerate arithmetic differences between x86 and ARM

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897178#comment-16897178 ] Robert Metzger commented on FLINK-13450: Spark had issues with {{Math}}: 

[jira] [Commented] (FLINK-13199) ARM support for Flink

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897175#comment-16897175 ] Robert Metzger commented on FLINK-13199: Maybe we should rename this ticket to related to build

[jira] [Updated] (FLINK-13291) Cannot provide AWS Direct Connect ENDPOINT

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13291: --- Summary: Cannot provide AWS Direct Connect ENDPOINT (was: Cannot Privide AWS Direct

[jira] [Commented] (FLINK-13340) Add more Kafka topic option of flink-connector-kafka

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897155#comment-16897155 ] Robert Metzger commented on FLINK-13340: Thanks a lot for following the process! I hope a

[jira] [Updated] (FLINK-13340) Add more Kafka topic option of flink-connector-kafka

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13340: --- Component/s: Table SQL / API > Add more Kafka topic option of flink-connector-kafka >

[jira] [Commented] (FLINK-13406) MetricConfig.getInteger() always returns null

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897138#comment-16897138 ] Robert Metzger commented on FLINK-13406: Does this mean we can close this ticket? >

[jira] [Commented] (FLINK-13459) Violation of the order queue messages from RabbitMQ.

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897129#comment-16897129 ] Robert Metzger commented on FLINK-13459: Are you writing out the data immediately after the

[jira] [Commented] (FLINK-13469) Resource used by StateMapSnapshot can not be released if snapshot fails

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897126#comment-16897126 ] Robert Metzger commented on FLINK-13469: After talking to [~carp84] offline, I assigned the

[jira] [Assigned] (FLINK-13469) Resource used by StateMapSnapshot can not be released if snapshot fails

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13469: -- Assignee: PengFei Li > Resource used by StateMapSnapshot can not be released if

[jira] [Updated] (FLINK-13459) Violation of the order queue messages from RabbitMQ.

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13459: --- Component/s: Connectors/ RabbitMQ > Violation of the order queue messages from RabbitMQ. >

[jira] [Updated] (FLINK-13472) taskmanager.jvm-exit-on-oom doesn't work reliably with YARN

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13472: --- Component/s: (was: core) Deployment / YARN >

[jira] [Updated] (FLINK-13477) Containerized TaskManager killed because of lack of memory overhead

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13477: --- Component/s: Deployment / YARN > Containerized TaskManager killed because of lack of memory

[jira] [Commented] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897093#comment-16897093 ] Robert Metzger commented on FLINK-13482: I'm not aware of a mechanism for that yet. There are

[jira] [Updated] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13482: --- Component/s: Runtime / Coordination > How can I cleanly shutdown streaming jobs in local

[jira] [Updated] (FLINK-13500) RestClusterClient requires S3 access when HA is configured

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13500: --- Component/s: Runtime / Coordination > RestClusterClient requires S3 access when HA is

[jira] [Commented] (FLINK-13506) flink1.6.1 can't consume the specified topic list,only a few topic was consumed

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897003#comment-16897003 ] Robert Metzger commented on FLINK-13506: Hi, I would like to ask you to refer to the user@

[jira] [Updated] (FLINK-13506) flink1.6.1 can't consume the specified topic list,only a few topic was consumed

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13506: --- Component/s: Connectors / Kafka > flink1.6.1 can't consume the specified topic list,only a

[jira] [Closed] (FLINK-13507) kafka consumer not able to distinguish topic name after add source

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-13507. -- Resolution: Duplicate > kafka consumer not able to distinguish topic name after add source >

[jira] [Commented] (FLINK-13507) kafka consumer not able to distinguish topic name after add source

2019-07-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896999#comment-16896999 ] Robert Metzger commented on FLINK-13507: Thanks a lot for opening this ticket. This has been

[jira] [Updated] (FLINK-13428) StreamingFileSink allow part file name to be configurable

2019-07-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13428: --- Component/s: Connectors / FileSystem > StreamingFileSink allow part file name to be

[jira] [Updated] (FLINK-13450) Adjust tests to tolerate arithmetic differences between x86 and ARM

2019-07-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13450: --- Component/s: Tests > Adjust tests to tolerate arithmetic differences between x86 and ARM >

[jira] [Updated] (FLINK-13333) Potentially NPE of preview plan functionality

2019-07-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1: --- Component/s: Command Line Client > Potentially NPE of preview plan functionality >

[jira] [Updated] (FLINK-13377) Streaming SQL e2e test failed on travis

2019-07-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13377: --- Component/s: Table SQL / Runtime > Streaming SQL e2e test failed on travis >

  1   2   3   4   5   6   7   8   9   10   >