[jira] [Created] (FLINK-18540) Unnecessary retract messages when setIdleStateRetentionTime before converting dynamic table to retract stream

[Shang Yuanchun (Jira)]

WeiqiangSun created FLINK-18540:
-----------------------------------

             Summary: Unnecessary retract messages when setIdleStateRetentionTime before converting dynamic table to retract stream
                 Key: FLINK-18540
                 URL: https://issues.apache.org/jira/browse/FLINK-18540
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner, Table SQL / Runtime
    Affects Versions: 1.10.0
            Reporter: WeiqiangSun


Unnecessary retract messages when setIdleStateRetentionTime before converting dynamic table to retract stream。  

 
{code:java}
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(1);

EnvironmentSettings es = EnvironmentSettings.newInstance().inStreamingMode().build();
StreamTableEnvironment fsTableEnv = StreamTableEnvironment.create(env,es);

DataStream<Integer> ds = env.fromElements(5,4,3,2,1);

// if do not setIdleStateRetentionTime, it will output only one message as expected like '(true,5)'
// if do setIdleStateRetentionTime, it will output unnecessary retract messages like '(false,5)/(true,5)'
fsTableEnv.getConfig().setIdleStateRetentionTime(Time.hours(1000000),Time.hours(10000000));
fsTableEnv.createTemporaryView("test",ds,"id");
Table test = fsTableEnv.sqlQuery("select max(id) from test");
fsTableEnv.toRetractStream(test,Row.class).printToErr();
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)