jeff1evesque opened a new issue, #4820: URL: https://github.com/apache/iceberg/issues/4820
I'm trying to combine the [`SlidingWindows/sliding-windows.py`](https://github.com/aws-samples/pyflink-getting-started/blob/main/pyflink-examples/SlidingWindows/sliding-windows.py#L88-L97) example, with the [`GettingStarted/getting-started.py`](https://github.com/aws-samples/pyflink-getting-started/blob/main/pyflink-examples/GettingStarted/getting-started.py). Specifically, I've created my own variant of [`sliding_window.py`](sliding_window.py), with an associated [`datagen/stock.py`](stock.py). However, when I run my variation, nothing happens in the Pycharm output:  However, if I comment out the first [`sliding_window_table`](https://github.com/jeff1evesque/kinesis-analytics-demo/blob/master/flink/sliding_window.py#L155-L167) assignment, and uncomment the second [`sliding_window_table`](https://github.com/jeff1evesque/kinesis-analytics-demo/blob/master/flink/sliding_window.py#L168) assignment: ```python #sliding_window_table = ( # input_table.window( # Slide.over(sliding_window_over) # .every(sliding_window_every) # .on(sliding_window_on) # .alias(sliding_window_alias) # ) # .group_by('ticker, {}'.format(sliding_window_alias)) # .select('ticker, price.min as p, {}.end as t'.format( # sliding_window_alias, # sliding_window_on # )) #) sliding_window_table = input_table.select('ticker, price, utc') ``` Then, the console is able to capture output:  However, my desire is to combine both the AWS provided sliding window example with the `print` connector example. Once I can get that baseline setup, I plan on deploying pyflink to AWS Kinesis Data Analytics. From there, I intend to join pyflink streaming data with potentially s3 data using Apache Iceberg. However, I may try to utilize Apache iceberg locally using the above PyCharm pyflink setup, before promoting the deployment package to Kinesis Analytics. Could someone with enough free cycles help me with my base case, and potentially set me off on the right foot with joining s3 data using Apache Iceberg? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
