Fokko commented on code in PR #951:
URL: https://github.com/apache/iceberg-python/pull/951#discussion_r1686074065
##
pyproject.toml:
##
@@ -61,7 +61,10 @@ tenacity = ">=8.2.3,<9.0.0"
pyarrow = { version = ">=9.0.0,<18.0.0", optional = true }
pandas = { version = ">=1.0.0,<3.0.
Fokko merged PR #10734:
URL: https://github.com/apache/iceberg/pull/10734
--
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: issues-unsubscr...@iceberg.apa
Fokko merged PR #10733:
URL: https://github.com/apache/iceberg/pull/10733
--
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: issues-unsubscr...@iceberg.apa
Fokko merged PR #10729:
URL: https://github.com/apache/iceberg/pull/10729
--
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: issues-unsubscr...@iceberg.apa
Fokko merged PR #10726:
URL: https://github.com/apache/iceberg/pull/10726
--
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: issues-unsubscr...@iceberg.apa
Fokko merged PR #10728:
URL: https://github.com/apache/iceberg/pull/10728
--
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: issues-unsubscr...@iceberg.apa
HonahX merged PR #951:
URL: https://github.com/apache/iceberg-python/pull/951
--
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: issues-unsubscr...@iceberg
dependabot[bot] commented on PR #930:
URL: https://github.com/apache/iceberg-python/pull/930#issuecomment-2242293691
Looks like setuptools is up-to-date now, so this is no longer needed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
dependabot[bot] closed pull request #930: Bump setuptools from 69.1.0 to 70.0.0
URL: https://github.com/apache/iceberg-python/pull/930
--
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 com
nastra merged PR #10731:
URL: https://github.com/apache/iceberg/pull/10731
--
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: issues-unsubscr...@iceberg.ap
tomtongue commented on code in PR #10684:
URL: https://github.com/apache/iceberg/pull/10684#discussion_r1686114529
##
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java:
##
@@ -91,19 +94,36 @@ public void testCompressionAvro() throws Excep
tomtongue commented on code in PR #10684:
URL: https://github.com/apache/iceberg/pull/10684#discussion_r1686114970
##
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestCompressionSettings.java:
##
@@ -91,19 +94,36 @@ public void testCompressionAvro() throws Excep
nastra merged PR #10684:
URL: https://github.com/apache/iceberg/pull/10684
--
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: issues-unsubscr...@iceberg.ap
nastra commented on code in PR #10722:
URL: https://github.com/apache/iceberg/pull/10722#discussion_r1686170249
##
open-api/rest-catalog-open-api.py:
##
@@ -441,6 +441,30 @@ class AssertViewUUID(BaseModel):
uuid: str
+class AzureCredentials(BaseModel):
+account_name
RoeeDev commented on issue #3044:
URL: https://github.com/apache/iceberg/issues/3044#issuecomment-2242394813
@mgmarino - I am also trying to use your solution in my pyFlink application
running on managed Flink, but the only thing I can't understand yet is - how do
I incorporate the `HadoopU
tomtongue commented on PR #10684:
URL: https://github.com/apache/iceberg/pull/10684#issuecomment-2242396006
Thanks for the review! Will submit a backport PR, then the Flink migration
will be complete.
--
This is an automated message from the Apache Git Service.
To respond to the message,
nastra commented on code in PR #10722:
URL: https://github.com/apache/iceberg/pull/10722#discussion_r1686287333
##
open-api/rest-catalog-open-api.yaml:
##
@@ -2747,6 +2747,54 @@ components:
uuid:
type: string
+AzureCredentials:
Review Comment:
there
jeesou commented on code in PR #10288:
URL: https://github.com/apache/iceberg/pull/10288#discussion_r1686321521
##
spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/NDVSketchGenerator.java:
##
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
pvary commented on issue #10710:
URL: https://github.com/apache/iceberg/issues/10710#issuecomment-2242675737
With a well configured IcebergSink, the number of `WriteResults` are quite
low compared to the number of records, we did not spent the resources on
writing the serializer/deserialize
pvary commented on code in PR #10548:
URL: https://github.com/apache/iceberg/pull/10548#discussion_r1686382506
##
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSpecExecSupport.java:
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache Software Foundat
pvary commented on code in PR #10548:
URL: https://github.com/apache/iceberg/pull/10548#discussion_r1686382902
##
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSpecExecSupport.java:
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache Software Foundat
pvary commented on PR #10548:
URL: https://github.com/apache/iceberg/pull/10548#issuecomment-2242713133
@venkata91: Nicely done, just a few small nits, and then I am fine with the
change.
I will give @stevenzwu a few days, if he wants to chime in. If not, then we
could move forward.
findepi commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1686399659
##
core/src/main/java/org/apache/iceberg/util/ParallelIterable.java:
##
@@ -136,30 +169,33 @@ private boolean checkTasks() {
}
}
- return !clos
findepi commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1686399659
##
core/src/main/java/org/apache/iceberg/util/ParallelIterable.java:
##
@@ -136,30 +169,33 @@ private boolean checkTasks() {
}
}
- return !clos
findepi commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1686401382
##
core/src/main/java/org/apache/iceberg/util/ParallelIterable.java:
##
@@ -136,30 +169,33 @@ private boolean checkTasks() {
}
}
- return !clos
findepi commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1686408402
##
core/src/main/java/org/apache/iceberg/util/ParallelIterable.java:
##
@@ -20,84 +20,117 @@
import java.io.Closeable;
import java.io.IOException;
+import java.io
findepi commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1686424317
##
core/src/test/java/org/apache/iceberg/util/TestParallelIterable.java:
##
@@ -133,6 +140,47 @@ public CloseableIterator iterator() {
.untilAsserted(() -> a
pvary commented on code in PR #10548:
URL: https://github.com/apache/iceberg/pull/10548#discussion_r1686427190
##
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSpecExecSupport.java:
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache Software Foundat
cfrancois7 opened a new issue, #953:
URL: https://github.com/apache/iceberg-python/issues/953
### Question
I'm looking for a tutorial to make a query on one subfield of a struct field.
I scrolled all internet but failed to find a way to do it simply with
pyiceberg.
To make i
ajantha-bhat commented on issue #10740:
URL: https://github.com/apache/iceberg/issues/10740#issuecomment-2242792614
I think it is better to have individual issue trackers for each feature
(with `KAFAKACONNECT` label). So, we can close them when each task is
completed.
--
This is an aut
lkokhreidze commented on issue #10683:
URL: https://github.com/apache/iceberg/issues/10683#issuecomment-2242798889
Hi @pvary thanks for the reply. I do not know internals of Paimon, if it
inserts both rows or not. But from the reader perspective, only the first row
will be visible.
Behav
pvary commented on PR #10567:
URL: https://github.com/apache/iceberg/pull/10567#issuecomment-2242800689
@zhongyujiang: Do I understand correctly, that the issue happens when the
following conditions are met:
- We have at least 3 FileScanTasks (FS1, FS2, FS3) to read
- We have a filter
zhongqishang commented on code in PR #10526:
URL: https://github.com/apache/iceberg/pull/10526#discussion_r1686446191
##
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java:
##
@@ -426,30 +425,44 @@ private void commitOperation(
}
@Ov
ajantha-bhat commented on PR #10739:
URL: https://github.com/apache/iceberg/pull/10739#issuecomment-2242818777
> This adds building of runtime distributions plus some integration tests
Can we please split into two PRs. one for adding runtime distributions and
one for integration tests
pvary commented on issue #10683:
URL: https://github.com/apache/iceberg/issues/10683#issuecomment-2242830276
Thanks @lkokhreidze!
Currently there is no such thing in the Flink Iceberg Sink. You need to
build your own operator for it.
--
This is an automated message from the Apache Git
bryanck commented on PR #10739:
URL: https://github.com/apache/iceberg/pull/10739#issuecomment-2242960006
The integration tests depend on the runtime.
--
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
syun64 commented on code in PR #951:
URL: https://github.com/apache/iceberg-python/pull/951#discussion_r1686558332
##
pyproject.toml:
##
@@ -61,7 +61,10 @@ tenacity = ">=8.2.3,<9.0.0"
pyarrow = { version = ">=9.0.0,<18.0.0", optional = true }
pandas = { version = ">=1.0.0,<3.0
Fokko commented on code in PR #951:
URL: https://github.com/apache/iceberg-python/pull/951#discussion_r1686567665
##
pyproject.toml:
##
@@ -61,7 +61,10 @@ tenacity = ">=8.2.3,<9.0.0"
pyarrow = { version = ">=9.0.0,<18.0.0", optional = true }
pandas = { version = ">=1.0.0,<3.0.
syun64 commented on code in PR #951:
URL: https://github.com/apache/iceberg-python/pull/951#discussion_r1686574599
##
pyproject.toml:
##
@@ -61,7 +61,10 @@ tenacity = ">=8.2.3,<9.0.0"
pyarrow = { version = ">=9.0.0,<18.0.0", optional = true }
pandas = { version = ">=1.0.0,<3.0
ajantha-bhat commented on PR #10739:
URL: https://github.com/apache/iceberg/pull/10739#issuecomment-2243015462
> The integration tests depend on the runtime.
I know. We can review and merge the runtime PR first and then rebase the
integration test PR?
--
This is an automated messa
bryanck commented on PR #10739:
URL: https://github.com/apache/iceberg/pull/10739#issuecomment-2243024192
The integration tests are testing the runtime, so I feel they belong
together. Also, the runtime build is just the `build.gradle` so this seems
unneccessary to me.
--
This is an auto
zhongyujiang commented on PR #10567:
URL: https://github.com/apache/iceberg/pull/10567#issuecomment-2243038965
Hi @pvary Thanks for reviewing.
I think the issue here is somewhat different from what you understand.
> We have at least 3 FileScanTasks (FS1, FS2, FS3) to read
> W
zhongyujiang commented on PR #10567:
URL: https://github.com/apache/iceberg/pull/10567#issuecomment-2243048745
> I can see 2 ways to fix this:
>
> Count every file in the fileOffset - even the ones which are skipped. This
seems more natural to me, but the state need to be converted
zhongyujiang commented on PR #10567:
URL: https://github.com/apache/iceberg/pull/10567#issuecomment-2243074141
> Edit: Would it be possible to create an e2e like unit test to simulate the
issue? It might be easier to understand the issue, or debug.
Unfortunately, I am unsure how to cr
jbonofre commented on issue #10745:
URL: https://github.com/apache/iceberg/issues/10745#issuecomment-2243116628
It makes sense to me. I would also include the Kafka connect artifact on
https://iceberg.apache.org/releases/
--
This is an automated message from the Apache Git Service.
To res
dimas-b commented on code in PR #8982:
URL: https://github.com/apache/iceberg/pull/8982#discussion_r1686695087
##
format/spec.md:
##
@@ -1370,3 +1370,16 @@ Writing v2 metadata:
* `sort_columns` was removed
Note that these requirements apply when writing data to a v2 tabl
bryanck commented on issue #10740:
URL: https://github.com/apache/iceberg/issues/10740#issuecomment-2243249790
Thanks @nk1506 that would be great! There definitely are some opportunities.
This is just a placeholder issue to note the big ticket items, I'll create
individual tasks soon for so
jqin61 opened a new issue, #954:
URL: https://github.com/apache/iceberg-python/issues/954
### Apache Iceberg version
None
### Please describe the bug 🐞
Hi I added this test which breaks:
```
def test_delete_overwrite_with_null(session_catalog: RestCatalog) -> None:
RussellSpitzer commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1686777206
##
core/src/test/java/org/apache/iceberg/util/TestParallelIterable.java:
##
@@ -133,6 +140,47 @@ public CloseableIterator iterator() {
.untilAsserted(
syun64 commented on issue #954:
URL: https://github.com/apache/iceberg-python/issues/954#issuecomment-2243289640
Hi @jqin61 - this looks like a critical issue that should be fixed for the
0.7.0.
Thank you very much for flagging this issue and starting to work on the fix!!
--
This
RussellSpitzer commented on code in PR #10735:
URL: https://github.com/apache/iceberg/pull/10735#discussion_r1686808627
##
.palantir/revapi.yml:
##
@@ -874,6 +874,10 @@ acceptedBreaks:
justification: "Static utility class - should not have public
constructor"
"1.4.0":
Vanlightly commented on issue #10720:
URL: https://github.com/apache/iceberg/issues/10720#issuecomment-2243351688
@amogh-jahagirdar I don't see a way of running a delete operation and
specifying the VALIDATE_FROM_SNAPSHOT option. The Spark dataframe API allows me
to set the option but doesn
RussellSpitzer commented on code in PR #10735:
URL: https://github.com/apache/iceberg/pull/10735#discussion_r1686819845
##
core/src/main/java/org/apache/iceberg/AllManifestsTableTaskParser.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
RussellSpitzer commented on code in PR #10735:
URL: https://github.com/apache/iceberg/pull/10735#discussion_r1686819845
##
core/src/main/java/org/apache/iceberg/AllManifestsTableTaskParser.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
amogh-jahagirdar merged PR #10744:
URL: https://github.com/apache/iceberg/pull/10744
--
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: issues-unsubscr...@
RussellSpitzer commented on PR #10736:
URL: https://github.com/apache/iceberg/pull/10736#issuecomment-2243378858
My big question here is what is the value of adding the Spec before you are
ready to write data?
--
This is an automated message from the Apache Git Service.
To respond to the
RussellSpitzer commented on code in PR #10724:
URL: https://github.com/apache/iceberg/pull/10724#discussion_r1686839951
##
core/src/main/java/org/apache/iceberg/DataFiles.java:
##
@@ -259,11 +268,19 @@ public Builder withFileSizeInBytes(long
newFileSizeInBytes) {
}
findepi commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1686847688
##
core/src/test/java/org/apache/iceberg/util/TestParallelIterable.java:
##
@@ -133,6 +140,47 @@ public CloseableIterator iterator() {
.untilAsserted(() -> a
RussellSpitzer commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1686853441
##
core/src/test/java/org/apache/iceberg/util/TestParallelIterable.java:
##
@@ -133,6 +140,47 @@ public CloseableIterator iterator() {
.untilAsserted(
nk1506 commented on issue #10740:
URL: https://github.com/apache/iceberg/issues/10740#issuecomment-2243412771
Thanks @bryanck , By any chance are we planning to consider adding `upsert`
support here too? I saw few thread on the slack where there was mixed feedback
about `upsert` performance
RussellSpitzer commented on code in PR #10711:
URL: https://github.com/apache/iceberg/pull/10711#discussion_r1686864538
##
api/src/main/java/org/apache/iceberg/io/SupportsRecoveryOperations.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
stevenzwu merged PR #10741:
URL: https://github.com/apache/iceberg/pull/10741
--
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: issues-unsubscr...@iceberg
stevenzwu commented on code in PR #10741:
URL: https://github.com/apache/iceberg/pull/10741#discussion_r1686874797
##
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSourceConfig.java:
##
@@ -46,8 +47,11 @@ public void testFlinkHintConfig() {
assert
stevenzwu commented on PR #10741:
URL: https://github.com/apache/iceberg/pull/10741#issuecomment-2243434588
thanks @nastra and @pvary for the review
--
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 t
amogh-jahagirdar commented on code in PR #10724:
URL: https://github.com/apache/iceberg/pull/10724#discussion_r1686880606
##
core/src/main/java/org/apache/iceberg/DataFiles.java:
##
@@ -259,11 +268,19 @@ public Builder withFileSizeInBytes(long
newFileSizeInBytes) {
}
amogh-jahagirdar commented on code in PR #10724:
URL: https://github.com/apache/iceberg/pull/10724#discussion_r1686880606
##
core/src/main/java/org/apache/iceberg/DataFiles.java:
##
@@ -259,11 +268,19 @@ public Builder withFileSizeInBytes(long
newFileSizeInBytes) {
}
shanielh commented on PR #10736:
URL: https://github.com/apache/iceberg/pull/10736#issuecomment-2243447797
> My big question here is what is the value of adding the Spec before you
are ready to write data?
I don't think it matters whether I add the spec just before writing to it or
p
bryanck commented on issue #10740:
URL: https://github.com/apache/iceberg/issues/10740#issuecomment-2243449689
That's the hope. It will likely involve a discussion with the community
first, as there are some performance considerations.
--
This is an automated message from the Apache Git S
amogh-jahagirdar commented on code in PR #10724:
URL: https://github.com/apache/iceberg/pull/10724#discussion_r1686880606
##
core/src/main/java/org/apache/iceberg/DataFiles.java:
##
@@ -259,11 +268,19 @@ public Builder withFileSizeInBytes(long
newFileSizeInBytes) {
}
hantangwangd commented on PR #10744:
URL: https://github.com/apache/iceberg/pull/10744#issuecomment-2243530601
@amogh-jahagirdar My pleasure!
--
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 s
amogh-jahagirdar commented on code in PR #10711:
URL: https://github.com/apache/iceberg/pull/10711#discussion_r1686972022
##
api/src/main/java/org/apache/iceberg/io/SupportsRecoveryOperations.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
amogh-jahagirdar commented on code in PR #10711:
URL: https://github.com/apache/iceberg/pull/10711#discussion_r1686972022
##
api/src/main/java/org/apache/iceberg/io/SupportsRecoveryOperations.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
amogh-jahagirdar commented on code in PR #10711:
URL: https://github.com/apache/iceberg/pull/10711#discussion_r1686972022
##
api/src/main/java/org/apache/iceberg/io/SupportsRecoveryOperations.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
emkornfield commented on code in PR #8982:
URL: https://github.com/apache/iceberg/pull/8982#discussion_r1686982629
##
format/spec.md:
##
@@ -1370,3 +1370,16 @@ Writing v2 metadata:
* `sort_columns` was removed
Note that these requirements apply when writing data to a v2
emkornfield commented on code in PR #8982:
URL: https://github.com/apache/iceberg/pull/8982#discussion_r1686992661
##
format/spec.md:
##
@@ -1370,3 +1370,16 @@ Writing v2 metadata:
* `sort_columns` was removed
Note that these requirements apply when writing data to a v2
venkata91 commented on code in PR #10548:
URL: https://github.com/apache/iceberg/pull/10548#discussion_r1686993453
##
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSpecExecSupport.java:
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache Software Fou
venkata91 commented on PR #10548:
URL: https://github.com/apache/iceberg/pull/10548#issuecomment-2243603565
@pvary should this change be ported to other flink versions like `1.17` and
`1.18`?
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
stevenzwu commented on code in PR #10735:
URL: https://github.com/apache/iceberg/pull/10735#discussion_r1687013697
##
.palantir/revapi.yml:
##
@@ -874,6 +874,10 @@ acceptedBreaks:
justification: "Static utility class - should not have public
constructor"
"1.4.0":
stevenzwu commented on code in PR #10735:
URL: https://github.com/apache/iceberg/pull/10735#discussion_r1687016293
##
core/src/main/java/org/apache/iceberg/AllManifestsTableTaskParser.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+
amogh-jahagirdar commented on code in PR #10711:
URL: https://github.com/apache/iceberg/pull/10711#discussion_r1687030827
##
api/src/main/java/org/apache/iceberg/io/SupportsRecoveryOperations.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
amogh-jahagirdar commented on PR #10711:
URL: https://github.com/apache/iceberg/pull/10711#issuecomment-2243643379
I'll leave this up for a bit, as I carry forward
https://github.com/apache/iceberg/pull/10445 maybe it'll be helpful to have
more of that implementation in place before we merg
danielcweeks commented on code in PR #10739:
URL: https://github.com/apache/iceberg/pull/10739#discussion_r1686952595
##
kafka-connect/kafka-connect-runtime/src/main/resources/manifest.json:
##
@@ -0,0 +1,47 @@
+{
+ "title": "Apache Iceberg Sink Connector",
+ "name": "iceberg-
danielcweeks commented on code in PR #10746:
URL: https://github.com/apache/iceberg/pull/10746#discussion_r1687067850
##
docs/docs/kafka-connect.md:
##
@@ -0,0 +1,354 @@
+---
+title: "Kafka Connect"
+---
+
+
+# Kafka Connect
+
+[Kafka Connect](https://docs.confluent.io/platform/
rdblue commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1687077960
##
core/src/main/java/org/apache/iceberg/util/ParallelIterable.java:
##
@@ -136,30 +169,33 @@ private boolean checkTasks() {
}
}
- return !close
rdblue merged PR #10691:
URL: https://github.com/apache/iceberg/pull/10691
--
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: issues-unsubscr...@iceberg.ap
rdblue commented on PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#issuecomment-2243728470
Thanks, @findepi! Good work finding a solution here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
rdblue commented on code in PR #10691:
URL: https://github.com/apache/iceberg/pull/10691#discussion_r1687083709
##
core/src/main/java/org/apache/iceberg/util/ParallelIterable.java:
##
@@ -20,84 +20,117 @@
import java.io.Closeable;
import java.io.IOException;
+import java.io.
rdblue commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1687095160
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3809,6 +4150,41 @@ components:
}
}
+# Note that this is a representative example response f
rdblue commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1687097927
##
open-api/rest-catalog-open-api.yaml:
##
@@ -541,6 +541,130 @@ paths:
5XX:
$ref: '#/components/responses/ServerErrorResponse'
+ /v1/{prefix}/nam
rdblue commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1687105937
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3647,6 +3786,173 @@ components:
type: integer
description: "List of equality field IDs"
+Pre
rdblue commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1687105937
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3647,6 +3786,173 @@ components:
type: integer
description: "List of equality field IDs"
+Pre
rdblue commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1687110606
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3647,6 +3818,176 @@ components:
type: integer
description: "List of equality field IDs"
+Pre
kevinjqliu commented on issue #953:
URL: https://github.com/apache/iceberg-python/issues/953#issuecomment-2243766926
I was able to reproduce this on latest main branch.
Example:
```
from pyiceberg.catalog.sql import SqlCatalog
import pyarrow as pa
schema = pa.schema([
kevinjqliu commented on issue #953:
URL: https://github.com/apache/iceberg-python/issues/953#issuecomment-2243774010
The issue might be in `_parse_row_filter` function
```
(Pdb) _parse_row_filter("employment = 'Employed'")
EqualTo(term=Reference(name='employment'), literal=litera
rdblue commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1687128848
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3647,6 +3818,176 @@ components:
type: integer
description: "List of equality field IDs"
+Pre
kevinjqliu commented on issue #953:
URL: https://github.com/apache/iceberg-python/issues/953#issuecomment-2243789428
Specifically in the parsing code
```
from pyiceberg.expressions.parser import parse
parse("employment.status = 'Employed'")
# > EqualTo(term=Reference(name='sta
stevenzwu merged PR #10457:
URL: https://github.com/apache/iceberg/pull/10457
--
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: issues-unsubscr...@iceberg
stevenzwu commented on PR #10457:
URL: https://github.com/apache/iceberg/pull/10457#issuecomment-2243805443
thanks @pvary for the review
--
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 specif
rdblue commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1687132205
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3647,6 +3818,176 @@ components:
type: integer
description: "List of equality field IDs"
+Pre
rdblue commented on code in PR #9695:
URL: https://github.com/apache/iceberg/pull/9695#discussion_r1687138776
##
open-api/rest-catalog-open-api.yaml:
##
@@ -3647,6 +3818,176 @@ components:
type: integer
description: "List of equality field IDs"
+Pre
1 - 100 of 174 matches
Mail list logo
