a8356555 closed issue #8916: Flink: Not Writing
URL: https://github.com/apache/iceberg/issues/8916
--
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: issue
MarquisC commented on issue #8916:
URL: https://github.com/apache/iceberg/issues/8916#issuecomment-2479772050
@belldoor I've always used this reference
https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/filesystem/#file-sink
--
This is an automated me
belldoor commented on issue #8916:
URL: https://github.com/apache/iceberg/issues/8916#issuecomment-2475756495
I have identified the root cause of the problem.
The Iceberg connector commits to the Iceberg table at the point when a
checkpoint is successfully completed. In my code, since I
belldoor commented on issue #8916:
URL: https://github.com/apache/iceberg/issues/8916#issuecomment-2475626871
Same here,
No errors are displayed at all, only the table is created and data is not
written.
You can easily reproduce from this code.
```py
from pyflink.datastr
pvary commented on issue #8916:
URL: https://github.com/apache/iceberg/issues/8916#issuecomment-2092323155
@parrik: The issue you have linked is for the cases where the checkpointing
is not enabled. If I read the python code correctly, this is not the case here.
Still, the issue seems sim
parrik commented on issue #8916:
URL: https://github.com/apache/iceberg/issues/8916#issuecomment-2091506520
https://github.com/apache/iceberg/pull/1515 fwiw
--
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
beingRealFrank commented on issue #8916:
URL: https://github.com/apache/iceberg/issues/8916#issuecomment-2090945914
I am seeing a very similar issue when trying to write to S3 from pyflink
using a query like the following.
```
INSERT INTO iceberg.devdb.table_name
SELECT * FROM t
parrik commented on issue #8916:
URL: https://github.com/apache/iceberg/issues/8916#issuecomment-2089011646
@a8356555 have a similar issue - how did you unblock yourself?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
a8356555 opened a new issue, #8916:
URL: https://github.com/apache/iceberg/issues/8916
### Apache Iceberg version
1.4.0
### Query engine
Flink
### Please describe the bug 🐞
I'm using following Dockerfile as my environment:
```Dockerfile
FROM alpine:3.1