[jira] [Updated] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function

[ https://issues.apache.org/jira/browse/FLINK-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9600: -- Labels: stale-minor (was: ) > Add DataStream transformation variants that pass timestamp to

[jira] [Commented] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]

[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321593#comment-17321593 ] Flink Jira Bot commented on FLINK-9221: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-9639) Order "User Configuration" Alphabetically on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-9639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9639: -- Labels: stale-minor (was: ) > Order "User Configuration" Alphabetically on Flink Dashboard >

[jira] [Updated] (FLINK-9448) contribute-code.html references Hadoop 1.x support

[ https://issues.apache.org/jira/browse/FLINK-9448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9448: -- Labels: stale-minor (was: ) > contribute-code.html references Hadoop 1.x support >

[jira] [Commented] (FLINK-9454) Build instructions for MapR do not work

[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321584#comment-17321584 ] Flink Jira Bot commented on FLINK-9454: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9095) Add metrics for Cassandra Connector

[ https://issues.apache.org/jira/browse/FLINK-9095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321597#comment-17321597 ] Flink Jira Bot commented on FLINK-9095: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9675) Avoid FileInputStream/FileOutputStream

[ https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321580#comment-17321580 ] Flink Jira Bot commented on FLINK-9675: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp

[ https://issues.apache.org/jira/browse/FLINK-8951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8951: -- Labels: stale-minor (was: ) > Support OVER windows PARTITION BY (rounded) timestamp >

[jira] [Commented] (FLINK-9448) contribute-code.html references Hadoop 1.x support

[ https://issues.apache.org/jira/browse/FLINK-9448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321585#comment-17321585 ] Flink Jira Bot commented on FLINK-9448: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-9422) Dedicated DISTINCT operator for streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9422: -- Labels: stale-minor (was: ) > Dedicated DISTINCT operator for streaming tables with time

[jira] [Updated] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc

[ https://issues.apache.org/jira/browse/FLINK-9130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9130: -- Labels: stale-minor (was: ) > Add cancel-job option to SavepointHandlers JavaDoc >

[jira] [Updated] (FLINK-9095) Add metrics for Cassandra Connector

[ https://issues.apache.org/jira/browse/FLINK-9095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9095: -- Labels: stale-minor (was: ) > Add metrics for Cassandra Connector >

[jira] [Updated] (FLINK-9085) Add a rate limiter to the Cassandra Connector

[ https://issues.apache.org/jira/browse/FLINK-9085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9085: -- Labels: stale-minor (was: ) > Add a rate limiter to the Cassandra Connector >

[jira] [Commented] (FLINK-9264) Add method Writer[A]#contramap[B](f: B => A): Writer[B]

[ https://issues.apache.org/jira/browse/FLINK-9264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321592#comment-17321592 ] Flink Jira Bot commented on FLINK-9264: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-9805) HTTP Redirect to Active JM in Flink CLI

[ https://issues.apache.org/jira/browse/FLINK-9805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9805: -- Labels: newbie pull-request-available stale-minor (was: newbie pull-request-available) >

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

[ https://issues.apache.org/jira/browse/FLINK-9824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321578#comment-17321578 ] Flink Jira Bot commented on FLINK-9824: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-9264) Add method Writer[A]#contramap[B](f: B => A): Writer[B]

[ https://issues.apache.org/jira/browse/FLINK-9264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9264: -- Labels: stale-minor (was: ) > Add method Writer[A]#contramap[B](f: B => A): Writer[B] >

[jira] [Updated] (FLINK-9388) Inconsistency in job shutdown produces confusing log message

[ https://issues.apache.org/jira/browse/FLINK-9388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9388: -- Labels: stale-minor (was: ) > Inconsistency in job shutdown produces confusing log message >

[jira] [Commented] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

[ https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321590#comment-17321590 ] Flink Jira Bot commented on FLINK-9340: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9805) HTTP Redirect to Active JM in Flink CLI

[ https://issues.apache.org/jira/browse/FLINK-9805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321579#comment-17321579 ] Flink Jira Bot commented on FLINK-9805: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9155) Provide message context information in DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-9155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321595#comment-17321595 ] Flink Jira Bot commented on FLINK-9155: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function

[ https://issues.apache.org/jira/browse/FLINK-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321583#comment-17321583 ] Flink Jira Bot commented on FLINK-9600: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-9621) Warning when enabling partition discovery

[ https://issues.apache.org/jira/browse/FLINK-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9621: -- Labels: stale-minor (was: ) > Warning when enabling partition discovery >

[jira] [Updated] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]

[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9221: -- Labels: flink stale-minor (was: flink) > Add method SinkFunction[A]#contramap[B](f: B => A):

[jira] [Updated] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

[ https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9390: -- Labels: stale-minor (was: ) > Shutdown of KafkaProducer causes confusing log message >

[jira] [Updated] (FLINK-9675) Avoid FileInputStream/FileOutputStream

[ https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9675: -- Labels: filesystem pull-request-available stale-minor (was: filesystem

[jira] [Commented] (FLINK-9395) Outer Joins with array types on the outer join input fail

[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321587#comment-17321587 ] Flink Jira Bot commented on FLINK-9395: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-9454) Build instructions for MapR do not work

[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9454: -- Labels: stale-minor (was: ) > Build instructions for MapR do not work >

[jira] [Updated] (FLINK-9395) Outer Joins with array types on the outer join input fail

[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9395: -- Labels: stale-minor (was: ) > Outer Joins with array types on the outer join input fail >

[jira] [Commented] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

[ https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321588#comment-17321588 ] Flink Jira Bot commented on FLINK-9390: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9621) Warning when enabling partition discovery

[ https://issues.apache.org/jira/browse/FLINK-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321582#comment-17321582 ] Flink Jira Bot commented on FLINK-9621: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9422) Dedicated DISTINCT operator for streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321586#comment-17321586 ] Flink Jira Bot commented on FLINK-9422: --- This issue and all of its Sub-Tasks have not been updated

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

[ https://issues.apache.org/jira/browse/FLINK-9824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9824: -- Labels: stale-minor (was: ) > Support IPv6 literal > > >

[jira] [Updated] (FLINK-9837) Display the job description in the Flink web UI

[ https://issues.apache.org/jira/browse/FLINK-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9837: -- Labels: stale-minor (was: ) > Display the job description in the Flink web UI >

[jira] [Commented] (FLINK-9989) The documentation of API Migration Guides is out of date

[ https://issues.apache.org/jira/browse/FLINK-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321574#comment-17321574 ] Flink Jira Bot commented on FLINK-9989: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9837) Display the job description in the Flink web UI

[ https://issues.apache.org/jira/browse/FLINK-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321577#comment-17321577 ] Flink Jira Bot commented on FLINK-9837: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9639) Order "User Configuration" Alphabetically on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-9639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321581#comment-17321581 ] Flink Jira Bot commented on FLINK-9639: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for Table API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321576#comment-17321576 ] Flink Jira Bot commented on FLINK-9970: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10036: --- Labels: stale-minor usability (was: usability) > Flink's CSV output format is not

[jira] [Updated] (FLINK-9970) Add ASCII/CHR function for Table API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9970: -- Labels: pull-request-available stale-minor (was: pull-request-available) > Add ASCII/CHR

[jira] [Commented] (FLINK-9971) Add more extensive documentation for operations that combine datastreams

[ https://issues.apache.org/jira/browse/FLINK-9971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321575#comment-17321575 ] Flink Jira Bot commented on FLINK-9971: --- This issue and all of its Sub-Tasks have not been updated

[jira] [Updated] (FLINK-10037) Document details event time behavior in a single location

[ https://issues.apache.org/jira/browse/FLINK-10037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10037: --- Labels: pull-request-available stale-minor (was: pull-request-available) > Document

[jira] [Commented] (FLINK-10048) Migrate module flink-gelly-examples to flink-examples and rename it

[ https://issues.apache.org/jira/browse/FLINK-10048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321570#comment-17321570 ] Flink Jira Bot commented on FLINK-10048: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x

[ https://issues.apache.org/jira/browse/FLINK-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10148: --- Labels: stale-minor (was: ) > flink cancel withSavepoint does not seem to use akka

[jira] [Updated] (FLINK-9989) The documentation of API Migration Guides is out of date

[ https://issues.apache.org/jira/browse/FLINK-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9989: -- Labels: stale-minor (was: ) > The documentation of API Migration Guides is out of date >

[jira] [Updated] (FLINK-10048) Migrate module flink-gelly-examples to flink-examples and rename it

[ https://issues.apache.org/jira/browse/FLINK-10048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10048: --- Labels: stale-minor (was: ) > Migrate module flink-gelly-examples to flink-examples and

[jira] [Updated] (FLINK-16365) awaitTermination() result is not checked

[ https://issues.apache.org/jira/browse/FLINK-16365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16365: --- Labels: stale-minor (was: ) > awaitTermination() result is not checked >

[jira] [Updated] (FLINK-16449) Deprecated methods in the Table API walkthrough.

[ https://issues.apache.org/jira/browse/FLINK-16449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16449: --- Labels: stale-minor (was: ) > Deprecated methods in the Table API walkthrough. >

[jira] [Updated] (FLINK-10387) StateBackend create methods should return interface not abstract KeyedStateBackend classes

[ https://issues.apache.org/jira/browse/FLINK-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10387: --- Labels: stale-minor (was: ) > StateBackend create methods should return interface not

[jira] [Commented] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x

[ https://issues.apache.org/jira/browse/FLINK-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321569#comment-17321569 ] Flink Jira Bot commented on FLINK-10148: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10372) There is no API to configure the timer state backend

[ https://issues.apache.org/jira/browse/FLINK-10372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10372: --- Labels: stale-minor (was: ) > There is no API to configure the timer state backend >

[jira] [Commented] (FLINK-10388) RestClientTest sometimes fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-10388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321562#comment-17321562 ] Flink Jira Bot commented on FLINK-10388: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-10420) Create and drop view in sql client should check the view created based on the configuration.

[ https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321560#comment-17321560 ] Flink Jira Bot commented on FLINK-10420: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10561) Flink doesn't start locally if remove log package

[ https://issues.apache.org/jira/browse/FLINK-10561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10561: --- Labels: stale-minor (was: ) > Flink doesn't start locally if remove log package >

[jira] [Updated] (FLINK-17574) Deduplicate the process execution logic in Flink

[ https://issues.apache.org/jira/browse/FLINK-17574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17574: --- Labels: stale-minor (was: ) > Deduplicate the process execution logic in Flink >

[jira] [Commented] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321573#comment-17321573 ] Flink Jira Bot commented on FLINK-10036: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-16481) Improved FlinkkafkaConnector support for dynamically increasing capacity

[ https://issues.apache.org/jira/browse/FLINK-16481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321400#comment-17321400 ] Flink Jira Bot commented on FLINK-16481: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10388) RestClientTest sometimes fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-10388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10388: --- Labels: stale-minor (was: ) > RestClientTest sometimes fails with AssertionError >

[jira] [Updated] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized

[ https://issues.apache.org/jira/browse/FLINK-10525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10525: --- Labels: stale-minor (was: ) > Deserialization schema, skip data, that couldn't be properly

[jira] [Updated] (FLINK-9971) Add more extensive documentation for operations that combine datastreams

[ https://issues.apache.org/jira/browse/FLINK-9971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9971: -- Labels: stale-minor (was: ) > Add more extensive documentation for operations that combine

[jira] [Updated] (FLINK-10604) Add REMAINDER math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10604: --- Labels: pull-request-available stale-minor (was: pull-request-available) > Add REMAINDER

[jira] [Commented] (FLINK-10037) Document details event time behavior in a single location

[ https://issues.apache.org/jira/browse/FLINK-10037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321571#comment-17321571 ] Flink Jira Bot commented on FLINK-10037: This issue and all of its Sub-Tasks have not been

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

[ https://issues.apache.org/jira/browse/FLINK-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321554#comment-17321554 ] Flink Jira Bot commented on FLINK-10604: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-10372) There is no API to configure the timer state backend

[ https://issues.apache.org/jira/browse/FLINK-10372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321564#comment-17321564 ] Flink Jira Bot commented on FLINK-10372: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-10272) using Avro's DateConversion causes ClassNotFoundException on Hadoop bundle

[ https://issues.apache.org/jira/browse/FLINK-10272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321566#comment-17321566 ] Flink Jira Bot commented on FLINK-10272: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-10387) StateBackend create methods should return interface not abstract KeyedStateBackend classes

[ https://issues.apache.org/jira/browse/FLINK-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321563#comment-17321563 ] Flink Jira Bot commented on FLINK-10387: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-10871) ExecutionEnvironment & TableEnvironment should be singleton

[ https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321549#comment-17321549 ] Flink Jira Bot commented on FLINK-10871: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-10656) Refactor org.apache.flink.runtime.io.network.api.reader.ReaderBase

[ https://issues.apache.org/jira/browse/FLINK-10656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321552#comment-17321552 ] Flink Jira Bot commented on FLINK-10656: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10272) using Avro's DateConversion causes ClassNotFoundException on Hadoop bundle

[ https://issues.apache.org/jira/browse/FLINK-10272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10272: --- Labels: stale-minor (was: ) > using Avro's DateConversion causes ClassNotFoundException on

[jira] [Commented] (FLINK-10239) Register eventtime timer only once in eventtrigger

[ https://issues.apache.org/jira/browse/FLINK-10239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321567#comment-17321567 ] Flink Jira Bot commented on FLINK-10239: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10194) Serialization issue with Scala's AggregateDataSet[Row]

[ https://issues.apache.org/jira/browse/FLINK-10194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10194: --- Labels: scala serialization stale-minor (was: scala serialization) > Serialization issue

[jira] [Updated] (FLINK-11028) Disable deployment of flink-fs-tests

[ https://issues.apache.org/jira/browse/FLINK-11028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11028: --- Labels: stale-minor (was: ) > Disable deployment of flink-fs-tests >

[jira] [Commented] (FLINK-10194) Serialization issue with Scala's AggregateDataSet[Row]

[ https://issues.apache.org/jira/browse/FLINK-10194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321568#comment-17321568 ] Flink Jira Bot commented on FLINK-10194: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10947) Document handling of null keys in the data types documentation

[ https://issues.apache.org/jira/browse/FLINK-10947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10947: --- Labels: documentation key stale-minor type-converter (was: documentation key

[jira] [Commented] (FLINK-10950) RocksDB backend does not work on Windows due to path issue

[ https://issues.apache.org/jira/browse/FLINK-10950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321547#comment-17321547 ] Flink Jira Bot commented on FLINK-10950: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10296) TypeExtractor only validates/matches exact POJO classes

[ https://issues.apache.org/jira/browse/FLINK-10296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10296: --- Labels: stale-minor (was: ) > TypeExtractor only validates/matches exact POJO classes >

[jira] [Updated] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils

[ https://issues.apache.org/jira/browse/FLINK-10391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10391: --- Labels: stale-minor (was: ) > MillisOfDay is used in place of instant for LocalTime ctor

[jira] [Commented] (FLINK-10296) TypeExtractor only validates/matches exact POJO classes

[ https://issues.apache.org/jira/browse/FLINK-10296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321565#comment-17321565 ] Flink Jira Bot commented on FLINK-10296: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10239) Register eventtime timer only once in eventtrigger

[ https://issues.apache.org/jira/browse/FLINK-10239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10239: --- Labels: stale-minor (was: ) > Register eventtime timer only once in eventtrigger >

[jira] [Commented] (FLINK-11133) FsCheckpointStorage is unaware about S3 entropy when creating directories

[ https://issues.apache.org/jira/browse/FLINK-11133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321545#comment-17321545 ] Flink Jira Bot commented on FLINK-11133: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10420) Create and drop view in sql client should check the view created based on the configuration.

[ https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10420: --- Labels: stale-minor (was: ) > Create and drop view in sql client should check the view

[jira] [Commented] (FLINK-11228) Flink web UI can not read stdout logs

[ https://issues.apache.org/jira/browse/FLINK-11228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321543#comment-17321543 ] Flink Jira Bot commented on FLINK-11228: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-11133) FsCheckpointStorage is unaware about S3 entropy when creating directories

[ https://issues.apache.org/jira/browse/FLINK-11133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11133: --- Labels: stale-minor (was: ) > FsCheckpointStorage is unaware about S3 entropy when

[jira] [Commented] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils

[ https://issues.apache.org/jira/browse/FLINK-10391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321561#comment-17321561 ] Flink Jira Bot commented on FLINK-10391: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321559#comment-17321559 ] Flink Jira Bot commented on FLINK-10464: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10477) Add rescale button to web interface

[ https://issues.apache.org/jira/browse/FLINK-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10477: --- Labels: stale-minor (was: ) > Add rescale button to web interface >

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10464: --- Labels: stale-minor (was: ) > TimeIndicatorRelDataType: digest can not describe a type

[jira] [Commented] (FLINK-10477) Add rescale button to web interface

[ https://issues.apache.org/jira/browse/FLINK-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321558#comment-17321558 ] Flink Jira Bot commented on FLINK-10477: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-10485) Gremlin Support from Flink for Graph Processing

[ https://issues.apache.org/jira/browse/FLINK-10485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10485: --- Labels: stale-minor (was: ) > Gremlin Support from Flink for Graph Processing >

[jira] [Updated] (FLINK-11324) Custom Log4j properties for each flink job

[ https://issues.apache.org/jira/browse/FLINK-11324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11324: --- Labels: stale-minor (was: ) > Custom Log4j properties for each flink job >

[jira] [Commented] (FLINK-10485) Gremlin Support from Flink for Graph Processing

[ https://issues.apache.org/jira/browse/FLINK-10485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321557#comment-17321557 ] Flink Jira Bot commented on FLINK-10485: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-11344) Display All Execution Attempt Information on Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-11344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11344: --- Labels: pull-request-available stale-minor (was: pull-request-available) > Display All

[jira] [Updated] (FLINK-11399) Parsing nested ROW()s in SQL

[ https://issues.apache.org/jira/browse/FLINK-11399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11399: --- Labels: stale-minor (was: ) > Parsing nested ROW()s in SQL >

[jira] [Updated] (FLINK-11433) JOIN on a table having a column of type MULTISET gives a NPE

[ https://issues.apache.org/jira/browse/FLINK-11433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11433: --- Labels: stale-minor (was: ) > JOIN on a table having a column of type MULTISET gives a

[jira] [Commented] (FLINK-11399) Parsing nested ROW()s in SQL

[ https://issues.apache.org/jira/browse/FLINK-11399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321539#comment-17321539 ] Flink Jira Bot commented on FLINK-11399: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-11344) Display All Execution Attempt Information on Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-11344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321540#comment-17321540 ] Flink Jira Bot commented on FLINK-11344: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-11416) DISTINCT on a JOIN inside of an UNION is not working

[ https://issues.apache.org/jira/browse/FLINK-11416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11416: --- Labels: stale-minor (was: ) > DISTINCT on a JOIN inside of an UNION is not working >

[jira] [Commented] (FLINK-10660) Failed index data to Elastic search using Flink-connector-elasticsearch with JUNIT test

[ https://issues.apache.org/jira/browse/FLINK-10660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321551#comment-17321551 ] Flink Jira Bot commented on FLINK-10660: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-10561) Flink doesn't start locally if remove log package

[ https://issues.apache.org/jira/browse/FLINK-10561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321555#comment-17321555 ] Flink Jira Bot commented on FLINK-10561: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-11028) Disable deployment of flink-fs-tests

[ https://issues.apache.org/jira/browse/FLINK-11028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321546#comment-17321546 ] Flink Jira Bot commented on FLINK-11028: This issue and all of its Sub-Tasks have not been

<    1   2   3   4   5   6   7   8   9   10   >