[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321505#comment-17321505 ] Flink Jira Bot commented on FLINK-12691: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-12941) Translate "Amazon AWS Kinesis Streams Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12941: --- Labels: stale-minor (was: ) > Translate "Amazon AWS Kinesis Streams Connector" page into Ch

[jira] [Commented] (FLINK-12593) Revise the document for CEP

[ https://issues.apache.org/jira/browse/FLINK-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321508#comment-17321508 ] Flink Jira Bot commented on FLINK-12593: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-12521) Use minio as AWS S3 alternative in end-to-end tests

[ https://issues.apache.org/jira/browse/FLINK-12521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12521: --- Labels: stale-minor (was: ) > Use minio as AWS S3 alternative in end-to-end tests > ---

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321504#comment-17321504 ] Flink Jira Bot commented on FLINK-12782: This issue and all of its Sub-Tasks hav

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321510#comment-17321510 ] Flink Jira Bot commented on FLINK-12486: This issue and all of its Sub-Tasks hav

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

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

[jira] [Commented] (FLINK-12521) Use minio as AWS S3 alternative in end-to-end tests

[ https://issues.apache.org/jira/browse/FLINK-12521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321509#comment-17321509 ] Flink Jira Bot commented on FLINK-12521: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-13053) Vectorization Support in Flink

[ https://issues.apache.org/jira/browse/FLINK-13053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321499#comment-17321499 ] Flink Jira Bot commented on FLINK-13053: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-12672) Use SingleInputGate.closeFuture in triggerPartitionStateCheck instead of consumer state in RemoteChannelStateChecker

[ https://issues.apache.org/jira/browse/FLINK-12672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321506#comment-17321506 ] Flink Jira Bot commented on FLINK-12672: This issue and all of its Sub-Tasks hav

[jira] [Updated] (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 ] Flink Jira Bot updated FLINK-12486: --- Labels: pull-request-available stale-minor (was: pull-request-available) > RocksDB State Ba

[jira] [Commented] (FLINK-12373) Improve checkpointing metrics

[ https://issues.apache.org/jira/browse/FLINK-12373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321512#comment-17321512 ] Flink Jira Bot commented on FLINK-12373: This issue and all of its Sub-Tasks hav

[jira] [Updated] (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 ] Flink Jira Bot updated FLINK-12383: --- Labels: stale-minor (was: ) > "Log file environment variable 'log.file' is not set" despite

[jira] [Updated] (FLINK-12373) Improve checkpointing metrics

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321511#comment-17321511 ] Flink Jira Bot commented on FLINK-12383: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-12320) Flink bucketing sink restart with save point cause data loss when using SequenceFile.CompressionType.BLOCK

[ https://issues.apache.org/jira/browse/FLINK-12320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321513#comment-17321513 ] Flink Jira Bot commented on FLINK-12320: This issue and all of its Sub-Tasks hav

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

[ https://issues.apache.org/jira/browse/FLINK-12305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321514#comment-17321514 ] Flink Jira Bot commented on FLINK-12305: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-12632) Flink WebUI doesn't show the full error response when a job deployment fails

[ https://issues.apache.org/jira/browse/FLINK-12632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321507#comment-17321507 ] Flink Jira Bot commented on FLINK-12632: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-19283) Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods

[ https://issues.apache.org/jira/browse/FLINK-19283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19283: --- Labels: stale-minor (was: ) > Allow subclasses to override/extend FlinkKafkaConsumerBase ch

[jira] [Updated] (FLINK-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment

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

[jira] [Closed] (FLINK-17324) Move the image we use to generate the docker official-images changes into flink-docker

[ https://issues.apache.org/jira/browse/FLINK-17324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17324. Resolution: Fixed docker-master: e47a802fba3ffbf7a496247cc3435d706216fa47 > Move the imag

[jira] [Commented] (FLINK-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment

[ https://issues.apache.org/jira/browse/FLINK-12259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321516#comment-17321516 ] Flink Jira Bot commented on FLINK-12259: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-12215) Introduce SqlProcessFunction for blink streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-12215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321517#comment-17321517 ] Flink Jira Bot commented on FLINK-12215: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-12215) Introduce SqlProcessFunction for blink streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-12215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12215: --- Labels: stale-minor (was: ) > Introduce SqlProcessFunction for blink streaming runtime > --

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

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

[jira] [Commented] (FLINK-12044) Flink CEP discards events as late if they have timestamps <= 0

[ https://issues.apache.org/jira/browse/FLINK-12044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321523#comment-17321523 ] Flink Jira Bot commented on FLINK-12044: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-12166) env.java.opts not taken into account on Windows

[ https://issues.apache.org/jira/browse/FLINK-12166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321518#comment-17321518 ] Flink Jira Bot commented on FLINK-12166: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-12166) env.java.opts not taken into account on Windows

[ https://issues.apache.org/jira/browse/FLINK-12166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12166: --- Labels: stale-minor (was: ) > env.java.opts not taken into account on Windows > ---

[jira] [Updated] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime

[ https://issues.apache.org/jira/browse/FLINK-11895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11895: --- Labels: stale-minor (was: ) > Allow FileSystem Configs to be altered at Runtime > -

[jira] [Commented] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

[ https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321519#comment-17321519 ] Flink Jira Bot commented on FLINK-12141: This issue and all of its Sub-Tasks hav

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

[ https://issues.apache.org/jira/browse/FLINK-12095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321520#comment-17321520 ] Flink Jira Bot commented on FLINK-12095: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-12085) Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint'

[ https://issues.apache.org/jira/browse/FLINK-12085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12085: --- Labels: stale-minor (was: ) > Improve Mesos job cluster entry point 'MesosJobClusterEntryp

[jira] [Updated] (FLINK-12044) Flink CEP discards events as late if they have timestamps <= 0

[ https://issues.apache.org/jira/browse/FLINK-12044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12044: --- Labels: stale-minor (was: ) > Flink CEP discards events as late if they have timestamps <=

[jira] [Commented] (FLINK-11852) Improve Processing function example

[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321526#comment-17321526 ] Flink Jira Bot commented on FLINK-11852: This issue and all of its Sub-Tasks hav

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321527#comment-17321527 ] Flink Jira Bot commented on FLINK-11824: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

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

[jira] [Commented] (FLINK-12060) Unify change pom version scripts

[ https://issues.apache.org/jira/browse/FLINK-12060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321522#comment-17321522 ] Flink Jira Bot commented on FLINK-12060: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-11852) Improve Processing function example

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

[jira] [Commented] (FLINK-11709) Bump jline version

[ https://issues.apache.org/jira/browse/FLINK-11709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321530#comment-17321530 ] Flink Jira Bot commented on FLINK-11709: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-12060) Unify change pom version scripts

[ https://issues.apache.org/jira/browse/FLINK-12060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12060: --- Labels: stale-minor (was: ) > Unify change pom version scripts > --

[jira] [Commented] (FLINK-12085) Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint'

[ https://issues.apache.org/jira/browse/FLINK-12085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321521#comment-17321521 ] Flink Jira Bot commented on FLINK-12085: This issue and all of its Sub-Tasks hav

[jira] [Updated] (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 ] Flink Jira Bot updated FLINK-11824: --- Labels: stale-minor (was: ) > Event-time attribute cannot have same name as in original for

[jira] [Commented] (FLINK-11991) Set headers to use for CSV output

[ https://issues.apache.org/jira/browse/FLINK-11991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321524#comment-17321524 ] Flink Jira Bot commented on FLINK-11991: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-19164) Release scripts break other dependency versions unintentionally

[ https://issues.apache.org/jira/browse/FLINK-19164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19164: - Labels: (was: stale-minor) > Release scripts break other dependency versions unintenti

[jira] [Updated] (FLINK-11709) Bump jline version

[ https://issues.apache.org/jira/browse/FLINK-11709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11709: --- Labels: stale-minor (was: ) > Bump jline version > -- > > K

[jira] [Updated] (FLINK-11991) Set headers to use for CSV output

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

[jira] [Updated] (FLINK-11805) A Common External Shuffle Service Framework

[ https://issues.apache.org/jira/browse/FLINK-11805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11805: --- Labels: stale-minor (was: ) > A Common External Shuffle Service Framework > ---

[jira] [Commented] (FLINK-11805) A Common External Shuffle Service Framework

[ https://issues.apache.org/jira/browse/FLINK-11805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321528#comment-17321528 ] Flink Jira Bot commented on FLINK-11805: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-11660) Implement HadoopReduceFunctionITCase for new Hadoop API

[ https://issues.apache.org/jira/browse/FLINK-11660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321533#comment-17321533 ] Flink Jira Bot commented on FLINK-11660: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime

[ https://issues.apache.org/jira/browse/FLINK-11895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321525#comment-17321525 ] Flink Jira Bot commented on FLINK-11895: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-11705) Port org.apache.flink.runtime.testingUtils.TestingUtils to Java

[ https://issues.apache.org/jira/browse/FLINK-11705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321531#comment-17321531 ] Flink Jira Bot commented on FLINK-11705: This issue and all of its Sub-Tasks hav

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

[ https://issues.apache.org/jira/browse/FLINK-11643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321535#comment-17321535 ] Flink Jira Bot commented on FLINK-11643: This issue and all of its Sub-Tasks hav

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

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

[jira] [Updated] (FLINK-11659) Implement HadoopMapFunctionITCase for new Hadoop API

[ https://issues.apache.org/jira/browse/FLINK-11659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11659: --- Labels: stale-minor (was: ) > Implement HadoopMapFunctionITCase for new Hadoop API > --

[jira] [Commented] (FLINK-11748) Optimize savepoint: Remove the task states and KeyedState into increments.

[ https://issues.apache.org/jira/browse/FLINK-11748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321529#comment-17321529 ] Flink Jira Bot commented on FLINK-11748: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-11659) Implement HadoopMapFunctionITCase for new Hadoop API

[ https://issues.apache.org/jira/browse/FLINK-11659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321534#comment-17321534 ] Flink Jira Bot commented on FLINK-11659: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-11595) Gelly's addEdge() in certain circumstances still includes duplicate vertices.

[ https://issues.apache.org/jira/browse/FLINK-11595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11595: --- Labels: stale-minor (was: ) > Gelly's addEdge() in certain circumstances still includes dup

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

[ https://issues.apache.org/jira/browse/FLINK-11661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321532#comment-17321532 ] Flink Jira Bot commented on FLINK-11661: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-11660) Implement HadoopReduceFunctionITCase for new Hadoop API

[ https://issues.apache.org/jira/browse/FLINK-11660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11660: --- Labels: stale-minor (was: ) > Implement HadoopReduceFunctionITCase for new Hadoop API > ---

[jira] [Commented] (FLINK-11255) RemoteStreamEnvironment should be able to execute in detached mode

[ https://issues.apache.org/jira/browse/FLINK-11255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321542#comment-17321542 ] Flink Jira Bot commented on FLINK-11255: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-11705) Port org.apache.flink.runtime.testingUtils.TestingUtils to Java

[ https://issues.apache.org/jira/browse/FLINK-11705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11705: --- Labels: stale-minor (was: ) > Port org.apache.flink.runtime.testingUtils.TestingUtils to Ja

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

[ https://issues.apache.org/jira/browse/FLINK-11324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321541#comment-17321541 ] Flink Jira Bot commented on FLINK-11324: This issue and all of its Sub-Tasks hav

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321537#comment-17321537 ] Flink Jira Bot commented on FLINK-11433: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-11255) RemoteStreamEnvironment should be able to execute in detached mode

[ https://issues.apache.org/jira/browse/FLINK-11255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11255: --- Labels: stale-minor (was: ) > RemoteStreamEnvironment should be able to execute in detached

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321538#comment-17321538 ] Flink Jira Bot commented on FLINK-11416: This issue and all of its Sub-Tasks hav

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-11228: --- Labels: stale-minor (was: ) > Flink web UI can not read stdout logs > -

[jira] [Updated] (FLINK-11748) Optimize savepoint: Remove the task states and KeyedState into increments.

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

[jira] [Updated] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication.

[ https://issues.apache.org/jira/browse/FLINK-11204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11204: --- Labels: stale-minor (was: ) > flink start-scala-shell.sh do not work in security mode with

[jira] [Commented] (FLINK-11595) Gelly's addEdge() in certain circumstances still includes duplicate vertices.

[ https://issues.apache.org/jira/browse/FLINK-11595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321536#comment-17321536 ] Flink Jira Bot commented on FLINK-11595: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication.

[ https://issues.apache.org/jira/browse/FLINK-11204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321544#comment-17321544 ] Flink Jira Bot commented on FLINK-11204: This issue and all of its Sub-Tasks hav

[jira] [Updated] (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 ] Flink Jira Bot updated FLINK-11661: --- Labels: stale-minor (was: ) > Implement HadoopReduceCombineFunctionITCase for new Hadoop AP

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

[ https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10871: --- Labels: stale-minor (was: ) > ExecutionEnvironment & TableEnvironment should be singleton >

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-10660: --- Labels: stale-minor (was: ) > Failed index data to Elastic search using Flink-connector-ela

[jira] [Commented] (FLINK-10611) Documentation should describe how to choose between Rolling & Streaming file sink

[ https://issues.apache.org/jira/browse/FLINK-10611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321553#comment-17321553 ] Flink Jira Bot commented on FLINK-10611: This issue and all of its Sub-Tasks hav

[jira] [Updated] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

[ https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10844: --- Labels: stale-minor (was: ) > ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2

[jira] [Updated] (FLINK-10611) Documentation should describe how to choose between Rolling & Streaming file sink

[ https://issues.apache.org/jira/browse/FLINK-10611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10611: --- Labels: stale-minor (was: ) > Documentation should describe how to choose between Rolling &

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321556#comment-17321556 ] Flink Jira Bot commented on FLINK-10525: This issue and all of its Sub-Tasks hav

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-10656: --- Labels: pull-request-available stale-minor (was: pull-request-available) > Refactor org.apa

[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&focusedCommentId=17321546#comment-17321546 ] Flink Jira Bot commented on FLINK-11028: This issue and all of its Sub-Tasks hav

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17321548#comment-17321548 ] Flink Jira Bot commented on FLINK-10947: This issue and all of its Sub-Tasks hav

[jira] [Commented] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

[ https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321550#comment-17321550 ] Flink Jira Bot commented on FLINK-10844: This issue and all of its Sub-Tasks hav

[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&focusedCommentId=17321555#comment-17321555 ] Flink Jira Bot commented on FLINK-10561: This issue and all of its Sub-Tasks hav

[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&focusedCommentId=17321551#comment-17321551 ] Flink Jira Bot commented on FLINK-10660: This issue and all of its Sub-Tasks hav

[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-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&focusedCommentId=17321540#comment-17321540 ] Flink Jira Bot commented on FLINK-11344: This issue and all of its Sub-Tasks hav

[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 NPE

[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&focusedCommentId=17321539#comment-17321539 ] Flink Jira Bot commented on FLINK-11399: This issue and all of its Sub-Tasks hav

[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-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 Exec

[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&focusedCommentId=17321557#comment-17321557 ] Flink Jira Bot commented on FLINK-10485: This issue and all of its Sub-Tasks hav

[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] [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&focusedCommentId=17321558#comment-17321558 ] Flink Jira Bot commented on FLINK-10477: This issue and all of its Sub-Tasks hav

[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&focusedCommentId=17321559#comment-17321559 ] Flink Jira Bot commented on FLINK-10464: This issue and all of its Sub-Tasks hav

[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 comp

[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 creating

[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&focusedCommentId=17321561#comment-17321561 ] Flink Jira Bot commented on FLINK-10391: This issue and all of its Sub-Tasks hav

[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 crea

[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&focusedCommentId=17321543#comment-17321543 ] Flink Jira Bot commented on FLINK-11228: This issue and all of its Sub-Tasks hav

<    3   4   5   6   7   8   9   10   11   12   >