martin-sucha opened a new issue, #1786:
URL: https://github.com/apache/cassandra-gocql-driver/issues/1786
There are use-cases for wrapping the executions of individual query attempts.
We currently have QueryObserver and BatchObserver that allow observing the
query attempts, but don't
testisnullus commented on PR #1756:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1756#issuecomment-2255274251
I think it is a great suggestion, we can create an issue for it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
cardonator commented on issue #1689:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1689#issuecomment-2256608881
Now that Apache owns this library, and DataStax is a major contributor to
the open source project, is there anyone at DataStax that could help with this
issue?
-
yifan-c opened a new pull request, #69:
URL: https://github.com/apache/cassandra-analytics/pull/69
Patch by Yifan Cai; Reviewed by Francisco Guerrero for CASSANDRA-19806
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dfoulks1 closed pull request #1418: Compare case-insensitive consistency in
UnmarshalText
URL: https://github.com/apache/cassandra-gocql-driver/pull/1418
--
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
jberragan opened a new pull request, #70:
URL: https://github.com/apache/cassandra-analytics/pull/70
… rows by concatenating the partition keys with the serialized hex string
instead of utf-8 string
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
kevinkyyro commented on code in PR #1767:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1767#discussion_r1697418363
##
host_source_test.go:
##
@@ -274,6 +274,32 @@ func TestRefreshDebouncer_EventsAfterRefreshNow(t
*testing.T) {
}
}
+// https://github.co
joao-r-reis commented on code in PR #1767:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1767#discussion_r1697627433
##
host_source_test.go:
##
@@ -274,6 +274,32 @@ func TestRefreshDebouncer_EventsAfterRefreshNow(t
*testing.T) {
}
}
+// https://github.c
joao-r-reis commented on code in PR #1767:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1767#discussion_r1697627433
##
host_source_test.go:
##
@@ -274,6 +274,32 @@ func TestRefreshDebouncer_EventsAfterRefreshNow(t
*testing.T) {
}
}
+// https://github.c
jberragan commented on PR #70:
URL:
https://github.com/apache/cassandra-analytics/pull/70#issuecomment-2259584709
Green CI:
https://app.circleci.com/pipelines/github/jberragan/cassandra-analytics/59/workflows/b32e6c89-9354-449f-9501-c98020ce7322
--
This is an automated message from the A
martin-sucha commented on code in PR #1787:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1787#discussion_r1698060702
##
CONTRIBUTING.md:
##
@@ -6,21 +6,22 @@ This guide outlines the process of landing patches in gocql
and the general appr
## Background
-The
martin-sucha commented on code in PR #1788:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1788#discussion_r1698094925
##
.asf.yaml:
##
@@ -0,0 +1,36 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the
ribaraka commented on issue #1686:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1686#issuecomment-2260103962
I have finalized the PR, so please take a look.
While working on it, I encountered an error message:
```
Error:
../../../go/pkg/mod/github.com/docker
testisnullus commented on code in PR #1724:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1724#discussion_r1698970948
##
session.go:
##
@@ -198,6 +198,22 @@ func (s *Session) init() error {
}
s.ring.endpoints = hosts
+ // filter hosts at the
testisnullus commented on PR #1724:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1724#issuecomment-2261203799
LGTM
--
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
michaelsembwever commented on code in PR #1788:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1788#discussion_r1699622635
##
.asf.yaml:
##
@@ -0,0 +1,36 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See
RostislavPorohnya opened a new issue, #1789:
URL: https://github.com/apache/cassandra-gocql-driver/issues/1789
According to the Contributor comment on #1665 issue:
It seems the behavior was like this since commit
83932d6de9af9257339038f8a3a017941c34921d that introduced the o
RostislavPorohnya opened a new pull request, #1790:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1790
In this PR `DisableInitialHostLookup` flag renamed to `DisableHostLookup`,
code logic is fixed to query `system.peers` only when the flag is set to
`false`.
Closes #1665.
OleksiienkoMykyta opened a new pull request, #1791:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1791
(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 comme
testisnullus commented on code in PR #1791:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1791#discussion_r1700660747
##
cassandra_test.go:
##
@@ -2278,12 +2283,17 @@ func TestMaterializedViewMetadata(t *testing.T) {
DefaultTimeToLive: 0,
michaelsembwever commented on code in PR #1787:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1787#discussion_r1702123651
##
CONTRIBUTING.md:
##
@@ -6,21 +6,22 @@ This guide outlines the process of landing patches in gocql
and the general appr
## Background
-
michaelsembwever opened a new pull request, #1792:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1792
patch by Mick Semb Wever; reviewed by XXX for CASSANDRA-19723
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
michaelsembwever commented on code in PR #1787:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1787#discussion_r1702151894
##
NOTICE:
##
@@ -48,7 +48,7 @@ Matt Robenolt
Phillip Couto *
Niklas Korz
Nimi Wariboko Jr
-Ghais Issa
+Ghais Issa *
Review Comment:
yifan-c merged PR #70:
URL: https://github.com/apache/cassandra-analytics/pull/70
--
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
martin-sucha commented on code in PR #1787:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1787#discussion_r1703654322
##
NOTICE:
##
@@ -48,7 +48,7 @@ Matt Robenolt
Phillip Couto *
Niklas Korz
Nimi Wariboko Jr
-Ghais Issa
+Ghais Issa *
Review Comment:
T
martin-sucha commented on code in PR #1787:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1787#discussion_r1703657168
##
CONTRIBUTING.md:
##
@@ -6,24 +6,39 @@ This guide outlines the process of landing patches in gocql
and the general appr
## Background
-The
worryg0d opened a new pull request, #1793:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1793
# Overview
This PR provides a mechanism that allows users to specify on which node the
query will be executed. It is now a typical use case, but it makes sense with
virtual tabl
martin-sucha commented on PR #1793:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1793#issuecomment-2268518112
Should the API allow for other routing preferences? For example only a
single data center/rack? Or be extensible to allow targeting a specific shard
in the scylladb/g
michaelsembwever commented on PR #1792:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1792#issuecomment-2268953133
> Related comment:
https://github.com/apache/cassandra-gocql-driver/issues/1751#issuecomment-2189623544
Oh, thanks for point that out, now I see/remember th
michaelsembwever commented on code in PR #1787:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1787#discussion_r1704041200
##
CONTRIBUTING.md:
##
@@ -6,24 +6,39 @@ This guide outlines the process of landing patches in gocql
and the general appr
## Background
-
michaelsembwever commented on code in PR #1787:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1787#discussion_r1704054428
##
NOTICE:
##
@@ -48,7 +48,7 @@ Matt Robenolt
Phillip Couto *
Niklas Korz
Nimi Wariboko Jr
-Ghais Issa
+Ghais Issa *
Review Comment:
michaelsembwever commented on PR #1792:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1792#issuecomment-2269643603
> It is not clear to me whether Árni Dagur and Tushar Das should have an
asterisk, since the comments
https://github.com/apache/cassandra-gocql-driver/issues/1751
michaelsembwever merged PR #1787:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1787
--
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: commit
jberragan opened a new pull request, #71:
URL: https://github.com/apache/cassandra-analytics/pull/71
…sed independently from Spark
--
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
OleksiienkoMykyta commented on code in PR #1791:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1791#discussion_r170521
##
cassandra_test.go:
##
@@ -2278,12 +2283,17 @@ func TestMaterializedViewMetadata(t *testing.T) {
DefaultTimeToLive: 0,
worryg0d commented on PR #1793:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1793#issuecomment-2270980898
> Should the API allow for other routing preferences? For example only a
single data center/rack? Or be extensible to allow targeting a specific shard
in the scylladb/goc
michaelsembwever merged PR #1792:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1792
--
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: commit
worryg0d commented on code in PR #1791:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1791#discussion_r1706791549
##
metadata.go:
##
@@ -975,69 +977,207 @@ func getViewsMetadata(session *Session, keyspaceName
string) ([]ViewMetadata, er
return views, nil
OleksiienkoMykyta commented on code in PR #1791:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1791#discussion_r1706855163
##
metadata.go:
##
@@ -975,69 +977,207 @@ func getViewsMetadata(session *Session, keyspaceName
string) ([]ViewMetadata, er
return vie
yifan-c merged PR #69:
URL: https://github.com/apache/cassandra-analytics/pull/69
--
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
tengu-alt opened a new pull request, #1794:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1794
(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
michaelsembwever commented on issue #1751:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1751#issuecomment-2276021255
The donation has happen. Once again I'd like to express thanks to everyone
who helped make this project and everyone that popped in again to agree to the
do
michaelsembwever closed issue #1751: Donate GoCQL to Apache Cassandra [YOUR
ACTION REQUIRED]
URL: https://github.com/apache/cassandra-gocql-driver/issues/1751
--
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
michaelsembwever commented on code in PR #1788:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1788#discussion_r1709696288
##
.asf.yaml:
##
@@ -0,0 +1,36 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See
michaelsembwever commented on code in PR #1788:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1788#discussion_r1699622635
##
.asf.yaml:
##
@@ -0,0 +1,36 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See
martin-sucha commented on code in PR #1788:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1788#discussion_r1709712468
##
.asf.yaml:
##
@@ -0,0 +1,36 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the
martin-sucha commented on PR #1788:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1788#issuecomment-2276057747
The change looks good to me. The commit message needs to be updated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
michaelsembwever commented on PR #1788:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1788#issuecomment-2276096951
commit rebased and msg updated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
michaelsembwever merged PR #1788:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1788
--
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: commit
yifan-c opened a new pull request, #72:
URL: https://github.com/apache/cassandra-analytics/pull/72
(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
frankgh commented on code in PR #72:
URL:
https://github.com/apache/cassandra-analytics/pull/72#discussion_r1711290581
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java:
##
@@ -184,6 +184,10 @@ public WriteResult write(Iterator> s
yifan-c commented on code in PR #72:
URL:
https://github.com/apache/cassandra-analytics/pull/72#discussion_r1711780489
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java:
##
@@ -184,6 +184,10 @@ public WriteResult write(Iterator> s
frankgh commented on code in PR #72:
URL:
https://github.com/apache/cassandra-analytics/pull/72#discussion_r1711847494
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java:
##
@@ -184,6 +184,10 @@ public WriteResult write(Iterator> s
frankgh commented on code in PR #72:
URL:
https://github.com/apache/cassandra-analytics/pull/72#discussion_r1712310480
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java:
##
@@ -184,6 +184,10 @@ public WriteResult write(Iterator> s
yifan-c merged PR #72:
URL: https://github.com/apache/cassandra-analytics/pull/72
--
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
dkropachev commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1712553534
##
metadata.go:
##
@@ -760,6 +879,37 @@ func getTableMetadata(session *Session, keyspaceName
string) ([]TableMetadata, e
return tables, nil
dkropachev commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1712560334
##
metadata.go:
##
@@ -269,6 +307,23 @@ func (s *schemaDescriber) getSchema(keyspaceName string)
(*KeyspaceMetadata, err
return metadata, ni
dkropachev commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1712560334
##
metadata.go:
##
@@ -269,6 +307,23 @@ func (s *schemaDescriber) getSchema(keyspaceName string)
(*KeyspaceMetadata, err
return metadata, ni
tengu-alt commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1713589130
##
metadata.go:
##
@@ -760,6 +879,37 @@ func getTableMetadata(session *Session, keyspaceName
string) ([]TableMetadata, e
return tables, nil
tengu-alt commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1713628549
##
metadata.go:
##
@@ -269,6 +307,23 @@ func (s *schemaDescriber) getSchema(keyspaceName string)
(*KeyspaceMetadata, err
return metadata, nil
tengu-alt commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1713635813
##
metadata.go:
##
@@ -240,6 +262,13 @@ type schemaDescriber struct {
cache map[string]*KeyspaceMetadata
}
+// queries the cluster for sche
tengu-alt commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1713628549
##
metadata.go:
##
@@ -269,6 +307,23 @@ func (s *schemaDescriber) getSchema(keyspaceName string)
(*KeyspaceMetadata, err
return metadata, nil
dkropachev commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1713644935
##
metadata.go:
##
@@ -269,6 +307,23 @@ func (s *schemaDescriber) getSchema(keyspaceName string)
(*KeyspaceMetadata, err
return metadata, ni
testisnullus opened a new pull request, #1796:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1796
In this PR a new custom type `connectionType` was added to categorize
different stages of client connections within a Cassandra cluster.
Additionally, the `ClientConnection` struct
yifan-c opened a new pull request, #73:
URL: https://github.com/apache/cassandra-analytics/pull/73
Option to specify the ideal timeout in seconds for bulk write jobs. It is
only effective when the bulk write job is using S3_COMPACT data transport mode.
When JOB_IDEAL_TIMEOUT_SECONDS is spec
SiyaoIsHiding opened a new pull request, #1943:
URL: https://github.com/apache/cassandra-java-driver/pull/1943
(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.
tengu-alt commented on code in PR #1794:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1794#discussion_r1714855768
##
metadata.go:
##
@@ -269,6 +307,23 @@ func (s *schemaDescriber) getSchema(keyspaceName string)
(*KeyspaceMetadata, err
return metadata, nil
worryg0d commented on code in PR #1796:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1796#discussion_r1715018420
##
session.go:
##
@@ -780,6 +780,87 @@ func (s *Session) MapExecuteBatchCAS(batch *Batch, dest
map[string]interface{})
return applied, iter, i
testisnullus commented on code in PR #1796:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1796#discussion_r1715390463
##
session.go:
##
@@ -780,6 +780,87 @@ func (s *Session) MapExecuteBatchCAS(batch *Batch, dest
map[string]interface{})
return applied, ite
testisnullus commented on code in PR #1796:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1796#discussion_r1715391305
##
session.go:
##
@@ -780,6 +780,87 @@ func (s *Session) MapExecuteBatchCAS(batch *Batch, dest
map[string]interface{})
return applied, ite
yifan-c commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1715753096
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlField.java:
##
@@ -35,19 +35,16 @@
import com.esotericsoftware.kryo.Kryo;
impo
dipeshhkc opened a new pull request, #1797:
URL: https://github.com/apache/cassandra-gocql-driver/pull/1797
Description to be followed shortly
--
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
yifan-c commented on code in PR #73:
URL:
https://github.com/apache/cassandra-analytics/pull/73#discussion_r1716138859
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/blobupload/StorageClient.java:
##
@@ -216,7 +215,8 @@ private List uploadPartsO
SiyaoIsHiding opened a new pull request, #1944:
URL: https://github.com/apache/cassandra-java-driver/pull/1944
Will change the docker image name later
--
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
yifan-c commented on PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#issuecomment-2287763045
This flaky test
`org.apache.cassandra.spark.EndToEndTests#testLargeBlobExclude` might be
related.
https://app.circleci.com/pipelines/github/yifan-c/cassandra-analytics/92/workfl
worryg0d commented on code in PR #1796:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1796#discussion_r1716394374
##
session.go:
##
@@ -780,6 +780,95 @@ func (s *Session) MapExecuteBatchCAS(batch *Batch, dest
map[string]interface{})
return applied, iter, i
testisnullus commented on code in PR #1796:
URL:
https://github.com/apache/cassandra-gocql-driver/pull/1796#discussion_r1716642579
##
session.go:
##
@@ -780,6 +780,95 @@ func (s *Session) MapExecuteBatchCAS(batch *Batch, dest
map[string]interface{})
return applied, ite
JeetKunDoug commented on code in PR #73:
URL:
https://github.com/apache/cassandra-analytics/pull/73#discussion_r1716939928
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkSparkConf.java:
##
@@ -182,7 +183,7 @@ public BulkSparkConf(SparkConf c
yifan-c commented on code in PR #73:
URL:
https://github.com/apache/cassandra-analytics/pull/73#discussion_r1717279848
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkSparkConf.java:
##
@@ -182,7 +183,7 @@ public BulkSparkConf(SparkConf conf,
yifan-c commented on code in PR #73:
URL:
https://github.com/apache/cassandra-analytics/pull/73#discussion_r1717280509
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraBulkSourceRelation.java:
##
@@ -243,7 +244,7 @@ private void persist(@
yifan-c commented on code in PR #73:
URL:
https://github.com/apache/cassandra-analytics/pull/73#discussion_r1717298908
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/ImportCompletionCoordinator.java:
##
@@ -219,28 +224,42 @@ private void addComp
yifan-c commented on code in PR #73:
URL:
https://github.com/apache/cassandra-analytics/pull/73#discussion_r1717306194
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SimpleTaskScheduler.java:
##
@@ -114,6 +123,25 @@ public synchronized void clos
yifan-c commented on code in PR #73:
URL:
https://github.com/apache/cassandra-analytics/pull/73#discussion_r1717309983
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SimpleTaskScheduler.java:
##
@@ -34,53 +34,62 @@
import org.apache.cassandra
yifan-c commented on code in PR #73:
URL:
https://github.com/apache/cassandra-analytics/pull/73#discussion_r1717311068
##
cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/bulkwriter/ImportCompletionCoordinatorTest.java:
##
@@ -237,6 +240,51 @@ void testAwaitSho
yifan-c merged PR #73:
URL: https://github.com/apache/cassandra-analytics/pull/73
--
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 opened a new pull request, #74:
URL: https://github.com/apache/cassandra-analytics/pull/74
When UDT field values are set to null, the bulk writer throws NPE
Patch by Yifan Cai; Reviewed by TBD for CASSANDRA-19836
--
This is an automated message from the Apache Git Service.
T
lukasz-antoniak opened a new pull request, #1945:
URL: https://github.com/apache/cassandra-java-driver/pull/1945
Fix
[JAVA-3167](https://datastax-oss.atlassian.net/jira/software/c/projects/JAVA/issues/JAVA-3167).
--
This is an automated message from the Apache Git Service.
To respond to t
tolbertam commented on code in PR #1945:
URL:
https://github.com/apache/cassandra-java-driver/pull/1945#discussion_r1719759517
##
core/src/main/java/com/datastax/oss/driver/internal/core/util/concurrent/CompletableFutures.java:
##
@@ -100,7 +100,10 @@ public static CompletionS
lukasz-antoniak commented on code in PR #1945:
URL:
https://github.com/apache/cassandra-java-driver/pull/1945#discussion_r1719764003
##
core/src/main/java/com/datastax/oss/driver/internal/core/util/concurrent/CompletableFutures.java:
##
@@ -100,7 +100,10 @@ public static Compl
Highstead commented on issue #1751:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1751#issuecomment-2293920730
LGTM 👍 Sorry i was out for a bit. Feel free to take whatever i contributed
to here in the past.
--
This is an automated message from the Apache Git Service.
To
michaelsembwever commented on code in PR #1944:
URL:
https://github.com/apache/cassandra-java-driver/pull/1944#discussion_r1721323037
##
Jenkinsfile-asf:
##
@@ -0,0 +1,84 @@
+#!groovy
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor l
michaelsembwever commented on code in PR #1944:
URL:
https://github.com/apache/cassandra-java-driver/pull/1944#discussion_r1721323694
##
Jenkinsfile-asf:
##
@@ -0,0 +1,84 @@
+#!groovy
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor l
michaelsembwever commented on PR #1944:
URL:
https://github.com/apache/cassandra-java-driver/pull/1944#issuecomment-2295849781
lgtm. do we have an accompanying cassandra-builds PR yet ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1721417265
##
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/SparkCellIterator.java:
##
@@ -325,7 +329,10 @@ private void maybeRebuildCluste
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1721422211
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/TypeConverter.java:
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software F
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1721425892
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlField.java:
##
@@ -330,14 +329,39 @@ public CqlType type()
return typ
jberragan commented on code in PR #71:
URL:
https://github.com/apache/cassandra-analytics/pull/71#discussion_r1721429729
##
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlField.java:
##
@@ -473,6 +462,11 @@ public void write(Kryo kryo, Output output
lukasz-antoniak commented on code in PR #1931:
URL:
https://github.com/apache/cassandra-java-driver/pull/1931#discussion_r1721938878
##
query-builder/src/main/java/com/datastax/oss/driver/api/querybuilder/select/Select.java:
##
@@ -146,6 +146,8 @@ default Select orderBy(@NonNul
lukasz-antoniak closed pull request #1946: CASSANDRA-19837: Support ORDER BY
ANN in query builder
URL: https://github.com/apache/cassandra-java-driver/pull/1946
--
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
lukasz-antoniak commented on PR #1946:
URL:
https://github.com/apache/cassandra-java-driver/pull/1946#issuecomment-2296801738
There is already another PR opened for same functionality
[PR-1931](https://github.com/apache/cassandra-java-driver/pull/1931).
--
This is an automated message fr
101 - 200 of 1572 matches
Mail list logo
