[jira] [Reopened] (FLINK-5873) KeyedStream: expose an user defined function for key group assignment

[ https://issues.apache.org/jira/browse/FLINK-5873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-5873: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > KeyedStre

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-10296: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > TypeEx

[jira] [Reopened] (FLINK-7467) a slow client on the BlobServer may block writing operations

[ https://issues.apache.org/jira/browse/FLINK-7467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-7467: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > a slow cl

[jira] [Reopened] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-17444: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Stream

[jira] [Reopened] (FLINK-8307) org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments

[ https://issues.apache.org/jira/browse/FLINK-8307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-8307: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > org.apach

[jira] [Reopened] (FLINK-14097) Optimize AsyncWaitOperator to process more than one element per mailbox letter

[ https://issues.apache.org/jira/browse/FLINK-14097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14097: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Optimi

[jira] [Reopened] (FLINK-3494) Integrate plan visualizer with web page

[ https://issues.apache.org/jira/browse/FLINK-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-3494: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Integrate

[jira] [Reopened] (FLINK-13664) "MD5" and "SHA" functions should SqlTypeFamily.CHARACTER instend of SqlTypeFamily.STRING

[ https://issues.apache.org/jira/browse/FLINK-13664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-13664: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > "MD5"

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

[ https://issues.apache.org/jira/browse/FLINK-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-8410: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Kafka con

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

[ https://issues.apache.org/jira/browse/FLINK-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-9621: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Warning w

[jira] [Reopened] (FLINK-16920) Flink UI cancel uses an undocumented rest api and uses GET rather than a mutating HTTP method

[ https://issues.apache.org/jira/browse/FLINK-16920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-16920: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Flink

[jira] [Reopened] (FLINK-14442) Add time based interval execution to JDBC connectors.

[ https://issues.apache.org/jira/browse/FLINK-14442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14442: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add ti

[jira] [Reopened] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort

[ https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-8037: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Missing c

[jira] [Reopened] (FLINK-3917) Remove mouse focus from plan visualizer

[ https://issues.apache.org/jira/browse/FLINK-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-3917: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Remove mo

[jira] [Reopened] (FLINK-12691) Make Queue Capacity and Timeout of AsyncWaitOperator changeable during runtime

[ https://issues.apache.org/jira/browse/FLINK-12691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-12691: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Make Q

[jira] [Reopened] (FLINK-3414) Add Scala DSL for CEP's pattern definition

[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-3414: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add Scala

[jira] [Reopened] (FLINK-14339) The checkpoint ID count wrong on restore savepoint log

[ https://issues.apache.org/jira/browse/FLINK-14339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14339: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > The ch

[jira] [Reopened] (FLINK-7682) Invalid state size formatting

[ https://issues.apache.org/jira/browse/FLINK-7682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-7682: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Invalid s

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-17574: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Dedupl

[jira] [Reopened] (FLINK-6889) Improve Path parsing for Windows paths with scheme

[ https://issues.apache.org/jira/browse/FLINK-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-6889: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Improve P

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-9221: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add metho

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-11324: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Custom

[jira] [Reopened] (FLINK-4721) Getting exception when using a key of type Option[String] in distinct operation

[ https://issues.apache.org/jira/browse/FLINK-4721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4721: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Getting e

[jira] [Reopened] (FLINK-16335) vertex timeline should display all status other than the last one

[ https://issues.apache.org/jira/browse/FLINK-16335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-16335: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > vertex

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-16449: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Deprec

[jira] [Reopened] (FLINK-4295) CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run

[ https://issues.apache.org/jira/browse/FLINK-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4295: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > CoGroupGr

[jira] [Reopened] (FLINK-14933) translate "Data Streaming Fault Tolerance" page in to Chinese

[ https://issues.apache.org/jira/browse/FLINK-14933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14933: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > transl

[jira] [Reopened] (FLINK-5950) create an example for async-io with an http client

[ https://issues.apache.org/jira/browse/FLINK-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-5950: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > create an

[jira] [Reopened] (FLINK-8197) Support include conf directories in flink config

[ https://issues.apache.org/jira/browse/FLINK-8197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-8197: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Support i

[jira] [Reopened] (FLINK-9496) Job created time is reset after restart

[ https://issues.apache.org/jira/browse/FLINK-9496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-9496: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Job creat

[jira] [Reopened] (FLINK-8041) Recommended Improvements for Gelly's Connected Components Algorithm

[ https://issues.apache.org/jira/browse/FLINK-8041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-8041: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Recommend

[jira] [Reopened] (FLINK-1267) Add crossGroup operator

[ https://issues.apache.org/jira/browse/FLINK-1267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-1267: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add cross

[jira] [Reopened] (FLINK-19029) Collect mulitple jobs in 1 UI

[ https://issues.apache.org/jira/browse/FLINK-19029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-19029: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Collec

[jira] [Reopened] (FLINK-12305) Table API Clarification

[ https://issues.apache.org/jira/browse/FLINK-12305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-12305: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Table

[jira] [Reopened] (FLINK-685) Add support for semi-joins

[ https://issues.apache.org/jira/browse/FLINK-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-685: Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add support

[jira] [Reopened] (FLINK-5439) Adjust max parallelism when migrating

[ https://issues.apache.org/jira/browse/FLINK-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-5439: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Adjust ma

[jira] [Reopened] (FLINK-1509) Streaming Group Reduce Combiner

[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-1509: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Streaming

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

[ https://issues.apache.org/jira/browse/FLINK-14103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14103: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Stream

[jira] [Reopened] (FLINK-14161) Wrong description of ValueState

[ https://issues.apache.org/jira/browse/FLINK-14161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14161: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Wrong

[jira] [Reopened] (FLINK-15111) java.lang.RuntimeException for KafkaPartitionDiscoverer.getAllPartitionsForTopics(KafkaPartitionDiscoverer.java:80) when using SASL_SSL

[ https://issues.apache.org/jira/browse/FLINK-15111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-15111: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > java.l

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-10036: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Flink'

[jira] [Reopened] (FLINK-8141) Add AppendStreamTableSink for bucketed ORC files

[ https://issues.apache.org/jira/browse/FLINK-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-8141: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add Appen

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-10272: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > using

[jira] [Reopened] (FLINK-6054) Add new state backend that dynamically stores data in memory and external storage

[ https://issues.apache.org/jira/browse/FLINK-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-6054: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add new s

[jira] [Reopened] (FLINK-17884) package the codegen directory to flink-sql-parser jar

[ https://issues.apache.org/jira/browse/FLINK-17884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-17884: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > packag

[jira] [Reopened] (FLINK-5973) check whether the direct memory size is always correctly calculated

[ https://issues.apache.org/jira/browse/FLINK-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-5973: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > check whe

[jira] [Reopened] (FLINK-12095) Canceling vs cancelling

[ https://issues.apache.org/jira/browse/FLINK-12095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-12095: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Cancel

[jira] [Reopened] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag

[ https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-1521: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Some Chai

[jira] [Reopened] (FLINK-1092) Allow operations, other than join and cogroup, on the solution set

[ https://issues.apache.org/jira/browse/FLINK-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-1092: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Allow ope

[jira] [Reopened] (FLINK-13565) Integrate springboot found error

[ https://issues.apache.org/jira/browse/FLINK-13565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-13565: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Integr

[jira] [Reopened] (FLINK-16039) [Discuss] Add API method to get last element in session window

[ https://issues.apache.org/jira/browse/FLINK-16039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-16039: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > [Discu

[jira] [Reopened] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.

[ https://issues.apache.org/jira/browse/FLINK-6912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-6912: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Consider

[jira] [Reopened] (FLINK-4979) Submit Job view: Replace checkboxes for job entry with a link on the job name

[ https://issues.apache.org/jira/browse/FLINK-4979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4979: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Submit Jo

[jira] [Reopened] (FLINK-12383) "Log file environment variable 'log.file' is not set" despite web.log.path being set

[ https://issues.apache.org/jira/browse/FLINK-12383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-12383: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > "Log f

[jira] [Reopened] (FLINK-4438) FlinkML Quickstart Guide implies incorrect type for test data

[ https://issues.apache.org/jira/browse/FLINK-4438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4438: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > FlinkML Q

[jira] [Reopened] (FLINK-16734) Remove ClusterSpecification

[ https://issues.apache.org/jira/browse/FLINK-16734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-16734: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Remove

[jira] [Reopened] (FLINK-16230) Use LinkedHashSet instead of HashSet for a deterministic order when testing serialization

[ https://issues.apache.org/jira/browse/FLINK-16230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-16230: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Use Li

[jira] [Reopened] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14653: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Job-re

[jira] [Reopened] (FLINK-13258) Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator

[ https://issues.apache.org/jira/browse/FLINK-13258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-13258: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add te

[jira] [Reopened] (FLINK-14238) ParquetPojoInputFormat logging bug

[ https://issues.apache.org/jira/browse/FLINK-14238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14238: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Parque

[jira] [Reopened] (FLINK-4493) Unify the snapshot output format for keyed-state backends

[ https://issues.apache.org/jira/browse/FLINK-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4493: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Unify the

[jira] [Reopened] (FLINK-13638) Refactor RemoteChannelStateChecker#isProducerConsumerReadyOrAbortConsumption to return result action

[ https://issues.apache.org/jira/browse/FLINK-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-13638: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Refact

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

[ https://issues.apache.org/jira/browse/FLINK-9155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-9155: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Provide m

[jira] [Reopened] (FLINK-4761) Web UI can't display large log files

[ https://issues.apache.org/jira/browse/FLINK-4761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4761: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Web UI ca

[jira] [Reopened] (FLINK-14571) flink connector for redis

[ https://issues.apache.org/jira/browse/FLINK-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14571: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > flink

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-11433: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > JOIN

[jira] [Reopened] (FLINK-4868) Insertion sort could avoid the swaps

[ https://issues.apache.org/jira/browse/FLINK-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4868: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Insertion

[jira] [Reopened] (FLINK-13200) Improve the generated code for if statements

[ https://issues.apache.org/jira/browse/FLINK-13200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-13200: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Improv

[jira] [Reopened] (FLINK-2672) Add partitioned output format to HDFS RollingSink

[ https://issues.apache.org/jira/browse/FLINK-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-2672: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add parti

[jira] [Reopened] (FLINK-7341) Update code snippets in documentation

[ https://issues.apache.org/jira/browse/FLINK-7341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-7341: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Update co

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-11344: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Displa

[jira] [Reopened] (FLINK-16839) Connectors Kinesis metrics can be disabled

[ https://issues.apache.org/jira/browse/FLINK-16839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-16839: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Connec

[jira] [Reopened] (FLINK-9165) Improve CassandraSinkBase to send Collections

[ https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-9165: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Improve C

[jira] [Reopened] (FLINK-11643) Remove useless code of externalizedCheckpointsDir

[ https://issues.apache.org/jira/browse/FLINK-11643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-11643: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Remove

[jira] [Reopened] (FLINK-7128) Timestamp types in Table API documenation not correct

[ https://issues.apache.org/jira/browse/FLINK-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-7128: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Timestamp

[jira] [Reopened] (FLINK-16469) Improve logging configurations

[ https://issues.apache.org/jira/browse/FLINK-16469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-16469: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Improv

[jira] [Reopened] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete

[ https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-2367: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > “flink-xx

[jira] [Reopened] (FLINK-19580) Creating PackagedProgram overwrites an actual job name with default JobName

[ https://issues.apache.org/jira/browse/FLINK-19580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-19580: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Creati

[jira] [Reopened] (FLINK-20312) The documentation is incomplete

[ https://issues.apache.org/jira/browse/FLINK-20312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-20312: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > The do

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-10239: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Regist

[jira] [Reopened] (FLINK-16453) A test failure in KafkaTest

[ https://issues.apache.org/jira/browse/FLINK-16453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-16453: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > A test

[jira] [Reopened] (FLINK-4978) Present dropdown list with possible entry points for job

[ https://issues.apache.org/jira/browse/FLINK-4978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4978: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Present d

[jira] [Reopened] (FLINK-5550) NotFoundException: Could not find job with id

[ https://issues.apache.org/jira/browse/FLINK-5550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-5550: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > NotFoundE

[jira] [Reopened] (FLINK-11824) Event-time attribute cannot have same name as in original format

[ https://issues.apache.org/jira/browse/FLINK-11824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-11824: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Event-

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-9971: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add more

[jira] [Reopened] (FLINK-15979) Fix the merged count is not accurate in CountDistinctWithMerge

[ https://issues.apache.org/jira/browse/FLINK-15979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-15979: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Fix th

[jira] [Reopened] (FLINK-13246) Implement external shuffle service for Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-13246: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Implem

[jira] [Reopened] (FLINK-12782) Show formatted timestamp in Watermark Tab of JM Web UI

[ https://issues.apache.org/jira/browse/FLINK-12782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-12782: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Show f

[jira] [Reopened] (FLINK-5935) confusing/misleading error message when failing to restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-5935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-5935: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > confusing

[jira] [Reopened] (FLINK-15784) Show the Watermark metrics of source node in the web UI.

[ https://issues.apache.org/jira/browse/FLINK-15784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-15784: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Show t

[jira] [Reopened] (FLINK-12486) RocksDB State Backend docs don't explain that operator state is kept on heap

[ https://issues.apache.org/jira/browse/FLINK-12486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-12486: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > RocksD

[jira] [Reopened] (FLINK-2193) Partial shuffling

[ https://issues.apache.org/jira/browse/FLINK-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-2193: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Partial s

[jira] [Reopened] (FLINK-5744) Check remote connection in Flink-shell

[ https://issues.apache.org/jira/browse/FLINK-5744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-5744: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Check rem

[jira] [Reopened] (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 ] Konstantin Knauf reopened FLINK-10525: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Deseri

[jira] [Reopened] (FLINK-7689) Instrument the Flink JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-7689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-7689: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Instrumen

[jira] [Reopened] (FLINK-11661) Implement HadoopReduceCombineFunctionITCase for new Hadoop API

[ https://issues.apache.org/jira/browse/FLINK-11661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-11661: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Implem

[jira] [Reopened] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure

[ https://issues.apache.org/jira/browse/FLINK-14110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-14110: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Deleti

[jira] [Reopened] (FLINK-1261) Handling of full temporary directories at startup and runtime

[ https://issues.apache.org/jira/browse/FLINK-1261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-1261: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Handling

[jira] [Reopened] (FLINK-12879) Improve the performance of AbstractBinaryWriter

[ https://issues.apache.org/jira/browse/FLINK-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-12879: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Improv

[jira] [Reopened] (FLINK-13252) Common CachedLookupFunction for All connector

[ https://issues.apache.org/jira/browse/FLINK-13252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-13252: -- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Common

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