Re: [I] Flink: Not Writing [iceberg]

2024-11-18 Thread via GitHub
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

Re: [I] Flink: Not Writing [iceberg]

2024-11-15 Thread via GitHub
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

Re: [I] Flink: Not Writing [iceberg]

2024-11-14 Thread via GitHub
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

Re: [I] Flink: Not Writing [iceberg]

2024-11-13 Thread via GitHub
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

Re: [I] Flink: Not Writing [iceberg]

2024-05-02 Thread via GitHub
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

Re: [I] Flink: Not Writing [iceberg]

2024-05-02 Thread via GitHub
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

Re: [I] Flink: Not Writing [iceberg]

2024-05-02 Thread via GitHub
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

Re: [I] Flink: Not Writing [iceberg]

2024-05-01 Thread via GitHub
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

[I] Flink: Not Writing [iceberg]

2023-10-24 Thread via GitHub
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