Re: Towards a spec for robust streaming SQL, Part 2

Tyler, Thanks for this. I am reading the document thoroughly and will give my feedback in a day or two. Julian > On Jul 25, 2017, at 12:54 PM, Pramod Immaneni wrote: > > Thanks for the invitation Tyler. I am sure folks who worked on the calcite > integration and

[RESULT][VOTE] Release Apache Flink-shaded 1.0 (RC2)

The vote time has passed. In total we collected 3 +1 votes (all binding) and no 0 or -1 votes. +1 votes: - Aljoscha - Stephan - Chesnay As such RC2 will be released as flink-shaded 1.0 . On 26.07.2017 15:45, Chesnay Schepler wrote: +1 - dependency versions match those used in Flink - can be

[jira] [Created] (FLINK-7287) test instability in Kafka010ITCase.testCommitOffsetsToKafka

=AKIAJRYRXRSVGNKPKO5A/20170727/us-east-1/s3/aws4_request=host=0b629a0c2b5daedc65c8aa8eb3293bc956f8fd61dc70066a051ed5878b004dbf -- This message was sent by Atlassian JIRA (v6.4.14#64029)

[jira] [Created] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

Elias Levy created FLINK-7286: - Summary: Flink Dashboard fails to display bytes/records received by sources Key: FLINK-7286 URL: https://issues.apache.org/jira/browse/FLINK-7286 Project: Flink

[jira] [Created] (FLINK-7285) allow submission of big job graphs

Nico Kruber created FLINK-7285: -- Summary: allow submission of big job graphs Key: FLINK-7285 URL: https://issues.apache.org/jira/browse/FLINK-7285 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Table API / SQL internal timestamp handling

Hi all, Thanks for the answers, @Fabian. @Jark, at first I also wanted the users to reassign the timestamp field arbitrarily. However, that means we have to break the current "time system" and create a new one. The blocked watermarks become meaningless and maybe a new WatermarkAssigner should be

[jira] [Created] (FLINK-7284) Verify compile time and runtime version of Hadoop

Till Rohrmann created FLINK-7284: Summary: Verify compile time and runtime version of Hadoop Key: FLINK-7284 URL: https://issues.apache.org/jira/browse/FLINK-7284 Project: Flink Issue Type:

[jira] [Created] (FLINK-7283) PythonPlanBinderTest issues with python paths

Nico Kruber created FLINK-7283: -- Summary: PythonPlanBinderTest issues with python paths Key: FLINK-7283 URL: https://issues.apache.org/jira/browse/FLINK-7283 Project: Flink Issue Type: Bug

Re: [DISCUSS] Planning Release 1.4

Hi Eron! Looking at the mailing list and JIRA the threads that are currently happening: - Flip 6 and resource elasticity (towards dynamic scaling) - Dependency rework (hide dependencies, rework classloading, etc) - Kafka exactly once producer and partition discovery - General robustness

[jira] [Created] (FLINK-7282) Credit-based Network Flow Control

zhijiang created FLINK-7282: --- Summary: Credit-based Network Flow Control Key: FLINK-7282 URL: https://issues.apache.org/jira/browse/FLINK-7282 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-7281) Fix various issues in (Maven) release infrastructure

Aljoscha Krettek created FLINK-7281: --- Summary: Fix various issues in (Maven) release infrastructure Key: FLINK-7281 URL: https://issues.apache.org/jira/browse/FLINK-7281 Project: Flink

[jira] [Created] (FLINK-7280) Wrong clearing SharedBuffer of Equal elements with same Timestamp

Dawid Wysakowicz created FLINK-7280: --- Summary: Wrong clearing SharedBuffer of Equal elements with same Timestamp Key: FLINK-7280 URL: https://issues.apache.org/jira/browse/FLINK-7280 Project: Flink

[jira] [Created] (FLINK-7279) MiniCluster can deadlock at shut down

Till Rohrmann created FLINK-7279: Summary: MiniCluster can deadlock at shut down Key: FLINK-7279 URL: https://issues.apache.org/jira/browse/FLINK-7279 Project: Flink Issue Type: Bug

RE: [DISCUSS] Table API / SQL internal timestamp handling

Hi all, @Shaoxuan - thanks for the remarks. I have a question regarding your suggestion not to consider to create proctime window in a regular column. I think this would be useful though. First you might need to carry the timestamp indicator of when the processing happened (for log purposes,