[jira] [Updated] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala

[ https://issues.apache.org/jira/browse/FLINK-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10167: --- Component/s: API / DataStream > SessionWindows not compatible with typed DataStreams in

[jira] [Updated] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9043: -- Component/s: Runtime / Checkpointing > Introduce a friendly way to resume the job from

[jira] [Updated] (FLINK-11457) PrometheusPushGatewayReporter does not cleanup its metrics

[ https://issues.apache.org/jira/browse/FLINK-11457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11457: --- Component/s: Runtime / Metrics > PrometheusPushGatewayReporter does not cleanup its metrics

[jira] [Updated] (FLINK-11247) Fix DESCRIBE command to support catalog tables

[ https://issues.apache.org/jira/browse/FLINK-11247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11247: --- Component/s: Connectors / Hive > Fix DESCRIBE command to support catalog tables >

[jira] [Updated] (FLINK-9924) Upgrade zookeeper to 3.4.13

[ https://issues.apache.org/jira/browse/FLINK-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9924: -- Component/s: Runtime / Coordination > Upgrade zookeeper to 3.4.13 >

[jira] [Updated] (FLINK-11205) Task Manager Metaspace Memory Leak

[ https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11205: --- Component/s: Runtime / Coordination > Task Manager Metaspace Memory Leak >

[jira] [Updated] (FLINK-11438) Config for submitted job path

[ https://issues.apache.org/jira/browse/FLINK-11438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11438: --- Component/s: Runtime / Web Frontend > Config for submitted job path >

[jira] [Updated] (FLINK-11208) Decrease build/testing time of modules

[ https://issues.apache.org/jira/browse/FLINK-11208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11208: --- Component/s: Build System > Decrease build/testing time of modules >

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10672: --- Component/s: Runtime / Coordination > Task stuck while writing output to flink >

[jira] [Updated] (FLINK-11105) Add a new implementation of the HighAvailabilityServices using etcd

[ https://issues.apache.org/jira/browse/FLINK-11105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11105: --- Component/s: Runtime / Coordination > Add a new implementation of the

[jira] [Updated] (FLINK-8822) RotateLogFile may not work well when sed version is below 4.2

[ https://issues.apache.org/jira/browse/FLINK-8822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-8822: -- Component/s: Command Line Client > RotateLogFile may not work well when sed version is below

[GitHub] aljoscha commented on issue #7156: [FLINK-10967] Update kafka dependency to 2.1.1

aljoscha commented on issue #7156: [FLINK-10967] Update kafka dependency to 2.1.1 URL: https://github.com/apache/flink/pull/7156#issuecomment-468333084 The test failed, although one failure was in the (unrelated) Kafka 0.11 connector. I restarted, let's see what we get.

[jira] [Updated] (FLINK-11118) Refactor and unify rowtime timestamp extractor interface

[ https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-8: --- Component/s: API / Table SQL > Refactor and unify rowtime timestamp extractor interface >

[jira] [Updated] (FLINK-9679) Implement AvroSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9679: -- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Implement

[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 ] Robert Metzger updated FLINK-11133: --- Component/s: FileSystems > FsCheckpointStorage is unaware about S3 entropy when creating

[jira] [Updated] (FLINK-11148) Rescaling operator regression in Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-11148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11148: --- Component/s: Runtime / Coordination > Rescaling operator regression in Flink 1.7 >

[jira] [Updated] (FLINK-9699) Add api to replace registered table

[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9699: -- Component/s: API / Table SQL > Add api to replace registered table >

[jira] [Updated] (FLINK-10967) Update kafka dependency to 2.1.1

[ https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10967: - Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-10598) >

[GitHub] asfgit closed pull request #7864: [FLINK-11785][table-api] Replace case class Null(type) by nullOf(type) expression

asfgit closed pull request #7864: [FLINK-11785][table-api] Replace case class Null(type) by nullOf(type) expression URL: https://github.com/apache/flink/pull/7864 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-10967) Update kafka dependency to 2.1.1

[ https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16780683#comment-16780683 ] Aljoscha Krettek commented on FLINK-10967: -- [~ijuma] I assigned the issue to you. And I think

[jira] [Assigned] (FLINK-10967) Update kafka dependency to 2.1.1

[ https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-10967: Assignee: Ismael Juma > Update kafka dependency to 2.1.1 >

[jira] [Updated] (FLINK-10434) Blob file not removed after job execution.

[ https://issues.apache.org/jira/browse/FLINK-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10434: --- Component/s: Runtime / Coordination > Blob file not removed after job execution. >

[GitHub] flinkbot edited a comment on issue #7860: [FLINK-9685] Adding support hostname-substitution for security.kerberos login.principal

flinkbot edited a comment on issue #7860: [FLINK-9685] Adding support hostname-substitution for security.kerberos login.principal URL: https://github.com/apache/flink/pull/7860#issuecomment-468248603 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] Salatich commented on issue #7860: [FLINK-9685] Adding support hostname-substitution for security.kerberos login.principal

Salatich commented on issue #7860: [FLINK-9685] Adding support hostname-substitution for security.kerberos login.principal URL: https://github.com/apache/flink/pull/7860#issuecomment-468330905 @flinkbot approve description

[jira] [Closed] (FLINK-2244) Add ability to start and stop persistent IaaS cluster

[ https://issues.apache.org/jira/browse/FLINK-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2244. Resolution: Won't Do Closed because of inactivity. > Add ability to start and stop persistent

[jira] [Closed] (FLINK-2667) Rework configuration parameters

[ https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2667. Resolution: Won't Do Closed for inactivity. > Rework configuration parameters >

[jira] [Closed] (FLINK-2623) Extend API completeness check to check signatures

[ https://issues.apache.org/jira/browse/FLINK-2623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2623. Resolution: Won't Do Closed for inactivity > Extend API completeness check to check signatures >

[jira] [Created] (FLINK-11788) Support Code Generation for RexNode

Jark Wu created FLINK-11788: --- Summary: Support Code Generation for RexNode Key: FLINK-11788 URL: https://issues.apache.org/jira/browse/FLINK-11788 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-2485) Handle removal of Java Unsafe

[ https://issues.apache.org/jira/browse/FLINK-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2485. Resolution: Duplicate > Handle removal of Java Unsafe > - > >

[jira] [Updated] (FLINK-10903) Shade Internal Akka Dependencies

[ https://issues.apache.org/jira/browse/FLINK-10903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10903: --- Component/s: Runtime / Coordination > Shade Internal Akka Dependencies >

[jira] [Updated] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10019: --- Component/s: SQL / Planner > Fix Composite getResultType of UDF cannot be chained with

[GitHub] flinkbot edited a comment on issue #7638: [FLINK-11510] [DataStream] Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums )

flinkbot edited a comment on issue #7638: [FLINK-11510] [DataStream] Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums ) URL: https://github.com/apache/flink/pull/7638#issuecomment-459738297 Thanks a lot for your contribution to the Apache Flink project. I'm

[jira] [Updated] (FLINK-10988) Improve debugging / visibility of job state

[ https://issues.apache.org/jira/browse/FLINK-10988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10988: --- Component/s: Runtime / Coordination > Improve debugging / visibility of job state >

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

[ https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9675: -- Component/s: FileSystems > Avoid FileInputStream/FileOutputStream >

[jira] [Updated] (FLINK-9718) Add enviroment variable in start-scala-shell.sh & flink to enable remote debug

[ https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9718: -- Component/s: Command Line Client > Add enviroment variable in start-scala-shell.sh & flink to

[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 ] Robert Metzger updated FLINK-10871: --- Component/s: API / Table SQL > ExecutionEnvironment & TableEnvironment should be singleton

[jira] [Updated] (FLINK-9195) Delete non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9195: -- Component/s: API / DataStream > Delete non-well-defined output methods on DataStream >

[GitHub] aljoscha commented on issue #7638: [FLINK-11510] [DataStream] Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums )

aljoscha commented on issue #7638: [FLINK-11510] [DataStream] Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums ) URL: https://github.com/apache/flink/pull/7638#issuecomment-468327466 @flinkbot disapprove consensus I think this addition doesn't fit well

[jira] [Commented] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time

[ https://issues.apache.org/jira/browse/FLINK-10756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16780667#comment-16780667 ] Chesnay Schepler commented on FLINK-10756: -- The second issue is due to us not actually

[jira] [Updated] (FLINK-10078) Dispatcher should only block job submission during recovery

[ https://issues.apache.org/jira/browse/FLINK-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10078: --- Component/s: Runtime / Coordination > Dispatcher should only block job submission during

[jira] [Updated] (FLINK-9363) Bump up the Jackson version

[ https://issues.apache.org/jira/browse/FLINK-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9363: -- Component/s: Runtime / Coordination > Bump up the Jackson version >

[jira] [Updated] (FLINK-10539) Support specific namespace in QueryableStateClient

[ https://issues.apache.org/jira/browse/FLINK-10539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10539: --- Component/s: Runtime / Queryable State > Support specific namespace in QueryableStateClient

[jira] [Closed] (FLINK-2370) Unify Client Code

[ https://issues.apache.org/jira/browse/FLINK-2370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2370. Resolution: Won't Do Closed because of inactivity. > Unify Client Code > - > >

[jira] [Updated] (FLINK-10467) Upgrade commons-compress to 1.18

[ https://issues.apache.org/jira/browse/FLINK-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10467: --- Component/s: FileSystems > Upgrade commons-compress to 1.18 >

[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 ] Robert Metzger updated FLINK-10464: --- Component/s: SQL / Planner > TimeIndicatorRelDataType: digest can not describe a type

[jira] [Updated] (FLINK-10667) Clean up Scala 2.10 remnants

[ https://issues.apache.org/jira/browse/FLINK-10667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10667: --- Component/s: API / Scala > Clean up Scala 2.10 remnants > - >

[jira] [Updated] (FLINK-11110) Support pipeline stage type inference

[ https://issues.apache.org/jira/browse/FLINK-0?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-0: --- Component/s: Library / Machine Learning > Support pipeline stage type inference >

[jira] [Closed] (FLINK-2060) Let maven fail on travis when modules reference to outdated internal dependency

[ https://issues.apache.org/jira/browse/FLINK-2060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2060. Resolution: Won't Do Doesn't seem to be a big problem. > Let maven fail on travis when modules

[jira] [Updated] (FLINK-10929) Add support for Apache Arrow

[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10929: --- Component/s: Runtime / State Backends > Add support for Apache Arrow >

[jira] [Updated] (FLINK-11109) Create Table based optimizers

[ https://issues.apache.org/jira/browse/FLINK-11109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11109: --- Component/s: Library / Machine Learning > Create Table based optimizers >

[jira] [Closed] (FLINK-2110) Early slot release after Execution failure

[ https://issues.apache.org/jira/browse/FLINK-2110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2110. Resolution: Duplicate Has been fixed with Flip-6. > Early slot release after Execution failure >

[jira] [Updated] (FLINK-11021) ZoneOffset objects don't appear to be serialized correctly

[ https://issues.apache.org/jira/browse/FLINK-11021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11021: --- Component/s: API / Type Serialization System > ZoneOffset objects don't appear to be

[jira] [Updated] (FLINK-10971) Dependency convergence issue when building flink-s3-fs-presto

[ https://issues.apache.org/jira/browse/FLINK-10971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10971: --- Component/s: FileSystems > Dependency convergence issue when building flink-s3-fs-presto >

[jira] [Commented] (FLINK-1833) Refactor partition availability notification in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16780657#comment-16780657 ] Till Rohrmann commented on FLINK-1833: -- This issue might become obsolete once FLINK-10653 has been

[jira] [Closed] (FLINK-1858) Add further checks to QA bot

[ https://issues.apache.org/jira/browse/FLINK-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1858. Resolution: Won't Do No longer relevant. > Add further checks to QA bot >

[jira] [Updated] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

[ https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10873: --- Component/s: API / Table SQL > Remove tableEnv in DataSetConversions#toTable and >

[jira] [Updated] (FLINK-10904) Expose Classloader before Pipeline execution

[ https://issues.apache.org/jira/browse/FLINK-10904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10904: --- Component/s: Runtime / Operators > Expose Classloader before Pipeline execution >

[jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4387: -- Component/s: Runtime / Queryable State > Instability in

[jira] [Updated] (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:all-tabpanel ] Robert Metzger updated FLINK-10950: --- Component/s: Runtime / State Backends > RocksDB backend does not work on Windows due to

[jira] [Updated] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-8482: -- Component/s: API / DataStream > Implement and expose option to use min / max / left / right

[jira] [Updated] (FLINK-10898) Add yarn.application-attempts-failures-validity-interval in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10898: --- Component/s: Deployment / YARN > Add yarn.application-attempts-failures-validity-interval

[jira] [Updated] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10908: --- Component/s: Deployment / YARN > Add yarn.application.priority in YarnConfigOptions >

[jira] [Updated] (FLINK-10162) Add host in checkpoint detail

[ https://issues.apache.org/jira/browse/FLINK-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10162: --- Component/s: Runtime / Web Frontend > Add host in checkpoint detail >

[jira] [Updated] (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:all-tabpanel ] Robert Metzger updated FLINK-9340: -- Component/s: Runtime / Network > ScheduleOrUpdateConsumersTest may fail with Address already

[jira] [Updated] (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 ] Robert Metzger updated FLINK-8037: -- Component/s: Connectors / Kafka > Missing cast in integer arithmetic in >

[jira] [Closed] (FLINK-1812) TaskManager shell scripts restart JVMs on process failures

[ https://issues.apache.org/jira/browse/FLINK-1812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1812. Resolution: Won't Do Closed because of inactivity > TaskManager shell scripts restart JVMs on

[jira] [Updated] (FLINK-8483) Implement and expose outer joins

[ https://issues.apache.org/jira/browse/FLINK-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-8483: -- Component/s: API / DataStream > Implement and expose outer joins >

[jira] [Updated] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9598: -- Component/s: Runtime / Checkpointing > [Checkpoints] The config Minimum Pause Between

[jira] [Updated] (FLINK-10196) API to test streaming pipelines with windows

[ https://issues.apache.org/jira/browse/FLINK-10196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10196: --- Component/s: API / DataStream > API to test streaming pipelines with windows >

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10794: --- Component/s: Runtime / Checkpointing > Do not create checkpointStorage when checkpoint is

[jira] [Updated] (FLINK-10831) Consider making processing time monotonically increasing by default

[ https://issues.apache.org/jira/browse/FLINK-10831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10831: --- Component/s: Runtime / Operators > Consider making processing time monotonically increasing

[jira] [Updated] (FLINK-10226) Latency metrics can choke job-manager

[ https://issues.apache.org/jira/browse/FLINK-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10226: --- Component/s: Runtime / Metrics > Latency metrics can choke job-manager >

[jira] [Updated] (FLINK-10830) Consider making processing time provider pluggable

[ https://issues.apache.org/jira/browse/FLINK-10830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10830: --- Component/s: Runtime / Operators > Consider making processing time provider pluggable >

[jira] [Updated] (FLINK-10306) Support the display of log file from any position on webUI

[ https://issues.apache.org/jira/browse/FLINK-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10306: --- Component/s: Runtime / Web Frontend > Support the display of log file from any position on

[jira] [Updated] (FLINK-10728) Unexpected items on ASF mirrors

[ https://issues.apache.org/jira/browse/FLINK-10728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10728: --- Component/s: BuildSystem / Shaded > Unexpected items on ASF mirrors >

[jira] [Updated] (FLINK-10574) Update documents of new batch job failover strategy

[ https://issues.apache.org/jira/browse/FLINK-10574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10574: --- Component/s: API / DataSet > Update documents of new batch job failover strategy >

[jira] [Updated] (FLINK-9607) Support ParquetTableSink

[ https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9607: -- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Support ParquetTableSink >

[jira] [Updated] (FLINK-10683) Error while executing BLOB connection. java.io.IOException: Unknown operation

[ https://issues.apache.org/jira/browse/FLINK-10683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10683: --- Component/s: Runtime / Coordination > Error while executing BLOB connection.

[jira] [Updated] (FLINK-10126) There should be a Scala DataSource

[ https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10126: --- Component/s: API / Scala > There should be a Scala DataSource >

[jira] [Updated] (FLINK-10654) AllowNonRestoredState should skip state that cannot be restored

[ https://issues.apache.org/jira/browse/FLINK-10654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10654: --- Component/s: Runtime / Coordination > AllowNonRestoredState should skip state that cannot

[GitHub] twalthr commented on issue #7864: [FLINK-11785][table-api] Replace case class Null(type) by nullOf(type) expression

twalthr commented on issue #7864: [FLINK-11785][table-api] Replace case class Null(type) by nullOf(type) expression URL: https://github.com/apache/flink/pull/7864#issuecomment-468322085 Thank you @sunjincheng121 for the very quick review. I will merge this...

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader (ZK 3.5.3-beta only)

[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10475: --- Component/s: Runtime / Coordination > Standalone HA - Leader election is not triggered on

[jira] [Updated] (FLINK-9432) Support extract epoch, decade, millisecond, microsecond

[ https://issues.apache.org/jira/browse/FLINK-9432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9432: -- Component/s: SQL / Planner > Support extract epoch, decade, millisecond, microsecond >

[jira] [Updated] (FLINK-10380) Check if key is not nul before assign to group in KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10380: --- Component/s: API / DataStream > Check if key is not nul before assign to group in

[jira] [Updated] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

[ https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10446: --- Component/s: Build System > Use the "guava beta checker" plugin to keep off of @Beta API >

[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 ] Robert Metzger updated FLINK-10388: --- Component/s: Runtime / Web Frontend > RestClientTest sometimes fails with AssertionError >

[jira] [Updated] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9048: -- Component/s: Runtime / Coordination >

[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 ] Robert Metzger updated FLINK-10391: --- Component/s: API / Type Serialization System > MillisOfDay is used in place of instant for

[jira] [Updated] (FLINK-10424) Inconsistency between JsonSchemaConveerter and FlinkTypeFactory

[ https://issues.apache.org/jira/browse/FLINK-10424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10424: --- Component/s: API / Type Serialization System > Inconsistency between JsonSchemaConveerter

[jira] [Closed] (FLINK-11780) Change version scheme of Hadoop-based modules to conform to SNAPSHOT guidelines

[ https://issues.apache.org/jira/browse/FLINK-11780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11780. Resolution: Fixed Merged on release-1.8 in 24ebc09f3ed516f4313a7612862f2c9a7863554c >

[jira] [Updated] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir

[ https://issues.apache.org/jira/browse/FLINK-9683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9683: -- Component/s: Runtime / Coordination > inconsistent behaviors when setting

[jira] [Updated] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10437: --- Component/s: Runtime / Web Frontend > Some of keys under withDeprecatedKeys aren't marked

[jira] [Updated] (FLINK-9849) Create hbase connector for hbase version to 2.0.2

[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9849: -- Component/s: Connectors / HBase > Create hbase connector for hbase version to 2.0.2 >

[jira] [Updated] (FLINK-10305) flink-conf.yaml grows continuously

[ https://issues.apache.org/jira/browse/FLINK-10305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10305: --- Component/s: Deployment / Docker > flink-conf.yaml grows continuously >

[jira] [Updated] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file

[ https://issues.apache.org/jira/browse/FLINK-10130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10130: --- Component/s: FileSystems > How to define two hdfs name-node IPs in flink-conf.yaml file >

[jira] [Updated] (FLINK-10212) REST API for listing all the available save points

[ https://issues.apache.org/jira/browse/FLINK-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10212: --- Component/s: Runtime / Web Frontend > REST API for listing all the available save points >

[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 ] Robert Metzger updated FLINK-10272: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > using Avro's DateConversion

[jira] [Updated] (FLINK-10198) Set Env object in DBOptions for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-10198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10198: --- Component/s: Runtime / State Backends > Set Env object in DBOptions for RocksDB >

[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 ] Robert Metzger updated FLINK-10239: --- Component/s: API / DataStream > Register eventtime timer only once in eventtrigger >

[jira] [Updated] (FLINK-10216) Add REGEXP_MATCH in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10216: --- Component/s: API / Table SQL > Add REGEXP_MATCH in TableAPI and SQL >

<    1   2   3   4   5   6   7   8   9   >