[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160180#comment-16160180 ] Michael Fong commented on FLINK-4500: - There is a PR looking for reviewer. Thanks! Re

[jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160060#comment-16160060 ] ASF GitHub Bot commented on FLINK-6563: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #4638: [FLINK-6563] [table] Add time indicator support to...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4638#discussion_r137933653 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java --- @@ -106,8 +240,191

[jira] [Assigned] (FLINK-7562) uploaded jars sort by upload-time on dashboard page

[ https://issues.apache.org/jira/browse/FLINK-7562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-7562: --- Assignee: Hai Zhou > uploaded jars sort by upload-time on dashboard page > --

[jira] [Commented] (FLINK-7562) uploaded jars sort by upload-time on dashboard page

[ https://issues.apache.org/jira/browse/FLINK-7562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16159824#comment-16159824 ] ASF GitHub Bot commented on FLINK-7562: --- GitHub user yew1eb opened a pull request:

[GitHub] flink pull request #4664: [FLINK-7562] Show uploaded-jars descending by uplo...

GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/4664 [FLINK-7562] Show uploaded-jars descending by upload time ## What is the purpose of the change Currently, upload the jar package show is unordered in the Apache Flink Web Dashboard page,

[jira] [Commented] (FLINK-6549) Improve error message for type mismatches with side outputs

[ https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16159802#comment-16159802 ] ASF GitHub Bot commented on FLINK-6549: --- GitHub user bowenli86 opened a pull request

[GitHub] flink pull request #4663: [FLINK-6549] [DataStream API] Improve error messag...

GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4663 [FLINK-6549] [DataStream API] Improve error message for type mismatches with side outputs ## What is the purpose of the change A type mismatch when using side outputs causes a ClassCastEx