Fokko commented on code in PR #6141:
URL: https://github.com/apache/iceberg/pull/6141#discussion_r1019433513
##
python/pyiceberg/expressions/literals.py:
##
@@ -125,81 +127,73 @@ def literal(value) -> Literal:
@literal.register(bool)
-def _(value: bool) -> Literal[bool]:
+d
Fokko commented on code in PR #6141:
URL: https://github.com/apache/iceberg/pull/6141#discussion_r1019434140
##
python/pyiceberg/expressions/literals.py:
##
@@ -125,81 +127,73 @@ def literal(value) -> Literal:
@literal.register(bool)
-def _(value: bool) -> Literal[bool]:
+d
rdblue commented on code in PR #6146:
URL: https://github.com/apache/iceberg/pull/6146#discussion_r1019448647
##
.palantir/revapi.yml:
##
@@ -1,4 +1,85 @@
acceptedBreaks:
+ "1.0.0":
+org.apache.iceberg:iceberg-core:
+- code: "java.class.defaultSerializationChanged"
+
Fokko commented on code in PR #6141:
URL: https://github.com/apache/iceberg/pull/6141#discussion_r1019453639
##
python/pyiceberg/expressions/literals.py:
##
@@ -125,81 +127,73 @@ def literal(value) -> Literal:
@literal.register(bool)
-def _(value: bool) -> Literal[bool]:
+d
Fokko commented on code in PR #6141:
URL: https://github.com/apache/iceberg/pull/6141#discussion_r1019454610
##
python/pyiceberg/expressions/literals.py:
##
@@ -125,81 +127,71 @@ def literal(value) -> Literal:
@literal.register(bool)
-def _(value: bool) -> Literal[bool]:
+d
Fokko merged PR #6170:
URL: https://github.com/apache/iceberg/pull/6170
--
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.apach
Fokko commented on PR #6170:
URL: https://github.com/apache/iceberg/pull/6170#issuecomment-1310735121
Thanks @rdblue
--
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 uns
singhpk234 commented on PR #5888:
URL: https://github.com/apache/iceberg/pull/5888#issuecomment-1310757061
Apologies for the delay in updating the pr, i was in the middle of changing
my work location.
Have addressed the feedback and moved the changes to SnapshotProducer from
BaseTran
Fokko commented on code in PR #6141:
URL: https://github.com/apache/iceberg/pull/6141#discussion_r1019523027
##
python/pyiceberg/expressions/literals.py:
##
@@ -58,25 +60,25 @@
timestamp_to_micros,
timestamptz_to_micros,
)
-from pyiceberg.utils.singleton import Single
RussellSpitzer commented on issue #6171:
URL: https://github.com/apache/iceberg/issues/6171#issuecomment-1310831081
IN your note you seem to be including both Scala 2.12 and 2.13 libraries,
this is probably the issue. Usually when I see noClassDef with Scala classes
like ```cala/$less$colon
RussellSpitzer commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019584432
##
core/src/test/java/org/apache/iceberg/TestPartitioning.java:
##
@@ -43,6 +43,12 @@ public class TestPartitioning {
required(1, "id", Types.IntegerT
RussellSpitzer commented on issue #6164:
URL: https://github.com/apache/iceberg/issues/6164#issuecomment-1310882642
Timestamp expressions can be created as in this test case
https://github.com/apache/iceberg/blob/master/core/src/test/java/org/apache/iceberg/expressions/TestExpressionP
singhpk234 commented on PR #4479:
URL: https://github.com/apache/iceberg/pull/4479#issuecomment-1310887312
cc @rdblue
--
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 un
XAZAD opened a new issue, #6172:
URL: https://github.com/apache/iceberg/issues/6172
### Apache Iceberg version
0.13.0
### Query engine
Spark
### Please describe the bug 🐞
Method rewriteDataFiles throws
`org.apache.spark.sql.connector.catalog.CatalogNotFo
Fokko commented on code in PR #6159:
URL: https://github.com/apache/iceberg/pull/6159#discussion_r1019658267
##
python/pyproject.toml:
##
@@ -107,7 +107,7 @@ force_grid_wrap = 4
all = true
[tool.mypy]
-no_implicit_optional = true
Review Comment:
@LuigiCerone I think we w
alec-heif opened a new pull request, #6173:
URL: https://github.com/apache/iceberg/pull/6173
I happened to notice this typo, which seems obviously wrong. The code isn't
yet exercised anywhere so it's not a big deal but figured I might as well fix
it.
--
This is an automated message from
dmgcodevil opened a new pull request, #6174:
URL: https://github.com/apache/iceberg/pull/6174
Sometimes it's not possible to use a filter to limit the size of files for
compaction (generic data pipelines) or the total size per partition exceeds JVM
heap. Using `totalSize` a user can limit t
dmgcodevil commented on issue #5675:
URL: https://github.com/apache/iceberg/issues/5675#issuecomment-1311065885
PR: https://github.com/apache/iceberg/pull/6174
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
dmgcodevil closed issue #3025: Schema field ids overridden when using nested
structs
URL: https://github.com/apache/iceberg/issues/3025
--
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 c
dmgcodevil closed issue #3168: How to sort Spark DataFrame ?
URL: https://github.com/apache/iceberg/issues/3168
--
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,
github-actions[bot] closed issue #4634: Backport updated method signature of
IcebergTableSource::getScanRuntimeProvider and
IcebergTableSink::getSinkRuntimeProvider from Flink 1.15 to Flink 1.14
URL: https://github.com/apache/iceberg/issues/4634
--
This is an automated message from the Apac
github-actions[bot] commented on issue #4631:
URL: https://github.com/apache/iceberg/issues/4631#issuecomment-1311066654
This issue has been closed because it has not received any activity in the
last 14 days since being marked as 'stale'
--
This is an automated message from the Apache Gi
github-actions[bot] closed issue #4621: [Feature Request] Iceberg integrates
with Pulsar, supports java to read iceberg tables sequentially
URL: https://github.com/apache/iceberg/issues/4621
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
github-actions[bot] commented on issue #4762:
URL: https://github.com/apache/iceberg/issues/4762#issuecomment-1311066602
This issue has been automatically marked as stale because it has been open
for 180 days with no activity. It will be closed in next 14 days if no further
activity occurs.
github-actions[bot] commented on issue #4634:
URL: https://github.com/apache/iceberg/issues/4634#issuecomment-1311066629
This issue has been closed because it has not received any activity in the
last 14 days since being marked as 'stale'
--
This is an automated message from the Apache Gi
github-actions[bot] commented on issue #4749:
URL: https://github.com/apache/iceberg/issues/4749#issuecomment-1311066615
This issue has been automatically marked as stale because it has been open
for 180 days with no activity. It will be closed in next 14 days if no further
activity occurs.
github-actions[bot] closed issue #4631: Python: PartitionSpec Construction
URL: https://github.com/apache/iceberg/issues/4631
--
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
github-actions[bot] commented on issue #4621:
URL: https://github.com/apache/iceberg/issues/4621#issuecomment-1311066680
This issue has been closed because it has not received any activity in the
last 14 days since being marked as 'stale'
--
This is an automated message from the Apache Gi
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019733840
##
core/src/main/java/org/apache/iceberg/Partitioning.java:
##
@@ -195,41 +198,68 @@ public Void alwaysNull(int fieldId, String sourceName,
int sourceId) {
}
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019734099
##
core/src/main/java/org/apache/iceberg/Partitioning.java:
##
@@ -195,41 +198,68 @@ public Void alwaysNull(int fieldId, String sourceName,
int sourceId) {
}
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019734173
##
core/src/main/java/org/apache/iceberg/Partitioning.java:
##
@@ -195,41 +198,68 @@ public Void alwaysNull(int fieldId, String sourceName,
int sourceId) {
}
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019734281
##
core/src/main/java/org/apache/iceberg/Partitioning.java:
##
@@ -298,4 +324,33 @@ private static boolean compatibleTransforms(Transform t1, Transform
||
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019735287
##
core/src/test/java/org/apache/iceberg/TestPartitioning.java:
##
@@ -43,6 +43,12 @@ public class TestPartitioning {
required(1, "id", Types.IntegerType
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019736124
##
core/src/main/java/org/apache/iceberg/Partitioning.java:
##
@@ -195,41 +198,75 @@ public Void alwaysNull(int fieldId, String sourceName,
int sourceId) {
}
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019735287
##
core/src/test/java/org/apache/iceberg/TestPartitioning.java:
##
@@ -43,6 +43,12 @@ public class TestPartitioning {
required(1, "id", Types.IntegerType
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019736124
##
core/src/main/java/org/apache/iceberg/Partitioning.java:
##
@@ -195,41 +198,75 @@ public Void alwaysNull(int fieldId, String sourceName,
int sourceId) {
}
aokolnychyi commented on code in PR #6163:
URL: https://github.com/apache/iceberg/pull/6163#discussion_r1019738831
##
core/src/main/java/org/apache/iceberg/Partitioning.java:
##
@@ -195,41 +198,75 @@ public Void alwaysNull(int fieldId, String sourceName,
int sourceId) {
}
aokolnychyi commented on issue #6162:
URL: https://github.com/apache/iceberg/issues/6162#issuecomment-1311095921
I looking into this.
--
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
lvyanquan commented on code in PR #6111:
URL: https://github.com/apache/iceberg/pull/6111#discussion_r1019761610
##
flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java:
##
@@ -145,8 +145,27 @@ protected Catalog createCatalog(
baseNamespace =
manuzhang commented on PR #5392:
URL: https://github.com/apache/iceberg/pull/5392#issuecomment-1311199510
@RussellSpitzer @rdblue @ajantha-bhat please take another look. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
aokolnychyi commented on code in PR #2276:
URL: https://github.com/apache/iceberg/pull/2276#discussion_r1019834880
##
core/src/main/java/org/apache/iceberg/util/TableScanUtil.java:
##
@@ -128,6 +136,61 @@ public static
CloseableIterable> planTaskG
combinedTasks -> new
aokolnychyi commented on code in PR #2276:
URL: https://github.com/apache/iceberg/pull/2276#discussion_r1019833535
##
api/src/main/java/org/apache/iceberg/util/StructProjection.java:
##
@@ -171,6 +178,11 @@ public StructProjection wrap(StructLike newStruct) {
return this;
aokolnychyi commented on code in PR #2276:
URL: https://github.com/apache/iceberg/pull/2276#discussion_r1019833535
##
api/src/main/java/org/apache/iceberg/util/StructProjection.java:
##
@@ -171,6 +178,11 @@ public StructProjection wrap(StructLike newStruct) {
return this;
aokolnychyi commented on code in PR #2276:
URL: https://github.com/apache/iceberg/pull/2276#discussion_r1019836554
##
api/src/main/java/org/apache/iceberg/util/StructProjection.java:
##
@@ -90,6 +90,13 @@ public static StructProjection createAllowMissing(
private final Struct
lirui-apache opened a new pull request, #6175:
URL: https://github.com/apache/iceberg/pull/6175
This addresses the issue #6071 by adding current UGI to the key of
`CachedClientPool.clientPoolCache`.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
V-yg commented on issue #4065:
URL: https://github.com/apache/iceberg/issues/4065#issuecomment-1311312103
@zhongyujiang Did you solve that problem? I had the same problem
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
nastra commented on code in PR #6175:
URL: https://github.com/apache/iceberg/pull/6175#discussion_r1019948958
##
hive-metastore/src/main/java/org/apache/iceberg/hive/CachedClientPool.java:
##
@@ -87,4 +92,50 @@ public R run(Action
action, boolean retry)
throws TExceptio
nastra commented on issue #6172:
URL: https://github.com/apache/iceberg/issues/6172#issuecomment-1311340587
The error message mentions `default_iceberg`/`ice` so you'd have to make
sure that this catalog is propertly set up: `spark.sql.catalog.(catalog_name):
...`. Addtional details can be
hililiwei commented on PR #175:
URL: https://github.com/apache/iceberg-docs/pull/175#issuecomment-1311366768
@ajantha-bhat Copy that, thx.
--
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 spec
ConeyLiu commented on issue #4626:
URL: https://github.com/apache/iceberg/issues/4626#issuecomment-1311375929
Hi @kbendick @szehon-ho @nastra, hope your guys could help take a look at
this issue again, thanks a lot.
--
This is an automated message from the Apache Git Service.
To respond t
XAZAD commented on issue #6172:
URL: https://github.com/apache/iceberg/issues/6172#issuecomment-1311380547
As a mentioned before catalogs are configured and working properly
`{ "hive.metastore.uris": "thrift://*",
"iceberg.engine.hive.enabled": "true",
"spark.sql.extensions":
zhongyujiang commented on issue #4065:
URL: https://github.com/apache/iceberg/issues/4065#issuecomment-1311445140
@V-yg No, I haven't.
--
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
XAZAD commented on issue #6172:
URL: https://github.com/apache/iceberg/issues/6172#issuecomment-1311676676
some more details:
https://user-images.githubusercontent.com/13484463/201346541-cf319f21-dd02-4781-956b-7ba98e64b599.png";>
full stack trace:
```
java.lang.RuntimeException:
nastra commented on issue #6172:
URL: https://github.com/apache/iceberg/issues/6172#issuecomment-1311769354
Could you maybe check whether the issue exists on the latest Iceberg version
(1.0.0)?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
XAZAD commented on issue #6172:
URL: https://github.com/apache/iceberg/issues/6172#issuecomment-1311770953
I'll try but it will take some tome cause infrastructure I'm using is huge
and it will take time to deploy new version on library even in dev.
--
This is an automated message from th
renshangtao commented on PR #5544:
URL: https://github.com/apache/iceberg/pull/5544#issuecomment-1311808301
@ggershinsky Hello, excuse me
I tested the code, and the file wasn't encrypted，test case execution failed.
All the testxxxWithoutKeys() are failed，Is my configuration incorrect
krvikash commented on PR #6174:
URL: https://github.com/apache/iceberg/pull/6174#issuecomment-1311835852
nit: I think all commits can be squashed into one single commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
danielcweeks commented on code in PR #6058:
URL: https://github.com/apache/iceberg/pull/6058#discussion_r1020398769
##
core/src/main/java/org/apache/iceberg/BaseTableScan.java:
##
@@ -141,6 +142,8 @@ public CloseableIterable planFiles() {
doPlanFiles(),
()
danielcweeks merged PR #6058:
URL: https://github.com/apache/iceberg/pull/6058
--
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...@iceber
aokolnychyi commented on issue #6162:
URL: https://github.com/apache/iceberg/issues/6162#issuecomment-1311964778
PR #6176 for Spark 3.3 is out.
--
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
aokolnychyi commented on code in PR #6176:
URL: https://github.com/apache/iceberg/pull/6176#discussion_r1020417580
##
spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/actions/RewriteManifestsSparkAction.java:
##
@@ -374,8 +378,9 @@ private static ManifestFile writeManifes
ddrinka opened a new issue, #6177:
URL: https://github.com/apache/iceberg/issues/6177
### Feature Request / Improvement
The Parquet support in Iceberg currently exposes the `writerVersion` in
`Parquet.WriteBuilder`, but this configuration should be extended out to a
table property.
ddrinka commented on issue #6177:
URL: https://github.com/apache/iceberg/issues/6177#issuecomment-1312058900
There's some relevant conversation here:
https://github.com/apache/iceberg/pull/2551
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
LuigiCerone commented on code in PR #6159:
URL: https://github.com/apache/iceberg/pull/6159#discussion_r1020505411
##
python/pyproject.toml:
##
@@ -107,7 +107,7 @@ force_grid_wrap = 4
all = true
[tool.mypy]
-no_implicit_optional = true
Review Comment:
@Fokko Yep, you're
flyrain commented on code in PR #6012:
URL: https://github.com/apache/iceberg/pull/6012#discussion_r1020522314
##
spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/GenerateChangesProcedure.java:
##
@@ -0,0 +1,271 @@
+/*
+ * Licensed to the Apache Software Founda
flyrain commented on code in PR #6012:
URL: https://github.com/apache/iceberg/pull/6012#discussion_r1020522314
##
spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/GenerateChangesProcedure.java:
##
@@ -0,0 +1,271 @@
+/*
+ * Licensed to the Apache Software Founda
LuigiCerone commented on code in PR #6159:
URL: https://github.com/apache/iceberg/pull/6159#discussion_r1020523338
##
python/tests/avro/test_decoder.py:
##
@@ -106,9 +107,11 @@ def read(self, size: int = 0) -> bytes:
self.pos += 1
return int.to_bytes(1, self.po
LuigiCerone commented on code in PR #6159:
URL: https://github.com/apache/iceberg/pull/6159#discussion_r1020523338
##
python/tests/avro/test_decoder.py:
##
@@ -106,9 +107,11 @@ def read(self, size: int = 0) -> bytes:
self.pos += 1
return int.to_bytes(1, self.po
Fokko merged PR #6173:
URL: https://github.com/apache/iceberg/pull/6173
--
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.apach
Fokko commented on code in PR #6159:
URL: https://github.com/apache/iceberg/pull/6159#discussion_r1020553202
##
python/tests/avro/test_decoder.py:
##
@@ -106,9 +107,11 @@ def read(self, size: int = 0) -> bytes:
self.pos += 1
return int.to_bytes(1, self.pos, byt
willshen opened a new pull request, #176:
URL: https://github.com/apache/iceberg-docs/pull/176
Fix broken Spark 2.4 and 3.0 runtime jar link on Releases page to keep up
with the changes in the module name/path
(https://github.com/apache/iceberg/pull/4158).
This is related to #174 but
haizhou-zhao commented on code in PR #6045:
URL: https://github.com/apache/iceberg/pull/6045#discussion_r1020581546
##
hive-metastore/src/main/java/org/apache/iceberg/hive/HiveCatalog.java:
##
@@ -365,6 +374,13 @@ public boolean dropNamespace(Namespace namespace) {
@Overrid
haizhou-zhao commented on PR #6045:
URL: https://github.com/apache/iceberg/pull/6045#issuecomment-131748
@gaborkaszab Thanks for the last round of review. I have some different
opinions on whether the preconditions for createNamespace and setProperty are
the same or different. Feel free
haizhou-zhao commented on code in PR #6045:
URL: https://github.com/apache/iceberg/pull/6045#discussion_r1020582495
##
hive-metastore/src/test/java/org/apache/iceberg/hive/TestHiveCatalog.java:
##
@@ -426,6 +510,194 @@ public void testSetNamespaceProperties() throws
TException
flyrain commented on code in PR #6012:
URL: https://github.com/apache/iceberg/pull/6012#discussion_r1020588386
##
spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/GenerateChangesProcedure.java:
##
@@ -0,0 +1,271 @@
+/*
+ * Licensed to the Apache Software Founda
github-actions[bot] closed issue #3726: Slove the problem that failed to remove
the data files when using HiveCatalog.dropTable
URL: https://github.com/apache/iceberg/issues/3726
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
github-actions[bot] commented on issue #3710:
URL: https://github.com/apache/iceberg/issues/3710#issuecomment-1312279301
This issue has been automatically marked as stale because it has been open
for 180 days with no activity. It will be closed in next 14 days if no further
activity occurs.
github-actions[bot] commented on issue #3726:
URL: https://github.com/apache/iceberg/issues/3726#issuecomment-1312279284
This issue has been closed because it has not received any activity in the
last 14 days since being marked as 'stale'
--
This is an automated message from the Apache Gi
github-actions[bot] commented on issue #3716:
URL: https://github.com/apache/iceberg/issues/3716#issuecomment-1312279293
This issue has been automatically marked as stale because it has been open
for 180 days with no activity. It will be closed in next 14 days if no further
activity occurs.
sunchao commented on code in PR #2276:
URL: https://github.com/apache/iceberg/pull/2276#discussion_r1020624495
##
core/src/main/java/org/apache/iceberg/util/TableScanUtil.java:
##
@@ -128,6 +136,61 @@ public static
CloseableIterable> planTaskG
combinedTasks -> new Bas
LuigiCerone commented on code in PR #6159:
URL: https://github.com/apache/iceberg/pull/6159#discussion_r1020777087
##
python/tests/avro/test_decoder.py:
##
@@ -106,9 +107,11 @@ def read(self, size: int = 0) -> bytes:
self.pos += 1
return int.to_bytes(1, self.po
krvikash opened a new pull request, #6178:
URL: https://github.com/apache/iceberg/pull/6178
Core: Remove redundant initialization
--
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 comm
dmgcodevil commented on PR #6174:
URL: https://github.com/apache/iceberg/pull/6174#issuecomment-1312545162
I've noticed one thing: `isPartialFileScan(task)` check is redundant b/c
`task.files().size() > 1` is always true. see `filteredGroupedTasks`.
--
This is an automated message from t
netanelm-upstream commented on issue #4065:
URL: https://github.com/apache/iceberg/issues/4065#issuecomment-1312548043
I have the same issue trying to write Iceberg ORC files using the JAVA API
with hive metastore as a catalog.
Somehow, it uploads this class:
org.apache.orc.storage.ql.ex
github-actions[bot] commented on issue #4739:
URL: https://github.com/apache/iceberg/issues/4739#issuecomment-1312601765
This issue has been automatically marked as stale because it has been open
for 180 days with no activity. It will be closed in next 14 days if no further
activity occurs.
github-actions[bot] commented on issue #3709:
URL: https://github.com/apache/iceberg/issues/3709#issuecomment-1312601781
This issue has been automatically marked as stale because it has been open
for 180 days with no activity. It will be closed in next 14 days if no further
activity occurs.
JonasJ-ap opened a new pull request, #6179:
URL: https://github.com/apache/iceberg/pull/6179
Follows PR #4402 .
As mentioned in
https://github.com/apache/iceberg/pull/4402#issuecomment-1261096282:
In `GlueCatalog`, if `s3.write.table-name-tag-enabled` and
`s3.write.namespace-name-tag
ggershinsky commented on code in PR #3471:
URL: https://github.com/apache/iceberg/pull/3471#discussion_r1020852734
##
core/src/main/java/org/apache/iceberg/TableProperties.java:
##
@@ -349,4 +350,27 @@ private TableProperties() {}
public static final String UPSERT_ENABLED =
get1boat opened a new issue, #6180:
URL: https://github.com/apache/iceberg/issues/6180
### Apache Iceberg version
1.0.0 (latest release)
### Query engine
Flink
### Please describe the bug 🐞
table DDL:
`
CREATE TABLE hive_catalog.ods_ice.tmp_lkj_kafka2i
krvikash commented on issue #6180:
URL: https://github.com/apache/iceberg/issues/6180#issuecomment-1312779669
Hi @get1boat,
You are missing the primary key while creating the table.
> Enabling UPSERT mode using upsert-enabled in the [write options](#Write
options) provides mor
stevenzwu commented on code in PR #6111:
URL: https://github.com/apache/iceberg/pull/6111#discussion_r1020938017
##
flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java:
##
@@ -145,8 +145,27 @@ protected Catalog createCatalog(
baseNamespace =
stevenzwu commented on code in PR #5984:
URL: https://github.com/apache/iceberg/pull/5984#discussion_r1020940001
##
api/src/main/java/org/apache/iceberg/IncrementalScan.java:
##
@@ -21,6 +21,23 @@
/** API for configuring an incremental scan. */
public interface IncrementalScan
stevenzwu commented on code in PR #5984:
URL: https://github.com/apache/iceberg/pull/5984#discussion_r1020940001
##
api/src/main/java/org/apache/iceberg/IncrementalScan.java:
##
@@ -21,6 +21,23 @@
/** API for configuring an incremental scan. */
public interface IncrementalScan
Samrose-Ahmed commented on issue #5997:
URL: https://github.com/apache/iceberg/issues/5997#issuecomment-1312796748
I would recommend running a Spark job. An AWS Glue job is the easiest to get
started but considering you're running this once, it'll likely be cheaper to
run on EMR (serverless
Fokko commented on code in PR #6159:
URL: https://github.com/apache/iceberg/pull/6159#discussion_r1020961137
##
python/pyiceberg/catalog/__init__.py:
##
@@ -120,16 +120,16 @@ def load_catalog(name: str, **properties: Optional[str])
-> Catalog:
or if it could not de
Fokko commented on code in PR #6139:
URL: https://github.com/apache/iceberg/pull/6139#discussion_r1020961770
##
python/pyiceberg/expressions/__init__.py:
##
@@ -90,16 +110,25 @@ def eval(self, struct: StructProtocol) -> T:
"""
return self.accessor.get(struct)
Fokko commented on code in PR #6139:
URL: https://github.com/apache/iceberg/pull/6139#discussion_r1020961425
##
python/pyiceberg/expressions/__init__.py:
##
@@ -48,12 +64,13 @@ class Bound(ABC):
"""Represents a bound value expression"""
-class Unbound(Generic[B], ABC):
Fokko commented on code in PR #6139:
URL: https://github.com/apache/iceberg/pull/6139#discussion_r1020962953
##
python/pyiceberg/expressions/literals.py:
##
@@ -108,7 +110,7 @@ def __ge__(self, other):
@singledispatch
-def literal(value) -> Literal:
+def literal(value: Any)
Fokko commented on code in PR #6139:
URL: https://github.com/apache/iceberg/pull/6139#discussion_r1020969932
##
python/tests/expressions/test_expressions.py:
##
@@ -365,7 +344,7 @@ def
test_bound_greater_than_or_equal_invert(table_schema_simple: Schema):
def test_bound_gre
github-actions[bot] commented on issue #4735:
URL: https://github.com/apache/iceberg/issues/4735#issuecomment-1312867245
This issue has been automatically marked as stale because it has been open
for 180 days with no activity. It will be closed in next 14 days if no further
activity occurs.
1701 - 1800 of 85865 matches
Mail list logo
